GoとアクターモデルでES+CQRSを実践！ / proto_actor_es_cqrs

Proto Actorを使ってES+CQRSを理解してみよう

Transcript

1. GoͱΞΫλʔϞσϧͰ ES+CQRSΛ࣮ફ SEN Developer Meetup vol.2
2. Pro fi le • ஛ᖒ ༗و a.k.a ytake • ઍגࣜձࣾ CTO / ΄͔ٕज़ސ໰ • Go / Scala • ΞΫλʔϞσϧେ޷͖
3. GoͰຊ֨తͳΞΫλʔϞσϧʂ
4. ݁ہͷͱ͜Ζ • ΞΫλʔϞσϧ͸ϓϩάϥϛϯάύϥμΠϜ͕ͪΐͬͱҧ͏΋ͷ • ฉ͚ͩ͘Ͱ͸ͳ͔ͳ͔೉͍͠ͷͰɺͥͻ৮ͬͯΈ͍ͯͩ͘͞ • εςʔτϑϧʹ
6. Proto.Actor • Akka / Pekkoͱڞ௨ͷ֓೦ʹجͮ͘΋ͷ • Akka / Pekko΄ͲߴػೳͰ͸ͳ͍͕ɺෆࣗ༝͕ͳ͍͘Β͍ἧ͍ͬͯΔ • ࠓճ͸ӬଓԽ౳ʹؔ͢Δ΋ͷ
7. ΞΫλʔϞσϧʹ͍ͭͯཧղ͢ΔͨΊʹ
8. ΑΓཧղ͢ΔͨΊʹ
10. ؆୯ʹ֓೦঺հ
11. ΞΫλʔϞσϧ • ฒߦܭࢉͷͨΊͷϞσϧ • ఻౷తͳϓϩάϥϛϯάελΠϧͱଟগ͜ͱͳΓɺ ͢΂ͯͷΞΫλʔ͸ಠཱͯ͠ฒߦ • ΦϒδΣΫτͷ֎͔Β௚઀ίʔϧͯ͠ґཔ͢ΔͳͲ͸Ͱ͖·ͤΜ
13. ֊૚ߏ଄Λ΋ͭ
16. ES+CQRSʹ͍ͭͯ
18. Command • γεςϜ΁ͷมߋࢦࣔ • ίϚϯυ͕࣮ߦ͞ΕΔͱɺγεςϜ͕৽͍͠ঢ়ଶʹมԽ
20. Query • ϢʔβʔʹσʔλΛදࣔͨ͠Γɺ • ผͷγεςϜʹૹ৴ͨ͠Γɺ ίϚϯυͱ͸ผͷ໨తͰ࢖༻ • ίϚϯυͱ͸Ϟσϧ͕ผͱ͍͏͜ͱ
22. Event Store? • ίϚϯυΛड͚ͯ৽͍͠ঢ়ଶʹมԽ • ͜ΕΛΠϕϯτͱͯ͠อ؅ʢΠϕϯτετΞ΁ʣ • ΠϕϯτετΞ͸௚઀ΫΤϦʹར༻͞ΕΔΘ͚Ͱ͸ͳ͍
25. ӬଓԽ͢Δʹ͸ • Protocol BuffersΛར༻͢Δ • ΠϕϯτετΞʹ͍ͭͯ͸ΠϯλʔϑΣʔεΛ࣮૷ • ΠϕϯτͷӬଓԽΛߦ͍ɺ֘౰ͷΞΫλʔͷঢ়ଶΛ؅ཧ • ঢ়ଶ෮ݩ͸ࣗಈͰ࣮ߦ͞Ε·͢
26. package persistence import ( "google.golang.org/protobuf/proto" ) // Provider is the abstraction used for persistence type Provider interface { GetState() ProviderState } // ProviderState is an object containing the implementation for the provider type ProviderState interface { SnapshotStore EventStore Restart() GetSnapshotInterval() int } type SnapshotStore interface { GetSnapshot(actorName string) (snapshot interface{}, eventIndex int, ok bool) PersistSnapshot(actorName string, snapshotIndex int, snapshot proto.Message) DeleteSnapshots(actorName string, inclusiveToIndex int) } type EventStore interface { GetEvents(actorName string, eventIndexStart int, eventIndexEnd int, callback func(e interface{})) PersistEvent(actorName string, eventIndex int, event proto.Message) DeleteEvents(actorName string, inclusiveToIndex int) }
27. package persistence import ( "google.golang.org/protobuf/proto" ) // Provider is the abstraction used for persistence type Provider interface { GetState() ProviderState } // ProviderState is an object containing the implementation for the provider type ProviderState interface { SnapshotStore EventStore Restart() GetSnapshotInterval() int } type SnapshotStore interface { GetSnapshot(actorName string) (snapshot interface{}, eventIndex int, ok bool) PersistSnapshot(actorName string, snapshotIndex int, snapshot proto.Message) DeleteSnapshots(actorName string, inclusiveToIndex int) } type EventStore interface { GetEvents(actorName string, eventIndexStart int, eventIndexEnd int, callback func(e interface{})) PersistEvent(actorName string, eventIndex int, event proto.Message) DeleteEvents(actorName string, inclusiveToIndex int) } ঢ়ଶͷӬଓԽʹͳʹΛ࢖͏͔
28. package persistence import ( "google.golang.org/protobuf/proto" ) // Provider is the abstraction used for persistence type Provider interface { GetState() ProviderState } // ProviderState is an object containing the implementation for the provider type ProviderState interface { SnapshotStore EventStore Restart() GetSnapshotInterval() int } type SnapshotStore interface { GetSnapshot(actorName string) (snapshot interface{}, eventIndex int, ok bool) PersistSnapshot(actorName string, snapshotIndex int, snapshot proto.Message) DeleteSnapshots(actorName string, inclusiveToIndex int) } type EventStore interface { GetEvents(actorName string, eventIndexStart int, eventIndexEnd int, callback func(e interface{})) PersistEvent(actorName string, eventIndex int, event proto.Message) DeleteEvents(actorName string, inclusiveToIndex int) } ΠϕϯτετΞʢδϟʔφϧʣ޲͚
    ӬଓԽͷํ๏ʢΫΤϦʣ΍
    ෮ݩ࣌ͷΫΤϦͳͲ
29. package persistence import ( "google.golang.org/protobuf/proto" ) // Provider is the abstraction used for persistence type Provider interface { GetState() ProviderState } // ProviderState is an object containing the implementation for the provider type ProviderState interface { SnapshotStore EventStore Restart() GetSnapshotInterval() int } type SnapshotStore interface { GetSnapshot(actorName string) (snapshot interface{}, eventIndex int, ok bool) PersistSnapshot(actorName string, snapshotIndex int, snapshot proto.Message) DeleteSnapshots(actorName string, inclusiveToIndex int) } type EventStore interface { GetEvents(actorName string, eventIndexStart int, eventIndexEnd int, callback func(e interface{})) PersistEvent(actorName string, eventIndex int, event proto.Message) DeleteEvents(actorName string, inclusiveToIndex int) } εφοϓγϣοτ޲͚
    ӬଓԽͷํ๏ʢΫΤϦʣ΍
    ෮ݩ࣌ͷΫΤϦͳͲ
30. ӬଓԽ • δϟʔφϧ͸ঢ়ଶมߋΛৗʹهԱ • δϟʔφϧΛ͍͔ͭ͘ॻ͖ࠐΉͨͼʹεφοϓγϣοτΛอ؅ • ෮ݩ͸಄͔Β࣮ߦ͞ΕΔ͕ɺεφοϓγϣοτ͕͋Ε͹͔ͦ͜Β෮ݩ
31. type Actor interface { Receive(c Context) }
32. package acme import ( "errors" "fmt" "github.com/asynkron/protoactor-go/actor" "github.com/asynkron/protoactor-go/persistence" // ུ "google.golang.org/protobuf/proto" ) // Cart is an actor to create cart type Cart struct { persistence.Mixin stream *actor.PID state *cart.Items }
33. package acme import ( "errors" "fmt" "github.com/asynkron/protoactor-go/actor" "github.com/asynkron/protoactor-go/persistence" // ུ "google.golang.org/protobuf/proto" ) // Cart is an actor to create cart type Cart struct { persistence.Mixin stream *actor.PID state *cart.Items } ΞΫλʔͷӬଓԽΛར༻͢Δ৔߹ʹ
    ඞਢ
34. package acme import ( "errors" "fmt" "github.com/asynkron/protoactor-go/actor" "github.com/asynkron/protoactor-go/persistence" // ུ "google.golang.org/protobuf/proto" ) // Cart is an actor to create cart type Cart struct { persistence.Mixin stream *actor.PID state *cart.Items } $BSUΞΫλʔͷঢ়ଶ
35. package acme import ( "errors" "fmt" "github.com/asynkron/protoactor-go/actor" "github.com/asynkron/protoactor-go/persistence" // ུ "google.golang.org/protobuf/proto" ) // Cart is an actor to create cart type Cart struct { persistence.Mixin stream *actor.PID state *cart.Items } ϦʔυϞσϧߋ৽ΞΫλʔͳͲ΁
38. ΞΫλʔͷঢ়ଶΛมߋ
    
    υϝΠϯϞσϧʹ߹Θͤͯදݱ
39. ΞΫλʔͷঢ়ଶΛมߋ
    
    υϝΠϯΠϕϯτ
40. ΠϕϯτετΞͰ
    ΠϕϯτӬଓԽ
41. func (u *Cart) Receive(context actor.Context) { defer context.Poison(context.Self()) switch msg := context.Message().(type) { case *persistence.RequestSnapshot: u.PersistSnapshot(u.state) case *persistence.ReplayComplete: // ϦϓϨΠ͕׬ྃͨ͠Β಺෦ঢ়ଶΛมߋ͢Δ context.Logger().Info( fmt.Sprintf("replay completed, internal state changed to '%v'", u.state)) case *command.AddItem: if u.IsStateExists(msg.Name) { context.Send(u.stream, &message.AddItemError{Message: "item already exists"}) return } // ུ u.persistence(context, ev) // xxxੜ੒ΠϕϯτΛΠϕϯτετϦʔϜ΁ context.Send(u.stream, ev) case *event.ItemAdded: if msg.String() != "" { // event ͕ϦϓϨΠ͞Εͨ৔߹͸ঢ়ଶΛߋ৽͢Δ u.state = msg u.sendToReadModelUpdater(context, msg) } } }
42. func (u *Cart) Receive(context actor.Context) { defer context.Poison(context.Self()) switch msg := context.Message().(type) { case *persistence.RequestSnapshot: u.PersistSnapshot(u.state) case *persistence.ReplayComplete: // ϦϓϨΠ͕׬ྃͨ͠Β಺෦ঢ়ଶΛมߋ͢Δ context.Logger().Info( fmt.Sprintf("replay completed, internal state changed to '%v'", u.state)) case *command.AddItem: if u.IsStateExists(msg.Email) { context.Send(u.stream, &message.AddItemError{Message: "item already exists"}) return } // ུ u.persistence(context, ev) // xxxੜ੒ΠϕϯτΛΠϕϯτετϦʔϜ΁ context.Send(u.stream, ev) case *event.ItemAdded: if msg.String() != "" { // event ͕ϦϓϨΠ͞Εͨ৔߹͸ঢ়ଶΛߋ৽͢Δ u.state = msg u.sendToReadModelUpdater(context, msg) } } } ίϚϯυΛडऔɺ
    ࣗΞΫλʔͷঢ়ଶΛมߋ
    ঢ়ଶมߋΛΠϕϯτͱͯ͠ӬଓԽ
43. func (u *Cart) Receive(context actor.Context) { defer context.Poison(context.Self()) switch msg := context.Message().(type) { case *persistence.RequestSnapshot: u.PersistSnapshot(u.state) case *persistence.ReplayComplete: // ϦϓϨΠ͕׬ྃͨ͠Β಺෦ঢ়ଶΛมߋ͢Δ context.Logger().Info( fmt.Sprintf("replay completed, internal state changed to '%v'", u.state)) case *command.AddItem: if u.IsStateExists(msg.Name) { context.Send(u.stream, &message.AddItemError{Message: "item already exists"}) return } // ུ u.persistence(context, ev) // xxxੜ੒ΠϕϯτΛΠϕϯτετϦʔϜ΁ context.Send(u.stream, ev) case *event.ItemAdded: if msg.String() != "" { // event ͕ϦϓϨΠ͞Εͨ৔߹͸ঢ়ଶΛߋ৽͢Δ u.state = msg u.sendToReadModelUpdater(context, msg) } } } ͢Ͱʹঢ়ଶ͕͋Δʢੜ੒ࡁΈͳͲʣ৔߹͸
    ࣗ਎Λมߋͤͣʹϝοηʔδฦ৴
44. func (u *Cart) Receive(context actor.Context) { defer context.Poison(context.Self()) switch msg := context.Message().(type) { case *persistence.RequestSnapshot: u.PersistSnapshot(u.state) case *persistence.ReplayComplete: // ϦϓϨΠ͕׬ྃͨ͠Β಺෦ঢ়ଶΛมߋ͢Δ context.Logger().Info( fmt.Sprintf("replay completed, internal state changed to '%v'", u.state)) case *command.AddItem: if u.IsStateExists(msg.Name) { context.Send(u.stream, &message.AddItemError{Message: "item already exists"}) return } // ུ u.persistence(context, ev) // xxxੜ੒ΠϕϯτΛΠϕϯτετϦʔϜ΁ context.Send(u.stream, ev) case *event.ItemAdded: if msg.String() != "" { // event ͕ϦϓϨΠ͞Εͨ৔߹͸ঢ়ଶΛߋ৽͢Δ u.state = msg u.sendToReadModelUpdater(context, msg) } } } ϦʔυϞσϧߋ৽ϋϯυϥʢΞΫλʔʣ΁
45. func (u *Cart) Receive(context actor.Context) { defer context.Poison(context.Self()) switch msg := context.Message().(type) { case *persistence.RequestSnapshot: u.PersistSnapshot(u.state) case *persistence.ReplayComplete: // ϦϓϨΠ͕׬ྃͨ͠Β಺෦ঢ়ଶΛมߋ͢Δ context.Logger().Info( fmt.Sprintf("replay completed, internal state changed to '%v'", u.state)) case *command.AddItem: if u.IsStateExists(msg.Name) { context.Send(u.stream, &message.AddItemError{Message: "item already exists"}) return } // ུ u.persistence(context, ev) // xxxੜ੒ΠϕϯτΛΠϕϯτετϦʔϜ΁ context.Send(u.stream, ev) case *event.ItemAdded: if msg.String() != "" { // event ͕ϦϓϨΠ͞Εͨ৔߹͸ঢ়ଶΛߋ৽͢Δ u.state = msg u.sendToReadModelUpdater(context, msg) } } } ॲཧऴྃޙʹΞΫλʔΛ࡟আ
46. func (u *Cart) Receive(context actor.Context) { defer context.Poison(context.Self()) switch msg := context.Message().(type) { case *persistence.RequestSnapshot: u.PersistSnapshot(u.state) case *persistence.ReplayComplete: // ϦϓϨΠ͕׬ྃͨ͠Β಺෦ঢ়ଶΛมߋ͢Δ context.Logger().Info( fmt.Sprintf("replay completed, internal state changed to '%v'", u.state)) case *command.AddItem: if u.IsStateExists(msg.Name) { context.Send(u.stream, &message.AddItemError{Message: "item already exists"}) return } // ུ u.persistence(context, ev) // xxxੜ੒ΠϕϯτΛΠϕϯτετϦʔϜ΁ context.Send(u.stream, ev) case *event.ItemAdded: if msg.String() != "" { // event ͕ϦϓϨΠ͞Εͨ৔߹͸ঢ়ଶΛߋ৽͢Δ u.state = msg u.sendToReadModelUpdater(context, msg) } } } ΞΫλʔੜ੒ʢ࠶ੜ੒ɺϦελʔτͳͲʣ࣌
    աڈͷঢ়ଶ͕͋Ε͹ɺ
    ࠷ॳͷΠϕϯτ͔Βड৴͠ɺঢ়ଶΛ෮ݩ
48. ϦʔυϞσϧߋ৽ΞΫλʔ͕
    2VFSZ༻ͷσʔλϕʔεΛߋ৽
49. // ReadModelUpdate is actor to update read model type ReadModelUpdate struct { query mysql.RegistrationItemExecutor } // NewReadModelUpdate is constructor for ReadModelUpdate func NewReadModelUpdate(query mysql.RegistrationItemExecutor) actor.Actor { return &ReadModelUpdate{ query: query, } } // Receive is sent messages to be processed from the mailbox associated with the instance of the actor func (u *ReadModelUpdate) Receive(ctx actor.Context) { switch msg := ctx.Message().(type) { case *event.ItemAdded: // ΠϕϯτΛಡΈࠐΜͰɺRead ModelΛߋ৽͢Δ // ͜͜Ͱ͸Read ModelʹΞΠςϜ͕ଘࡏ͠ͳ͍৔߹ʹ࡞੒͢Δ෩ err := u.query.AddItemIfNotExists(context.Background(), mysql.AddItemParams{ Name: msg.ItemName, ID: msg.ItemID, }) if err != nil { // Τϥʔ͕ൃੜͨ͠৔߹͸ϩάΛग़ྗ͢Δ ctx.Logger().Error(err.Error()) return } } }
50. // ReadModelUpdate is actor to update read model type ReadModelUpdate struct { query mysql.RegistrationItemExecutor } // NewReadModelUpdate is constructor for ReadModelUpdate func NewReadModelUpdate(query mysql.RegistrationItemExecutor) actor.Actor { return &ReadModelUpdate{ query: query, } } // Receive is sent messages to be processed from the mailbox associated with the instance of the actor func (u *ReadModelUpdate) Receive(ctx actor.Context) { switch msg := ctx.Message().(type) { case *event.ItemAdded: // ΠϕϯτΛಡΈࠐΜͰɺRead ModelΛߋ৽͢Δ // ͜͜Ͱ͸Read ModelʹΞΠςϜ͕ଘࡏ͠ͳ͍৔߹ʹ࡞੒͢Δ෩ err := u.query.AddItemIfNotExists(context.Background(), mysql.AddItemParams{ Name: msg.ItemName, ID: msg.ItemID, }) if err != nil { // Τϥʔ͕ൃੜͨ͠৔߹͸ϩάΛग़ྗ͢Δ ctx.Logger().Error(err.Error()) return } } } 2VFSZͰར༻͍ͨ͠ςʔϒϧͳͲʹ൓ө
51. ΞΫλʔΛੜ੒ • ͜ͷྫͰ͸RestAPIΞΫλʔΛϧʔτʹ • ίϚϯυ͔Βঢ়ଶมԽɺ ΫΤϦͰඞཁͳςʔϒϧͷՃ޻ʢϦʔυϞσϧߋ৽ϋϯυϥʣ ͦΕͧΕͷΞΫλʔΛੜ੒
52. func (a *RestAPI) Receive(ctx actor.Context) { switch msg := ctx.Message().(type) { case *actor.Started: a.rmu = ctx.Spawn(actor.PropsFromProducer(func() actor.Actor { return registration.NewItemModelUpdate(a.db) })) case *command.AddItem: ref, err := ctx.SpawnNamed( actor.PropsFromProducer(func() actor.Actor { return registration.NewItem(msg.Stream, a.rmu) }, actor.WithReceiverMiddleware(persistence.Using(a.provider))), "item-"+msg.Name) if errors.Is(err, actor.ErrNameExists) { ctx.Send(msg.Stream, &message.ItemCreateError{Message: fmt.Sprintf("item %s already exists", msg.Email)}) return } if err != nil { ctx.Send(msg.Stream, &message.ItemCreateError{Message: fmt.Sprintf("failed error %s", err.Error())}) return } ctx.Send(ref, msg) } }
53. func (a *RestAPI) Receive(ctx actor.Context) { switch msg := ctx.Message().(type) { case *actor.Started: a.rmu = ctx.Spawn(actor.PropsFromProducer(func() actor.Actor { return registration.NewItemModelUpdate(a.db) })) case *command.AddItem: ref, err := ctx.SpawnNamed( actor.PropsFromProducer(func() actor.Actor { return registration.NewItem(msg.Stream, a.rmu) }, actor.WithReceiverMiddleware(persistence.Using(a.provider))), "item-"+msg.Name) if errors.Is(err, actor.ErrNameExists) { ctx.Send(msg.Stream, &message.ItemCreateError{Message: fmt.Sprintf("item %s already exists", msg.Email)}) return } if err != nil { ctx.Send(msg.Stream, &message.ItemCreateError{Message: fmt.Sprintf("failed error %s", err.Error())}) return } ctx.Send(ref, msg) } } ϦʔυϞσϧߋ৽ΞΫλʔ
54. func (a *RestAPI) Receive(ctx actor.Context) { switch msg := ctx.Message().(type) { case *actor.Started: a.rmu = ctx.Spawn(actor.PropsFromProducer(func() actor.Actor { return registration.NewItemModelUpdate(a.db) })) case *command.AddItem: ref, err := ctx.SpawnNamed( actor.PropsFromProducer(func() actor.Actor { return registration.NewItem(msg.Stream, a.rmu) }, actor.WithReceiverMiddleware(persistence.Using(a.provider))), "item-"+msg.Name) if errors.Is(err, actor.ErrNameExists) { ctx.Send(msg.Stream, &message.ItemCreateError{Message: fmt.Sprintf("item %s already exists", msg.Email)}) return } if err != nil { ctx.Send(msg.Stream, &message.ItemCreateError{Message: fmt.Sprintf("failed error %s", err.Error())}) return } ctx.Send(ref, msg) } } ίϚϯυΛड͚෇͚ΔΞΫλʔ
55. func (a *RestAPI) Receive(ctx actor.Context) { switch msg := ctx.Message().(type) { case *actor.Started: a.rmu = ctx.Spawn(actor.PropsFromProducer(func() actor.Actor { return registration.NewItemModelUpdate(a.db) })) case *command.AddItem: ref, err := ctx.SpawnNamed( actor.PropsFromProducer(func() actor.Actor { return registration.NewItem(msg.Stream, a.rmu) }, actor.WithReceiverMiddleware(persistence.Using(a.provider))), "item-"+msg.Name) if errors.Is(err, actor.ErrNameExists) { ctx.Send(msg.Stream, &message.ItemCreateError{Message: fmt.Sprintf("item %s already exists", msg.Email)}) return } if err != nil { ctx.Send(msg.Stream, &message.ItemCreateError{Message: fmt.Sprintf("failed error %s", err.Error())}) return } ctx.Send(ref, msg) } } ΞΫλʔͷӬଓԽࢦࣔ
    1SPUP"DUPSͰ͸ϛυϧ΢ΣΞͱͯ͠දݱ
56. func (a *RestAPI) Receive(ctx actor.Context) { switch msg := ctx.Message().(type) { case *actor.Started: a.rmu = ctx.Spawn(actor.PropsFromProducer(func() actor.Actor { return registration.NewItemModelUpdate(a.db) })) case *command.AddItem: ref, err := ctx.SpawnNamed( actor.PropsFromProducer(func() actor.Actor { return registration.NewItem(msg.Stream, a.rmu) }, actor.WithReceiverMiddleware(persistence.Using(a.provider))), "item-"+msg.Name) if errors.Is(err, actor.ErrNameExists) { ctx.Send(msg.Stream, &message.ItemCreateError{Message: fmt.Sprintf("item %s already exists", msg.Email)}) return } if err != nil { ctx.Send(msg.Stream, &message.ItemCreateError{Message: fmt.Sprintf("failed error %s", err.Error())}) return } ctx.Send(ref, msg) } } ಠཱͨ͠ΞΫλʔʹࣝผՄೳͳ໊લΛ༩͑ɺ
    ෮ݩ࣌ʹಠཱͯ͠෮ݩ͞ΕΔ
57. func (a *RestAPI) Receive(ctx actor.Context) { switch msg := ctx.Message().(type) { case *actor.Started: a.rmu = ctx.Spawn(actor.PropsFromProducer(func() actor.Actor { return registration.NewItemModelUpdate(a.db) })) case *command.AddItem: ref, err := ctx.SpawnNamed( actor.PropsFromProducer(func() actor.Actor { return registration.NewItem(msg.Stream, a.rmu) }, actor.WithReceiverMiddleware(persistence.Using(a.provider))), "item-"+msg.Name) if errors.Is(err, actor.ErrNameExists) { ctx.Send(msg.Stream, &message.ItemCreateError{Message: fmt.Sprintf("item %s already exists", msg.Email)}) return } if err != nil { ctx.Send(msg.Stream, &message.ItemCreateError{Message: fmt.Sprintf("failed error %s", err.Error())}) return } ctx.Send(ref, msg) } } ΞΫλʔ͕ੜ੒Ͱ͖ͳ͔ͬͨ৔߹ͷΤϥʔ
58. ΞΫλʔγεςϜ͕શମΛ؅ཧ
    ো֐ͳͲʹ΋ڧ͘ɺ
    ಄͔Β࣮֬ʹ෮چ
60. func (u *ItemRegistration) Handle(c echo.Context) error { ui := new(itemInput) if err := c.Bind(ui); err != nil { return echo.NewHTTPError(http.StatusBadRequest, err.Error()) } if err := c.Validate(ui); err != nil { return err } go func() { u.system.Root.Send(u.ref, &command.AddItem{ // ུ Name: ui.Name, Stream: u.stream.PID(), }) }() res := <-u.stream.C() if res.IsSuccess() { return c.JSON(http.StatusOK, res) } return c.JSON(http.StatusBadRequest, res) }
61. func (u *ItemRegistration) Handle(c echo.Context) error { ui := new(itemInput) if err := c.Bind(ui); err != nil { return echo.NewHTTPError(http.StatusBadRequest, err.Error()) } if err := c.Validate(ui); err != nil { return err } go func() { u.system.Root.Send(u.ref, &command.AddItem{ // ུ Name: ui.Name, Stream: u.stream.PID(), }) }() res := <-u.stream.C() if res.IsSuccess() { return c.JSON(http.StatusOK, res) } return c.JSON(http.StatusBadRequest, res) } 1SPUP
    "DUPS΁ૹ৴
62. func (u *ItemRegistration) Handle(c echo.Context) error { ui := new(itemInput) if err := c.Bind(ui); err != nil { return echo.NewHTTPError(http.StatusBadRequest, err.Error()) } if err := c.Validate(ui); err != nil { return err } go func() { u.system.Root.Send(u.ref, &command.AddItem{ // ུ Name: ui.Name, Stream: u.stream.PID(), }) }() res := <-u.stream.C() if res.IsSuccess() { return c.JSON(http.StatusOK, res) } return c.JSON(http.StatusBadRequest, res) } ΄͍͠ϝοηʔδΛετϦʔϜ͔ΒऔΓग़͢
    ଞʹ΋'VUVSFΛ࢖͏ͳͲ΋͋Γ·͢
63. ·ͱΊ • ΞΫλʔϞσϧ͸ϓϩάϥϛϯάύϥμΠϜ͕ͪΐͬͱҧ͏΋ͷ • ฉ͚ͩ͘Ͱ͸ͳ͔ͳ͔೉͍͠ͷͰɺͥͻ৮ͬͯΈ͍ͯͩ͘͞ • ཧղ͑͞Ͱ͖Ε͹ڧྗͳπʔϧʹʂ