core

Documentation

Overview

Package core provides the 'core' service, which must be started once and only once in every server process

Index

• type Options
  • func (o Options) NewService() *Service
• type Service
  • func (s *Service) Shutdown() error
  • func (s *Service) Startup() error

Types

type Options

type Options struct {
	services.Options

	ActorStorage    storage.ActorStorage
	ProcessStorage  storage.ProcessStorage
	ProcessManager  *process.Manager
	PipelineManager *pipeline.Manager
	LogStorage      storage.LogStorage
	EnvelopeStorage storage.EnvelopeStorage
}

Options is used to create a 'core' service

func (Options) NewService

func (o Options) NewService() *Service

NewService creates a Emitter

type Service

type Service struct {
	services.BaseService
	// contains filtered or unexported fields
}

Service is in charge of emitting envelopes to Actors

func (*Service) Shutdown

func (s *Service) Shutdown() error

Shutdown stops the service

func (*Service) Startup

func (s *Service) Startup() error

Startup starts the service