processor

Documentation

Index

• func DefaultReporter(context.Context, componentsapi.Component, *operatorv1.ResourceResult) error
• type BindingManager
• type Options
• type Processor
  • func New(opts Options) *Processor
  • func (p *Processor) AddPendingComponent(ctx context.Context, comp componentsapi.Component) bool
  • func (p *Processor) AddPendingEndpoint(ctx context.Context, endpoint httpendpointsapi.HTTPEndpoint) bool
  • func (p *Processor) AddPendingSubscription(ctx context.Context, subscriptions ...subapi.Subscription) bool
  • func (p *Processor) Binding() BindingManager
  • func (p *Processor) Close(comp componentsapi.Component) error
  • func (p *Processor) CloseSubscription(ctx context.Context, sub *subapi.Subscription) error
  • func (p *Processor) Init(ctx context.Context, comp componentsapi.Component) error
  • func (p *Processor) Process(ctx context.Context) error
  • func (p *Processor) Secret() SecretManager
  • func (p *Processor) State() StateManager
  • func (p *Processor) Subscriber() SubscribeManager
  • func (p *Processor) WaitForEmptyComponentQueue()
  • func (p *Processor) WorkflowBackend() WorkflowBackendManager
• type SecretManager
• type StateManager
• type SubscribeManager
• type WorkflowBackendManager

Functions

func DefaultReporter

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

	// PodName is the name of the pod.
	PodName string

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

	// 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
}

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

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

func (*Processor) AddPendingEndpoint

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

func (*Processor) AddPendingSubscription

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

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

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) Process

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

func (*Processor) Secret

func (p *Processor) Secret() SecretManager

func (*Processor) State

func (p *Processor) State() StateManager

func (*Processor) Subscriber

func (p *Processor) Subscriber() SubscribeManager

func (*Processor) WaitForEmptyComponentQueue

func (p *Processor) WaitForEmptyComponentQueue()

WaitForEmptyComponentQueue waits for the component queue to be empty.

func (*Processor) WorkflowBackend

func (p *Processor) WorkflowBackend() WorkflowBackendManager

type SecretManager

type SecretManager interface {
	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

type SubscribeManager interface {
	InitProgramaticSubscriptions(context.Context) error
	StartAppSubscriptions() error
	StopAppSubscriptions()
	StopAllSubscriptionsForever()
	ReloadDeclaredAppSubscription(name, pubsubName string) error
	StartStreamerSubscription(key string) error
	StopStreamerSubscription(pubsubName, key string)
	ReloadPubSub(string) error
	StopPubSub(string)
}

type WorkflowBackendManager

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