Versions in this module Expand all Collapse all v0 v0.1.4 Nov 16, 2023 v0.1.3 Nov 16, 2023 Changes in this version + const CommandHdrPrefix + const CommandNameHdr + const CommandReplyChannelHdr + const FailureReply + const OutcomeFailure + const OutcomeSuccess + const ReplyHdrPrefix + const ReplyNameHdr + const ReplyOutcomeHdr + const SuccessReply + var File_message_types_proto protoreflect.FileDescriptor + type AckType int + const AckTypeAuto + const AckTypeManual + type AckWait time.Duration + type CommandMessage interface + type CommandMessageData struct + OccurredAt *timestamppb.Timestamp + Payload []byte + func (*CommandMessageData) Descriptor() ([]byte, []int) + func (*CommandMessageData) ProtoMessage() + func (x *CommandMessageData) GetOccurredAt() *timestamppb.Timestamp + func (x *CommandMessageData) GetPayload() []byte + func (x *CommandMessageData) ProtoReflect() protoreflect.Message + func (x *CommandMessageData) Reset() + func (x *CommandMessageData) String() string + type CommandPublisher interface + Publish func(context.Context, string, ddd.Command) error + func NewCommandPublisher(reg registry.Registry, publisher MessagePublisher, ...) CommandPublisher + type EventMessage interface + type EventMessageData struct + OccurredAt *timestamppb.Timestamp + Payload []byte + func (*EventMessageData) Descriptor() ([]byte, []int) + func (*EventMessageData) ProtoMessage() + func (x *EventMessageData) GetOccurredAt() *timestamppb.Timestamp + func (x *EventMessageData) GetPayload() []byte + func (x *EventMessageData) ProtoReflect() protoreflect.Message + func (x *EventMessageData) Reset() + func (x *EventMessageData) String() string + type EventPublisher interface + Publish func(context.Context, string, ddd.Event) error + func NewEventPublisher(reg registry.Registry, msgPublisher MessagePublisher, ...) EventPublisher + type GroupName string + type IncomingCommandMessage interface + type IncomingEventMessage interface + type IncomingMessage interface + Data func() []byte + type IncomingMessageBase interface + Ack func() error + Extend func() error + Kill func() error + NAck func() error + ReceivedAt func() time.Time + type IncomingReplyMessage interface + type MaxRedeliver int + type Message interface + Data func() []byte + type MessageBase interface + MessageName func() string + Metadata func() ddd.Metadata + SentAt func() time.Time + Subject func() string + type MessageFilter []string + type MessageHandler interface + HandleMessage func(ctx context.Context, msg IncomingMessage) error + func MessageHandlerWithMiddleware(handler MessageHandler, mws ...MessageHandlerMiddleware) MessageHandler + func NewCommandHandler(reg registry.Registry, publisher ReplyPublisher, ...) MessageHandler + func NewEventHandler(reg registry.Registry, handler ddd.EventHandler[ddd.Event], ...) MessageHandler + func NewReplyHandler(reg registry.Registry, handler ddd.ReplyHandler[ddd.Reply], ...) MessageHandler + type MessageHandlerFunc func(ctx context.Context, msg IncomingMessage) error + func (f MessageHandlerFunc) HandleMessage(ctx context.Context, cmd IncomingMessage) error + type MessageHandlerMiddleware = func(next MessageHandler) MessageHandler + type MessagePublisher interface + Publish func(ctx context.Context, topicName string, msg Message) error + func MessagePublisherWithMiddleware(publisher MessagePublisher, mws ...MessagePublisherMiddleware) MessagePublisher + func NewMessagePublisher(publisher MessagePublisher, mws ...MessagePublisherMiddleware) MessagePublisher + type MessagePublisherFunc func(ctx context.Context, topicName string, msg Message) error + func (f MessagePublisherFunc) Publish(ctx context.Context, topicName string, msg Message) error + type MessagePublisherMiddleware = func(next MessagePublisher) MessagePublisher + type MessageStream interface + func MessageStreamWithMiddleware(stream MessageStream, mws ...MessageStreamMiddleware) MessageStream + type MessageStreamMiddleware = func(next MessageStream) MessageStream + type MessageSubscriber interface + Subscribe func(topicName string, handler MessageHandler, options ...SubscriberOption) (Subscription, error) + Unsubscribe func() error + func NewMessageSubscriber(subscriber MessageSubscriber, mws ...MessageHandlerMiddleware) MessageSubscriber + type MockCommandPublisher struct + func NewMockCommandPublisher(t interface{ ... }) *MockCommandPublisher + func (_m *MockCommandPublisher) Publish(_a0 context.Context, _a1 string, _a2 ddd.Command) error + type MockEventPublisher struct + func NewMockEventPublisher(t interface{ ... }) *MockEventPublisher + func (_m *MockEventPublisher) Publish(_a0 context.Context, _a1 string, _a2 ddd.Event) error + type MockMessageHandler struct + func NewMockMessageHandler(t interface{ ... }) *MockMessageHandler + func (_m *MockMessageHandler) HandleMessage(ctx context.Context, msg IncomingMessage) error + type MockMessagePublisher struct + func NewMockMessagePublisher(t interface{ ... }) *MockMessagePublisher + func (_m *MockMessagePublisher) Publish(ctx context.Context, topicName string, msg Message) error + type MockMessageSubscriber struct + func NewMockMessageSubscriber(t interface{ ... }) *MockMessageSubscriber + func (_m *MockMessageSubscriber) Subscribe(topicName string, handler MessageHandler, options ...SubscriberOption) (Subscription, error) + func (_m *MockMessageSubscriber) Unsubscribe() error + type MockReplyPublisher struct + func NewMockReplyPublisher(t interface{ ... }) *MockReplyPublisher + func (_m *MockReplyPublisher) Publish(ctx context.Context, topicName string, reply ddd.Reply) error + type ReplyMessage interface + type ReplyMessageData struct + OccurredAt *timestamppb.Timestamp + Payload []byte + func (*ReplyMessageData) Descriptor() ([]byte, []int) + func (*ReplyMessageData) ProtoMessage() + func (x *ReplyMessageData) GetOccurredAt() *timestamppb.Timestamp + func (x *ReplyMessageData) GetPayload() []byte + func (x *ReplyMessageData) ProtoReflect() protoreflect.Message + func (x *ReplyMessageData) Reset() + func (x *ReplyMessageData) String() string + type ReplyPublisher interface + Publish func(ctx context.Context, topicName string, reply ddd.Reply) error + func NewReplyPublisher(reg registry.Registry, msgPublisher MessagePublisher, ...) ReplyPublisher + type SubscriberConfig struct + func NewSubscriberConfig(options []SubscriberOption) SubscriberConfig + func (c SubscriberConfig) AckType() AckType + func (c SubscriberConfig) AckWait() time.Duration + func (c SubscriberConfig) GroupName() string + func (c SubscriberConfig) MaxRedeliver() int + func (c SubscriberConfig) MessageFilters() []string + type SubscriberOption interface + type Subscription interface + Unsubscribe func() error
Go to main page