manager

Documentation

Index

• type LifecycleManager
  • func New(rtFactory *router.Factory, brtFactory *batchrouter.Factory, ...) *LifecycleManager
  • func (r *LifecycleManager) RouterIdentifier(destinationID, destinationType string) string
  • func (r *LifecycleManager) Start() error
  • func (r *LifecycleManager) Stop()

Types

type LifecycleManager

type LifecycleManager struct {
	BackendConfig backendconfig.BackendConfig
	// contains filtered or unexported fields
}

func New

func New(rtFactory *router.Factory, brtFactory *batchrouter.Factory,
	backendConfig backendconfig.BackendConfig,
) *LifecycleManager

New creates a new Router instance

func (*LifecycleManager) RouterIdentifier

func (r *LifecycleManager) RouterIdentifier(destinationID, destinationType string) string

func (*LifecycleManager) Start

func (r *LifecycleManager) Start() error

Start starts a Router, this is not a blocking call. If the router is not completely started and the data started coming then also it will not be problematic as we are assuming that the DBs will be up.

func (*LifecycleManager) Stop

func (r *LifecycleManager) Stop()

Stop stops the Router, this is a blocking call.