Help us shape the future of Go! Take the 2026 Go Developer Survey

compstore

package
v1.17.17 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 2026 License: Apache-2.0 Imports: 23 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 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) 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) 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) 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) 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) 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 added in v1.14.0 

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

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