relay

Documentation

Index

• type Announcer
  • func NewAnnouncer(relayID string, conn bus.Connection, catalog *bundle.Catalog) Announcer
• type DynamicConfigUpdater
  • func NewDynamicConfigUpdater(relayID string, busOpts bus.ConnectionOptions, dynamicConfigRoot string, ...) *DynamicConfigUpdater
  • func (dcu *DynamicConfigUpdater) Halt()
  • func (dcu *DynamicConfigUpdater) Run() error
• type Relay
  • func NewRelay(config *config.Config) (Relay, error)

Types

type Announcer

type Announcer interface {
	SendAnnouncement()
	SetSubscriptions() error
	Run() error
	Halt()
}

Announcer announces Relay bundles lists to Cog

func NewAnnouncer

func NewAnnouncer(relayID string, conn bus.Connection, catalog *bundle.Catalog) Announcer

NewAnnouncer creates a new Announcer

type DynamicConfigUpdater

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

DynamicConfigUpdater periodically updates bundle dynamic configurations from Cog

func NewDynamicConfigUpdater

func NewDynamicConfigUpdater(relayID string, busOpts bus.ConnectionOptions, dynamicConfigRoot string,
	refreshInterval time.Duration) *DynamicConfigUpdater

NewDynamicConfigUpdater creates a new updater

func (*DynamicConfigUpdater) Halt

func (dcu *DynamicConfigUpdater) Halt()

Halt tells the DCU to stop.

func (*DynamicConfigUpdater) Run

func (dcu *DynamicConfigUpdater) Run() error

type Relay

type Relay interface {
	Start() error
	Stop() error
}

Relay is responsible for connecting to the message bus and processing directly or dispatching to a worker pool any incoming messages.

func NewRelay

func NewRelay(config *config.Config) (Relay, error)

NewRelay constructs a new Relay instance