pack

package
v0.0.21 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 28, 2023 License: Apache-2.0 Imports: 21 Imported by: 18

Documentation

Index

Constants

View Source 
const (
	FATAL   byte = 30
	WARNING byte = 20
	INFO    byte = 10
	NONE    byte = 0

	ESCALATION_KEY string = "_esca_"
	UUID_KEY       string = "_uuid_"
	STATUS_KEY     string = "_status_"
	OTYPE_KEY      string = "_otype_"
)
View Source 
const (
	HITMAP_LENGTH = 120
	// 2.5초
	HITMAP_VERTICAL_INDEX = 20
	// 5초
	HITMAP_HORIZONTAL_INDEX = 60
)
View Source 
const (
	ZIPPED    = 1
	UN_ZIPPED = 0
)
View Source 
const (
	// 256
	PACK_PARAMETER = 0x0100
	// 512
	//PACK_COUNTER       	= 0x0200
	// 513
	PACK_COUNTER_1 = 0x0201
	// 768
	PACK_PROFILE            = 0x0300
	PACK_BIZMON_HELP        = 0x0301
	PACK_PROFILE_STEP_SPLIT = 0x302
	// 1025
	PACK_ACTIVESTACK_1 = 0x0401
	// 1792
	PACK_TEXT    = 0x0700
	PACK_HV_TEXT = 0x0701
	// 2048
	//PACK_ERROR_SNAP    	= 0x0800
	// 2049
	PACK_ERROR_SNAP_1 = 0x0801
	// 3840
	PACK_REALTIME_USER   = 0x0f00
	PACK_REALTIME_USER_1 = 0x0f01

	// 2304
	PACK_STAT_SERVICE   = 0x0900
	PACK_STAT_SERVICE_1 = 0x0901
	// 2320
	PACK_STAT_GENERAL = 0x0910

	// 2560
	PACK_STAT_SQL = 0x0a00
	// 2816
	PACK_STAT_HTTPC = 0x0b00
	// 3072
	PACK_STAT_ERROR = 0x0c00
	// 3584
	PACK_STAT_METHOD = 0x0e00
	// 4096
	PACK_STAT_TOP_SERVICE = 0x1000
	// 4352
	PACK_STAT_REMOTE_IP = 0x1100
	// 4608
	PACK_STAT_USER_AGENT   = 0x1200
	PACK_STAT_USER_AGENT_1 = 0x1201

	// 5120
	PACK_EVENT = 0x1400
	// 5376
	//PACK_HITMAP    		= 0x1500
	// 5377
	PACK_HITMAP_1 = 0x1501
	// 5632
	PACK_EXTENSION = 0x1600
	TAG_COUNT      = 0x1601
	TAG_LOG        = 0x1602

	// 5888
	PACK_COMPOSITE = 0x1700

	// 5889
	PACK_BSM_RECORD = 0x1701
	// 5890
	PACK_AP_NUT = 0x1702
	// 5891
	PACK_ADDIN_COUNT = 0x1703

	PACK_KUBE_MASTER_COUNT = 0x1704
	PACK_KUBE_MASTER_STAT  = 0x1705
	PACK_KUBE_NODE         = 0x1706
	PACK_WEB_CHECK_COUNT   = 0x1707
	PACK_LOGSINK           = 0x170a
	PACK_ZIP               = 0x170b
	PACK_AGENT_MAPPING     = 0x170c
	PACK_LOGSINK_ZIP       = 0x170d

	PACK_SM_BASE       = 0x3008
	PACK_SM_DISK_QUATA = 0x3001
	PACK_SM_NET_PERF   = 0x3002
	PACK_SM_PROC_PERF  = 0x3003
	PACK_SM_PORT_PERF  = 0x3004
	PACK_SM_LOG_EVENT  = 0x3005
	PACK_SM_DOWN_CHECK = 0x3006
	PACK_SM_PROC_GROUP = 0x3007
	PACK_SM_BASE_1     = 0x3008
	PACK_SM_META       = 0x3009

	PACK_SM_EXTENSION = 0x1600

	PACK_SM_NUT  = 0x3010
	PACK_SM_ATTR = 0x3011
	PACK_SM_PING = 0x3012

	ADDIN_VTYPE_CONTAINER = "container"

	PACK_SERVERINFO = 0x6500
)
View Source 
const (
	OS_LINUX   = 1
	OS_WINDOW  = 2
	OS_OSX     = 3
	OS_HPUX    = 4
	OS_AIX     = 5
	OS_SUNOS   = 6
	OS_OPENBSD = 7
	OS_FREEBSD = 8
)
View Source 
const (
	TEXT_SERVICE            = 1
	TEXT_SQL                = 2
	TEXT_DB_URL             = 3
	TEXT_HTTPC_URL          = 4
	TEXT_ERROR              = 5
	TEXT_METHOD             = 6
	TEXT_STACK_ELEMENTS     = 7
	TEXT_REFERER            = 8
	TEXT_USER_AGENT         = 9
	TEXT_HTTPC_HOST         = 10
	TEXT_MESSAGE            = 11
	TEXT_CRUD               = 12
	TEXT_ONAME              = 13
	TEXT_COMMAND            = 14
	TEXT_USER_AGENT_OS      = 15
	TEXT_USER_AGENT_BROWSER = 16
	TEXT_CITY               = 17

	TEXT_LOGIN       = 18
	TEXT_SQL_PARAM   = 19
	TEXT_HTTP_DOMAIN = 20

	TEXT_SYS_DEVICE_ID     = 21
	TEXT_SYS_MOUNT_POINT   = 22
	TEXT_SYS_FILE_SYSTEM   = 23
	TEXT_SYS_NET_DESC      = 24
	TEXT_SYS_PROC_CMD1     = 26
	TEXT_SYS_PROC_CMD2     = 27
	TEXT_SYS_PROC_USER     = 28
	TEXT_SYS_PROC_STATE    = 29
	TEXT_SYS_PROC_FILENAME = 30
	TEXT_SM_LOG_FILE       = 31

	TEXT_DB_COUNTER_NAME = 41
	TEXT_DB_COUNTER_UNIT = 42

	TEXT_CW_AGENT_IP = 51
	TEXT_CW_MXID     = 52

	TEXT_MTRACE_SPEC       = 53
	TEXT_MTRACE_CALLER_URL = 54

	ADDIN_AID_NAME   = 55
	ADDIN_COUNT_NAME = 56

	TEXT_OKIND      = 57
	KUBE_COUNT_NAME = 59

	CONTAINER = 60
	PODNAME   = 61

	CONTAINER_IMAGE   = 62
	ONODE_NAME        = 63
	CONTAINER_COMMAND = 64
	REPLICASETNAME    = 65
	NAMESPACE         = 66
)
View Source 
const RUMCTL string = "rumctl"
View Source 
const (
	STAT_REMOTEIP_TABLE_MAX_SIZE = 10000
)
View Source 
const (
	STAT_USERAGENT_TABLE_MAX_SIZE = 500
)
View Source 
const (
	VERSION = 0x01
)

Variables

View Source 
var (
	EVENTSOURCE_FILE     = byte(1)
	EVENTSOURCE_WINEVENT = byte(2)
	EVENTSOURCE_SCRIPT   = byte(3)
)

Functions

func CreateMap 

func CreateMap(cnt int) *hmap.IntKeyMap

TODO 추후 이름이 혼동되지 않도록 CreateIntKeyMap 또는 StatServicePack 내부로 넣을 것 ? StatServicePack. func CreateMap(cnt int) *hmap.IntKeyMap {

func GetPackTypeString 

func GetPackTypeString(t int16) string

func ReadShortArray added in v0.0.15 

func ReadShortArray(din *io.DataInputX, sz int) []int16

func Sort 

func Sort(data *hmap.StringKeyLinkedMap, sortKey string, asc bool) *hmap.StringKeyLinkedMap

func SortAnyList 

func SortAnyList(data *hmap.StringKeyLinkedMap, sortKey string, asc bool, sortKey2 string, asc2 bool) *hmap.StringKeyLinkedMap

func ToBytesPack 

func ToBytesPack(p Pack) []byte

func ToBytesPackECB 

func ToBytesPackECB(p Pack, fmtLen int) []byte

func WritePack 

func WritePack(out *io.DataOutputX, p Pack) *io.DataOutputX

func WriteTransactionRec 

func WriteTransactionRec(o *io.DataOutputX, m *TransactionRec, version byte)

Types

type AbstractPack 

type AbstractPack struct {
	Pcode int64
	Oid   int32
	Okind int32
	Onode int32
	Time  int64
}

func (*AbstractPack) GetPCODE added in v0.0.15 

func (this *AbstractPack) GetPCODE() int64

pcode 설정 pack interface

func (*AbstractPack) GetTime added in v0.0.16 

func (this *AbstractPack) GetTime() int64

Get Time

func (*AbstractPack) Read 

func (this *AbstractPack) Read(din *io.DataInputX)

func (*AbstractPack) SetOID 

func (this *AbstractPack) SetOID(oid int32)

oid 설정 pack interface

func (*AbstractPack) SetOKIND 

func (this *AbstractPack) SetOKIND(okind int32)

oid 설정 pack interface

func (*AbstractPack) SetONODE 

func (this *AbstractPack) SetONODE(onode int32)

pcode 설정 pack interface

func (*AbstractPack) SetPCODE 

func (this *AbstractPack) SetPCODE(pcode int64)

pcode 설정 pack interface

func (*AbstractPack) SetTime added in v0.0.16 

func (this *AbstractPack) SetTime(t int64)

Set Time

func (*AbstractPack) ToString 

func (this *AbstractPack) ToString() string

func (*AbstractPack) Write 

func (this *AbstractPack) Write(dout *io.DataOutputX)

type ActiveStackPack 

type ActiveStackPack struct {
	AbstractPack
	Seq           int64
	ProfileSeq    int64
	Service       int32
	CallStack     []int32
	CallStackHash int32

	Elapsed int32
}

func NewActiveStackPack 

func NewActiveStackPack() *ActiveStackPack

func (*ActiveStackPack) GetPackType 

func (this *ActiveStackPack) GetPackType() int16

func (*ActiveStackPack) Read 

func (this *ActiveStackPack) Read(din *io.DataInputX)

func (*ActiveStackPack) Write 

func (this *ActiveStackPack) Write(dout *io.DataOutputX)

type CompositePack 

type CompositePack struct {
	AbstractPack
	// contains filtered or unexported fields
}

func NewCompositePack 

func NewCompositePack() *CompositePack

func (*CompositePack) GetPackType 

func (this *CompositePack) GetPackType() int16

func (*CompositePack) Read 

func (this *CompositePack) Read(din *io.DataInputX)

func (*CompositePack) Write 

func (this *CompositePack) Write(dout *io.DataOutputX)

type CounterPack1 

type CounterPack1 struct {
	AbstractPack

	Version byte

	Duration int32
	Cputime  int64

	HeapTot                 int64
	HeapUse                 int64
	HeapPerm                int64
	HeapPendingFinalization int32
	HeapMax                 int64

	GcCount       int32
	GcTime        int64
	GcOldgenCount int32

	ServiceCount int32
	ServiceError int32
	ServiceTime  int64

	TxDbcTime   float32
	TxSqlTime   float32
	TxHttpcTime float32

	SqlCount int32
	SqlError int32
	SqlTime  int64

	SqlFetchCount int64
	SqlFetchTime  int64

	HttpcCount int32
	HttpcError int32
	HttpcTime  int64

	//active_tx_cont
	ActSvcCount int32
	//active_tx_slice
	ActSvcSlice []int16

	Cpu      float32
	CpuSys   float32
	CpuUsr   float32
	CpuWait  float32
	CpuSteal float32
	CpuIrq   float32

	CpuProc  float32
	CpuCores int32

	Mem  float32
	Swap float32
	Disk float32

	ThreadTotalStarted int64
	ThreadCount        int32
	ThreadDaemon       int32
	ThreadPeakCount    int32

	Starttime   int64
	PackDropped int64

	DbNumActive *hmap.IntIntMap
	DbNumIdle   *hmap.IntIntMap

	Netstat *NETSTAT

	HostIp      int32
	ProcFd      int32
	Tps         float32
	RespTime    int32
	ArrivalRate float32

	// Java = 1, Node = 2, Python = 3, PHP = 4,  URL = 5
	ApType int16

	Websocket *WEBSOCKET

	MacHash int32

	//public IntMapValue extra;
	Extra *value.IntMapValue

	//public int pid;
	Pid int32

	//public final static String[] active_stat_keys = { "method", "sql", "httpc", "dbc", "socket" };
	ActiveStatKeys []string
	//public []int16 active_stat;
	ActiveStat []int16

	//public int32 threadpool_activeCount;
	ThreadPoolActiveCount int32
	//public int32 threadpool_queueSize;
	ThreadPoolQueueSize int32

	//public IntKeyLinkedMap<TxMeter> txcaller_oid_meter;
	TxcallerOidMeter  *hmap.IntKeyLinkedMap
	TxcallerPOidMeter *hmap.LinkedMap
	//public IntKeyLinkedMap<SqlMeter> sql_meter;
	SqlMeter *hmap.IntKeyLinkedMap
	//public IntKeyLinkedMap<HttpcMeter> httpc_meter;
	HttpcMeter *hmap.IntKeyLinkedMap
	//public LinkedMap<PKIND, TxMeter> txcaller_group_meter;
	TxcallerGroupMeter *hmap.LinkedMap
	//public TxMeter txcaller_unknown;
	TxcallerUnknown *TxMeter

	ContainerKey int32

	// AppDex
	ApdexSatisfied int32
	ApdexTolerated int32
	ApdexTotal     int32

	// TODO
	ProcFdMax int32

	// -1 초기화 안됨 , 0 old버전, 0.1이상 정상 수집
	Metering float32

	Resp90     int32
	Resp95     int32
	TimeSqrSum int64

	// java transient , read, write 없음.
	CollectIntervalMs int
}

func NewCounterPack1 

func NewCounterPack1() *CounterPack1

func (*CounterPack1) GetPackType 

func (this *CounterPack1) GetPackType() int16

func (*CounterPack1) Read 

func (this *CounterPack1) Read(in *io.DataInputX)

func (*CounterPack1) ReadDropMap 

func (this *CounterPack1) ReadDropMap(in *io.DataInputX)

func (*CounterPack1) Write 

func (this *CounterPack1) Write(out *io.DataOutputX)

type Cpu 

type Cpu interface {
	Write(dout *io.DataOutputX)
	Read(din *io.DataInputX)
}

################################################## CPU ELEMENT ##################################################

type CpuLinux 

type CpuLinux struct {
	User    float32
	System  float32
	Idle    float32
	Nice    float32
	Irq     float32
	Softirq float32
	Steal   float32
	Iowait  float32

	Load1  float32
	Load5  float32
	Load15 float32
}

func (*CpuLinux) Read 

func (this *CpuLinux) Read(dinx *io.DataInputX)

func (*CpuLinux) Write 

func (this *CpuLinux) Write(doutx *io.DataOutputX)

type CpuOSX 

type CpuOSX struct {
	User    float32
	System  float32
	Idle    float32
	Nice    float32
	Irq     float32
	Softirq float32
	Steal   float32
	Iowait  float32

	Load1  float32
	Load5  float32
	Load15 float32
}

CpuOSX CpuOSX

func (*CpuOSX) Read 

func (this *CpuOSX) Read(dinx *io.DataInputX)

func (*CpuOSX) Write 

func (this *CpuOSX) Write(doutx *io.DataOutputX)

type CpuWindow 

type CpuWindow struct {
	User   float32
	System float32
	Idle   float32

	ProcessorQueueLength float32
}

func (*CpuWindow) Read 

func (this *CpuWindow) Read(dinx *io.DataInputX)

func (*CpuWindow) Write 

func (this *CpuWindow) Write(doutx *io.DataOutputX)

type DiskPerf 

type DiskPerf struct {
	DeviceID   int32 /*hash*/
	MountPoint int32
	FileSystem int32

	FreeSpace  int64
	UsedSpace  int64
	TotalSpace int64

	FreePercent float32
	UsedPercent float32

	Blksize     int32
	ReadIops    float64
	WriteIops   float64
	ReadBps     float64
	WriteBps    float64
	IOPercent   float32
	Count       int32
	QueueLength float32

	InodeTotal       int64
	InodeUsed        int64
	InodeUsedPercent float32
	MountOption      int32
}

func (*DiskPerf) Read 

func (this *DiskPerf) Read(in *io.DataInputX)

func (*DiskPerf) Write 

func (this *DiskPerf) Write(out *io.DataOutputX)

type DownCheckRec 

type DownCheckRec struct {
	Name string
	Host string
	Port int32
	Ok   bool
}

type ErrorRec 

type ErrorRec struct {
	ClassHash int32
	Service   int32
	SnapSeq   int64
	Msg       int32
	Count     int32
}
type ErrorRec struct {
	ClassHash int32
	Service   int32
	SnapSeq   int64
	Msg       int32
	Count     int32
}

func NewErrorRec 

func NewErrorRec() *ErrorRec

func (*ErrorRec) GetKey 

func (this *ErrorRec) GetKey() int64

func (*ErrorRec) Merge 

func (this *ErrorRec) Merge(o *ErrorRec)

func (*ErrorRec) SetClassAndTxUrl 

func (this *ErrorRec) SetClassAndTxUrl(classHash int32, txUrl int32)

type ErrorSnapPack1 

type ErrorSnapPack1 struct {
	AbstractPack
	Seq     int64
	Profile []byte
	Stack   []byte

	AppendType byte
	AppendHash int32
}

func NewErrorSnapPack1 

func NewErrorSnapPack1() *ErrorSnapPack1

func (*ErrorSnapPack1) GetPackType 

func (this *ErrorSnapPack1) GetPackType() int16

func (*ErrorSnapPack1) Read 

func (this *ErrorSnapPack1) Read(din *io.DataInputX)

func (*ErrorSnapPack1) SetProfile 

func (this *ErrorSnapPack1) SetProfile(steps []step.Step)

func (*ErrorSnapPack1) SetStack 

func (this *ErrorSnapPack1) SetStack(callstack []int32)

func (*ErrorSnapPack1) Write 

func (this *ErrorSnapPack1) Write(dout *io.DataOutputX)

type EventPack 

type EventPack struct {
	AbstractPack

	Uuid       string
	Escalation bool

	Level   byte
	Title   string
	Message string
	Status  int32
	Otype   int32

	Attr *hmap.StringKeyLinkedMap

	Eid int64
}

func NewEventPack 

func NewEventPack() *EventPack

func (*EventPack) GetPackType 

func (this *EventPack) GetPackType() int16

func (*EventPack) Read 

func (this *EventPack) Read(din *io.DataInputX)

func (*EventPack) SetUuid 

func (this *EventPack) SetUuid()

func (*EventPack) Size 

func (this *EventPack) Size() int

func (*EventPack) ToString 

func (this *EventPack) ToString() string

func (*EventPack) Write 

func (this *EventPack) Write(dout *io.DataOutputX)

type ExtensionPack 

type ExtensionPack struct {
	AbstractPack

	IsProjectWide bool
	Header        *hmap.StringIntLinkedMap
	Value         *value.IntMapValue
}

func NewExtensionPack 

func NewExtensionPack() *ExtensionPack

func (*ExtensionPack) GetPackType 

func (this *ExtensionPack) GetPackType() int16

func (*ExtensionPack) Read 

func (this *ExtensionPack) Read(din *io.DataInputX)

func (*ExtensionPack) Write 

func (this *ExtensionPack) Write(dout *io.DataOutputX)

type HitMapPack1 

type HitMapPack1 struct {
	AbstractPack
	Hit   []int32
	Error []int32
}

func NewHitMapPack1 

func NewHitMapPack1() *HitMapPack1

func (*HitMapPack1) Add 

func (this *HitMapPack1) Add(time int, isError bool)

func (*HitMapPack1) GetPackType 

func (this *HitMapPack1) GetPackType() int16

func (*HitMapPack1) HitMapIndex 

func (this *HitMapPack1) HitMapIndex(time int) int

java에는 없지만 index, time 을 외부에서 쓰기 위해 추가

func (*HitMapPack1) HitMapTime 

func (this *HitMapPack1) HitMapTime(index int) int

func (*HitMapPack1) Read 

func (this *HitMapPack1) Read(din *io.DataInputX)

func (*HitMapPack1) Write 

func (this *HitMapPack1) Write(dout *io.DataOutputX)

type HttpcMeter 

type HttpcMeter struct {
	TxMeter
}

func NewHttpcMeter 

func NewHttpcMeter() *HttpcMeter

func (*HttpcMeter) ToString 

func (this *HttpcMeter) ToString() string

type HttpcRec 

type HttpcRec struct {
	Url        int32
	Host       int32
	Port       int32
	CountTotal int32
	CountError int32
	//CountActived int32
	TimeSum int64
	TimeStd int64
	TimeMin int32
	TimeMax int32

	Service int32
}

func NewHttpcRec 

func NewHttpcRec() *HttpcRec

func (*HttpcRec) GetDeviation 

func (this *HttpcRec) GetDeviation() float64

func (*HttpcRec) KeyFull 

func (this *HttpcRec) KeyFull() *variable.I3

func (*HttpcRec) KeyHostPort 

func (this *HttpcRec) KeyHostPort() *variable.I2

func (*HttpcRec) Merge 

func (this *HttpcRec) Merge(o *HttpcRec)

func (*HttpcRec) Read 

func (this *HttpcRec) Read(in *io.DataInputX) *HttpcRec

func (*HttpcRec) SetUrlHostPort 

func (this *HttpcRec) SetUrlHostPort(url, host, port int32)

func (*HttpcRec) ToString 

func (this *HttpcRec) ToString() string

func (*HttpcRec) Write 

func (this *HttpcRec) Write(o *io.DataOutputX)

type LogSinkPack 

type LogSinkPack struct {
	AbstractPack

	Category string
	TagHash  int64
	Tags     *value.MapValue
	Line     int64
	Content  string
	Fields   *value.MapValue
}

func NewLogSinkPack 

func NewLogSinkPack() *LogSinkPack

func (*LogSinkPack) GetContent 

func (this *LogSinkPack) GetContent() string

func (*LogSinkPack) GetContentBytes 

func (this *LogSinkPack) GetContentBytes() []byte

func (*LogSinkPack) GetPackType 

func (this *LogSinkPack) GetPackType() int16

func (*LogSinkPack) GetTabAsBytes 

func (this *LogSinkPack) GetTabAsBytes() []byte

func (*LogSinkPack) Read 

func (this *LogSinkPack) Read(din *io.DataInputX)

func (*LogSinkPack) ResetTagHash 

func (this *LogSinkPack) ResetTagHash() []byte

func (*LogSinkPack) SetContent 

func (this *LogSinkPack) SetContent(str string)

func (*LogSinkPack) SetContentBytes 

func (this *LogSinkPack) SetContentBytes(d []byte)

func (*LogSinkPack) ToString 

func (this *LogSinkPack) ToString() string

func (*LogSinkPack) TransferOidToTag 

func (this *LogSinkPack) TransferOidToTag()

func (*LogSinkPack) Write 

func (this *LogSinkPack) Write(dout *io.DataOutputX)

type LogSinkZipPack added in v0.0.16 

type LogSinkZipPack struct {
	AbstractPack

	Records     []byte
	RecordCount int
	Status      byte
}

func NewLogSinkZipPack added in v0.0.16 

func NewLogSinkZipPack() *LogSinkZipPack

func (*LogSinkZipPack) GetPackType added in v0.0.16 

func (this *LogSinkZipPack) GetPackType() int16

func (*LogSinkZipPack) GetRecords added in v0.0.16 

func (this *LogSinkZipPack) GetRecords() []*LogSinkPack

func (*LogSinkZipPack) Read added in v0.0.16 

func (this *LogSinkZipPack) Read(din *io.DataInputX)

func (*LogSinkZipPack) SetRecords added in v0.0.16 

func (this *LogSinkZipPack) SetRecords(records []byte, zipMinSize int)

func (*LogSinkZipPack) ToString added in v0.0.16 

func (this *LogSinkZipPack) ToString() string

func (*LogSinkZipPack) Write added in v0.0.16 

func (this *LogSinkZipPack) Write(dout *io.DataOutputX)

type Memory 

type Memory interface {
	Write(dout *io.DataOutputX)
	Read(din *io.DataInputX)
}

################################################## MEMORY ELEMENT ##################################################

type MemoryLinux 

type MemoryLinux struct {
	Total      int64
	Free       int64
	Cached     int64
	Used       int64
	Pused      float32
	Available  int64
	Pavailable float32

	Buffers int64
	Shared  int64

	SwapUsed  int64
	SwapPused float32
	SwapTotal int64

	PageFault float32

	Slab         int64
	SReclaimable int64
	SUnreclaim   int64
}

func (*MemoryLinux) Read 

func (this *MemoryLinux) Read(dinx *io.DataInputX)

func (*MemoryLinux) Write 

func (this *MemoryLinux) Write(doutx *io.DataOutputX)

type MemoryWindow 

type MemoryWindow struct {
	Total             int64
	Free              int64
	Cached            int64
	Used              int64
	Pused             float32
	Available         int64
	Pavailable        float32
	PageFault         float32
	SwapUsed          int64
	SwapPused         float32
	SwapTotal         int64
	PoolPagedBytes    int64
	PoolNonpagedBytes int64
}

MemoryWindow MemoryWindow

func (*MemoryWindow) Read 

func (this *MemoryWindow) Read(dinx *io.DataInputX)

func (*MemoryWindow) Write 

func (this *MemoryWindow) Write(doutx *io.DataOutputX)

type NETSTAT 

type NETSTAT struct {
	Est  int32
	FinW int32
	TimW int32
	CloW int32
}

func NewNETSTAT 

func NewNETSTAT() *NETSTAT

type NetPerf 

type NetPerf struct {
	Desc       int32
	IP         []byte
	HwAddr     string
	TrafficIn  float64
	TrafficOut float64
	PacketIn   float64
	PacketOut  float64
	ErrorOut   float64
	ErrorIn    float64
	DroppedOut float64
	DroppedIn  float64
	Count      int32
}

func (*NetPerf) Read 

func (this *NetPerf) Read(in *io.DataInputX)

func (*NetPerf) Write 

func (this *NetPerf) Write(out *io.DataOutputX)

type Pack 

type Pack interface {
	GetPackType() int16
	Write(out *io.DataOutputX)
	Read(in *io.DataInputX)

	// OID, PCODE 설정을 위한 함수
	SetOID(oid int32)
	SetPCODE(pcode int64)
	GetPCODE() int64
	SetOKIND(okind int32)
	SetONODE(onode int32)

	// Time interface 추가
	GetTime() int64
	SetTime(t int64)
}

func CreatePack 

func CreatePack(t int16) Pack

func ReadPack 

func ReadPack(in *io.DataInputX) Pack

func ToPack 

func ToPack(b []byte) Pack

type ParamPack 

type ParamPack struct {
	AbstractPack
	Id int32

	Request  int64
	Response int64
	// contains filtered or unexported fields
}

func NewParamPack 

func NewParamPack() *ParamPack

func (*ParamPack) Clear 

func (this *ParamPack) Clear()

func (*ParamPack) Get 

func (this *ParamPack) Get(key string) val.Value

func (*ParamPack) GetLong 

func (this *ParamPack) GetLong(key string) int64

func (*ParamPack) GetMap 

func (this *ParamPack) GetMap(key string) *val.MapValue

func (*ParamPack) GetPackType 

func (this *ParamPack) GetPackType() int16

func (*ParamPack) GetString 

func (this *ParamPack) GetString(key string) string

func (*ParamPack) Keys 

func (this *ParamPack) Keys() hmap.StringEnumer

func (*ParamPack) Put 

func (this *ParamPack) Put(key string, value val.Value)

func (*ParamPack) PutLong 

func (this *ParamPack) PutLong(key string, value int64)

func (*ParamPack) PutString 

func (this *ParamPack) PutString(key string, value string)

func (*ParamPack) Read 

func (this *ParamPack) Read(din *io.DataInputX)

func (*ParamPack) SetMapValue 

func (this *ParamPack) SetMapValue(mapValue *val.MapValue) *ParamPack

func (*ParamPack) Size 

func (this *ParamPack) Size()

func (*ParamPack) ToResponse 

func (this *ParamPack) ToResponse() *ParamPack

func (*ParamPack) ToString 

func (this *ParamPack) ToString() string

func (*ParamPack) Write 

func (this *ParamPack) Write(dout *io.DataOutputX)

type ProcFilePerf 

type ProcFilePerf struct {
	FilePath int32
	Size     int64
}

func (*ProcFilePerf) Read 

func (this *ProcFilePerf) Read(in *io.DataInputX)

func (*ProcFilePerf) Write 

func (this *ProcFilePerf) Write(out *io.DataOutputX)

type ProcNetPerf 

type ProcNetPerf struct {
	IP    int32
	Port  int16
	Count int32
}

func (*ProcNetPerf) Read 

func (this *ProcNetPerf) Read(in *io.DataInputX)

func (*ProcNetPerf) Write 

func (this *ProcNetPerf) Write(out *io.DataOutputX)

type ProcPerf 

type ProcPerf struct {
	Ppid          int32
	Pid           int32
	Cpu           float32
	MemoryBytes   int64
	MemoryPercent float32
	ReadBps       float32
	WriteBps      float32
	Cmd1          int32
	Cmd2          int32
	ReadIops      float32
	WriteIops     float32

	User       int32
	State      int32
	CreateTime int64

	Group int64

	Net                 []ProcNetPerf
	File                []ProcFilePerf
	MemoryShared        int64
	OpenFileDescriptors int64
}

func (*ProcPerf) Read 

func (this *ProcPerf) Read(in *io.DataInputX)

func (*ProcPerf) Write 

func (this *ProcPerf) Write(out *io.DataOutputX)

type ProfilePack 

type ProfilePack struct {
	AbstractPack
	// DEBUG TxRecord
	//Transaction service.Service
	Transaction *service.TxRecord
	Steps       []byte
}

func NewProfilePack 

func NewProfilePack() *ProfilePack

func (*ProfilePack) GetPackType 

func (this *ProfilePack) GetPackType() int16

func (*ProfilePack) Read 

func (this *ProfilePack) Read(din *io.DataInputX)

func (*ProfilePack) SetProfile 

func (this *ProfilePack) SetProfile(steps []step.Step)

func (*ProfilePack) Write 

func (this *ProfilePack) Write(dout *io.DataOutputX)

type ProfileStepSplitPack added in v0.0.15 

type ProfileStepSplitPack struct {
	AbstractPack
	Txid  int64
	Inx   int
	Steps []byte
}

func NewProfileStepSplitPack added in v0.0.15 

func NewProfileStepSplitPack() *ProfileStepSplitPack

func (*ProfileStepSplitPack) GetPackType added in v0.0.15 

func (this *ProfileStepSplitPack) GetPackType() int16

func (*ProfileStepSplitPack) Read added in v0.0.15 

func (this *ProfileStepSplitPack) Read(din *io.DataInputX)

func (*ProfileStepSplitPack) SetProfile added in v0.0.15 

func (this *ProfileStepSplitPack) SetProfile(steps []step.Step) *ProfileStepSplitPack

func (*ProfileStepSplitPack) ToString added in v0.0.15 

func (this *ProfileStepSplitPack) ToString() string

func (*ProfileStepSplitPack) Write added in v0.0.15 

func (this *ProfileStepSplitPack) Write(dout *io.DataOutputX)

type RealtimeUserPack 

type RealtimeUserPack struct {
	AbstractPack
	Logbits []byte
}

func NewRealtimeUserPack 

func NewRealtimeUserPack() *RealtimeUserPack

func (*RealtimeUserPack) GetPackType 

func (this *RealtimeUserPack) GetPackType() int16

func (*RealtimeUserPack) Read 

func (this *RealtimeUserPack) Read(din *io.DataInputX)

func (*RealtimeUserPack) Write 

func (this *RealtimeUserPack) Write(dout *io.DataOutputX)

type SMBasePack 

type SMBasePack struct {
	AbstractPack
	IP        int32
	OS        int16
	Cpu       Cpu
	CpuCore   []Cpu
	Memory    Memory
	UpTime    int64
	EpochTime int64
}

################################################## SYSBASE PACK ##################################################

func NewSMBasePack 

func NewSMBasePack() *SMBasePack

func (*SMBasePack) GetPackType 

func (this *SMBasePack) GetPackType() int16

func (*SMBasePack) Read 

func (this *SMBasePack) Read(dinx *io.DataInputX)

func (*SMBasePack) Write 

func (this *SMBasePack) Write(doutx *io.DataOutputX)

type SMDiskPerfPack 

type SMDiskPerfPack struct {
	AbstractPack
	OS   int16
	Disk []DiskPerf
}

func NewSMDiskPerfPack 

func NewSMDiskPerfPack() *SMDiskPerfPack

func (*SMDiskPerfPack) GetPackType 

func (this *SMDiskPerfPack) GetPackType() int16

func (*SMDiskPerfPack) Read 

func (this *SMDiskPerfPack) Read(din *io.DataInputX)

func (*SMDiskPerfPack) Write 

func (this *SMDiskPerfPack) Write(dout *io.DataOutputX)

type SMDownCheckPack 

type SMDownCheckPack struct {
	AbstractPack

	Records     []byte
	RecordCount int32
	// contains filtered or unexported fields
}

func NewSMDownCheckPack 

func NewSMDownCheckPack() *SMDownCheckPack

func (*SMDownCheckPack) GetPackType 

func (this *SMDownCheckPack) GetPackType() int16

func (*SMDownCheckPack) GetRecords 

func (this *SMDownCheckPack) GetRecords() []*DownCheckRec

func (*SMDownCheckPack) Read 

func (this *SMDownCheckPack) Read(din *io.DataInputX)

func (*SMDownCheckPack) ReadRec 

func (this *SMDownCheckPack) ReadRec(in *io.DataInputX) *DownCheckRec

func (*SMDownCheckPack) SetRecords 

func (this *SMDownCheckPack) SetRecords(items []*DownCheckRec)

func (*SMDownCheckPack) Write 

func (this *SMDownCheckPack) Write(dout *io.DataOutputX)

func (*SMDownCheckPack) WriteRec 

func (this *SMDownCheckPack) WriteRec(o *io.DataOutputX, m *DownCheckRec)

type SMExtension 

type SMExtension struct {
	AbstractPack
	// contains filtered or unexported fields
}

func NewSMExtensionPack 

func NewSMExtensionPack() *SMExtension

func (*SMExtension) GetPackType 

func (this *SMExtension) GetPackType() int16

func (*SMExtension) Read 

func (this *SMExtension) Read(din *io.DataInputX)

func (*SMExtension) SetHeader 

func (this *SMExtension) SetHeader(header *value.IntMapValue)

func (*SMExtension) SetIsProjectwide 

func (this *SMExtension) SetIsProjectwide(isProjectwide bool)

func (*SMExtension) SetMetaValues 

func (this *SMExtension) SetMetaValues(values *value.IntMapValue)

func (*SMExtension) SetValues 

func (this *SMExtension) SetValues(values *value.IntMapValue)

func (*SMExtension) Write 

func (this *SMExtension) Write(dout *io.DataOutputX)

type SMLogEvent 

type SMLogEvent struct {
	EventSource byte
	Severity    byte
	FilePath    *string
	LogContent  *string

	WinLogFile    *string
	WinType       int32
	WinSourceName *string
	WinEventCode  int32
	WinCreateTime int64

	Keyword *string
	LogRule *string
}

func (*SMLogEvent) Read 

func (this *SMLogEvent) Read(in *io.DataInputX)

func (*SMLogEvent) Write 

func (this *SMLogEvent) Write(out *io.DataOutputX)

type SMLogEventPack 

type SMLogEventPack struct {
	AbstractPack
	LogEvent []SMLogEvent
}

func NewSMLogEventPack 

func NewSMLogEventPack() *SMLogEventPack

func (*SMLogEventPack) GetPackType 

func (this *SMLogEventPack) GetPackType() int16

func (*SMLogEventPack) Read 

func (this *SMLogEventPack) Read(din *io.DataInputX)

func (*SMLogEventPack) Write 

func (this *SMLogEventPack) Write(dout *io.DataOutputX)

type SMNetPerfPack 

type SMNetPerfPack struct {
	AbstractPack
	OS  int16
	Net []NetPerf
}

func NewSMNetPerfPack 

func NewSMNetPerfPack() *SMNetPerfPack

func (*SMNetPerfPack) GetPackType 

func (this *SMNetPerfPack) GetPackType() int16

func (*SMNetPerfPack) Read 

func (this *SMNetPerfPack) Read(din *io.DataInputX)

func (*SMNetPerfPack) Write 

func (this *SMNetPerfPack) Write(dout *io.DataOutputX)

type SMPingPack 

type SMPingPack struct {
	AbstractPack
	IP   int32
	OS   int16
	Core int16
}

################################################## SYSBASE PACK ##################################################

func NewSMPingPack 

func NewSMPingPack() *SMPingPack

func (*SMPingPack) GetPackType 

func (this *SMPingPack) GetPackType() int16

func (*SMPingPack) Read 

func (this *SMPingPack) Read(dinx *io.DataInputX)

func (*SMPingPack) Write 

func (this *SMPingPack) Write(doutx *io.DataOutputX)

type SMProcPerfPack 

type SMProcPerfPack struct {
	AbstractPack
	OS   int16
	Proc []ProcPerf
}

func NewSMProcPerfPack 

func NewSMProcPerfPack() *SMProcPerfPack

func (*SMProcPerfPack) GetPackType 

func (this *SMProcPerfPack) GetPackType() int16

func (*SMProcPerfPack) Read 

func (this *SMProcPerfPack) Read(din *io.DataInputX)

func (*SMProcPerfPack) Write 

func (this *SMProcPerfPack) Write(dout *io.DataOutputX)

type SMTCPPerfPack 

type SMTCPPerfPack struct {
	AbstractPack
	TCPPortPerf []TCPPortPerf
}

func NewSMTCPPerfPack 

func NewSMTCPPerfPack() *SMTCPPerfPack

func (*SMTCPPerfPack) GetPackType 

func (this *SMTCPPerfPack) GetPackType() int16

func (*SMTCPPerfPack) Read 

func (this *SMTCPPerfPack) Read(din *io.DataInputX)

func (*SMTCPPerfPack) Write 

func (this *SMTCPPerfPack) Write(dout *io.DataOutputX)

type ServerInfoPack added in v0.0.15 

type ServerInfoPack struct {
	AbstractPack

	Version    int32
	Host       string
	Port       int64
	ServerName string
	UpTime     int64
	Attr       *value.MapValue
	KeepTime   int64
}

func NewServerInfoPack added in v0.0.15 

func NewServerInfoPack() *ServerInfoPack

func (*ServerInfoPack) GetPackType added in v0.0.15 

func (this *ServerInfoPack) GetPackType() int16

func (*ServerInfoPack) Read added in v0.0.15 

func (this *ServerInfoPack) Read(din *io.DataInputX)

func (*ServerInfoPack) Write added in v0.0.15 

func (this *ServerInfoPack) Write(dout *io.DataOutputX)

type ServiceRec deprecated 

type ServiceRec struct {
	Hash            int32
	Profiled        bool
	Count           int32
	Error           int32
	Actived         int32
	TimeSum         int64
	TimeStd         int64
	TimeMin         int32
	TimeMax         int32
	SqlCount        int32
	SqlTime         int64
	SqlFetch        int32
	SqlFetchTime    int64
	SqlUpdateRecord int32
	SqlCommitCount  int32

	SqlSelect int32
	SqlUpdate int32
	SqlDelete int32
	SqlInsert int32
	SqlOthers int32

	HttpcCount int32
	HttpcTime  int64

	MallocSum int64
	CpuSum    int64

	Status200 int32
	Status300 int32
	Status400 int32
	Status500 int32

	SqlMap   *hmap.IntKeyMap
	HttpcMap *hmap.IntKeyMap
}

Deprecated: Use StatTransactionPack instead

func NewServiceRec 

func NewServiceRec() *ServiceRec

func ReadRec 

func ReadRec(in *io.DataInputX) *ServiceRec

func (*ServiceRec) Merge 

func (this *ServiceRec) Merge(o *ServiceRec)

func (*ServiceRec) SetUrlHash 

func (this *ServiceRec) SetUrlHash(hash int32) *ServiceRec

func (*ServiceRec) ToString 

func (this *ServiceRec) ToString() string

type SqlMeter 

type SqlMeter struct {
	TxMeter
	FetchCount int64
	FetchTime  int64
}

func NewSqlMeter 

func NewSqlMeter() *SqlMeter

func (*SqlMeter) ToString 

func (this *SqlMeter) ToString() string

type SqlRec 

type SqlRec struct {
	// int32
	Dbc int32
	// int32
	Sql int32
	// byte
	SqlCrud byte
	// int32
	CountTotal int32
	// int32
	CountError int32
	// int32
	//CountActived int32
	// int64
	TimeSum int64
	// int64
	TimeStd int64
	// int32
	TimeMin int32
	// int32
	TimeMax int32
	// int64
	FetchCount int64
	// int64
	FetchTime int64
	// int64
	UpdateCount int64

	Service int32
}

func NewSqlRec 

func NewSqlRec() *SqlRec

func (*SqlRec) GetDeviation 

func (this *SqlRec) GetDeviation() float64

func (*SqlRec) Key 

func (this *SqlRec) Key() int64

func (this *StatSqlPack) Key() int64 {

func (*SqlRec) Merge 

func (this *SqlRec) Merge(o SqlRec)

func (this *StatSqlPack) Merge(o SqlRec)

func (*SqlRec) Read 

func (this *SqlRec) Read(in *io.DataInputX) *SqlRec

func (*SqlRec) SetDbcSql 

func (this *SqlRec) SetDbcSql(dbc, sql int32) *SqlRec

func (this *StatSqlPack) SetDbcSql(dbc, sql int32) SqlRec {

func (*SqlRec) Write 

func (this *SqlRec) Write(o *io.DataOutputX)

type StatErrorPack 

type StatErrorPack struct {
	AbstractPack
	Records     []byte
	RecordCount int32
}

func NewStatErrorPack 

func NewStatErrorPack() *StatErrorPack

func (*StatErrorPack) GetPackType 

func (this *StatErrorPack) GetPackType() int16

func (*StatErrorPack) GetRecords 

func (this *StatErrorPack) GetRecords() []*ErrorRec

func (*StatErrorPack) Read 

func (this *StatErrorPack) Read(din *io.DataInputX)

func (*StatErrorPack) ReadRec 

func (this *StatErrorPack) ReadRec(in *io.DataInputX) *ErrorRec

func (*StatErrorPack) SetRecords 

func (this *StatErrorPack) SetRecords(size int, items hmap.Enumeration) *StatErrorPack

func (*StatErrorPack) SetRecordsArray 

func (this *StatErrorPack) SetRecordsArray(items []*ErrorRec)

func (*StatErrorPack) Write 

func (this *StatErrorPack) Write(dout *io.DataOutputX)

func (*StatErrorPack) WriteRec 

func (this *StatErrorPack) WriteRec(o *io.DataOutputX, m *ErrorRec)

type StatGeneralPack 

type StatGeneralPack struct {
	AbstractPack
	Id string
	// contains filtered or unexported fields
}

func NewStatGeneralPack 

func NewStatGeneralPack() *StatGeneralPack

func (*StatGeneralPack) Get 

func (this *StatGeneralPack) Get(key string) list.AnyList

func (*StatGeneralPack) GetDataTable 

func (this *StatGeneralPack) GetDataTable() *hmap.StringKeyLinkedMap

func (*StatGeneralPack) GetPackType 

func (this *StatGeneralPack) GetPackType() int16

func (*StatGeneralPack) IsEmpty 

func (this *StatGeneralPack) IsEmpty() bool

func (*StatGeneralPack) Iterate 

func (this *StatGeneralPack) Iterate(h func(a []string, b []list.AnyList, c int))

func (*StatGeneralPack) Put 

func (this *StatGeneralPack) Put(key string, data list.AnyList)

func (*StatGeneralPack) Read 

func (this *StatGeneralPack) Read(din *io.DataInputX)

func (*StatGeneralPack) Sort 

func (this *StatGeneralPack) Sort(sortKey string, asc bool)

func (*StatGeneralPack) SortAnyList 

func (this *StatGeneralPack) SortAnyList(sortKey string, asc bool, sortKey2 string, asc2 bool)

func (*StatGeneralPack) ToString 

func (this *StatGeneralPack) ToString() string

func (*StatGeneralPack) Write 

func (this *StatGeneralPack) Write(dout *io.DataOutputX)

type StatHttpcPack 

type StatHttpcPack struct {
	AbstractPack
	Records     []byte
	RecordCount int32
}

func NewStatHttpcPack 

func NewStatHttpcPack() *StatHttpcPack

func (*StatHttpcPack) GetPackType 

func (this *StatHttpcPack) GetPackType() int16

Implements Pack

func (*StatHttpcPack) GetRecords 

func (this *StatHttpcPack) GetRecords() *list.List

func (*StatHttpcPack) Read 

func (this *StatHttpcPack) Read(din *io.DataInputX)

func (*StatHttpcPack) SetRecords 

func (this *StatHttpcPack) SetRecords(size int, items hmap.Enumeration) *StatHttpcPack

func (*StatHttpcPack) SetRecordsList 

func (this *StatHttpcPack) SetRecordsList(items *list.List) *StatHttpcPack

func (*StatHttpcPack) ToString 

func (this *StatHttpcPack) ToString() string

func (*StatHttpcPack) Write 

func (this *StatHttpcPack) Write(dout *io.DataOutputX)

type StatRemoteIpPack 

type StatRemoteIpPack struct {
	AbstractPack
	IpTable *hmap.IntIntLinkedMap
}

func NewStatRemoteIpPack 

func NewStatRemoteIpPack() *StatRemoteIpPack

func (*StatRemoteIpPack) GetPackType 

func (this *StatRemoteIpPack) GetPackType() int16

func (*StatRemoteIpPack) Read 

func (this *StatRemoteIpPack) Read(din *io.DataInputX)

func (*StatRemoteIpPack) Write 

func (this *StatRemoteIpPack) Write(dout *io.DataOutputX)

type StatServicePack 

type StatServicePack struct {
	AbstractPack
	// [] byte
	Records []byte
	// int
	RecordCount int
}

func NewStatServicePack 

func NewStatServicePack() *StatServicePack

func (*StatServicePack) GetPackType 

func (this *StatServicePack) GetPackType() int16

func (*StatServicePack) Read 

func (this *StatServicePack) Read(din *io.DataInputX)

func (*StatServicePack) SetRecords 

func (this *StatServicePack) SetRecords(size int, items hmap.Enumeration) *StatServicePack

func (*StatServicePack) ToString 

func (this *StatServicePack) ToString() string

func (*StatServicePack) Write 

func (this *StatServicePack) Write(dout *io.DataOutputX)

func (*StatServicePack) WriteRec 

func (this *StatServicePack) WriteRec(o *io.DataOutputX, m *ServiceRec)

type StatSqlPack 

type StatSqlPack struct {
	AbstractPack
	// []byte
	Records []byte
	// int32
	RecordCount int32
}

func NewStatSqlPack 

func NewStatSqlPack() *StatSqlPack

func (*StatSqlPack) GetPackType 

func (this *StatSqlPack) GetPackType() int16

Implements Pack

func (*StatSqlPack) GetRecords 

func (this *StatSqlPack) GetRecords() *list.List

func (*StatSqlPack) Read 

func (this *StatSqlPack) Read(din *io.DataInputX)

func (*StatSqlPack) SetRecords 

func (this *StatSqlPack) SetRecords(size int, items hmap.Enumeration) *StatSqlPack

func (*StatSqlPack) SetRecordsList 

func (this *StatSqlPack) SetRecordsList(items *list.List) *StatSqlPack

TODO 테스트

func (*StatSqlPack) ToString 

func (this *StatSqlPack) ToString() string

func (*StatSqlPack) Write 

func (this *StatSqlPack) Write(dout *io.DataOutputX)

type StatTransactionPack 

type StatTransactionPack struct {
	AbstractPack
	// [] byte
	Records []byte
	// int
	RecordCount int

	// byte
	Version byte
}

func NewStatTransactionPack 

func NewStatTransactionPack() *StatTransactionPack

func (*StatTransactionPack) GetPackType 

func (this *StatTransactionPack) GetPackType() int16

func (*StatTransactionPack) GetRecords 

func (this *StatTransactionPack) GetRecords() *list.List

func (*StatTransactionPack) Read 

func (this *StatTransactionPack) Read(din *io.DataInputX)

func (*StatTransactionPack) SetRecords 

func (this *StatTransactionPack) SetRecords(size int, items hmap.Enumeration) *StatTransactionPack

func (*StatTransactionPack) SetRecordsList 

func (this *StatTransactionPack) SetRecordsList(items *list.List) *StatTransactionPack

func (*StatTransactionPack) ToString 

func (this *StatTransactionPack) ToString() string

func (*StatTransactionPack) Write 

func (this *StatTransactionPack) Write(dout *io.DataOutputX)

type StatTransactionPack1 

type StatTransactionPack1 struct {
	AbstractPack
	// [] byte
	Records []byte
	// int
	RecordCount int

	Spec int

	Version byte
}

func NewStatTransactionPack1 

func NewStatTransactionPack1() *StatTransactionPack1

func (*StatTransactionPack1) GetPackType 

func (this *StatTransactionPack1) GetPackType() int16

func (*StatTransactionPack1) GetRecords 

func (this *StatTransactionPack1) GetRecords() *list.List

func (*StatTransactionPack1) Read 

func (this *StatTransactionPack1) Read(din *io.DataInputX)

func (*StatTransactionPack1) SetRecords 

func (this *StatTransactionPack1) SetRecords(size int, items hmap.Enumeration) *StatTransactionPack1

func (*StatTransactionPack1) SetRecordsList 

func (this *StatTransactionPack1) SetRecordsList(items *list.List) *StatTransactionPack1

func (*StatTransactionPack1) ToString 

func (this *StatTransactionPack1) ToString() string

func (*StatTransactionPack1) Write 

func (this *StatTransactionPack1) Write(dout *io.DataOutputX)

type StatUserAgentPack 

type StatUserAgentPack struct {
	AbstractPack
	UserAgents *hmap.IntIntLinkedMap
}

func NewStatUserAgentPack 

func NewStatUserAgentPack() *StatUserAgentPack

func (*StatUserAgentPack) GetPackType 

func (this *StatUserAgentPack) GetPackType() int16

func (*StatUserAgentPack) Read 

func (this *StatUserAgentPack) Read(din *io.DataInputX)

func (*StatUserAgentPack) Write 

func (this *StatUserAgentPack) Write(dout *io.DataOutputX)

type TCPPortPerf 

type TCPPortPerf struct {
	Port    int32
	IsAlive bool
}

func (*TCPPortPerf) Read 

func (this *TCPPortPerf) Read(in *io.DataInputX)

func (*TCPPortPerf) Write 

func (this *TCPPortPerf) Write(out *io.DataOutputX)

type TagCountPack 

type TagCountPack struct {
	AbstractPack
	Category string

	Tags *value.MapValue
	Data *value.MapValue
	// contains filtered or unexported fields
}

func NewTagCountPack 

func NewTagCountPack() *TagCountPack

func (*TagCountPack) Clear 

func (this *TagCountPack) Clear()

func (*TagCountPack) Get 

func (this *TagCountPack) Get(name string) value.Value

func (*TagCountPack) GetFloat 

func (this *TagCountPack) GetFloat(name string) float64

func (*TagCountPack) GetLong 

func (this *TagCountPack) GetLong(name string) int64

func (*TagCountPack) GetPackType 

func (this *TagCountPack) GetPackType() int16

func (*TagCountPack) GetTag 

func (this *TagCountPack) GetTag(name string) string

func (*TagCountPack) GetTagHash added in v0.0.15 

func (this *TagCountPack) GetTagHash() int64

func (*TagCountPack) IsEmpty 

func (this *TagCountPack) IsEmpty() bool

func (*TagCountPack) Put 

func (this *TagCountPack) Put(name string, v interface{})

func (*TagCountPack) PutTag 

func (this *TagCountPack) PutTag(name, val string)

func (*TagCountPack) Read 

func (this *TagCountPack) Read(din *io.DataInputX)

func (*TagCountPack) Size 

func (this *TagCountPack) Size() int

func (*TagCountPack) ToString 

func (this *TagCountPack) ToString() string

func (*TagCountPack) Write 

func (this *TagCountPack) Write(dout *io.DataOutputX)

type TagLogPack 

type TagLogPack struct {
	AbstractPack
	Category string

	Tags   *value.MapValue
	Fields *value.MapValue
	// contains filtered or unexported fields
}

func NewTagLogPack 

func NewTagLogPack() *TagLogPack

func (*TagLogPack) Clear 

func (this *TagLogPack) Clear()

func (*TagLogPack) Get 

func (this *TagLogPack) Get(name string) value.Value

func (*TagLogPack) GetFloat 

func (this *TagLogPack) GetFloat(name string) float64

func (*TagLogPack) GetLong 

func (this *TagLogPack) GetLong(name string) int64

func (*TagLogPack) GetPackType 

func (this *TagLogPack) GetPackType() int16

func (*TagLogPack) GetTag 

func (this *TagLogPack) GetTag(name string) string

func (*TagLogPack) IsEmpty 

func (this *TagLogPack) IsEmpty() bool

func (*TagLogPack) Put 

func (this *TagLogPack) Put(name string, v interface{})

func (*TagLogPack) PutTag 

func (this *TagLogPack) PutTag(name, val string)

func (*TagLogPack) PutTagLong 

func (this *TagLogPack) PutTagLong(name string, val int64)

func (*TagLogPack) Read 

func (this *TagLogPack) Read(din *io.DataInputX)

func (*TagLogPack) Size 

func (this *TagLogPack) Size() int

func (*TagLogPack) ToString 

func (this *TagLogPack) ToString() string

func (*TagLogPack) Write 

func (this *TagLogPack) Write(dout *io.DataOutputX)

type TextPack 

type TextPack struct {
	AbstractPack
	// contains filtered or unexported fields
}

func NewTextPack 

func NewTextPack() *TextPack

func (*TextPack) AddText 

func (this *TextPack) AddText(text TextRec)

func (*TextPack) AddTexts 

func (this *TextPack) AddTexts(texts []TextRec)

func (*TextPack) GetPackType 

func (this *TextPack) GetPackType() int16

func (*TextPack) Read 

func (this *TextPack) Read(din *io.DataInputX)

func (*TextPack) Write 

func (this *TextPack) Write(dout *io.DataOutputX)

type TextRec 

type TextRec struct {
	Div  byte
	Hash int32
	Text string
}

type TimeCount 

type TimeCount struct {
	Count int32
	Error int32
	Time  int64
}

func NewTimeCount 

func NewTimeCount(count int32, err int32, time int64) *TimeCount

func NewTimeCountDefault 

func NewTimeCountDefault() *TimeCount

func (*TimeCount) Add 

func (this *TimeCount) Add(time int32, err bool)

func (*TimeCount) Copy 

func (this *TimeCount) Copy() *TimeCount

func (*TimeCount) Merge 

func (this *TimeCount) Merge(o *TimeCount)

func (*TimeCount) Read 

func (this *TimeCount) Read(in *io.DataInputX) *TimeCount

func (*TimeCount) Write 

func (this *TimeCount) Write(o *io.DataOutputX)

type TransactionRec 

type TransactionRec struct {
	Hash int32

	Profiled bool
	Count    int32
	Error    int32

	//Actived         int32
	TimeSum int64
	//TimeStd         int64
	//TimeMin         int32
	TimeMax int32

	SqlCount     int32
	SqlTime      int64
	SqlFetch     int32
	SqlFetchTime int64

	HttpcCount int32
	HttpcTime  int64

	MallocSum int64
	CpuSum    int64

	SqlMap   *hmap.IntKeyMap
	HttpcMap *hmap.IntKeyMap

	// ver3
	ApdexSatisfied int32
	ApdexTolerated int32

	// ver4
	TimeMin int32
	TimeStd int64
}

StatServicePack -> TransactionRec

func NewTransactionRec 

func NewTransactionRec() *TransactionRec

func ReadTransactionRec 

func ReadTransactionRec(in *io.DataInputX) *TransactionRec

func (*TransactionRec) Merge 

func (this *TransactionRec) Merge(o *TransactionRec)

func (*TransactionRec) MergeForStat 

func (this *TransactionRec) MergeForStat(o *TransactionRec)

func (*TransactionRec) SetUrlHash 

func (this *TransactionRec) SetUrlHash(hash int32) *TransactionRec

func (*TransactionRec) ToString 

func (this *TransactionRec) ToString() string

type TxMeter 

type TxMeter struct {
	Time  int64
	Count int32
	Error int32
	Actx  int32
	Acts  []int16
}

func NewTxMeter 

func NewTxMeter() *TxMeter

func (*TxMeter) ToString 

func (this *TxMeter) ToString() string

type WEBSOCKET 

type WEBSOCKET struct {
	Count int32
	In    int64
	Out   int64
}

func NewWEBSOCKET 

func NewWEBSOCKET() *WEBSOCKET

type ZipPack 

type ZipPack struct {
	AbstractPack

	Records     []byte
	RecordCount int
	Status      byte
}

func NewZipPack 

func NewZipPack() *ZipPack

func (*ZipPack) GetPackType 

func (this *ZipPack) GetPackType() int16

func (*ZipPack) GetRecords 

func (this *ZipPack) GetRecords() []Pack

func (*ZipPack) Read 

func (this *ZipPack) Read(din *io.DataInputX)

func (*ZipPack) SetRecords 

func (this *ZipPack) SetRecords(items []Pack) *ZipPack

func (*ZipPack) ToString 

func (this *ZipPack) ToString() string

func (*ZipPack) Write 

func (this *ZipPack) Write(dout *io.DataOutputX)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.