INNER CODE UNIT · Go
executeOrderApprovedCommand
shijuvar/go-distributed-sys · eventstream/reviewworker/main.go:75
func executeOrderApprovedCommand(command ordermodel.ChangeOrderStatusCommand) error {
conn, err := grpc.Dial(grpcUri, grpc.WithTransportCredentials(insecure.NewCredentials()))
if err != nil {
log.Fatalf("Unable to connect: %v", err)
}
defer conn.Close()
client := eventstore.NewEventStoreClient(conn)
eventid, _ := uuid.NewUUID()
event := &eventstore.Event{
EventId: eventid.String(),
EventType: event,
AggregateId: command.OrderID,
AggregateType: aggregate,
EventData: "",
Stream: stream,
}
createEventRequest := &eventstore.CreateEventRequest{Event: event}