compstore

package
v1.18.3 Latest Latest
Warning

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

 Go to latest Published: Aug 14, 2026 License: Apache-2.0 Imports: 27 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) AddConfigurationResource added in v1.18.0 

func (c *ComponentStore) AddConfigurationResource(cfg configapi.Configuration)

func (*ComponentStore) AddConfigurationSubscribe 

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

func (*ComponentStore) AddConversation added in v1.15.0 

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

func (*ComponentStore) AddCryptoProvider 

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

func (*ComponentStore) AddDeclarativeSubscription added in v1.14.0 

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) AddMCPServer added in v1.18.0 

func (c *ComponentStore) AddMCPServer(s mcpserverv1alpha1.MCPServer)

AddMCPServer adds or replaces an MCPServer in the store.

func (*ComponentStore) AddOutputBinding 

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

func (*ComponentStore) AddPendingComponentForCommit added in v1.13.0 

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

func (*ComponentStore) AddPubSub 

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

func (*ComponentStore) AddResiliencyResource added in v1.18.0 

func (c *ComponentStore) AddResiliencyResource(res resiliencyapi.Resiliency)

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 added in v1.13.0 

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

func (*ComponentStore) AddStreamSubscription added in v1.14.0 

func (c *ComponentStore) AddStreamSubscription(comp *subapi.Subscription, connectionID rtpubsub.ConnectionID) error

func (*ComponentStore) AddWorkflowAccessPolicy added in v1.18.0 

func (c *ComponentStore) AddWorkflowAccessPolicy(policy wfaclapi.WorkflowAccessPolicy)

func (*ComponentStore) CommitPendingComponent added in v1.13.0 

func (c *ComponentStore) CommitPendingComponent() error

func (*ComponentStore) ConfigurationsLen 

func (c *ComponentStore) ConfigurationsLen() int

func (*ComponentStore) ConversationsLen added in v1.15.0 

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) DeleteConfigurationResource added in v1.18.0 

func (c *ComponentStore) DeleteConfigurationResource(name string)

func (*ComponentStore) DeleteConfigurationSubscribe 

func (c *ComponentStore) DeleteConfigurationSubscribe(name string)

func (*ComponentStore) DeleteConversation added in v1.15.0 

func (c *ComponentStore) DeleteConversation(name string)

func (*ComponentStore) DeleteCryptoProvider 

func (c *ComponentStore) DeleteCryptoProvider(name string)

func (*ComponentStore) DeleteDeclarativeSubscription added in v1.14.0 

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) DeleteMCPServer added in v1.18.0 

func (c *ComponentStore) DeleteMCPServer(name string)

DeleteMCPServer removes the MCPServer with the given name from the store.

func (*ComponentStore) DeleteOutputBinding 

func (c *ComponentStore) DeleteOutputBinding(name string)

func (*ComponentStore) DeletePubSub 

func (c *ComponentStore) DeletePubSub(name string)

func (*ComponentStore) DeleteResiliencyResource added in v1.18.0 

func (c *ComponentStore) DeleteResiliencyResource(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 added in v1.14.0 

func (c *ComponentStore) DeleteStreamSubscription(comp *subapi.Subscription)

func (*ComponentStore) DeleteWorkflowAccessPolicy added in v1.18.0 

func (c *ComponentStore) DeleteWorkflowAccessPolicy(name string)

func (*ComponentStore) DropPendingComponent added in v1.13.0 

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) GetConfigurationResource added in v1.18.0 

func (c *ComponentStore) GetConfigurationResource(name string) (configapi.Configuration, bool)

func (*ComponentStore) GetConfigurationSubscribe 

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

func (*ComponentStore) GetConversation added in v1.15.0 

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

func (*ComponentStore) GetCryptoProvider 

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

func (*ComponentStore) GetDeclarativeSubscription added in v1.14.0 

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) GetMCPServer added in v1.18.0 

func (c *ComponentStore) GetMCPServer(name string) (mcpserverv1alpha1.MCPServer, bool)

GetMCPServer returns the MCPServer with the given name, if it exists.

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 added in v1.12.0 

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

func (*ComponentStore) GetResiliencyResource added in v1.18.0 

func (c *ComponentStore) GetResiliencyResource(name string) (resiliencyapi.Resiliency, bool)

func (*ComponentStore) GetSecret added in v1.18.0 

func (c *ComponentStore) GetSecret(ctx context.Context, storeName, secretName, secretKey string) (string, error)

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 added in v1.13.0 

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

func (*ComponentStore) GetStateStoreActorWithRevision added in v1.18.3 

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

GetStateStoreActorWithRevision returns the actor state store along with the revision of the actor state store slot. The revision increments on every set or clear of the slot, so comparing revisions detects transitions (including a remove+add of the same store name).

func (*ComponentStore) GetStreamSubscription added in v1.14.0 

func (c *ComponentStore) GetStreamSubscription(subscription *subapi.Subscription) (*NamedSubscription, bool)

func (*ComponentStore) ListComponents 

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

func (*ComponentStore) ListConfigurationResources added in v1.18.0 

func (c *ComponentStore) ListConfigurationResources() []configapi.Configuration

func (*ComponentStore) ListConfigurations 

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

func (*ComponentStore) ListConversations added in v1.15.0 

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

func (*ComponentStore) ListCryptoProviders 

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

func (*ComponentStore) ListDeclarativeSubscriptions added in v1.14.0 

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) ListMCPServers added in v1.18.0 

func (c *ComponentStore) ListMCPServers() []mcpserverv1alpha1.MCPServer

ListMCPServers returns a copy of all MCPServer resources in the store.

func (*ComponentStore) ListOutputBindings 

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

func (*ComponentStore) ListProgramaticSubscriptions added in v1.14.0 

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

func (*ComponentStore) ListPubSubs 

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

func (*ComponentStore) ListResiliencyResources added in v1.18.0 

func (c *ComponentStore) ListResiliencyResources() []resiliencyapi.Resiliency

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 added in v1.14.0 

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

func (*ComponentStore) ListSubscriptionsStreamByPubSub added in v1.14.0 

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

func (*ComponentStore) ListTypedSubscriptions added in v1.14.0 

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

func (*ComponentStore) ListWorkflowAccessPolicies added in v1.18.0 

func (c *ComponentStore) ListWorkflowAccessPolicies() []wfaclapi.WorkflowAccessPolicy

func (*ComponentStore) LocksLen 

func (c *ComponentStore) LocksLen() int

func (*ComponentStore) NextSubscriberIndex added in v1.16.0 

func (c *ComponentStore) NextSubscriberIndex() rtpubsub.ConnectionID

func (*ComponentStore) PubSubsLen 

func (c *ComponentStore) PubSubsLen() int

func (*ComponentStore) SecretStoresLen 

func (c *ComponentStore) SecretStoresLen() int

func (*ComponentStore) SetProgramaticSubscriptions added in v1.14.0 

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

func (*ComponentStore) StateStoresLen 

func (c *ComponentStore) StateStoresLen() int

type DeclarativeSubscription added in v1.14.0 

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

type NamedSubscription added in v1.14.0 

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

type TypedSubscription added in v1.14.0 

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.