Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumerServer ¶
type ConsumerServer struct {
// contains filtered or unexported fields
}
func NewConsumerServer ¶
func NewConsumerServer(rdAddr string, repo types.Repository) *ConsumerServer
func (*ConsumerServer) AddHandlers ¶
func (cs *ConsumerServer) AddHandlers(consumers map[string]types.ConsumerFn) *ConsumerServer
func (*ConsumerServer) Start ¶
func (cs *ConsumerServer) Start() error
func (*ConsumerServer) WithConsumerServer ¶
func (cs *ConsumerServer) WithConsumerServer(rdAddr string, repo types.Repository) *ConsumerServer
type Producer ¶
type Producer struct {
// contains filtered or unexported fields
}
func NewProducer ¶
type SagaPattern ¶
type SagaPattern struct {
ConsumerServer
Consumers []types.ConsumerInput
Options types.Opts
SequencePayloads bool
// contains filtered or unexported fields
}
func NewSagaPattern ¶
func NewSagaPattern(rdAddr string, repo types.Repository, consumers []types.ConsumerInput, options types.Opts, sequencePayloads bool) *SagaPattern
func (SagaPattern) Close ¶
func (sp SagaPattern) Close()
func (SagaPattern) Consumer ¶
func (sp SagaPattern) Consumer(ctx context.Context, payload types.PayloadInput) error
Source Files
Click to show internal directories.
Click to hide internal directories.