INNER CODE UNIT · Go
executePaymentDebitedCommand
shijuvar/go-distributed-sys · eventstream/paymentworker/main.go:70
func executePaymentDebitedCommand(command ordermodel.PaymentDebitedCommand) 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)
paymentJSON, _ := json.Marshal(command)
eventid, _ := uuid.NewUUID()
event := &eventstore.Event{
EventId: eventid.String(),
EventType: event,
AggregateId: command.OrderID,
AggregateType: aggregate,
EventData: string(paymentJSON),
Stream: stream,
}