observer

Documentation

Index

• type NotificationStatus
• type Observer
  • func NewObserver(ctx context.Context, sStore storage.Database, blacklist blacklist.Blacklister, ...) (*Observer, error)
  • func (o *Observer) HandleEvent(ctx context.Context, event events.EventMessage)
• type Overseer

Types

type NotificationStatus

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

type Observer

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

func NewObserver

func NewObserver(
	ctx context.Context,
	sStore storage.Database,
	blacklist blacklist.Blacklister,
	eventManager *events.EventManager,
) (*Observer, error)

func (*Observer) HandleEvent

func (o *Observer) HandleEvent(ctx context.Context, event events.EventMessage)

type Overseer

type Overseer interface {
	HandleEvent(context.Context, events.EventMessage)
}