actors

package
v1.15.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 30, 2025 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	WorkflowNameLabelKey = "workflow"
	ActivityNameLabelKey = "activity"
	ActorTypePrefix      = "dapr.internal."
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Actors added in v1.15.0 

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

func New added in v1.15.0 

func New(opts Options) *Actors

func (*Actors) AbandonActivityWorkItem added in v1.15.0 

func (*Actors) AbandonActivityWorkItem(ctx context.Context, wi *backend.ActivityWorkItem) error

AbandonActivityWorkItem implements backend.Backend. It gets called by durabletask-go when there is an unexpected failure in the workflow activity execution pipeline.

func (*Actors) AbandonOrchestrationWorkItem added in v1.15.0 

func (*Actors) AbandonOrchestrationWorkItem(ctx context.Context, wi *backend.OrchestrationWorkItem) error

AbandonOrchestrationWorkItem implements backend.Backend. It gets called by durabletask-go when there is an unexpected failure in the workflow orchestration execution pipeline.

func (*Actors) ActivityActorType added in v1.15.0 

func (abe *Actors) ActivityActorType() string

func (*Actors) AddNewOrchestrationEvent added in v1.15.0 

func (abe *Actors) AddNewOrchestrationEvent(ctx context.Context, id api.InstanceID, e *backend.HistoryEvent) error

AddNewOrchestrationEvent implements backend.Backend and sends the event e to the workflow actor identified by id.

func (*Actors) CompleteActivityWorkItem added in v1.15.0 

func (*Actors) CompleteActivityWorkItem(ctx context.Context, wi *backend.ActivityWorkItem) error

CompleteActivityWorkItem implements backend.Backend

func (*Actors) CompleteOrchestrationWorkItem added in v1.15.0 

func (*Actors) CompleteOrchestrationWorkItem(ctx context.Context, wi *backend.OrchestrationWorkItem) error

CompleteOrchestrationWorkItem implements backend.Backend

func (*Actors) CreateOrchestrationInstance added in v1.15.0 

func (abe *Actors) CreateOrchestrationInstance(ctx context.Context, e *backend.HistoryEvent, opts ...backend.OrchestrationIdReusePolicyOptions) error

CreateOrchestrationInstance implements backend.Backend and creates a new workflow instance.

Internally, creating a workflow instance also creates a new actor with the same ID. The create request is saved into the actor's "inbox" and then executed via a reminder thread. If the app is scaled out across multiple replicas, the actor might get assigned to a replicas other than this one.

func (*Actors) CreateTaskHub added in v1.15.0 

func (*Actors) CreateTaskHub(context.Context) error

CreateTaskHub implements backend.Backend

func (*Actors) DeleteTaskHub added in v1.15.0 

func (*Actors) DeleteTaskHub(context.Context) error

DeleteTaskHub implements backend.Backend

func (*Actors) GetOrchestrationMetadata added in v1.15.0 

func (abe *Actors) GetOrchestrationMetadata(ctx context.Context, id api.InstanceID) (*backend.OrchestrationMetadata, error)

GetOrchestrationMetadata implements backend.Backend

func (*Actors) GetOrchestrationRuntimeState added in v1.15.0 

func (abe *Actors) GetOrchestrationRuntimeState(ctx context.Context, owi *backend.OrchestrationWorkItem) (*backend.OrchestrationRuntimeState, error)

GetOrchestrationRuntimeState implements backend.Backend

func (*Actors) NextActivityWorkItem added in v1.15.0 

func (abe *Actors) NextActivityWorkItem(ctx context.Context) (*backend.ActivityWorkItem, error)

NextActivityWorkItem implements backend.Backend

func (*Actors) NextOrchestrationWorkItem added in v1.15.0 

func (abe *Actors) NextOrchestrationWorkItem(ctx context.Context) (*backend.OrchestrationWorkItem, error)

NextOrchestrationWorkItem implements backend.Backend

func (*Actors) PurgeOrchestrationState added in v1.15.0 

func (abe *Actors) PurgeOrchestrationState(ctx context.Context, id api.InstanceID) error

PurgeOrchestrationState deletes all saved state for the specific orchestration instance.

func (*Actors) RegisterActors added in v1.15.0 

func (abe *Actors) RegisterActors(ctx context.Context) error

func (*Actors) Start added in v1.15.0 

func (abe *Actors) Start(ctx context.Context) error

Start implements backend.Backend

func (*Actors) Stop added in v1.15.0 

func (*Actors) Stop(context.Context) error

Stop implements backend.Backend

func (*Actors) String added in v1.15.0 

func (abe *Actors) String() string

String displays the type information

func (*Actors) UnRegisterActors added in v1.15.0 

func (abe *Actors) UnRegisterActors(ctx context.Context) error

func (*Actors) WatchOrchestrationRuntimeStatus added in v1.15.0 

func (abe *Actors) WatchOrchestrationRuntimeStatus(ctx context.Context, id api.InstanceID, ch chan<- *backend.OrchestrationMetadata) error

type Options added in v1.15.0 

type Options struct {
	AppID              string
	Namespace          string
	Actors             actors.Interface
	Resiliency         resiliency.Provider
	SchedulerReminders bool
	EventSink          workflow.EventSink
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.