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) CallWithRetry(ctx context.Context, method string, publish func(ctx context.Context) error) error
  • func (r *Relay) Run(id int, conn *grpc.ClientConn, ctx context.Context)
  • func (r *Relay) StartWorkers() error

Constants

const (
	DefaultNumWorkers = 10

	QueueFlushInterval = 10 * time.Second
	DefaultBatchSize   = 100 // number of messages to batch

	MaxGRPCRetries = 5

	// Maximum message size for GRPC client in bytes
	MaxGRPCMessageSize = 1024 * 1024 * 100 // 100MB
	GRPCRetrySleep     = time.Second * 5
)

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
	BatchSize   int
	RelayCh     chan interface{}
	DisableTLS  bool
	Timeout     time.Duration // general grpc timeout (used for all grpc calls)
	Type        string
}

type Relay

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

func New

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

func (*Relay) CallWithRetry

func (r *Relay) CallWithRetry(ctx context.Context, method string, publish func(ctx context.Context) error) error

CallWithRetry will retry a GRPC call until it succeeds or reaches a maximum number of retries defined by MaxGRPCRetries

func (*Relay) Run

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

func (*Relay) StartWorkers

func (r *Relay) StartWorkers() error