sharddistributor

Documentation

Index

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

Types

type Service

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

Service represents the shard distributor service

func FXService

func FXService(params ServiceParams) *Service

FXService builds a new shard distributor service

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 starts the service

func (*Service) Stop

func (s *Service) Stop()

type ServiceParams

type ServiceParams struct {
	fx.In

	Logger            log.Logger
	MetricsClient     metrics.Client
	RPCFactory        rpc.Factory
	DynamicCollection *dynamicconfig.Collection

	Lifecycle fx.Lifecycle

	HostName string `name:"hostname"`

	MembershipRings map[string]membership.SingleProvider
}