workflowstate

package

v0.19.0 Latest Latest Go to latest Published: Oct 27, 2024 License: MIT Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func GetSignalChannel[T any](ctx sync.Context, wf *WfState, name string) sync.Channel[T]

func NewReplayLogger(replayer Replayer, logger *slog.Logger) *slog.Logger

func ReceiveSignal(wf *WfState, name string, arg payload.Payload)

func WithWorkflowState(ctx sync.Context, wfState *WfState) sync.Context

type DecodingSettable struct {
	Set  func(v payload.Payload, err error) error
	Name string
}

func AsDecodingSettable[T any](cv converter.Converter, name string, f sync.SettableFuture[T]) *DecodingSettable

Use this to track futures for the workflow state. It's required to map the generic Future interface to a type without type parameters.

type Replayer interface {
	Replaying() bool
}

type WfState struct {
	// contains filtered or unexported fields
}

func NewWorkflowState(instance *core.WorkflowInstance, logger *slog.Logger, tracer trace.Tracer, clock clock.Clock) *WfState

func WorkflowState(ctx sync.Context) *WfState

func (wf *WfState) AddCommand(cmd command.Command)

func (wf *WfState) CommandByScheduleEventID(scheduleEventID int64) command.Command

func (wf *WfState) Commands() []command.Command

func (wf *WfState) FutureByScheduleEventID(scheduleEventID int64) (*DecodingSettable, bool)

func (wf *WfState) GetNextScheduleEventID() int64

func (wf *WfState) HasPendingFutures() bool

func (wf *WfState) Instance() *core.WorkflowInstance

func (wf *WfState) Logger() *slog.Logger

func (wf *WfState) PendingFutureNames() map[int64]string

func (wf *WfState) RemoveFuture(scheduleEventID int64)

func (wf *WfState) Replaying() bool

func (wf *WfState) SetReplaying(replaying bool)

func (wf *WfState) SetTime(t time.Time)

func (wf *WfState) Time() time.Time

func (wf *WfState) Tracer() trace.Tracer

func (wf *WfState) TrackFuture(scheduleEventID int64, f *DecodingSettable)