envelopestorage

Documentation

Index

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

Constants

const (
	// ServiceName name of the service
	ServiceName = "envelopestorage"

	// QueueName queue name for queuesubscribes
	QueueName = "xbus.services." + ServiceName
)

Variables

var (
	// EnvelopeStallDelay is the delay after which an envelope is marked stalled
	// when its emitter stops sending fragments.
	// TODO in a later version, this value should be envelope-dependant and be
	// set by the emitter itself (within reasonnable limits)
	EnvelopeStallDelay = 30 * time.Second
)

Types

type Options

type Options struct {
	services.Options

	EnvelopeStorage storage.EnvelopeStorage
	JobStorage      storage.JobStorage
}

Options is used to create a 'envelopestorage' service

func (Options) NewService

func (o Options) NewService() *Service

NewService creates a Service

type Service

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

Service is in charge of emitting process status events to various subjects

func (*Service) Shutdown

func (s *Service) Shutdown() error

Shutdown stops the service

func (*Service) Startup

func (s *Service) Startup() error

Startup starts the service