Documentation
¶
Index ¶
- func NewRedisConfigurationStore(logger logger.Logger) configuration.Store
- type ConfigurationStore
- func (r *ConfigurationStore) Get(ctx context.Context, req *configuration.GetRequest) (*configuration.GetResponse, error)
- func (r *ConfigurationStore) GetComponentMetadata() map[string]string
- func (r *ConfigurationStore) Init(ctx context.Context, metadata configuration.Metadata) error
- func (r *ConfigurationStore) Subscribe(ctx context.Context, req *configuration.SubscribeRequest, ...) (string, error)
- func (r *ConfigurationStore) Unsubscribe(ctx context.Context, req *configuration.UnsubscribeRequest) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewRedisConfigurationStore ¶
func NewRedisConfigurationStore(logger logger.Logger) configuration.Store
NewRedisConfigurationStore returns a new redis state store.
Types ¶
type ConfigurationStore ¶
type ConfigurationStore struct {
// contains filtered or unexported fields
}
ConfigurationStore is a Redis configuration store.
func (*ConfigurationStore) Get ¶
func (r *ConfigurationStore) Get(ctx context.Context, req *configuration.GetRequest) (*configuration.GetResponse, error)
func (*ConfigurationStore) GetComponentMetadata ¶
func (r *ConfigurationStore) GetComponentMetadata() map[string]string
GetComponentMetadata returns the metadata of the component.
func (*ConfigurationStore) Init ¶
func (r *ConfigurationStore) Init(ctx context.Context, metadata configuration.Metadata) error
Init does metadata and connection parsing.
func (*ConfigurationStore) Subscribe ¶
func (r *ConfigurationStore) Subscribe(ctx context.Context, req *configuration.SubscribeRequest, handler configuration.UpdateHandler) (string, error)
func (*ConfigurationStore) Unsubscribe ¶
func (r *ConfigurationStore) Unsubscribe(ctx context.Context, req *configuration.UnsubscribeRequest) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.