subscribers

Documentation

Index

• type Subscriber
  • func (s *Subscriber) DispatchEvent(event *interface{})
  • func (s *Subscriber) InternalInit(eventChannel *chan *interface{}, name string)
  • func (s *Subscriber) InternalTerminate()

Types

type Subscriber

type Subscriber struct {
	Channel *chan *interface{}
	Logger  zerolog.Logger
}

func (*Subscriber) DispatchEvent

func (s *Subscriber) DispatchEvent(event *interface{})

func (*Subscriber) InternalInit

func (s *Subscriber) InternalInit(eventChannel *chan *interface{}, name string)

func (*Subscriber) InternalTerminate

func (s *Subscriber) InternalTerminate()