compstore

package
v0.0.0-...-949823d Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 10, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ComponentStore 

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

ComponentStore is a store of all components which have been configured for the runtime. The store is dynamic. Each component type is indexed by its Component name.

func New 

func New() *ComponentStore

func (*ComponentStore) AddConfiguration 

func (c *ComponentStore) AddConfiguration(name string, store configuration.Store)

func (*ComponentStore) AddConfigurationSubscribe 

func (c *ComponentStore) AddConfigurationSubscribe(name string, ch chan struct{})

func (*ComponentStore) AddConversation 

func (c *ComponentStore) AddConversation(name string, conversation conversation.Conversation)

func (*ComponentStore) AddCryptoProvider 

func (c *ComponentStore) AddCryptoProvider(name string, provider crypto.SubtleCrypto)

func (*ComponentStore) AddDeclarativeSubscription 

func (c *ComponentStore) AddDeclarativeSubscription(comp *subapi.Subscription, sub rtpubsub.Subscription)

func (*ComponentStore) AddHTTPEndpoint 

func (c *ComponentStore) AddHTTPEndpoint(httpEndpoint httpEndpointv1alpha1.HTTPEndpoint)

func (*ComponentStore) AddInputBinding 

func (c *ComponentStore) AddInputBinding(name string, binding bindings.InputBinding)

func (*ComponentStore) AddInputBindingRoute 

func (c *ComponentStore) AddInputBindingRoute(name, route string)

func (*ComponentStore) AddLock 

func (c *ComponentStore) AddLock(name string, store lock.Store)

func (*ComponentStore) AddOutputBinding 

func (c *ComponentStore) AddOutputBinding(name string, binding bindings.OutputBinding)

func (*ComponentStore) AddPendingComponentForCommit 

func (c *ComponentStore) AddPendingComponentForCommit(component compsv1alpha1.Component) error

func (*ComponentStore) AddPubSub 

func (c *ComponentStore) AddPubSub(name string, item *rtpubsub.PubsubItem)

func (*ComponentStore) AddSecretStore 

func (c *ComponentStore) AddSecretStore(name string, store secretstores.SecretStore)

func (*ComponentStore) AddSecretsConfiguration 

func (c *ComponentStore) AddSecretsConfiguration(name string, secretsScope config.SecretsScope)

func (*ComponentStore) AddStateStore 

func (c *ComponentStore) AddStateStore(name string, store state.Store)

func (*ComponentStore) AddStateStoreActor 

func (c *ComponentStore) AddStateStoreActor(name string, store state.Store) error

func (*ComponentStore) AddStreamSubscription 

func (c *ComponentStore) AddStreamSubscription(comp *subapi.Subscription) error

func (*ComponentStore) AddWorkflow 

func (c *ComponentStore) AddWorkflow(name string, workflow workflows.Workflow)

func (*ComponentStore) AddWorkflowBackend 

func (c *ComponentStore) AddWorkflowBackend(name string, backend backend.Backend)

func (*ComponentStore) CommitPendingComponent 

func (c *ComponentStore) CommitPendingComponent() error

func (*ComponentStore) ConfigurationsLen 

func (c *ComponentStore) ConfigurationsLen() int

func (*ComponentStore) ConversationsLen 

func (c *ComponentStore) ConversationsLen() int

func (*ComponentStore) CryptoProvidersLen 

func (c *ComponentStore) CryptoProvidersLen() int

func (*ComponentStore) DeleteAllConfigurationSubscribe 

func (c *ComponentStore) DeleteAllConfigurationSubscribe()

func (*ComponentStore) DeleteComponent 

func (c *ComponentStore) DeleteComponent(name string)

func (*ComponentStore) DeleteConfiguration 

func (c *ComponentStore) DeleteConfiguration(name string)

func (*ComponentStore) DeleteConfigurationSubscribe 

func (c *ComponentStore) DeleteConfigurationSubscribe(name string)

func (*ComponentStore) DeleteConversation 

func (c *ComponentStore) DeleteConversation(name string)

func (*ComponentStore) DeleteCryptoProvider 

func (c *ComponentStore) DeleteCryptoProvider(name string)

func (*ComponentStore) DeleteDeclarativeSubscription 

func (c *ComponentStore) DeleteDeclarativeSubscription(names ...string)

func (*ComponentStore) DeleteHTTPEndpoint 

func (c *ComponentStore) DeleteHTTPEndpoint(name string)

func (*ComponentStore) DeleteInputBinding 

func (c *ComponentStore) DeleteInputBinding(name string)

func (*ComponentStore) DeleteInputBindingRoute 

func (c *ComponentStore) DeleteInputBindingRoute(name string)

func (*ComponentStore) DeleteLock 

func (c *ComponentStore) DeleteLock(name string)

func (*ComponentStore) DeleteOutputBinding 

func (c *ComponentStore) DeleteOutputBinding(name string)

func (*ComponentStore) DeletePubSub 

func (c *ComponentStore) DeletePubSub(name string)

func (*ComponentStore) DeleteSecretStore 

func (c *ComponentStore) DeleteSecretStore(name string)

func (*ComponentStore) DeleteSecretsConfiguration 

func (c *ComponentStore) DeleteSecretsConfiguration(name string)

func (*ComponentStore) DeleteStateStore 

func (c *ComponentStore) DeleteStateStore(name string)

func (*ComponentStore) DeleteStreamSubscription 

func (c *ComponentStore) DeleteStreamSubscription(names ...string)

func (*ComponentStore) DeleteWorkflow 

func (c *ComponentStore) DeleteWorkflow(name string)

func (*ComponentStore) DeleteWorkflowBackend 

func (c *ComponentStore) DeleteWorkflowBackend(name string)

func (*ComponentStore) DropPendingComponent 

func (c *ComponentStore) DropPendingComponent() error

func (*ComponentStore) GetComponent 

func (c *ComponentStore) GetComponent(name string) (compsv1alpha1.Component, bool)

func (*ComponentStore) GetConfiguration 

func (c *ComponentStore) GetConfiguration(name string) (configuration.Store, bool)

func (*ComponentStore) GetConfigurationSubscribe 

func (c *ComponentStore) GetConfigurationSubscribe(name string) (chan struct{}, bool)

func (*ComponentStore) GetConversation 

func (c *ComponentStore) GetConversation(name string) (conversation.Conversation, bool)

func (*ComponentStore) GetCryptoProvider 

func (c *ComponentStore) GetCryptoProvider(name string) (crypto.SubtleCrypto, bool)

func (*ComponentStore) GetDeclarativeSubscription 

func (c *ComponentStore) GetDeclarativeSubscription(name string) (*DeclarativeSubscription, bool)

func (*ComponentStore) GetHTTPEndpoint 

func (c *ComponentStore) GetHTTPEndpoint(name string) (httpEndpointv1alpha1.HTTPEndpoint, bool)

func (*ComponentStore) GetInputBinding 

func (c *ComponentStore) GetInputBinding(name string) (bindings.InputBinding, bool)

func (*ComponentStore) GetInputBindingRoute 

func (c *ComponentStore) GetInputBindingRoute(name string) (string, bool)

func (*ComponentStore) GetLock 

func (c *ComponentStore) GetLock(name string) (lock.Store, bool)

func (*ComponentStore) GetOutputBinding 

func (c *ComponentStore) GetOutputBinding(name string) (bindings.OutputBinding, bool)

func (*ComponentStore) GetPubSub 

func (c *ComponentStore) GetPubSub(name string) (*rtpubsub.PubsubItem, bool)

func (*ComponentStore) GetPubSubComponent 

func (c *ComponentStore) GetPubSubComponent(name string) (pubsub.PubSub, bool)

func (*ComponentStore) GetSecretStore 

func (c *ComponentStore) GetSecretStore(name string) (secretstores.SecretStore, bool)

func (*ComponentStore) GetSecretsConfiguration 

func (c *ComponentStore) GetSecretsConfiguration(name string) (config.SecretsScope, bool)

func (*ComponentStore) GetStateStore 

func (c *ComponentStore) GetStateStore(name string) (state.Store, bool)

func (*ComponentStore) GetStateStoreActor 

func (c *ComponentStore) GetStateStoreActor() (state.Store, string, bool)

func (*ComponentStore) GetStreamSubscription 

func (c *ComponentStore) GetStreamSubscription(key string) (*NamedSubscription, bool)

func (*ComponentStore) GetWorkflow 

func (c *ComponentStore) GetWorkflow(name string) (workflows.Workflow, bool)

func (*ComponentStore) GetWorkflowBackend 

func (c *ComponentStore) GetWorkflowBackend(name string) (backend.Backend, bool)

func (*ComponentStore) ListComponents 

func (c *ComponentStore) ListComponents() []compsv1alpha1.Component

func (*ComponentStore) ListConfigurations 

func (c *ComponentStore) ListConfigurations() map[string]configuration.Store

func (*ComponentStore) ListConversations 

func (c *ComponentStore) ListConversations() map[string]conversation.Conversation

func (*ComponentStore) ListCryptoProviders 

func (c *ComponentStore) ListCryptoProviders() map[string]crypto.SubtleCrypto

func (*ComponentStore) ListDeclarativeSubscriptions 

func (c *ComponentStore) ListDeclarativeSubscriptions() []subapi.Subscription

func (*ComponentStore) ListHTTPEndpoints 

func (c *ComponentStore) ListHTTPEndpoints() []httpEndpointv1alpha1.HTTPEndpoint

func (*ComponentStore) ListInputBindingRoutes 

func (c *ComponentStore) ListInputBindingRoutes() map[string]string

func (*ComponentStore) ListInputBindings 

func (c *ComponentStore) ListInputBindings() map[string]bindings.InputBinding

func (*ComponentStore) ListLocks 

func (c *ComponentStore) ListLocks() map[string]lock.Store

func (*ComponentStore) ListOutputBindings 

func (c *ComponentStore) ListOutputBindings() map[string]bindings.OutputBinding

func (*ComponentStore) ListProgramaticSubscriptions 

func (c *ComponentStore) ListProgramaticSubscriptions() []rtpubsub.Subscription

func (*ComponentStore) ListPubSubs 

func (c *ComponentStore) ListPubSubs() map[string]*rtpubsub.PubsubItem

func (*ComponentStore) ListSecretStores 

func (c *ComponentStore) ListSecretStores() map[string]secretstores.SecretStore

func (*ComponentStore) ListStateStores 

func (c *ComponentStore) ListStateStores() map[string]state.Store

func (*ComponentStore) ListSubscriptionsAppByPubSub 

func (c *ComponentStore) ListSubscriptionsAppByPubSub(name string) []*NamedSubscription

func (*ComponentStore) ListSubscriptionsStreamByPubSub 

func (c *ComponentStore) ListSubscriptionsStreamByPubSub(name string) []*NamedSubscription

func (*ComponentStore) ListTypedSubscriptions 

func (c *ComponentStore) ListTypedSubscriptions() []TypedSubscription

func (*ComponentStore) ListWorkflowBackends 

func (c *ComponentStore) ListWorkflowBackends() map[string]backend.Backend

func (*ComponentStore) ListWorkflows 

func (c *ComponentStore) ListWorkflows() map[string]workflows.Workflow

func (*ComponentStore) LocksLen 

func (c *ComponentStore) LocksLen() int

func (*ComponentStore) PubSubsLen 

func (c *ComponentStore) PubSubsLen() int

func (*ComponentStore) SecretStoresLen 

func (c *ComponentStore) SecretStoresLen() int

func (*ComponentStore) SetProgramaticSubscriptions 

func (c *ComponentStore) SetProgramaticSubscriptions(subs ...rtpubsub.Subscription)

func (*ComponentStore) StateStoresLen 

func (c *ComponentStore) StateStoresLen() int

type DeclarativeSubscription 

type DeclarativeSubscription struct {
	Comp *subapi.Subscription
	*NamedSubscription
}

type NamedSubscription 

type NamedSubscription struct {
	// Name is the optional name of the subscription. If not set, the name of the
	// component is used.
	Name *string
	rtpubsub.Subscription
}

type TypedSubscription 

type TypedSubscription struct {
	rtpubsub.Subscription
	Type runtimev1pb.PubsubSubscriptionType
}

MetadataSubscription is a temporary wrapper for rtpubsub.Subscription to add a Type attribute to be used in GetMetadata

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.