manager

Documentation

Index

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

Types

type LifecycleManager

type LifecycleManager struct {
	// contains filtered or unexported fields
}

func New

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

New creates a new Router instance

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.