watermill

Documentation

Index

• type Router
  • func NewRouter(ctx context.Context, outHandler message.NoPublishHandlerFunc) Router
  • func (v Router) CreateMessageSender(helper affinity.Helper, accessor beat.History) messagesender.Service
  • func (v Router) IsZero() bool
  • func (v Router) PublishMessage(topic string, msg *message.Message) error
  • func (v Router) ReplacePublisher(publisher message.Publisher) Router
  • func (v Router) SubscribeForMessages(inHandler func(beat.Message) error) (stopFn func())

Types

type Router

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

func NewRouter

func NewRouter(ctx context.Context, outHandler message.NoPublishHandlerFunc) Router

func (Router) CreateMessageSender

func (v Router) CreateMessageSender(helper affinity.Helper, accessor beat.History) messagesender.Service

func (Router) IsZero

func (v Router) IsZero() bool

func (Router) PublishMessage

func (v Router) PublishMessage(topic string, msg *message.Message) error

func (Router) ReplacePublisher

func (v Router) ReplacePublisher(publisher message.Publisher) Router

func (Router) SubscribeForMessages

func (v Router) SubscribeForMessages(inHandler func(beat.Message) error) (stopFn func())