redis

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) Init(metadata configuration.Metadata) error
  • func (r *ConfigurationStore) Subscribe(ctx context.Context, req *configuration.SubscribeRequest, ...) error

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

func (r *ConfigurationStore) Init(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) error