flowmonitor

Documentation

Index

• func InitFlowMonitor(conf *Config) (err error)
• type Config
• type FlowMonitor
  • func (fm *FlowMonitor) Add(appId string, source string, timeRangeKey string, kind string, status string) error
  • func (fm *FlowMonitor) AddEvent(e *event.ProcessorEvent, source string, kind string, status string)

Functions

func InitFlowMonitor

func InitFlowMonitor(conf *Config) (err error)

InitFlowMonitor init flow monitor

Types

type Config

type Config struct {
	Interval xtime.Duration
	Addr     string
}

type FlowMonitor

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

var Fm *FlowMonitor

func (*FlowMonitor) Add

func (fm *FlowMonitor) Add(appId string, source string, timeRangeKey string, kind string, status string) error

Add do the metric

func (*FlowMonitor) AddEvent

func (fm *FlowMonitor) AddEvent(e *event.ProcessorEvent, source string, kind string, status string)