Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

requestreply

package

Go to main page

Versions in this module

v1

v1.5.2

May 13, 2026

v1.5.1

Sep 2, 2025

v1.5.0

Aug 25, 2025

v1.4.7

Jul 3, 2025

v1.4.6

Mar 19, 2025

v1.4.5

Mar 10, 2025

v1.4.4

Jan 16, 2025

v1.4.3

Jan 13, 2025

v1.4.2

Jan 8, 2025

v1.4.1

Nov 2, 2024

v1.4.0

Oct 29, 2024

v1.4.0-rc.2

Oct 25, 2024

v1.4.0-rc.1

Sep 25, 2024

v1.3.7

Aug 26, 2024

v1.3.6

Aug 24, 2024

Changes in this version

type PubSubBackendConfig

+ ReplyPublishErrorHandler ReplyPublishErrorHandler

+ type ReplyPublishErrorHandler func(replyTopic string, notificationMsg *message.Message, err error) error

v1.3.5

Sep 24, 2023

Changes in this version

+ const ErrorMetadataKey

+ const HasErrorMetadataKey

+ const OperationIDMetadataKey

+ func NewCommandHandler(handlerName string, backend Backend[struct{}], ...) cqrs.CommandHandler

+ func NewCommandHandlerWithResult(handlerName string, backend Backend[Result], ...) cqrs.CommandHandler

+ func SendWithReplies(ctx context.Context, c CommandBus, backend Backend[Result], cmd any) (replCh <-chan Reply[Result], cancel func(), err error)

+ type Backend interface

+ ListenForNotifications func(ctx context.Context, params BackendListenForNotificationsParams) (<-chan Reply[Result], error)

+ OnCommandProcessed func(ctx context.Context, params BackendOnCommandProcessedParams[Result]) error

+ type BackendListenForNotificationsParams struct

+ Command any

+ OperationID OperationID

+ type BackendOnCommandProcessedParams struct

+ Command any

+ CommandMessage *message.Message

+ HandleErr error

+ HandlerResult Result

+ type BackendPubsubJSONMarshaler struct

+ func (m BackendPubsubJSONMarshaler[Result]) MarshalReply(params BackendOnCommandProcessedParams[Result]) (*message.Message, error)

+ func (m BackendPubsubJSONMarshaler[Result]) UnmarshalReply(msg *message.Message) (Reply[Result], error)

+ type BackendPubsubMarshaler interface

+ MarshalReply func(params BackendOnCommandProcessedParams[Result]) (*message.Message, error)

+ UnmarshalReply func(msg *message.Message) (reply Reply[Result], err error)

+ type CommandBus interface

+ SendWithModifiedMessage func(ctx context.Context, cmd any, modify func(*message.Message) error) error

+ type CommandHandlerError struct

+ Err error

+ func (e CommandHandlerError) Error() string

+ func (e CommandHandlerError) Unwrap() error

+ type NoResult = struct

+ type OperationID string

+ type PubSubBackend struct

+ func NewPubSubBackend(config PubSubBackendConfig, marshaler BackendPubsubMarshaler[Result]) (*PubSubBackend[Result], error)

+ func (p PubSubBackend[Result]) ListenForNotifications(ctx context.Context, params BackendListenForNotificationsParams) (<-chan Reply[Result], error)

+ func (p PubSubBackend[Result]) OnCommandProcessed(ctx context.Context, params BackendOnCommandProcessedParams[Result]) error

+ type PubSubBackendConfig struct

+ AckCommandErrors bool

+ GeneratePublishTopic PubSubBackendGeneratePublishTopicFn

+ GenerateSubscribeTopic PubSubBackendGenerateSubscribeTopicFn

+ ListenForReplyTimeout *time.Duration

+ Logger watermill.LoggerAdapter

+ ModifyNotificationMessage PubSubBackendModifyNotificationMessageFn

+ OnListenForReplyFinished PubSubBackendOnListenForReplyFinishedFn

+ Publisher message.Publisher

+ SubscriberConstructor PubSubBackendSubscriberConstructorFn

+ func (p *PubSubBackendConfig) Validate() error

+ type PubSubBackendGeneratePublishTopicFn func(PubSubBackendPublishParams) (string, error)

+ type PubSubBackendGenerateSubscribeTopicFn func(PubSubBackendSubscribeParams) (string, error)

+ type PubSubBackendModifyNotificationMessageFn func(msg *message.Message, params PubSubBackendOnCommandProcessedParams) error

+ type PubSubBackendOnCommandProcessedParams struct

+ HandleErr error

+ type PubSubBackendOnListenForReplyFinishedFn func(ctx context.Context, params PubSubBackendSubscribeParams)

+ type PubSubBackendPublishParams struct

+ Command any

+ CommandMessage *message.Message

+ OperationID OperationID

+ type PubSubBackendSubscribeParams struct

+ Command any

+ OperationID OperationID

+ type PubSubBackendSubscriberConstructorFn func(PubSubBackendSubscribeParams) (message.Subscriber, error)

+ type Reply struct

+ Error error

+ HandlerResult Result

+ NotificationMessage *message.Message

+ func SendWithReply(ctx context.Context, c CommandBus, backend Backend[Result], cmd any) (Reply[Result], error)

+ type ReplyTimeoutError struct

+ Duration time.Duration

+ Err error

+ func (e ReplyTimeoutError) Error() string

+ type ReplyUnmarshalError struct

+ Err error

+ func (r ReplyUnmarshalError) Error() string

+ func (r ReplyUnmarshalError) Unwrap() error