Directories
¶
| Path | Synopsis |
|---|---|
|
charts
|
|
|
dapr
Package daprcrds embeds the Dapr CRD YAML files so the runtime can extract validation rules (CEL, minLength, etc.) for standalone mode where there is no Kubernetes API server to enforce them.
|
Package daprcrds embeds the Dapr CRD YAML files so the runtime can extract validation rules (CEL, minLength, etc.) for standalone mode where there is no Kubernetes API server to enforce them. |
|
cmd
|
|
|
daprd
command
|
|
|
injector
command
|
|
|
operator
command
|
|
|
placement
command
|
|
|
scheduler
command
|
|
|
sentry
command
|
|
|
pkg
|
|
|
actors/callbackstream
Package callbackstream coordinates the app-initiated actor callback stream.
|
Package callbackstream coordinates the app-initiated actor callback stream. |
|
actors/hashing/rendezvous
Package rendezvous implements rendezvous (highest random weight) hashing over a set of host addresses.
|
Package rendezvous implements rendezvous (highest random weight) hashing over a set of host addresses. |
|
actors/hostauthz
Package hostauthz authorizes an actor host report against the caller's SPIFFE identity, shared by the placement service and the scheduler's placement server.
|
Package hostauthz authorizes an actor host report against the caller's SPIFFE identity, shared by the placement service and the scheduler's placement server. |
|
actors/internal/placement/connector/leader
Package leader is the placement connector which dials the current scheduler placement leader, discovered from the scheduler WatchHosts stream.
|
Package leader is the placement connector which dials the current scheduler placement leader, discovered from the scheduler WatchHosts stream. |
|
actors/internal/placement/loops/stream/transport
Package transport abstracts the placement stream wire protocol behind a protocol-neutral interface so the placement client loops are identical for the v1 (standalone placement service, ReportDaprStatus) and v2 (scheduler, ReportActorTypes) protocols.
|
Package transport abstracts the placement stream wire protocol behind a protocol-neutral interface so the placement client loops are identical for the v1 (standalone placement service, ReportDaprStatus) and v2 (scheduler, ReportActorTypes) protocols. |
|
actors/internal/placement/loops/stream/transport/v1
Package v1 implements the placement stream transport speaking the v1 protocol of the standalone placement service (ReportDaprStatus).
|
Package v1 implements the placement stream transport speaking the v1 protocol of the standalone placement service (ReportDaprStatus). |
|
actors/internal/placement/loops/stream/transport/v2
Package v2 implements the placement stream transport speaking the v2 protocol of the scheduler placement service (ReportActorTypes): per actor type placement orders with seq-keyed rounds and partial tables.
|
Package v2 implements the placement stream transport speaking the v2 protocol of the scheduler placement service (ReportActorTypes): per actor type placement orders with seq-keyed rounds and partial tables. |
|
actors/targets/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. |
|
actors/targets/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. |
|
actors/targets/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. |
|
actors/targets/workflow/activity/claim
Package claim implements the durable execution-claim record for activity actors under the WorkflowsFastPath preview: a lease written only around placement churn, so a recovery arrival on a new placement owner can tell a live cross-host execution, or its published result, from one that died with its host.
|
Package claim implements the durable execution-claim record for activity actors under the WorkflowsFastPath preview: a lease written only around placement churn, so a recovery arrival on a new placement owner can tell a live cross-host execution, or its published result, from one that died with its host. |
|
actors/targets/workflow/common/detached
Package detached runs work that must outlive the invocation requesting it, such as arming the reminder of an already committed inbox row, on a runtime-lifetime context rather than an invocation, claim, or wake context.
|
Package detached runs work that must outlive the invocation requesting it, such as arming the reminder of an already committed inbox row, on a runtime-lifetime context rather than an invocation, claim, or wake context. |
|
actors/targets/workflow/common/pendingstart
Package pendingstart describes a workflow instance whose creation was committed but which has never executed a turn.
|
Package pendingstart describes a workflow instance whose creation was committed but which has never executed a turn. |
|
actors/targets/workflow/executor/pending
Package pending implements a process-local rendezvous between workflow and activity task waiters and the completions reported by the application.
|
Package pending implements a process-local rendezvous between workflow and activity task waiters and the completions reported by the application. |
|
api/universal
Package universal contains the implementation of APIs that are shared between gRPC and HTTP servers.
|
Package universal contains the implementation of APIs that are shared between gRPC and HTTP servers. |
|
apis/components/v1alpha1
+kubebuilder:object:generate=true +groupName=dapr.io
|
+kubebuilder:object:generate=true +groupName=dapr.io |
|
apis/configuration/v1alpha1
+kubebuilder:object:generate=true +groupName=dapr.io
|
+kubebuilder:object:generate=true +groupName=dapr.io |
|
apis/httpEndpoint/v1alpha1
+kubebuilder:object:generate=true +groupName=dapr.io
|
+kubebuilder:object:generate=true +groupName=dapr.io |
|
apis/mcpserver/v1alpha1
+kubebuilder:object:generate=true +groupName=dapr.io
|
+kubebuilder:object:generate=true +groupName=dapr.io |
|
apis/resiliency/v1alpha1
+kubebuilder:object:generate=true +groupName=dapr.io
|
+kubebuilder:object:generate=true +groupName=dapr.io |
|
apis/subscriptions/v1alpha1
+kubebuilder:object:generate=true +groupName=dapr.io
|
+kubebuilder:object:generate=true +groupName=dapr.io |
|
apis/subscriptions/v2alpha1
+kubebuilder:object:generate=true +groupName=dapr.io
|
+kubebuilder:object:generate=true +groupName=dapr.io |
|
apis/workflowaccesspolicy/v1alpha1
+kubebuilder:object:generate=true +groupName=dapr.io
|
+kubebuilder:object:generate=true +groupName=dapr.io |
|
client/clientset/versioned
This package has the automatically generated clientset.
|
This package has the automatically generated clientset. |
|
client/clientset/versioned/fake
This package has the automatically generated fake clientset.
|
This package has the automatically generated fake clientset. |
|
client/clientset/versioned/scheme
This package contains the scheme of the automatically generated clientset.
|
This package contains the scheme of the automatically generated clientset. |
|
client/clientset/versioned/typed/components/v1alpha1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/components/v1alpha1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
client/clientset/versioned/typed/configuration/v1alpha1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/configuration/v1alpha1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
client/clientset/versioned/typed/mcpserver/v1alpha1
This package has the automatically generated typed clients.
|
This package has the automatically generated typed clients. |
|
client/clientset/versioned/typed/mcpserver/v1alpha1/fake
Package fake has the automatically generated clients.
|
Package fake has the automatically generated clients. |
|
injector/annotations
Package annotations contains the list of annotations for Dapr deployments.
|
Package annotations contains the list of annotations for Dapr deployments. |
|
injector/patcher
Package patcher contains utilities to patch a Pod to inject the Dapr sidecar container.
|
Package patcher contains utilities to patch a Pod to inject the Dapr sidecar container. |
|
internal/loader/validate
Package validate provides CRD-based validation for Dapr resources in standalone mode.
|
Package validate provides CRD-based validation for Dapr resources in standalone mode. |
|
placement/hashing
Package placement is an implementation of Consistent Hashing and Consistent Hashing With Bounded Loads.
|
Package placement is an implementation of Consistent Hashing and Consistent Hashing With Bounded Loads. |
|
runtime/processor
Package processor manages the lifecycle of every resource that flows through daprd: components, HTTP endpoints, MCP servers and subscriptions.
|
Package processor manages the lifecycle of every resource that flows through daprd: components, HTTP endpoints, MCP servers and subscriptions. |
|
runtime/scheduler/leadership
Package leadership tracks the scheduler placement leader as observed on the WatchHosts stream, for consumers (the actor placement client) which need to connect to the current leader and react to leadership changes.
|
Package leadership tracks the scheduler placement leader as observed on the WatchHosts stream, for consumers (the actor placement client) which need to connect to the current leader and react to leadership changes. |
|
runtime/wfengine/inprocess
Package inprocess creates and configures the in-process workflow executor used for dapr-internal workflows (e.g.
|
Package inprocess creates and configures the in-process workflow executor used for dapr-internal workflows (e.g. |
|
scheduler/server/internal/handoff
Package handoff tracks the facts deciding the actor placement authority handoff, all derived from live observation so they rebuild whenever the observers do:
|
Package handoff tracks the facts deciding the actor placement authority handoff, all derived from live observation so they rebuild whenever the observers do: |
|
scheduler/server/internal/placement
Package placement implements the actor placement service inside the scheduler.
|
Package placement implements the actor placement service inside the scheduler. |
|
scheduler/server/internal/placement/loops/connections
Package connections is the per namespace placement controller.
|
Package connections is the per namespace placement controller. |
|
scheduler/server/internal/placement/loops/namespaces
Package namespaces is the top level placement controller, scoping streams and placement state by namespace.
|
Package namespaces is the top level placement controller, scoping streams and placement state by namespace. |
|
scheduler/server/internal/placement/loops/store
Package store holds the in-memory placement membership of a single namespace: which stream hosts which actor types.
|
Package store holds the in-memory placement membership of a single namespace: which stream hosts which actor types. |
|
scheduler/server/internal/placement/loops/stream
Package stream handles a single ReportActorTypes stream: sending placement orders and receiving host reports and acks.
|
Package stream handles a single ReportActorTypes stream: sending placement orders and receiving host reports and acks. |
|
scheduler/server/internal/placement/loops/timeout
Package timeout schedules dissemination round timeouts, keyed by round seq.
|
Package timeout schedules dissemination round timeouts, keyed by round seq. |
|
sentry/server/images
Package images defines the container images X.509 certificate extension which Sentry stamps into workload SVIDs.
|
Package images defines the container images X.509 certificate extension which Sentry stamps into workload SVIDs. |
|
testing
Package testing is a generated GoMock package.
|
Package testing is a generated GoMock package. |
|
tests
|
|
|
apps/actorapp
command
|
|
|
apps/actorclientapp
command
|
|
|
apps/actorfeatures
command
|
|
|
apps/actorinvocationapp
command
|
|
|
apps/actorreentrancy
command
|
|
|
apps/actorstate
command
|
|
|
apps/binding_input
command
|
|
|
apps/binding_input_grpc
command
|
|
|
apps/binding_output
command
|
|
|
apps/configurationapp
command
|
|
|
apps/healthapp
command
|
|
|
apps/hellodapr
command
|
|
|
apps/injectorapp
command
|
|
|
apps/injectorapp-init
command
|
|
|
apps/job-publisher
command
|
|
|
apps/metadata
command
|
|
|
apps/middleware
command
|
|
|
apps/perf/configuration
command
|
|
|
apps/perf/pubsub_subscribe_http
command
|
|
|
apps/pubsub-bulk-subscriber
command
|
|
|
apps/pubsub-publisher
command
|
|
|
apps/pubsub-subscriber
command
|
|
|
apps/pubsub-subscriber-routing
command
|
|
|
apps/pubsub-subscriber_grpc
command
|
|
|
apps/runtime
command
|
|
|
apps/runtime_init
command
|
|
|
apps/schedulerapp
command
|
|
|
apps/schedulerapp_grpc
command
|
|
|
apps/secretapp
command
|
|
|
apps/service_invocation
command
|
|
|
apps/service_invocation_external
command
|
|
|
apps/service_invocation_grpc
command
|
|
|
apps/stateapp
command
|
|
|
apps/tracingapp
command
|
|
|
integration/framework/process/statestore/cosmosbatch
Package cosmosbatch provides a state.Store implementation that wraps the in-memory store and mirrors Azure Cosmos DB's transactional-batch semantics: if any delete operation in a Multi targets a key that does not exist, the whole batch is rejected with a generic "transaction failed" error and none of the operations are applied.
|
Package cosmosbatch provides a state.Store implementation that wraps the in-memory store and mirrors Azure Cosmos DB's transactional-batch semantics: if any delete operation in a Multi targets a key that does not exist, the whole batch is rejected with a generic "transaction failed" error and none of the operations are applied. |
|
integration/framework/process/statestore/fault
Package fault provides a state.Store implementation that wraps the in-memory store and lets tests deterministically inject transient transactional save failures keyed by a substring of the operation key.
|
Package fault provides a state.Store implementation that wraps the in-memory store and lets tests deterministically inject transient transactional save failures keyed by a substring of the operation key. |
|
integration/framework/progress
Package progress draws a live progress line for an integration test run.
|
Package progress draws a live progress line for an integration test run. |
|
integration/suite/actors/schedulerplacement
Package schedulerplacement tests actor placement served by the scheduler.
|
Package schedulerplacement tests actor placement served by the scheduler. |
|
integration/suite/daprd/workflow/statefulhistory
Package statefulhistory contains integration tests for the stateful-history (delta) work-item optimization, where a worker that advertises WORKER_CAPABILITY_STATEFUL_HISTORY retains an instance's committed history between turns so the sidecar sends only the new events.
|
Package statefulhistory contains integration tests for the stateful-history (delta) work-item optimization, where a worker that advertises WORKER_CAPABILITY_STATEFUL_HISTORY retains an instance's committed history between turns so the sidecar sends only the new events. |
|
perf/report
command
|
|
|
apps/actorload
module
|
|
|
apps/crypto
module
|
|
|
apps/perf/actorfeatures
module
|
|
|
apps/perf/tester
module
|
|
|
apps/pluggable_redis-pubsub
module
|
|
|
apps/resiliencyapp
module
|
|
|
apps/resiliencyapp_grpc
module
|
|
Click to show internal directories.
Click to hide internal directories.

