processor

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

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

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 struct {
	// contains filtered or unexported fields
}

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 interface {
	ActorStateStoreName() (string, bool)
	// contains filtered or unexported methods
}