publish

type FailedEvent struct {
	Payload app.Payload
	Err     error
}

type PublishCommandInput struct {
	Destination string
	Payload     app.Payload
	Events      []app.Payload
	Frame       app.FrameBuilder
	Authorizer  app.RequestAuthorizer
}

type PublishCommandOutput struct {
	Failures []FailedEvent
	Success  bool
}

type PublishMessage interface {
	Publish(context.Context, PublishCommandInput) (*PublishCommandOutput, error)
}

type PublishMessageUsecase struct {
	// contains filtered or unexported fields
}

type ReceivePublishResult interface {
	Receive(context.Context, protocol.PublishResult)
}

type Reply chan error