am

type AckType int

type AckWait time.Duration

type Command interface {
	ddd.Command
	Destination() string
}

type CommandMessage interface {
	Message
	ddd.Command
}

type CommandMessageData struct {
	Payload    []byte                 `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	OccurredAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	Metadata   *structpb.Struct       `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

type CommandMessageHandler interface {
	HandleMessage(ctx context.Context, msg IncomingCommandMessage) (ddd.Reply, error)
}

type CommandMessageHandlerFunc func(ctx context.Context, msg IncomingCommandMessage) (ddd.Reply, error)

type CommandPublisher = MessagePublisher[ddd.Command]

type CommandStream interface {
	MessagePublisher[ddd.Command]
	CommandSubscriber
}

type CommandSubscriber interface {
	Subscribe(topicName string, handler CommandMessageHandler, options ...SubscriberOption) error
}

type EventMessage interface {
	Message
	ddd.Event
}

type EventMessageData struct {
	Payload    []byte                 `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	OccurredAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	Metadata   *structpb.Struct       `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

type EventPublisher = MessagePublisher[ddd.Event]

type EventStream = MessageStream[ddd.Event, IncomingEventMessage]

type EventSubscriber = MessageSubscriber[IncomingEventMessage]

type GroupName string

type IncomingCommandMessage interface {
	IncomingMessage
	ddd.Command
}

type IncomingEventMessage interface {
	IncomingMessage
	ddd.Event
}

type IncomingMessage interface {
	Message
	Ack() error
	NAck() error
	Extend() error
	Kill() error
}

type IncomingRawMessage interface {
	IncomingMessage
	Data() []byte
}

type IncomingReplyMessage interface {
	IncomingMessage
	ddd.Reply
}

type MaxRedeliver int

type Message interface {
	ddd.IDer
	MessageName() string
}

type MessageFilter []string

type MessageHandler[I IncomingMessage] interface {
	HandleMessage(ctx context.Context, msg I) error
}

type MessageHandlerFunc[I IncomingMessage] func(ctx context.Context, msg I) error

type MessagePublisher[O any] interface {
	Publish(ctx context.Context, topicName string, v O) error
}

type MessageStream[O any, I IncomingMessage] interface {
	MessagePublisher[O]
	MessageSubscriber[I]
}

type MessageSubscriber[I IncomingMessage] interface {
	Subscribe(topicName string, handler MessageHandler[I], options ...SubscriberOption) error
}

type RawMessage interface {
	Message
	Data() []byte
}

type RawMessageHandler = MessageHandler[IncomingRawMessage]

type RawMessagePublisher = MessagePublisher[RawMessage]

type RawMessageStream = MessageStream[RawMessage, IncomingRawMessage]

type RawMessageSubscriber = MessageSubscriber[IncomingRawMessage]

type ReplyMessage interface {
	Message
	ddd.Reply
}

type ReplyMessageData struct {
	Payload    []byte                 `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	OccurredAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	Metadata   *structpb.Struct       `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

type ReplyPublisher = MessagePublisher[ddd.Reply]

type ReplyStream = MessageStream[ddd.Reply, IncomingReplyMessage]

type ReplySubscriber = MessageSubscriber[IncomingReplyMessage]

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

type SubscriberOption interface {
	// contains filtered or unexported methods
}