sharddistributor

Documentation

Index

• type Service
  • func NewService(params *resource.Params, factory resource.ResourceFactory) (*Service, error)
  • func (s *Service) Start()
  • func (s *Service) Stop()

Types

type Service

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

Service represents the shard distributor service for legacy resource based initialization. DEPRECATED: use fx and sharddistributorfx to avoid creating start/stopper.

func NewService

func NewService(
	params *resource.Params,
	factory resource.ResourceFactory,
) (*Service, error)

NewService is an adapter for legacy initialization without fx.

func (*Service) Start

func (s *Service) Start()

Start legacy mode fx stops the component and ensures order/wait time between dependent components.

func (*Service) Stop

func (s *Service) Stop()

Stop legacy mode, fx stops the component and ensures order/wait time between dependent components.