relay

Documentation

Index

• Constants
• func NewConnection(address, token string, timeout time.Duration, disableTLS, noCtx bool) (*grpc.ClientConn, context.Context, error)
• func TestConnection(cfg *Config) error
• type Config
• type Relay
  • func New(relayCfg *Config) (*Relay, error)
  • func (r *Relay) Run(id int, conn *grpc.ClientConn, ctx context.Context)
  • func (r *Relay) StartWorkers() error

Constants

const (
	DefaultNumWorkers = 10
)

Functions

func NewConnection

func NewConnection(address, token string, timeout time.Duration, disableTLS, noCtx bool) (*grpc.ClientConn, context.Context, error)

func TestConnection

func TestConnection(cfg *Config) error

Types

type Config

type Config struct {
	Token       string
	GRPCAddress string
	NumWorkers  int
	RelayCh     chan interface{}
	DisableTLS  bool
	Timeout     time.Duration // general grpc timeout (used for all grpc calls)
}

type Relay

type Relay struct {
	Config *Config
	// contains filtered or unexported fields
}

func New

func New(relayCfg *Config) (*Relay, error)

func (*Relay) Run

func (r *Relay) Run(id int, conn *grpc.ClientConn, ctx context.Context)

func (*Relay) StartWorkers

func (r *Relay) StartWorkers() error