pubsub

Documentation

Index

• Variables
• type Handler
• type Processor
  • func NewProcessor(ch <-chan interface{}, timeout time.Duration, handler Handler) Processor
• type Pubsub
  • func NewPubsub(size int) (Pubsub, error)

Variables

var (
	ErrProcessorTimeout = errors.New("failed to send message because of timeout")
)

var (
	ErrPubsubTimeout = errors.New("failed to send message to topic because of timeout")
)

Types

type Handler

type Handler interface {
	OnMessage(interface{}) error
	OnTimeout() error
}

type Processor

type Processor interface {
	Start()
	Close()
}

func NewProcessor

func NewProcessor(ch <-chan interface{}, timeout time.Duration, handler Handler) Processor

type Pubsub

type Pubsub interface {
	Publish(topic string, msg interface{}) error
	Subscribe(topic string) (<-chan interface{}, error)
	Unsubscribe(topic string, ch <-chan interface{}) error
	io.Closer
}

func NewPubsub

func NewPubsub(size int) (Pubsub, error)