processor

package
v1.18.3 Latest Latest
Warning

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

 Go to latest Published: Aug 14, 2026 License: Apache-2.0 Imports: 50 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DefaultReporter added in v1.15.0 

func DefaultReporter(context.Context, componentsapi.Component, *operatorv1.ResourceResult) error

DefaultReporter is the default resource reporter for the registry. It does nothing.

Types

type BindingManager 

type BindingManager interface {
	SendToOutputBinding(context.Context, string, *bindings.InvokeRequest) (*bindings.InvokeResponse, error)

	StartReadingFromBindings(context.Context) error
	StopReadingFromBindings(forever bool)
	// contains filtered or unexported methods
}

type Options 

type Options struct {
	// ID is the ID of this Dapr instance.
	ID string

	// Namespace is the namespace of this Dapr instance.
	Namespace string

	// Mode is the mode of this Dapr instance.
	Mode modes.DaprMode

	// ActorsEnabled indicates whether placement service is enabled in this Dapr cluster.
	ActorsEnabled bool
	Actors        actors.Interface

	// IsHTTP indicates whether the connection to the application is using the
	// HTTP protocol.
	IsHTTP bool

	// Registry is the all-component registry.
	Registry *registry.Registry

	// ComponentStore is the component store.
	ComponentStore *compstore.ComponentStore

	// Metadata is the metadata helper.
	Meta *meta.Meta

	// GlobalConfig is the global configuration.
	GlobalConfig *config.Configuration

	Resiliency resiliency.Provider

	GRPC *grpcmanager.Manager

	Channels *channels.Channels

	OperatorClient operatorv1.OperatorClient

	MiddlewareHTTP *http.HTTP

	Security security.Handler

	Outbox outbox.Outbox

	Adapter         rtpubsub.Adapter
	AdapterStreamer rtpubsub.AdapterStreamer

	// Reporter is the reporter for the operator.
	Reporter registry.Reporter

	// ProgrammaticSubscriptionEnabled indicates whether programmatic subscriptions are active.
	ProgrammaticSubscriptionEnabled bool
	AppBindingOptionsTimeout        time.Duration
}

type Processor 

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

Processor manages the lifecycle of all components categories.

func New 

func New(opts Options) *Processor

func (*Processor) AddPendingComponent added in v1.13.0 

func (p *Processor) AddPendingComponent(ctx context.Context, comp componentsapi.Component) bool

func (*Processor) AddPendingEndpoint added in v1.13.0 

func (p *Processor) AddPendingEndpoint(ctx context.Context, endpoint httpendpointsapi.HTTPEndpoint) bool

func (*Processor) AddPendingMCPServer added in v1.18.0 

func (p *Processor) AddPendingMCPServer(ctx context.Context, s mcpserverapi.MCPServer) bool

AddPendingMCPServer enqueues an MCPServer for processing. Returns false if the processor has shut down or the context is done.

func (*Processor) AddPendingSubscription added in v1.14.0 

func (p *Processor) AddPendingSubscription(ctx context.Context, subscriptions ...subapi.Subscription) bool

func (*Processor) Binding 

func (p *Processor) Binding() BindingManager

func (*Processor) Close 

func (p *Processor) Close(comp componentsapi.Component) error

Close closes the component and reports the result.

func (*Processor) CloseSubscription added in v1.14.0 

func (p *Processor) CloseSubscription(ctx context.Context, sub *subapi.Subscription) error

func (*Processor) DeleteMCPServer added in v1.18.0 

func (p *Processor) DeleteMCPServer(serverName string)

DeleteMCPServer removes an MCPServer from the store and unregisters its workflows.

func (*Processor) Init 

func (p *Processor) Init(ctx context.Context, comp componentsapi.Component) error

Init initializes a component of a category and reports the result.

func (*Processor) OnActorStateStoreChanged added in v1.18.3 

func (p *Processor) OnActorStateStoreChanged()

OnActorStateStoreChanged notifies the actor runtime that the actor state store was added, removed, or replaced. Safe to call when no actor runtime is configured.

func (*Processor) Process added in v1.13.0 

func (p *Processor) Process(ctx context.Context) error

func (*Processor) ProcessMCPServerSecrets added in v1.18.2 

func (p *Processor) ProcessMCPServerSecrets(ctx context.Context, s *mcpserverapi.MCPServer)

ProcessMCPServerSecrets resolves secretKeyRef and envRef entries in the transport headers (spec.endpoint.streamableHTTP.headers or spec.endpoint.sse.headers) and spec.endpoint.stdio.env using the configured secret store. Unlike components, MCPServer resources load after all secret store components are initialized, so secrets are available immediately. The underlying p.secret.ProcessResource (the secret manager) logs errors internally and resolves what it can; it does not return an error. Unresolvable secretKeyRef values remain as empty strings.

This does NOT resolve auth.oauth2.secretKeyRef: the OAuth2 client secret is fetched at connection time by the MCP worker (see pkg/runtime/mcp/auth) and is never written into the spec, so it does not take part in the hot-reload diff.

The hot-reload reconciler also calls this on a copy of an incoming spec before comparing it against the already-resolved stored copy, so an unchanged secret-ref server is not needlessly reloaded while a rotated secret value still triggers a reload.

func (*Processor) Secret added in v1.13.0 

func (p *Processor) Secret() SecretManager

func (*Processor) SetInProcessWorkflows added in v1.18.0 

func (p *Processor) SetInProcessWorkflows(r wfregistrar.Registrar)

SetInProcessWorkflows installs the in-process workflow wfregistrar.

func (*Processor) State 

func (p *Processor) State() StateManager

func (*Processor) Subscriber added in v1.14.0 

func (p *Processor) Subscriber() SubscribeManager

func (*Processor) WaitForEmptyComponentQueue added in v1.13.0 

func (p *Processor) WaitForEmptyComponentQueue()

WaitForEmptyComponentQueue waits for the component queue to be empty.

func (*Processor) WorkflowBackend added in v1.13.0 

func (p *Processor) WorkflowBackend() WorkflowBackendManager

type SecretManager added in v1.13.0 

type SecretManager interface {
	// TODO: update to return an error.
	ProcessResource(context.Context, meta.Resource) (bool, string)
	// contains filtered or unexported methods
}

type StateManager 

type StateManager interface {
	ActorStateStoreName() (string, bool)
	// contains filtered or unexported methods
}

type SubscribeManager added in v1.14.0 

type SubscribeManager interface {
	InitProgramaticSubscriptions(context.Context) error
	StartAppSubscriptions() error
	StopAppSubscriptions()
	StopAllSubscriptionsForever()
	ReloadDeclaredAppSubscription(name, pubsubName string) error
	StartStreamerSubscription(sub *subapi.Subscription, connectionID rtpubsub.ConnectionID) error
	StopStreamerSubscription(sub *subapi.Subscription, connectionID rtpubsub.ConnectionID)
	ReloadPubSub(string) error
	StopPubSub(string)
}

type WorkflowBackendManager added in v1.13.0 

type WorkflowBackendManager interface {
	Backend() (backend.Backend, bool)
}

Source Files

View all Source files

Directories

Path Synopsis
input

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.