process

type Adaptor struct {
	// Identity is the handler's identity.
	Identity *envelopespec.Identity

	// Handler is the process message handler that implements the
	// application-specific message handling logic.
	Handler dogma.ProcessMessageHandler

	// Loader is used to load process instances into memory.
	Loader *Loader

	// Marshaler is used to marshal process instances.
	Marshaler marshalkit.ValueMarshaler

	// Cache is an in-memory cache of process instances.
	Cache cache.Cache

	// Queue is the message queue that stores pending timeout messages.
	Queue *queue.Queue

	// Packer is used to create new parcels for messages produced by the
	// handler.
	Packer *parcel.Packer

	// LoadTimeout is the timeout duration allowed while loading process
	// state.
	LoadTimeout time.Duration

	// Logger is the target for log messages produced within the handler.
	// If it is nil, logging.DefaultLogger is used.
	Logger logging.Logger
}

type Instance struct {
	persistence.ProcessInstance
	Root dogma.ProcessRoot
}

type Loader struct {
	// Repository is the repository used to load process instances.
	Repository persistence.ProcessRepository

	// Marshaler is used to marshal/unmarshal process instances.
	Marshaler marshalkit.ValueMarshaler
}