configkv

Documentation

Index

• type ConfigKV
  • func NewConfigKV(jetstreamContext nats.JetStreamContext) (*ConfigKV, error)
  • func (configkv *ConfigKV) GetConfigBytes(key string) ([]byte, error)
  • func (configkv *ConfigKV) Put(key string, value []byte) (uint64, error)
• type ConfigKVHTTPGetAll
  • func NewConfigKVHTTPGetAll(configkv *ConfigKV) *ConfigKVHTTPGetAll
  • func (handler *ConfigKVHTTPGetAll) ServeHTTP(w http.ResponseWriter, r *http.Request)

Types

type ConfigKV

type ConfigKV struct {
	KV nats.KeyValue
	// contains filtered or unexported fields
}

func NewConfigKV

func NewConfigKV(jetstreamContext nats.JetStreamContext) (*ConfigKV, error)

NewConfigKV is the constructor for *ConfigKV

func (*ConfigKV) GetConfigBytes

func (configkv *ConfigKV) GetConfigBytes(key string) ([]byte, error)

GetConfigBytes returns config from the KV backend in bytes

func (*ConfigKV) Put

func (configkv *ConfigKV) Put(key string, value []byte) (uint64, error)

Put is a wrapper on Nats KV.Put

type ConfigKVHTTPGetAll

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

ConfigKVHTTPGetAll is http handler to render all config in JSON format

func NewConfigKVHTTPGetAll

func NewConfigKVHTTPGetAll(configkv *ConfigKV) *ConfigKVHTTPGetAll

NewConfigKVHTTPGetAll is constructor for ConfigKVHTTPGetAll

func (*ConfigKVHTTPGetAll) ServeHTTP

func (handler *ConfigKVHTTPGetAll) ServeHTTP(w http.ResponseWriter, r *http.Request)