observer

Documentation

Index

• func PublishPoisonMessage(payload Topic, subscriber Subscriber) error
• func RetryInternalEvent()
• func SetGlobalPublisher(publisher *Publisher)
• type Publisher
  • func GetGlobalPublisher() *Publisher
  • func NewPublisher(debug bool) *Publisher
  • func (p *Publisher) AttachSubscriber(topic string, sub Subscriber)
  • func (p *Publisher) Publish(topic Topic)
• type Subscriber
• type Topic
  • func EmptyTopic() Topic

Functions

func PublishPoisonMessage

func PublishPoisonMessage(payload Topic, subscriber Subscriber) error

func RetryInternalEvent

func RetryInternalEvent()

func SetGlobalPublisher

func SetGlobalPublisher(publisher *Publisher)

Types

type Publisher

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

func GetGlobalPublisher

func GetGlobalPublisher() *Publisher

func NewPublisher

func NewPublisher(debug bool) *Publisher

func (*Publisher) AttachSubscriber

func (p *Publisher) AttachSubscriber(topic string, sub Subscriber)

func (*Publisher) Publish

func (p *Publisher) Publish(topic Topic)

type Subscriber

type Subscriber interface {
	Subscribe(topic Topic)
}

type Topic

type Topic struct {
	RequestID       string
	Subject         string
	Payload         interface{}
	RetrialAttempts int
}

func EmptyTopic

func EmptyTopic() Topic