relay

Documentation

Index

• Constants
• func New(cfg Config, log logger.Log) *relay
• type Config
• type Relay

Constants

const (
	CYCLE = 1 * time.Second
)

Functions

func New

func New(cfg Config, log logger.Log) *relay

Types

type Config

type Config struct {
	Rc   int    // push retries
	Name string // worker's name
}

type Relay

type Relay interface {
	Run()
	Stop()
	SendChannel() chan<- *message.Packet // channel should close after Stop by caller
	RecvChannel() <-chan *message.Packet // channel will automatically close after stop
}