relay

Feb 16, 2022

Changes in this version

type Config

+ MainShutdownCtx context.Context

Jan 26, 2022

Changes in this version

+ var ErrMissingMessage = errors.New("msg cannot be nil")

+ var ErrMissingMessageOptions = errors.New("msg.Options cannot be nil")

+ var ErrMissingMessageValue = errors.New("msg.Value cannot be nil")

Dec 6, 2021

Changes in this version

+ var ErrMissingID = errors.New("missing ID in relay message")

+ var ErrMissingKeyName = errors.New("missing Key in relay message")

+ var ErrMissingStreamName = errors.New("missing Stream in relay message")

+ var ErrNSQMissingChannel = errors.New("NSQ channel cannot be empty")

+ var ErrNSQMissingTopic = errors.New("NSQ topic cannot be empty")

type Config

+ ErrorCh chan *records.ErrorRecord

Jun 24, 2021

Changes in this version

+ var ErrMissingConfig = errors.New("Relay config cannot be nil")

+ var ErrMissingGRPCAddress = errors.New("GRPCAddress cannot be empty")

+ var ErrMissingRelayCh = errors.New("RelayCh cannot be nil")

+ var ErrMissingServiceShutdownCtx = errors.New("ServiceShutdownCtx cannot be nil")

+ var ErrMissingToken = errors.New("Token cannot be empty")

type Config

+ MainShutdownFunc context.CancelFunc

+ ServiceShutdownCtx context.Context

+ type IRelayBackend interface

+ Relay func() error

type Relay

+ Workers map[int]struct{}

+ WorkersMutex *sync.RWMutex

+ func (r *Relay) WaitForShutdown()

Apr 8, 2021

Changes in this version

type Config

+ Type string

Mar 19, 2021

Changes in this version

+ const GRPCRetrySleep

+ const MaxGRPCMessageSize

+ const MaxGRPCRetries

type Relay

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

Jan 29, 2021

Changes in this version

+ const DefaultBatchSize

+ const QueueFlushInterval

type Config

+ BatchSize int

Sep 21, 2020

Changes in this version

+ const DefaultNumWorkers

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

+ func TestConnection(cfg *Config) error

+ type Config struct

+ DisableTLS bool

+ GRPCAddress string

+ NumWorkers int

+ RelayCh chan interface{}

+ Timeout time.Duration

+ Token string

+ type Relay struct

+ Config *Config

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

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

+ func (r *Relay) StartWorkers() error