core

package
Version: v0.0.0-...-821bb50 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 29, 2021 License: MIT Imports: 8 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL