Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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.
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
|
|
|
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. |
Click to show internal directories.
Click to hide internal directories.