registry

Documentation

Index

• type ComponentRegistry
• type ComponentsCallback
• type Options
  • func NewOptions() *Options
  • func (o *Options) WithBindings(registry *bindings.Registry) *Options
  • func (o *Options) WithComponentsCallback(componentsCallback ComponentsCallback) *Options
  • func (o *Options) WithConfigurations(registry *configuration.Registry) *Options
  • func (o *Options) WithConversations(registry *conversation.Registry) *Options
  • func (o *Options) WithCryptoProviders(registry *crypto.Registry) *Options
  • func (o *Options) WithHTTPMiddlewares(registry *http.Registry) *Options
  • func (o *Options) WithLocks(registry *lock.Registry) *Options
  • func (o *Options) WithNameResolutions(registry *nameresolution.Registry) *Options
  • func (o *Options) WithPubSubs(registry *pubsub.Registry) *Options
  • func (o *Options) WithReporter(reporter Reporter) *Options
  • func (o *Options) WithSecretStores(registry *secretstores.Registry) *Options
  • func (o *Options) WithStateStores(registry *state.Registry) *Options
  • func (o *Options) WithWorkflowBackends(registry *wfbe.Registry) *Options
  • func (o *Options) WithWorkflows(registry *workflows.Registry) *Options
• type Registry
  • func New(opts *Options) *Registry
  • func (r *Registry) Bindings() *bindings.Registry
  • func (r *Registry) ComponentsCallback() ComponentsCallback
  • func (r *Registry) Configurations() *configuration.Registry
  • func (r *Registry) Conversations() *conversation.Registry
  • func (r *Registry) Crypto() *crypto.Registry
  • func (r *Registry) HTTPMiddlewares() *http.Registry
  • func (r *Registry) Locks() *lock.Registry
  • func (r *Registry) NameResolutions() *nameresolution.Registry
  • func (r *Registry) PubSubs() *pubsub.Registry
  • func (r *Registry) Reporter() Reporter
  • func (r *Registry) SecretStores() *secretstores.Registry
  • func (r *Registry) StateStores() *state.Registry
  • func (r *Registry) WorkflowBackends() *wfbe.Registry
  • func (r *Registry) Workflows() *workflows.Registry
• type Reporter

Types

type ComponentRegistry

type ComponentRegistry struct {
	DirectMessaging messagingv1.DirectMessaging
	CompStore       *compstore.ComponentStore
}

type ComponentsCallback

type ComponentsCallback func(components ComponentRegistry) error

type Options

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

Options is the options to configure the registries

func NewOptions

func NewOptions() *Options

func (*Options) WithBindings

func (o *Options) WithBindings(registry *bindings.Registry) *Options

WithBindings adds binding components to the runtime.

func (*Options) WithComponentsCallback

func (o *Options) WithComponentsCallback(componentsCallback ComponentsCallback) *Options

WithComponentsCallback sets the components callback for applications that embed Dapr.

func (*Options) WithConfigurations

func (o *Options) WithConfigurations(registry *configuration.Registry) *Options

WithConfigurations adds configuration store components to the runtime.

func (*Options) WithConversations

func (o *Options) WithConversations(registry *conversation.Registry) *Options

WithConversations adds conversation components to the runtime.

func (*Options) WithCryptoProviders

func (o *Options) WithCryptoProviders(registry *crypto.Registry) *Options

WithCryptoProviders adds crypto components to the runtime.

func (*Options) WithHTTPMiddlewares

func (o *Options) WithHTTPMiddlewares(registry *http.Registry) *Options

WithHTTPMiddlewares adds http middleware components to the runtime.

func (*Options) WithLocks

func (o *Options) WithLocks(registry *lock.Registry) *Options

WithLocks adds lock store components to the runtime.

func (*Options) WithNameResolutions

func (o *Options) WithNameResolutions(registry *nameresolution.Registry) *Options

WithNameResolution adds name resolution components to the runtime.

func (*Options) WithPubSubs

func (o *Options) WithPubSubs(registry *pubsub.Registry) *Options

WithPubSubs adds pubsub components to the runtime.

func (*Options) WithReporter

func (o *Options) WithReporter(reporter Reporter) *Options

WithReporter sets the resource reporter for the registry.

func (*Options) WithSecretStores

func (o *Options) WithSecretStores(registry *secretstores.Registry) *Options

WithSecretStores adds secret store components to the runtime.

func (*Options) WithStateStores

func (o *Options) WithStateStores(registry *state.Registry) *Options

WithStateStores adds state store components to the runtime.

func (*Options) WithWorkflowBackends

func (o *Options) WithWorkflowBackends(registry *wfbe.Registry) *Options

WithWorkflows adds workflow components to the runtime.

func (*Options) WithWorkflows

func (o *Options) WithWorkflows(registry *workflows.Registry) *Options

WithWorkflows adds workflow components to the runtime.

type Registry

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

Registry is a collection of component registries.

func New

func New(opts *Options) *Registry

func (*Registry) Bindings

func (r *Registry) Bindings() *bindings.Registry

func (*Registry) ComponentsCallback

func (r *Registry) ComponentsCallback() ComponentsCallback

func (*Registry) Configurations

func (r *Registry) Configurations() *configuration.Registry

func (*Registry) Conversations

func (r *Registry) Conversations() *conversation.Registry

func (*Registry) Crypto

func (r *Registry) Crypto() *crypto.Registry

func (*Registry) HTTPMiddlewares

func (r *Registry) HTTPMiddlewares() *http.Registry

func (*Registry) Locks

func (r *Registry) Locks() *lock.Registry

func (*Registry) NameResolutions

func (r *Registry) NameResolutions() *nameresolution.Registry

func (*Registry) PubSubs

func (r *Registry) PubSubs() *pubsub.Registry

func (*Registry) Reporter

func (r *Registry) Reporter() Reporter

func (*Registry) SecretStores

func (r *Registry) SecretStores() *secretstores.Registry

func (*Registry) StateStores

func (r *Registry) StateStores() *state.Registry

func (*Registry) WorkflowBackends

func (r *Registry) WorkflowBackends() *wfbe.Registry

func (*Registry) Workflows

func (r *Registry) Workflows() *workflows.Registry

type Reporter

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