mapper

Documentation

Index

• Constants
• func BuildParamKey(paramSpace string, key []byte) []byte
• type Mapper
  • func GetMapper(ctx context.Context) *Mapper
  • func NewMapper() *Mapper
  • func (mapper *Mapper) Copy() mapper.IMapper
  • func (mapper Mapper) GetModuleParamSet(module string) (set qtypes.ParamSet, exists bool)
  • func (mapper Mapper) GetModuleParams(module string) (set qtypes.ParamSet, exists bool)
  • func (mapper Mapper) GetParam(paramSpace string, key string) (value interface{}, exists bool)
  • func (mapper Mapper) GetParamSet(params qtypes.ParamSet)
  • func (mapper Mapper) GetParams() (params []qtypes.ParamSet)
  • func (mapper Mapper) RegisterParamSet(ps ...qtypes.ParamSet)
  • func (mapper Mapper) SetParam(paramSpace string, key string, value interface{})
  • func (mapper Mapper) SetParamSet(params qtypes.ParamSet)
  • func (mapper *Mapper) SetUpMetrics(cfg *config.InstrumentationConfig)
  • func (mapper Mapper) UpdateMetrics(paramSpace, key string, value interface{})
  • func (mapper Mapper) Validate(paramSpace string, key string, value string) btypes.Error
• type Metrics
  • func NopMetrics() *Metrics
  • func PrometheusMetrics(cfg *config.InstrumentationConfig) *Metrics

Constants

const (
	MetricsSubsystem = "params"
	ParamLabel       = "key"
)

const MapperName = "params"

Functions

func BuildParamKey

func BuildParamKey(paramSpace string, key []byte) []byte

Types

type Mapper

type Mapper struct {
	*mapper.BaseMapper

	Metrics *Metrics
	// contains filtered or unexported fields
}

参数存储操作

func GetMapper

func GetMapper(ctx context.Context) *Mapper

func NewMapper

func NewMapper() *Mapper

func (*Mapper) Copy

func (mapper *Mapper) Copy() mapper.IMapper

func (Mapper) GetModuleParamSet

func (mapper Mapper) GetModuleParamSet(module string) (set qtypes.ParamSet, exists bool)

获取模块参数结构，并非保存在数据库中参数数据

func (Mapper) GetModuleParams

func (mapper Mapper) GetModuleParams(module string) (set qtypes.ParamSet, exists bool)

获取模块参数集

func (Mapper) GetParam

func (mapper Mapper) GetParam(paramSpace string, key string) (value interface{}, exists bool)

获取单个参数

func (Mapper) GetParamSet

func (mapper Mapper) GetParamSet(params qtypes.ParamSet)

获取参数集

func (Mapper) GetParams

func (mapper Mapper) GetParams() (params []qtypes.ParamSet)

获取所有参数

func (Mapper) RegisterParamSet

func (mapper Mapper) RegisterParamSet(ps ...qtypes.ParamSet)

参数注册

func (Mapper) SetParam

func (mapper Mapper) SetParam(paramSpace string, key string, value interface{})

设置单个参数

func (Mapper) SetParamSet

func (mapper Mapper) SetParamSet(params qtypes.ParamSet)

保存参数集

func (*Mapper) SetUpMetrics

func (mapper *Mapper) SetUpMetrics(cfg *config.InstrumentationConfig)

设置prometheus监控项

func (Mapper) UpdateMetrics

func (mapper Mapper) UpdateMetrics(paramSpace, key string, value interface{})

metrics

func (Mapper) Validate

func (mapper Mapper) Validate(paramSpace string, key string, value string) btypes.Error

参数校验

type Metrics

type Metrics struct {
	Param metrics.Gauge
}

func NopMetrics

func NopMetrics() *Metrics

func PrometheusMetrics

func PrometheusMetrics(cfg *config.InstrumentationConfig) *Metrics