compstore

package
v1.12.1 Latest Latest
Warning

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

 Go to latest Published: Nov 15, 2023 License: Apache-2.0 Imports: 13 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) AddComponent 

func (c *ComponentStore) AddComponent(component compsv1alpha1.Component)

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

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

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

func (c *ComponentStore) AddPubSub(name string, item 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) AddWorkflow 

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

func (*ComponentStore) ConfigurationsLen 

func (c *ComponentStore) ConfigurationsLen() int

func (*ComponentStore) CryptoProvidersLen 

func (c *ComponentStore) CryptoProvidersLen() int

func (*ComponentStore) DeleteAllConfigurationSubscribe 

func (c *ComponentStore) DeleteAllConfigurationSubscribe()

func (*ComponentStore) DeleteComponent 

func (c *ComponentStore) DeleteComponent(compType, name string)

func (*ComponentStore) DeleteConfiguration 

func (c *ComponentStore) DeleteConfiguration(name string)

func (*ComponentStore) DeleteConfigurationSubscribe 

func (c *ComponentStore) DeleteConfigurationSubscribe(name string)

func (*ComponentStore) DeleteCryptoProvider 

func (c *ComponentStore) DeleteCryptoProvider(name 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) DeleteTopicRoute added in v1.12.0 

func (c *ComponentStore) DeleteTopicRoute(name string)

func (*ComponentStore) DeleteWorkflow 

func (c *ComponentStore) DeleteWorkflow(name string)

func (*ComponentStore) GetComponent 

func (c *ComponentStore) GetComponent(componentType, 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) GetCryptoProvider 

func (c *ComponentStore) GetCryptoProvider(name string) (crypto.SubtleCrypto, 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) (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) GetTopicRoutes 

func (c *ComponentStore) GetTopicRoutes() map[string]TopicRoutes

func (*ComponentStore) GetWorkflow 

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

func (*ComponentStore) ListComponents 

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

func (*ComponentStore) ListConfigurations 

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

func (*ComponentStore) ListCryptoProviders 

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

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

func (c *ComponentStore) ListPubSubs() map[string]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) ListSubscriptions 

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

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

func (c *ComponentStore) SetSubscriptions(subscriptions []rtpubsub.Subscription)

func (*ComponentStore) SetTopicRoutes 

func (c *ComponentStore) SetTopicRoutes(topicRoutes map[string]TopicRoutes)

func (*ComponentStore) StateStoresLen 

func (c *ComponentStore) StateStoresLen() int

type PubsubItem 

type PubsubItem struct {
	Component           pubsub.PubSub
	ScopedSubscriptions []string
	ScopedPublishings   []string
	AllowedTopics       []string
	ProtectedTopics     []string
	NamespaceScoped     bool
}

PubsubItem is a pubsub component with its scoped subscriptions and publishings.

type TopicRouteElem 

type TopicRouteElem struct {
	Metadata        map[string]string
	Rules           []*rtpubsub.Rule
	DeadLetterTopic string
	BulkSubscribe   *rtpubsub.BulkSubscribe
}

type TopicRoutes 

type TopicRoutes map[string]TopicRouteElem

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.