count

Documentation

Index

• func DelChannel(db string, channelId string)
• func DelDB(db string)
• func DelTable(db string, tableId string)
• func DoInit()
• func SetChannel(db string, channelId string) chan *FlowCount
• func SetDB(db string)
• func SetTable(db string, tableId string)
• type CountContent
  • func GetFlowAll(flowType string) []CountContent
  • func GetFlowByChannel(db string, channelId string, flowType string) []CountContent
  • func GetFlowByDb(db string, flowType string) []CountContent
  • func GetFlowByTable(db string, tableId string, flowType string) []CountContent
• type CountFlow
• type FlowCount

Functions

func DelChannel

func DelChannel(db string, channelId string)

func DelDB

func DelDB(db string)

func DelTable

func DelTable(db string, tableId string)

func DoInit

func DoInit()

func SetChannel

func SetChannel(db string, channelId string) chan *FlowCount

func SetDB

func SetDB(db string)

func SetTable

func SetTable(db string, tableId string)

Types

type CountContent

type CountContent struct {
	Time     int64
	Count    int64
	ByteSize int64
}

func GetFlowAll

func GetFlowAll(flowType string) []CountContent

func GetFlowByChannel

func GetFlowByChannel(db string, channelId string, flowType string) []CountContent

func GetFlowByDb

func GetFlowByDb(db string, flowType string) []CountContent

func GetFlowByTable

func GetFlowByTable(db string, tableId string, flowType string) []CountContent

type CountFlow

type CountFlow struct {
	Minute    []CountContent
	TenMinute []CountContent
	Hour      []CountContent
	EightHour []CountContent
	Day       []CountContent
	Content   *CountContent
}

type FlowCount

type FlowCount struct {
	Time     int64
	TableId  string
	Count    int64
	ByteSize int64
}