state

package

v1.15.0-rc.2 Latest Latest Go to latest Published: Dec 20, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dapr/dapr

Links

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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(runtimeState *backend.OrchestrationRuntimeState)

func (*State) ClearInbox ¶

func (s *State) ClearInbox()

func (*State) DecodeWorkflowState ¶

func (s *State) DecodeWorkflowState(encodedState []byte) error

DecodeWorkflowState decodes the workflow state from a byte array encoded using `EncodeWorkflowState`. It only decodes the inbox, history, and custom status.

func (*State) EncodeWorkflowState ¶

func (s *State) EncodeWorkflowState() ([]byte, error)

EncodeWorkflowState encodes the workflow state into a byte array. It only encodes the inbox, history, and custom status.

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.

Source Files ¶

View all Source files

state.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL