dispatcher

Documentation

Index

• Constants
• type DispatchEvent
• type DispatchState
• type Dispatcher
  • func NewNotificationDispatcher(logger *log.Logger, specs map[string]*receivers.Spec, config *notifcfg.Config, ...) Dispatcher

Constants

const (
	InTransit = DispatchState("in-transit")
	Retrying  = DispatchState("retrying")
	Error     = DispatchState("error")
	Success   = DispatchState("success")
)

Types

type DispatchEvent

type DispatchEvent struct {
	State        DispatchState
	ReceiverId   string
	ReceiverDesc string
	Retries      int
	Error        error
	Response     *clients.Response
}

DispatchEvent provides a struct for storing dispatching events.

type DispatchState

type DispatchState string

DispatchState provides a dispatch state

type Dispatcher

type Dispatcher interface {
	Dispatch(ctx context.Context) error
	Events() chan DispatchEvent
	Done() chan struct{}
	SetMockClient(impl clients.ClientImpl)
}

Dispatcher provides an interface for implementing dispatching protocol.

func NewNotificationDispatcher

func NewNotificationDispatcher(
	logger *log.Logger,
	specs map[string]*receivers.Spec,
	config *notifcfg.Config,
	params, envVars map[string]string,
) Dispatcher

NewNotificationDispatcher returns an implementation of *Dispatcher* service.