channels

Documentation

Index

• Variables
• func NewErrorJitterChannel(cfg ErrorJitterChannelConfigs) *errorJitterPool
• func NewErrorNonJitterChannel(cfg ErrorNonJitterChannelConfigs) *errorNonJitterPool
• func NewRPCCallerChannel(cfg RPCCallerChannelConfigs) *rpcCallerPool
• func NewWebhookChannel(cfg WebhookChannelConfigs) *webhookPool
• type ErrorJitterChannelConfigs
• type ErrorNonJitterChannelConfigs
• type RPCCallerChannelConfigs
• type WebhookChannelConfigs
• type WorkerPool

Variables

var ErrorJitterChannelName = "ErrorJitterChannel"

var ErrorNonJitterChannelName = "ErrorNonJitterChannel"

var RPCCallerChannelName = "RPCCallerChannel"

var WebhookChannelName = "WebhookChannel"

Functions

func NewErrorJitterChannel

func NewErrorJitterChannel(cfg ErrorJitterChannelConfigs) *errorJitterPool

func NewErrorNonJitterChannel

func NewErrorNonJitterChannel(cfg ErrorNonJitterChannelConfigs) *errorNonJitterPool

func NewRPCCallerChannel

func NewRPCCallerChannel(cfg RPCCallerChannelConfigs) *rpcCallerPool

func NewWebhookChannel

func NewWebhookChannel(cfg WebhookChannelConfigs) *webhookPool

Types

type ErrorJitterChannelConfigs

type ErrorJitterChannelConfigs struct {
	TxManager            services.TransactionManager
	Router               router.Router
	MaxBufferSize        int
	MaxWorkers           int
	MaxRetries           int
	MinWaitBtwnRetriesMS int
}

type ErrorNonJitterChannelConfigs

type ErrorNonJitterChannelConfigs struct {
	TxManager         services.TransactionManager
	Router            router.Router
	MaxBufferSize     int
	MaxWorkers        int
	MaxRetries        int
	WaitBtwnRetriesMS int
}

type RPCCallerChannelConfigs

type RPCCallerChannelConfigs struct {
	TxManager     services.TransactionManager
	Router        router.Router
	Store         store.Store
	MaxBufferSize int
	MaxWorkers    int
}

type WebhookChannelConfigs

type WebhookChannelConfigs struct {
	HTTPClient           utils.HTTPClient
	Store                store.Store
	MaxBufferSize        int
	MaxWorkers           int
	MaxRetries           int
	MinWaitBtwnRetriesMS int
}

type WorkerPool

type WorkerPool interface {
	Submit(task func())
	StopAndWait()
}