kubernetes

type ConfigurationStore ¶

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

ConfigurationStore implements a Kubernetes ConfigMap-backed configuration store. A SharedIndexInformer watches the configured ConfigMap. Each Subscribe call registers a per-subscriber event handler on the informer, which handles initial state replay, change notifications, and deletion atomically.

func (s *ConfigurationStore) Close() error

func (s *ConfigurationStore) Get(_ context.Context, req *configuration.GetRequest) (*configuration.GetResponse, error)

func (s *ConfigurationStore) GetComponentMetadata() (metadataInfo contribMetadata.MetadataMap)

func (s *ConfigurationStore) Init(ctx context.Context, meta configuration.Metadata) error

func (s *ConfigurationStore) Subscribe(ctx context.Context, req *configuration.SubscribeRequest, handler configuration.UpdateHandler) (string, error)

func (s *ConfigurationStore) Unsubscribe(_ context.Context, req *configuration.UnsubscribeRequest) error