notificator

Documentation

Index

• type Config
• type Notificator
  • func New(cfg *Config) (*Notificator, error)
  • func (n *Notificator) Run(ctx context.Context, wg *sync.WaitGroup, _ chan<- error)
  • func (n *Notificator) Send(ev *event.Event)

Types

type Config

type Config struct {
	Logger        *zap.Logger
	VideoAPIURL   string
	VideoAPIToken string
}

type Notificator

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

Notificator is asynchronous Video API notification service. It takes events and calls videoapi service-side API in separate goroutine.

TODO In the future could be replaced with actual message queue.

func New

func New(cfg *Config) (*Notificator, error)

func (*Notificator) Run

func (n *Notificator) Run(ctx context.Context, wg *sync.WaitGroup, _ chan<- error)

func (*Notificator) Send

func (n *Notificator) Send(ev *event.Event)