stats_manager

Documentation

Index

• Constants
• type ChannelMsg
• type Events
• type PipeMsg
• type Stats
• type StatsCollector
  • func NewStatsCollector(componentName string) *StatsCollector
  • func (sc *StatsCollector) Destroy()
  • func (sc *StatsCollector) Init()
  • func (sc *StatsCollector) PushEvents(op string, path string, mp map[string]interface{})
  • func (sc *StatsCollector) UpdateStats(op string, key string, val interface{})

Constants

const (
	// Stats collection operation types
	Increment = "increment"
	Decrement = "decrement"
	Replace   = "replace"
)

Types

type ChannelMsg

type ChannelMsg struct {
	IsEvent bool
	CompMsg interface{}
}

type Events

type Events struct {
	Timestamp string
	Operation string
	Path      string
	Value     map[string]interface{}
}

type PipeMsg

type PipeMsg struct {
	Timestamp     string                 `json:"timestamp"`
	ComponentName string                 `json:"componentName,omitempty"`
	Operation     string                 `json:"operation,omitempty"`
	Path          string                 `json:"path,omitempty"`
	Value         map[string]interface{} `json:"value,omitempty"`
}

type Stats

type Stats struct {
	Timestamp string
	Operation string
	Key       string
	Value     interface{}
}

type StatsCollector

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

func NewStatsCollector

func NewStatsCollector(componentName string) *StatsCollector

func (*StatsCollector) Destroy

func (sc *StatsCollector) Destroy()

func (*StatsCollector) Init

func (sc *StatsCollector) Init()

func (*StatsCollector) PushEvents

func (sc *StatsCollector) PushEvents(op string, path string, mp map[string]interface{})

func (*StatsCollector) UpdateStats

func (sc *StatsCollector) UpdateStats(op string, key string, val interface{})