config_mgr

Documentation

Index

• type ConfigMgr
  • func NewConfigMgr(ctx context.Context, wg *sync.WaitGroup, strmprov rkcy.StreamProvider, ...) *ConfigMgr
  • func (confMgr *ConfigMgr) BuildConfigResponse() *rkcypb.ConfigReadResponse
  • func (confMgr *ConfigMgr) GetBool(key string) (bool, bool)
  • func (confMgr *ConfigMgr) GetComplexBytes(msgType string, key string) ([]byte, bool)
  • func (confMgr *ConfigMgr) GetComplexMsg(msgType string, key string) (proto.Message, bool)
  • func (confMgr *ConfigMgr) GetFloat64(key string) (float64, bool)
  • func (confMgr *ConfigMgr) GetString(key string) (string, bool)
  • func (confMgr *ConfigMgr) SetBool(key string, val bool)
  • func (confMgr *ConfigMgr) SetComplexBytes(msgType string, key string, val []byte)
  • func (confMgr *ConfigMgr) SetComplexMsg(msgType string, key string, msg proto.Message)
  • func (confMgr *ConfigMgr) SetFloat64(key string, val float64)
  • func (confMgr *ConfigMgr) SetString(key string, val string)
• type ConfigMgrRdr
  • func NewConfigMgrRdr(mgr *ConfigMgr) *ConfigMgrRdr
  • func (rdr *ConfigMgrRdr) BuildConfigResponse() *rkcypb.ConfigReadResponse
  • func (rdr *ConfigMgrRdr) GetBool(key string) (bool, bool)
  • func (rdr *ConfigMgrRdr) GetComplexBytes(msgType string, key string) ([]byte, bool)
  • func (rdr *ConfigMgrRdr) GetComplexMsg(msgType string, key string) (proto.Message, bool)
  • func (rdr *ConfigMgrRdr) GetFloat64(key string) (float64, bool)
  • func (rdr *ConfigMgrRdr) GetString(key string) (string, bool)

Types

type ConfigMgr

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

func NewConfigMgr

func NewConfigMgr(
	ctx context.Context,
	wg *sync.WaitGroup,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
) *ConfigMgr

func (*ConfigMgr) BuildConfigResponse

func (confMgr *ConfigMgr) BuildConfigResponse() *rkcypb.ConfigReadResponse

func (*ConfigMgr) GetBool

func (confMgr *ConfigMgr) GetBool(key string) (bool, bool)

func (*ConfigMgr) GetComplexBytes

func (confMgr *ConfigMgr) GetComplexBytes(msgType string, key string) ([]byte, bool)

func (*ConfigMgr) GetComplexMsg

func (confMgr *ConfigMgr) GetComplexMsg(msgType string, key string) (proto.Message, bool)

func (*ConfigMgr) GetFloat64

func (confMgr *ConfigMgr) GetFloat64(key string) (float64, bool)

func (*ConfigMgr) GetString

func (confMgr *ConfigMgr) GetString(key string) (string, bool)

func (*ConfigMgr) SetBool

func (confMgr *ConfigMgr) SetBool(key string, val bool)

func (*ConfigMgr) SetComplexBytes

func (confMgr *ConfigMgr) SetComplexBytes(msgType string, key string, val []byte)

func (*ConfigMgr) SetComplexMsg

func (confMgr *ConfigMgr) SetComplexMsg(msgType string, key string, msg proto.Message)

func (*ConfigMgr) SetFloat64

func (confMgr *ConfigMgr) SetFloat64(key string, val float64)

func (*ConfigMgr) SetString

func (confMgr *ConfigMgr) SetString(key string, val string)

type ConfigMgrRdr

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

func NewConfigMgrRdr

func NewConfigMgrRdr(mgr *ConfigMgr) *ConfigMgrRdr

func (*ConfigMgrRdr) BuildConfigResponse

func (rdr *ConfigMgrRdr) BuildConfigResponse() *rkcypb.ConfigReadResponse

func (*ConfigMgrRdr) GetBool

func (rdr *ConfigMgrRdr) GetBool(key string) (bool, bool)

func (*ConfigMgrRdr) GetComplexBytes

func (rdr *ConfigMgrRdr) GetComplexBytes(msgType string, key string) ([]byte, bool)

func (*ConfigMgrRdr) GetComplexMsg

func (rdr *ConfigMgrRdr) GetComplexMsg(msgType string, key string) (proto.Message, bool)

func (*ConfigMgrRdr) GetFloat64

func (rdr *ConfigMgrRdr) GetFloat64(key string) (float64, bool)

func (*ConfigMgrRdr) GetString

func (rdr *ConfigMgrRdr) GetString(key string) (string, bool)