manager

Documentation

Index

• type LifecycleManager
  • func New(rtFactory *router.Factory, brtFactory *batchrouter.Factory, ...) *LifecycleManager
  • func (*LifecycleManager) Run(ctx context.Context) error
  • func (r *LifecycleManager) Start()
  • 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) Run

func (*LifecycleManager) Run(ctx context.Context) error

func (*LifecycleManager) Start

func (r *LifecycleManager) Start()

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.