processor

Documentation

Index

• type BindingManager
• type Options
• type Processor
  • func New(opts Options) *Processor
  • func (p *Processor) Binding() BindingManager
  • func (p *Processor) Category(comp compapi.Component) components.Category
  • func (p *Processor) Close(comp compapi.Component) error
  • func (p *Processor) Init(ctx context.Context, comp compapi.Component) error
  • func (p *Processor) PubSub() PubsubManager
  • func (p *Processor) State() StateManager
• type PubsubManager
• type StateManager

Types

type BindingManager

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

	StartReadingFromBindings(context.Context) error
	StopReadingFromBindings()
	// 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

	// PlacementEnabled indicates whether placement service is enabled in this
	// Dapr cluster.
	PlacementEnabled 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

	Standalone configmodes.StandaloneConfig

	Resiliency resiliency.Provider

	GRPC *grpcmanager.Manager

	Channels *channels.Channels

	OperatorClient operatorv1.OperatorClient
}

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

func (p *Processor) Binding() BindingManager

func (*Processor) Category

func (p *Processor) Category(comp compapi.Component) components.Category

func (*Processor) Close

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

Close closes the component.

func (*Processor) Init

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

Init initializes a component of a category.

func (*Processor) PubSub

func (p *Processor) PubSub() PubsubManager

func (*Processor) State

func (p *Processor) State() StateManager

type PubsubManager

type PubsubManager interface {
	Publish(context.Context, *contribpubsub.PublishRequest) error
	BulkPublish(context.Context, *contribpubsub.BulkPublishRequest) (contribpubsub.BulkPublishResponse, error)

	StartSubscriptions(context.Context) error
	StopSubscriptions()
	Outbox() outbox.Outbox
	// contains filtered or unexported methods
}

type StateManager

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