state

Documentation

Index

• type Options
• type State
  • func LoadWorkflowState(ctx context.Context, state state.Interface, actorID string, opts Options) (*State, error)
  • func NewState(opts Options) *State
  • func (s *State) AddToInbox(e *backend.HistoryEvent)
  • func (s *State) ApplyRuntimeStateChanges(rs *backend.OrchestrationRuntimeState)
  • func (s *State) ClearInbox()
  • func (s *State) GetPurgeRequest(actorID string) (*api.TransactionalRequest, error)
  • func (s *State) GetSaveRequest(actorID string) (*api.TransactionalRequest, error)
  • func (s *State) Reset()
  • func (s *State) ResetChangeTracking()
  • func (s *State) String() string

Types

type Options

type Options struct {
	AppID             string
	WorkflowActorType string
	ActivityActorType string
}

type State

type State struct {
	Inbox        []*backend.HistoryEvent
	History      []*backend.HistoryEvent
	CustomStatus *wrapperspb.StringValue
	Generation   uint64
	// contains filtered or unexported fields
}

func LoadWorkflowState

func LoadWorkflowState(ctx context.Context, state state.Interface, actorID string, opts Options) (*State, error)

func NewState

func NewState(opts Options) *State

func (*State) AddToInbox

func (s *State) AddToInbox(e *backend.HistoryEvent)

func (*State) ApplyRuntimeStateChanges

func (s *State) ApplyRuntimeStateChanges(rs *backend.OrchestrationRuntimeState)

func (*State) ClearInbox

func (s *State) ClearInbox()

func (*State) GetPurgeRequest

func (s *State) GetPurgeRequest(actorID string) (*api.TransactionalRequest, error)

func (*State) GetSaveRequest

func (s *State) GetSaveRequest(actorID string) (*api.TransactionalRequest, error)

func (*State) Reset

func (s *State) Reset()

func (*State) ResetChangeTracking

func (s *State) ResetChangeTracking()

ResetChangeTracking resets the change tracking counters. This should be called after a save request.

func (*State) String

func (s *State) String() string

String implements fmt.Stringer and is primarily used for debugging purposes.