actors

package
v1.18.0 Latest Latest
Warning

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

Go to latest
Published: Jun 10, 2026 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ValidateHostEnvironment added in v0.11.2

func ValidateHostEnvironment(mTLSEnabled bool, mode modes.DaprMode, namespace string) error

ValidateHostEnvironment validates that actors can be initialized properly given a set of parameters And the mode the runtime is operating in.

Types

type InitOptions added in v1.15.0

type InitOptions struct {
	StateStoreName    string
	Hostname          string
	GRPC              *manager.Manager
	SchedulerClient   schedulerv1pb.SchedulerClient
	SchedulerReloader schedclient.Reloader
}

type Interface added in v1.15.0

type Interface interface {
	Init(InitOptions) error
	Run(context.Context) error
	Router(context.Context) (router.Interface, error)
	Table(context.Context) (table.Interface, error)
	State(context.Context) (actorstate.Interface, error)
	Timers(context.Context) (timers.Interface, error)
	Reminders(context.Context) (reminders.Interface, error)
	Placement(context.Context) (placement.Interface, error)
	RuntimeStatus() *runtimev1pb.ActorRuntime
	RegisterHosted(context.Context, hostconfig.Config) error
	UnRegisterHosted(ctx context.Context, actorTypes ...string) error
	WaitForRegisteredHosts(ctx context.Context) error
}

Interface is the main runtime for the actors subsystem.

func New added in v1.15.0

func New(opts Options) Interface

New create a new actors runtime with given config.

type Options added in v1.15.0

type Options struct {
	AppID              string
	Namespace          string
	Port               int
	PlacementAddresses []string
	HealthEndpoint     string
	Resiliency         resiliency.Provider
	Security           security.Handler
	Healthz            healthz.Healthz
	CompStore          *compstore.ComponentStore
	// TODO: @joshvanl Remove in Dapr 1.12 when ActorStateTTL is finalized.
	StateTTLEnabled    bool
	MaxRequestBodySize int
	Mode               modes.DaprMode

	// DisseminationTimeout is the daprd-side timeout for a placement
	// LOCK -> UPDATE -> UNLOCK round.
	DisseminationTimeout time.Duration
}

Directories

Path Synopsis
Package callbackstream coordinates the app-initiated actor callback stream.
Package callbackstream coordinates the app-initiated actor callback stream.
internal
key
app
app/transport
Package transport defines the Invoker interface that isolates HTTP and gRPC wire details from the rest of the actor target code.
Package transport defines the Invoker interface that isolates HTTP and gRPC wire details from the rest of the actor target code.
app/transport/grpc
Package grpc implements the transport.Invoker interface against the app-initiated SubscribeActorEventsAlpha1 stream.
Package grpc implements the transport.Invoker interface against the app-initiated SubscribeActorEventsAlpha1 stream.
app/transport/http
Package http implements the transport.Invoker interface for the HTTP actor callback protocol: PUT /actors/{type}/{id}/method/{method}, POST/DELETE /actors/..., with X-Daprerrorresponseheader and X-Daprremindercancel response headers signalling actor errors and reminder cancellation respectively.
Package http implements the transport.Invoker interface for the HTTP actor callback protocol: PUT /actors/{type}/{id}/method/{method}, POST/DELETE /actors/..., with X-Daprerrorresponseheader and X-Daprremindercancel response headers signalling actor errors and reminder cancellation respectively.

Jump to

Keyboard shortcuts

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