servicemanager

Documentation

Index

• type GenericService
  • func NewGenericService(name string, dependencies []string, run RunFunc) *GenericService
  • func (s *GenericService) Dependencies() []string
  • func (s *GenericService) Name() string
  • func (s *GenericService) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error
• type RunFunc
• type Runner
• type Service
• type ServiceManager
  • func NewServiceManager(startRec *startuprecorder.StartupRecorder) *ServiceManager
  • func (m *ServiceManager) AddService(s Service) error
  • func (s *ServiceManager) Dependencies() []string
  • func (s *ServiceManager) Name() string
  • func (m *ServiceManager) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error

Types

type GenericService

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

func NewGenericService

func NewGenericService(name string, dependencies []string, run RunFunc) *GenericService

func (*GenericService) Dependencies

func (s *GenericService) Dependencies() []string

func (*GenericService) Name

func (s *GenericService) Name() string

func (*GenericService) Run

func (s *GenericService) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error

type RunFunc

type RunFunc func(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error

type Runner

type Runner interface {
	Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error
}

type Service

type Service interface {
	Name() string
	Dependencies() []string
	Runner
}

type ServiceManager

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

func NewServiceManager

func NewServiceManager(startRec *startuprecorder.StartupRecorder) *ServiceManager

func (*ServiceManager) AddService

func (m *ServiceManager) AddService(s Service) error

func (*ServiceManager) Dependencies

func (s *ServiceManager) Dependencies() []string

func (*ServiceManager) Name

func (s *ServiceManager) Name() string

func (*ServiceManager) Run

func (m *ServiceManager) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error