Documentation ¶
Index ¶
- Constants
- Variables
- type Metric
- type PipelineData
- type PoolRunner
- type PushData
- type PushGateWay
- func (p *PushGateWay) CacheMetric(data *PushData) (respData *RespData, err error)
- func (p *PushGateWay) CacheMetrics()
- func (p *PushGateWay) GetMetric(jobName, id string) (metric *PushData, err error)
- func (p *PushGateWay) GetMetrics() (metricByte []byte, err error)
- func (p *PushGateWay) Paging(keys []string) (keysGroup [][]string)
- func (p *PushGateWay) ReadFromRedisPipeline(keys []string) (metricValues [][]byte, err error)
- func (p *PushGateWay) WriteToRedisPipeline(metrics []*PushData) (err error)
- type RespData
Constants ¶
View Source
const (
MetricPrefix = "metric"
)
Variables ¶
View Source
var (
MetricsChannel = make(chan *PushData, global.Config.RedisAgent.KeyCount)
)
Functions ¶
This section is empty.
Types ¶
type PipelineData ¶
type PoolRunner ¶
type PushGateWay ¶
type PushGateWay struct { Agent *redis.Agent MetricTemplate *template.Template // contains filtered or unexported fields }
func NewPushGateWayController ¶
func NewPushGateWayController(agent *redis.Agent) *PushGateWay
func (*PushGateWay) CacheMetric ¶
func (p *PushGateWay) CacheMetric(data *PushData) (respData *RespData, err error)
func (*PushGateWay) CacheMetrics ¶
func (p *PushGateWay) CacheMetrics()
func (*PushGateWay) GetMetric ¶
func (p *PushGateWay) GetMetric(jobName, id string) (metric *PushData, err error)
func (*PushGateWay) GetMetrics ¶
func (p *PushGateWay) GetMetrics() (metricByte []byte, err error)
func (*PushGateWay) Paging ¶
func (p *PushGateWay) Paging(keys []string) (keysGroup [][]string)
func (*PushGateWay) ReadFromRedisPipeline ¶
func (p *PushGateWay) ReadFromRedisPipeline(keys []string) (metricValues [][]byte, err error)
func (*PushGateWay) WriteToRedisPipeline ¶
func (p *PushGateWay) WriteToRedisPipeline(metrics []*PushData) (err error)
Click to show internal directories.
Click to hide internal directories.