core

Documentation

Index

• Variables
• type Captin
  • func NewCaptin(configMap interfaces.ConfigMapperInterface) *Captin
  • func (c *Captin) Execute(ctx context.Context, ie interfaces.IncomingEventInterface) (bool, []interfaces.ErrorInterface)
  • func (c Captin) IsRunning() bool
  • func (c *Captin) SetDestinationFilters(filters []destination_filters.DestinationFilterInterface)
  • func (c *Captin) SetDestinationMiddlewares(middlewares []destination_filters.DestinationMiddlewareInterface)
  • func (c *Captin) SetDispatchDelayer(delayer interfaces.DispatchDelayerInterface)
  • func (c *Captin) SetDispatchErrorHandler(handler interfaces.ErrorHandlerInterface)
  • func (c *Captin) SetDispatchFilters(filters []destination_filters.DestinationFilterInterface)
  • func (c *Captin) SetDispatchMiddlewares(middlewares []destination_filters.DestinationMiddlewareInterface)
  • func (c *Captin) SetDocumentStoreMapping(mappings map[string]interfaces.DocumentStoreInterface)
  • func (c *Captin) SetSenderMapping(senderMapping map[string]interfaces.EventSenderInterface)
  • func (c *Captin) SetStore(store interfaces.StoreInterface)
  • func (c *Captin) SetThrottler(throttle interfaces.ThrottleInterface)

Variables

var STATUS_READY = "ready"

var STATUS_RUNNING = "running"

Types

type Captin

type Captin struct {
	Status    string
	ConfigMap interfaces.ConfigMapperInterface

	SenderMapping map[string]interfaces.EventSenderInterface

	DocumentStoreMapping map[string]interfaces.DocumentStoreInterface
	// contains filtered or unexported fields
}

Captin - Captin instance

func NewCaptin

func NewCaptin(configMap interfaces.ConfigMapperInterface) *Captin

NewCaptin - Create Captin instance with default http senders and time throttler

func (*Captin) Execute

func (c *Captin) Execute(ctx context.Context, ie interfaces.IncomingEventInterface) (bool, []interfaces.ErrorInterface)

Execute - Execute for events

func (Captin) IsRunning

func (c Captin) IsRunning() bool

func (*Captin) SetDestinationFilters

func (c *Captin) SetDestinationFilters(filters []destination_filters.DestinationFilterInterface)

SetDestinationFilters - Set filters

func (*Captin) SetDestinationMiddlewares

func (c *Captin) SetDestinationMiddlewares(middlewares []destination_filters.DestinationMiddlewareInterface)

SetDestinationMiddlewares - Set middlewares

func (*Captin) SetDispatchDelayer

func (c *Captin) SetDispatchDelayer(delayer interfaces.DispatchDelayerInterface)

func (*Captin) SetDispatchErrorHandler

func (c *Captin) SetDispatchErrorHandler(handler interfaces.ErrorHandlerInterface)

func (*Captin) SetDispatchFilters

func (c *Captin) SetDispatchFilters(filters []destination_filters.DestinationFilterInterface)

SetDestinationFilters - Set filters

func (*Captin) SetDispatchMiddlewares

func (c *Captin) SetDispatchMiddlewares(middlewares []destination_filters.DestinationMiddlewareInterface)

func (*Captin) SetDocumentStoreMapping

func (c *Captin) SetDocumentStoreMapping(mappings map[string]interfaces.DocumentStoreInterface)

SetDocumentStoreMapping - Set store where event targets are being stored

func (*Captin) SetSenderMapping

func (c *Captin) SetSenderMapping(senderMapping map[string]interfaces.EventSenderInterface)

func (*Captin) SetStore

func (c *Captin) SetStore(store interfaces.StoreInterface)

SetStore - Set store

func (*Captin) SetThrottler

func (c *Captin) SetThrottler(throttle interfaces.ThrottleInterface)

SetThrottler - Set throttle