processor

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

	Standalone configmodes.StandaloneConfig

	Resiliency resiliency.Provider

	GRPC *grpcmanager.Manager

	Channels *channels.Channels

	OperatorClient operatorv1.OperatorClient

	MiddlewareHTTP *http.HTTP
}

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(forever bool)
	Outbox() outbox.Outbox
	// contains filtered or unexported methods
}

type SecretManager interface {
	ProcessResource(context.Context, meta.Resource) (bool, string)
	// contains filtered or unexported methods
}

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

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