processstate

Documentation

Index

• Constants
• type Options
  • func (o Options) NewService() *Service
• type Service
  • func (s *Service) AckResult(ctx context.Context, emitterID string, req api.AckResultRequest) error
  • func (s *Service) GetEnvelopeState(ctx context.Context, emitterID string, req api.GetEnvelopeStateRequest) (api.EmitterEnvelopeState, error)
  • func (s *Service) List(ctx context.Context, emitterID string, req api.ProcessFilter, ...) error
  • func (s *Service) Startup() error

Constants

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

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

Types

type Options

type Options struct {
	services.Options

	LogStorage      storage.LogStorage
	ProcessManager  *process.Manager
	EnvelopeStorage storage.EnvelopeStorage
	ActorStorage    storage.ActorStorage
}

Options is used to create a 'processstate' 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) AckResult

func (s *Service) AckResult(
	ctx context.Context, emitterID string, req api.AckResultRequest,
) error

AckResult mark a process result as acked

func (*Service) GetEnvelopeState

func (s *Service) GetEnvelopeState(
	ctx context.Context, emitterID string, req api.GetEnvelopeStateRequest,
) (
	api.EmitterEnvelopeState, error,
)

GetEnvelopeState implements ProcessState.GetEnvelopeState

func (*Service) List

func (s *Service) List(
	ctx context.Context, emitterID string, req api.ProcessFilter,
	send func(api.EmitterEnvelopeStateList),
) error

List the process of this emitter

func (*Service) Startup

func (s *Service) Startup() error

Startup starts the service