pubsub

Documentation

Index

• type Publisher
• type Subject
  • func NewSubject(logger *zap.Logger) Subject
• type SubjectChannel
• type SubjectEvent
• type Subscriber

Types

type Publisher

type Publisher interface {
	Notify(e SubjectEvent)
}

Publisher introduces "write" capabilities on the subject

type Subject

type Subject interface {
	Subscriber
	Publisher
}

Subject represent the interface for a subject

func NewSubject

func NewSubject(logger *zap.Logger) Subject

NewSubject creates a new instance of the internal struct

type SubjectChannel

type SubjectChannel chan SubjectEvent

SubjectChannel is the channel that will pass the events

type SubjectEvent

type SubjectEvent interface{}

SubjectEvent is the event being fired

type Subscriber

type Subscriber interface {
	Register(id string) (SubjectChannel, error)
	Deregister(id string)
}

Subscriber represents the base functionality of a subject (used by observers)