netdata

package
v0.9.3 Latest Latest
Warning

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

 Go to latest Published: Jan 16, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	XTYPE_WEB_SERVICE  XlogType = 0
	XTYPE_APP_SERVICE  XlogType = 1
	XTYPE_BACK_THREAD  XlogType = 2
	XTYPE_BACK_THREAD2 XlogType = 4
	XTYPE_ZIPKIN_SPAN  XlogType = 5
	XTYPE_UNKNOWN      XlogType = 99

	XLOG_DISCARD_NONE          XlogDiscardType = 1
	XLOG_DISCARD_ALL           XlogDiscardType = 2
	XLOG_DISCARD_PROFILE       XlogDiscardType = 3
	XLOG_DISCARD_ALL_FORCE     XlogDiscardType = 4
	XLOG_DISCARD_PROFILE_FORCE XlogDiscardType = 5
)
View Source 
const APICALL byte = 6
View Source 
const APICALL2 byte = 15
View Source 
const APICALL_SUM byte = 43
View Source 
const CONTROL byte = 99
View Source 
const DISPATCH byte = 13
View Source 
const DUMP byte = 12
View Source 
const HASHED_MESSAGE byte = 9
View Source 
const MESSAGE byte = 3
View Source 
const MESSAGE_SUM byte = 31
View Source 
const METHOD byte = 1
View Source 
const METHOD2 byte = 10
View Source 
const METHOD_SUM byte = 11
View Source 
const PARAMETERIZED_MESSAGE byte = 17
View Source 
const SOCKET byte = 5
View Source 
const SOCKET_SUM byte = 42
View Source 
const SPAN byte = 51
View Source 
const SPANCALL byte = 52
View Source 
const SQL byte = 2
View Source 
const SQL2 byte = 8
View Source 
const SQL3 byte = 16
View Source 
const SQL_SUM byte = 21
View Source 
const THREAD_CALL_POSSIBLE byte = 14
View Source 
const THREAD_SUBMIT byte = 7
View Source 
const TimeTypeFiveMin int8 = 3
View Source 
const TimeTypeRealTime int8 = 1

Variables

This section is empty.

Functions

func StepsToBytes 

func StepsToBytes(steps []Step) []byte

Types

type AlertLevel 

type AlertLevel uint8
const AlertError AlertLevel = 2
const AlertFatal AlertLevel = 3
const AlertInfo AlertLevel = 0
const AlertWarn AlertLevel = 1

type AlertPack 

type AlertPack struct {
	Time    int64
	ObjType string
	ObjHash int32
	Level   AlertLevel
	Title   string
	Message string
	Tags    *MapValue
}

AlertPack has text info

func NewAlertPack 

func NewAlertPack() *AlertPack

func (*AlertPack) GetPackType 

func (pack *AlertPack) GetPackType() byte

GetPackType returns pack type

func (*AlertPack) Read 

func (p *AlertPack) Read(in *DataInputX) (Pack, error)

func (*AlertPack) ToString 

func (pack *AlertPack) ToString() string

func (*AlertPack) Write 

func (p *AlertPack) Write(out *DataOutputX) error

type AsyncServiceStep 

type AsyncServiceStep struct {
	SingleStep
	Txid    int64
	Hash    int32
	Elapsed int32
}

func NewAsyncServiceStep 

func NewAsyncServiceStep() *AsyncServiceStep

func (*AsyncServiceStep) GetStepType 

func (s *AsyncServiceStep) GetStepType() byte

func (*AsyncServiceStep) Write 

func (s *AsyncServiceStep) Write(out *DataOutputX) error

type BooleanValue 

type BooleanValue struct {
	Value bool
}

BooleanValue has bool value

func NewBooleanEmptyValue 

func NewBooleanEmptyValue() *BooleanValue

NewBooleanEmptyValue return new BooleanVaue instance

func NewBooleanValue 

func NewBooleanValue(value bool) *BooleanValue

NewBooleanValue return new BooleanVaue instance

func (*BooleanValue) GetValueType 

func (booleanValue *BooleanValue) GetValueType() byte

GetValueType returns value type

func (*BooleanValue) Read 

func (booleanValue *BooleanValue) Read(in *DataInputX) (Value, error)

func (*BooleanValue) ToString 

func (booleanValue *BooleanValue) ToString() string

ToString returns converted string value from boolean value

func (*BooleanValue) Write 

func (booleanValue *BooleanValue) Write(out *DataOutputX) error

type DataInputX 

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

DataInputX is a byte buffer read stream struct

func NewDataInputX 

func NewDataInputX(any interface{}) *DataInputX

NewDataInputX returns DataInputX instace

func (*DataInputX) ReadBoolean 

func (in *DataInputX) ReadBoolean() (bool, error)

ReadBoolean reads bool value

func (*DataInputX) ReadDecimal 

func (in *DataInputX) ReadDecimal() (int64, error)

ReadDecimal returns number value

func (*DataInputX) ReadFloat32 

func (in *DataInputX) ReadFloat32() (float32, error)

ReadFloat32 returns float32 value

func (*DataInputX) ReadInt16 

func (in *DataInputX) ReadInt16() (int16, error)

ReadInt16 returns int16 value

func (*DataInputX) ReadInt32 

func (in *DataInputX) ReadInt32() (int32, error)

ReadInt32 returns int16 value

func (*DataInputX) ReadInt64 

func (in *DataInputX) ReadInt64() (int64, error)

ReadInt64 returns int16 value

func (*DataInputX) ReadInt8 

func (in *DataInputX) ReadInt8() (int8, error)

ReadInt8 returns int8 value

func (*DataInputX) ReadIntBytes 

func (in *DataInputX) ReadIntBytes() ([]byte, error)

func (*DataInputX) ReadPack 

func (in *DataInputX) ReadPack() (Pack, error)

func (*DataInputX) ReadString 

func (in *DataInputX) ReadString() (string, error)

ReadString returns string value

func (*DataInputX) ReadUInt8 

func (in *DataInputX) ReadUInt8() (uint8, error)

func (*DataInputX) ReadValue 

func (in *DataInputX) ReadValue() (Value, error)

ReadValue reads value from datainputx

type DataOutputX 

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

A DataOutputX is a output stream which used write various kinds of data.

func NewDataOutputX 

func NewDataOutputX(any interface{}) *DataOutputX

NewDataOutputX returns DataOutputX object

func (*DataOutputX) Bytes 

func (out *DataOutputX) Bytes() []byte

Bytes returns buffer's bytes

func (*DataOutputX) GetWriteSize 

func (out *DataOutputX) GetWriteSize() int32

GetWriteSize returns written size

func (*DataOutputX) Size 

func (out *DataOutputX) Size() int32

Size returns written size

func (*DataOutputX) Write 

func (out *DataOutputX) Write(value []byte) error

func (*DataOutputX) WriteBlob 

func (out *DataOutputX) WriteBlob(value []byte) error

WriteBlob writes byte array to buffer

func (*DataOutputX) WriteBoolean 

func (out *DataOutputX) WriteBoolean(value bool) (*DataOutputX, error)

WriteBoolean write bool valvue to buffer

func (*DataOutputX) WriteDecimal 

func (out *DataOutputX) WriteDecimal(value int64) (*DataOutputX, error)

WriteDecimal writes number type value to buffer

func (*DataOutputX) WriteDecimal32 

func (out *DataOutputX) WriteDecimal32(value int32) (*DataOutputX, error)

func (*DataOutputX) WriteFloat32 

func (out *DataOutputX) WriteFloat32(value float32) (*DataOutputX, error)

WriteFloat32 writes float32 value to buffer

func (*DataOutputX) WriteInt16 

func (out *DataOutputX) WriteInt16(value int16) (*DataOutputX, error)

WriteInt16 write int16 number to buffer.

func (*DataOutputX) WriteInt32 

func (out *DataOutputX) WriteInt32(value int32) (*DataOutputX, error)

WriteInt32 write int32 number to buffer.

func (*DataOutputX) WriteInt32Array 

func (out *DataOutputX) WriteInt32Array(values []int32) (*DataOutputX, error)

func (*DataOutputX) WriteInt64 

func (out *DataOutputX) WriteInt64(value int64) (*DataOutputX, error)

WriteInt64 write int64 number to buffer.

func (*DataOutputX) WriteInt8 

func (out *DataOutputX) WriteInt8(value int8) (*DataOutputX, error)

WriteInt8 write int8 number to buffer

func (*DataOutputX) WriteIntBytes 

func (out *DataOutputX) WriteIntBytes(value []byte) error

func (*DataOutputX) WritePack 

func (out *DataOutputX) WritePack(pack Pack) (*DataOutputX, error)

func (*DataOutputX) WriteStep 

func (out *DataOutputX) WriteStep(step Step) (*DataOutputX, error)

func (*DataOutputX) WriteString 

func (out *DataOutputX) WriteString(value string) (*DataOutputX, error)

WriteString writes string value to buffer

func (*DataOutputX) WriteUInt64 

func (out *DataOutputX) WriteUInt64(value uint64) (*DataOutputX, error)

WriteUInt64 write uint64 number to buffer.

func (*DataOutputX) WriteUInt8 

func (out *DataOutputX) WriteUInt8(value uint8) (*DataOutputX, error)

WriteUInt8 write int8 number to buffer

func (*DataOutputX) WriteValue 

func (out *DataOutputX) WriteValue(value Value) (*DataOutputX, error)

WriteValue wtires value type to buffer

type DecimalValue 

type DecimalValue struct {
	Value int64
}

DecimalValue struct has number value

func NewDecimalEmptyValue 

func NewDecimalEmptyValue() *DecimalValue

NewDecimalEmptyValue return DeciamlValue instance

func NewDecimalValue 

func NewDecimalValue(value int64) *DecimalValue

NewDecimalValue return DeciamlValue instance

func (*DecimalValue) GetValueType 

func (decimalValue *DecimalValue) GetValueType() byte

GetValueType returns value type

func (*DecimalValue) Read 

func (decimalValue *DecimalValue) Read(in *DataInputX) (Value, error)

Read function reads a value from datainputx

func (*DecimalValue) ToString 

func (decimalValue *DecimalValue) ToString() string

ToString returns converted string value from decimal value

func (*DecimalValue) Write 

func (decimalValue *DecimalValue) Write(out *DataOutputX) error

Write function writes a number value to dataoutputx

type DumpStep 

type DumpStep struct {
	SingleStep
	Stacks []int32
	// contains filtered or unexported fields
}

func NewDumpStep 

func NewDumpStep() *DumpStep

func (*DumpStep) GetStepType 

func (s *DumpStep) GetStepType() byte

func (*DumpStep) Write 

func (s *DumpStep) Write(out *DataOutputX) error

type Float32Value 

type Float32Value struct {
	Value float32
}

Float32Value has float32 value

func NewFloatEmptyValue 

func NewFloatEmptyValue() *Float32Value

NewFloatEmptyValue returns new FloatValue instance

func NewFloatValue 

func NewFloatValue(value float32) *Float32Value

NewFloatValue returns new FloatValue instance

func (*Float32Value) GetValueType 

func (floatValue *Float32Value) GetValueType() byte

GetValueType returns value type

func (*Float32Value) Read 

func (floatValue *Float32Value) Read(in *DataInputX) (Value, error)

Read function reads a value from datainputx

func (*Float32Value) ToString 

func (floatValue *Float32Value) ToString() string

ToString returns converted float value

func (*Float32Value) Write 

func (floatValue *Float32Value) Write(out *DataOutputX) error

Write function write a float value to dataoutputx

type HashedMessageStep 

type HashedMessageStep struct {
	SingleStep
	Hash  int32
	Time  int32
	Value int32
}

func NewHashedMessageStep 

func NewHashedMessageStep(hash int32, startTime int32) *HashedMessageStep

func (*HashedMessageStep) GetStepType 

func (s *HashedMessageStep) GetStepType() byte

func (*HashedMessageStep) Write 

func (s *HashedMessageStep) Write(out *DataOutputX) error

type ListValue 

type ListValue struct {
	Value []Value
}

ListValue has Value type Slice

func NewListValue 

func NewListValue() *ListValue

NewListValue returns new ListVaue instance

func NewListValueWithValue 

func NewListValueWithValue(value []Value) *ListValue

NewListValueWithValue returns new ListVaue instance

func (*ListValue) Add 

func (listValue *ListValue) Add(value Value) *ListValue

Add function adds a value to slice

func (*ListValue) AddBoolean 

func (listValue *ListValue) AddBoolean(value bool) *ListValue

AddString add a string value to slice

func (*ListValue) AddFloat 

func (listValue *ListValue) AddFloat(value float32) *ListValue

AddFloat add a float value to slice

func (*ListValue) AddInt32 

func (listValue *ListValue) AddInt32(value int32) *ListValue

AddInt32 adds a int64 value to slice

func (*ListValue) AddInt64 

func (listValue *ListValue) AddInt64(value int64) *ListValue

AddInt64 adds a int64 value to slice

func (*ListValue) AddString 

func (listValue *ListValue) AddString(value string) *ListValue

AddString add a string value to slice

func (*ListValue) GetBoolean 

func (listValue *ListValue) GetBoolean(i int) bool

GetBoolean returns bool value

func (*ListValue) GetFloat 

func (listValue *ListValue) GetFloat(i int) float32

GetFloat returns float value

func (*ListValue) GetInt32 

func (listValue *ListValue) GetInt32(i int) int32

GetInt32 returns int32 value

func (*ListValue) GetInt64 

func (listValue *ListValue) GetInt64(i int) int64

GetInt64 returns int64 value

func (*ListValue) GetString 

func (listValue *ListValue) GetString(i int) string

GetString returns string value

func (*ListValue) GetValueType 

func (listValue *ListValue) GetValueType() byte

GetValueType returns value type

func (*ListValue) Read 

func (listValue *ListValue) Read(in *DataInputX) (Value, error)

Read function reads value from datainputx

func (*ListValue) Size 

func (listValue *ListValue) Size() int

Size retunrs slice's size

func (*ListValue) ToString 

func (listValue *ListValue) ToString() string

ToString returns converted string value

func (*ListValue) Write 

func (listValue *ListValue) Write(out *DataOutputX) error

Write function writes list value to outputx

type MapPack 

type MapPack struct {
	Table map[string]Value
}

func NewMapPack 

func NewMapPack() *MapPack

func (*MapPack) ContainsKey 

func (mapPack *MapPack) ContainsKey(key string) bool

ContainsKey returns whether mapvalue contains value for given key

func (*MapPack) GetBoolean 

func (mapPack *MapPack) GetBoolean(key string) bool

GetBoolean returns string value

func (*MapPack) GetInt16 

func (mapPack *MapPack) GetInt16(key string) int16

GetInt16 returns int16 value

func (*MapPack) GetInt32 

func (mapPack *MapPack) GetInt32(key string) int32

GetInt32 returns int32 value

func (*MapPack) GetInt64 

func (mapPack *MapPack) GetInt64(key string) int64

GetInt64 returns int64 value

func (*MapPack) GetInt8 

func (mapPack *MapPack) GetInt8(key string) int8

GetInt8 returns int8 value

func (*MapPack) GetPackType 

func (mapPack *MapPack) GetPackType() byte

GetValueType returns value type

func (*MapPack) GetString 

func (mapPack *MapPack) GetString(key string) string

GetString returns string value

func (*MapPack) IsEmpty 

func (mapPack *MapPack) IsEmpty() bool

func (*MapPack) NewList 

func (mapPack *MapPack) NewList(key string) *ListValue

func (*MapPack) Put 

func (mapPack *MapPack) Put(key string, any interface{})

Put add string value to map

func (*MapPack) Read 

func (mapPack *MapPack) Read(in *DataInputX) (Pack, error)

Read will reads a value from datainputx

func (*MapPack) ToString 

func (mapPack *MapPack) ToString() string

ToString returns converted string map data

func (*MapPack) Write 

func (mapPack *MapPack) Write(out *DataOutputX) error

Write function write a text value to dataoutputx

type MapValue 

type MapValue struct {
	Table map[string]Value
}

MapValue has map data

func NewMapValue 

func NewMapValue() *MapValue

NewMapValue returns new MapValue instance

func (*MapValue) ContainesKey 

func (mapValue *MapValue) ContainesKey(key string) bool

ContainesKey returns whether mapvalue contains value for given key

func (*MapValue) GetBoolean 

func (mapValue *MapValue) GetBoolean(key string) bool

GetBoolean returns string value

func (*MapValue) GetInt16 

func (mapValue *MapValue) GetInt16(key string) int16

GetInt16 returns int16 value

func (*MapValue) GetInt32 

func (mapValue *MapValue) GetInt32(key string) int32

GetInt32 returns int32 value

func (*MapValue) GetInt64 

func (mapValue *MapValue) GetInt64(key string) int64

GetInt64 returns int64 value

func (*MapValue) GetInt8 

func (mapValue *MapValue) GetInt8(key string) int8

GetInt8 returns int8 value

func (*MapValue) GetString 

func (mapValue *MapValue) GetString(key string) string

GetString returns string value

func (*MapValue) GetValueType 

func (mapValue *MapValue) GetValueType() byte

GetValueType returns value type

func (*MapValue) IsEmpty 

func (mapValue *MapValue) IsEmpty() bool

IsEmpty return whether mapvalue is empty or not

func (*MapValue) Put 

func (mapValue *MapValue) Put(key string, any interface{})

Put add string value to map

func (*MapValue) Read 

func (mapValue *MapValue) Read(in *DataInputX) (Value, error)

Read will reads a value from datainputx

func (*MapValue) ToString 

func (mapValue *MapValue) ToString() string

ToString returns converted string map data

func (*MapValue) Write 

func (mapValue *MapValue) Write(out *DataOutputX) error

Write function write a text value to dataoutputx

type MessageStep 

type MessageStep struct {
	SingleStep
	Message string
}

func NewMessageStep 

func NewMessageStep(m string, startTime int32) *MessageStep

func (*MessageStep) GetStepType 

func (s *MessageStep) GetStepType() byte

func (*MessageStep) Write 

func (s *MessageStep) Write(out *DataOutputX) error

type MethodStep 

type MethodStep struct {
	SingleStep
	Hash    int32
	Elapsed int32
	CpuTime int32
}

func NewMethodStep 

func NewMethodStep() *MethodStep

func (*MethodStep) GetStepType 

func (s *MethodStep) GetStepType() byte

func (*MethodStep) Write 

func (s *MethodStep) Write(out *DataOutputX) error

type NilValue 

type NilValue struct {
	Value interface{}
}

NilValue has nil value

func NewNilValue 

func NewNilValue() *NilValue

NewNilValue returns new NilValue instance

func (*NilValue) GetValueType 

func (nilValue *NilValue) GetValueType() byte

GetValueType returns value type

func (*NilValue) Read 

func (nilValue *NilValue) Read(in *DataInputX) (Value, error)

Read return nil value

func (*NilValue) ToString 

func (nilValue *NilValue) ToString() string

ToString returns null string

func (*NilValue) Write 

func (nilValue *NilValue) Write(out *DataOutputX) error

Write wrtire nil value to output

type ObjectPack 

type ObjectPack struct {
	ObjType string
	ObjHash int32
	ObjName string
	Address string
	Version string
	Alive   bool
	Wakeup  int64
	Tags    *MapValue
}

ObjectPack has object info

func NewObjectPack 

func NewObjectPack() *ObjectPack

NewObjectPack returns new object pack instance

func (*ObjectPack) GetPackType 

func (objectPack *ObjectPack) GetPackType() byte

GetPackType returns pack type

func (*ObjectPack) Read 

func (objectPack *ObjectPack) Read(in *DataInputX) (Pack, error)

func (*ObjectPack) SetStatus 

func (objectPack *ObjectPack) SetStatus(status int)

func (*ObjectPack) ToString 

func (objectPack *ObjectPack) ToString() string

ToString returns objectpack2 info

func (*ObjectPack) Write 

func (objectPack *ObjectPack) Write(out *DataOutputX) error

type ObjectPack2 

type ObjectPack2 struct {
	SiteID  string
	ObjType string
	ObjHash int32
	ObjName string
	Address string
	Version string
	Alive   bool
	Wakeup  int64
	Family  int8
	Tags    *MapValue
}

ObjectPack2 has object info

func NewObjectPack2 

func NewObjectPack2() *ObjectPack2

NewObjectPack2 returns new object pack instance

func (*ObjectPack2) GetPackType 

func (objectPack *ObjectPack2) GetPackType() byte

GetPackType returns pack type

func (*ObjectPack2) Read 

func (objectPack *ObjectPack2) Read(in *DataInputX) (Pack, error)

func (*ObjectPack2) SetStatus 

func (objectPack *ObjectPack2) SetStatus(status int)

func (*ObjectPack2) ToString 

func (objectPack *ObjectPack2) ToString() string

ToString returns objectpack2 info

func (*ObjectPack2) Write 

func (objectPack *ObjectPack2) Write(out *DataOutputX) error

type PMessageLevel 

type PMessageLevel byte
const PMSG_DEBUG PMessageLevel = 0
const PMSG_ERROR PMessageLevel = 3
const PMSG_FATAL PMessageLevel = 4
const PMSG_INFO PMessageLevel = 1
const PMSG_WARN PMessageLevel = 2

type PMessageStep 

type PMessageStep struct {
	SingleStep
	Hash    int32
	Elapsed int32
	Level   PMessageLevel
	// contains filtered or unexported fields
}

func NewPMessageStep 

func NewPMessageStep(startTime int32) *PMessageStep

func (*PMessageStep) GetStepType 

func (s *PMessageStep) GetStepType() byte

func (*PMessageStep) SetMessage 

func (s *PMessageStep) SetMessage(hash int32, params ...string)

func (*PMessageStep) Write 

func (s *PMessageStep) Write(out *DataOutputX) error

type Pack 

type Pack interface {
	Write(out *DataOutputX) error
	Read(in *DataInputX) (Pack, error)
	ToString() string
	GetPackType() byte
}

Pack is a interface

func CreatePack 

func CreatePack(packType byte) Pack

CreateValue return Value instacne

type PerfCounterK8SPack 

type PerfCounterK8SPack struct {
	Time           int64
	SiteID         string
	Cluster        string
	NameSpace      string
	NodeName       string
	DaemonSetName  string
	DeploymentName string
	PodName        string
	ContainerName  string
	ObjName        string
	Timetype       int8
	MetricLevel    int8
	Data           *MapValue
}

PerfCounterPack has metric counter which has key/value type

func NewPerfCounterK8SPack 

func NewPerfCounterK8SPack() *PerfCounterK8SPack

NewPerfCounterPack returns PerfCounterPack instance

func (*PerfCounterK8SPack) GetPackType 

func (pack *PerfCounterK8SPack) GetPackType() byte

GetPackType returns pack type

func (*PerfCounterK8SPack) Put 

func (pack *PerfCounterK8SPack) Put(key string, any interface{})

Put will put key/value to PerfCounterPack

func (*PerfCounterK8SPack) Read 

func (pack *PerfCounterK8SPack) Read(in *DataInputX) (Pack, error)

Read will read PerfCounterPack from datainputx

func (*PerfCounterK8SPack) ToString 

func (pack *PerfCounterK8SPack) ToString() string

ToString returns converted perfcounterpack value

func (*PerfCounterK8SPack) Write 

func (pack *PerfCounterK8SPack) Write(out *DataOutputX) error

Write will write PerfCounterPack to datoutputx

type PerfCounterPack 

type PerfCounterPack struct {
	Time     int64
	ObjName  string
	Timetype int8
	Data     *MapValue
}

PerfCounterPack has metric counter which has key/value type

func NewPerfCounterPack 

func NewPerfCounterPack() *PerfCounterPack

NewPerfCounterPack returns PerfCounterPack instance

func (*PerfCounterPack) GetPackType 

func (pack *PerfCounterPack) GetPackType() byte

GetPackType returns pack type

func (*PerfCounterPack) Put 

func (pack *PerfCounterPack) Put(key string, any interface{})

Put will put key/value to PerfCounterPack

func (*PerfCounterPack) Read 

func (pack *PerfCounterPack) Read(in *DataInputX) (Pack, error)

Read will read PerfCounterPack from datainputx

func (*PerfCounterPack) ToString 

func (pack *PerfCounterPack) ToString() string

ToString returns converted perfcounterpack value

func (*PerfCounterPack) Write 

func (pack *PerfCounterPack) Write(out *DataOutputX) error

Write will write PerfCounterPack to datoutputx

type SingleStep 

type SingleStep struct {
	Parent    int32
	Index     int32
	StartTime int32
}

func (*SingleStep) GetOrder 

func (ss *SingleStep) GetOrder() int32

func (*SingleStep) GetParent 

func (ss *SingleStep) GetParent() int32

func (*SingleStep) GetStepType 

func (ss *SingleStep) GetStepType() byte

func (*SingleStep) Read 

func (ss *SingleStep) Read(in *DataInputX) (Step, error)

func (*SingleStep) SetIndex 

func (ss *SingleStep) SetIndex(index int32)

func (*SingleStep) SetParent 

func (ss *SingleStep) SetParent(parent int32)

func (*SingleStep) Write 

func (ss *SingleStep) Write(out *DataOutputX) error

type Step 

type Step interface {
	GetOrder() int32
	GetStepType() byte
	Write(out *DataOutputX) error
	Read(in *DataInputX) (Step, error)

	SetIndex(index int32)
	SetParent(parent int32)
	GetParent() int32
}

type TextPack 

type TextPack struct {
	Xtype texttype.TextType
	Hash  int32
	Text  string
}

TextPack has text info

func NewTextPack 

func NewTextPack() *TextPack

func (*TextPack) GetPackType 

func (pack *TextPack) GetPackType() byte

GetPackType returns pack type

func (*TextPack) Read 

func (p *TextPack) Read(in *DataInputX) (Pack, error)

func (*TextPack) ToString 

func (pack *TextPack) ToString() string

func (*TextPack) Write 

func (p *TextPack) Write(out *DataOutputX) error

type TextValue 

type TextValue struct {
	Value string
}

TextValue contains string value

func NewTextEmptyValue 

func NewTextEmptyValue() *TextValue

NewTextEmptyValue returns TextValue instance

func NewTextValue 

func NewTextValue(value string) *TextValue

NewTextValue returns TextValue instance

func (*TextValue) GetValueType 

func (textValue *TextValue) GetValueType() byte

GetValueType returns value type

func (*TextValue) Read 

func (textValue *TextValue) Read(in *DataInputX) (Value, error)

Read function reads a value from datainputx

func (*TextValue) ToString 

func (textValue *TextValue) ToString() string

ToString returns value

func (*TextValue) Write 

func (textValue *TextValue) Write(out *DataOutputX) error

Write function write a text value to dataoutputx

type Value 

type Value interface {
	Write(out *DataOutputX) error
	Read(in *DataInputX) (Value, error)
	GetValueType() byte
	ToString() string
}

Value is interface for all value type

func CreateValue 

func CreateValue(valueType byte) Value

CreateValue return Value instacne

type XlogDiscardType 

type XlogDiscardType uint8

type XlogPack 

type XlogPack struct {
	EndTime int64
	ObjHash int32

	Service int32

	Txid           int64
	ThreadNameHash int32
	Caller         int64
	Gxid           int64

	Elapsed int32

	Error    int32
	Cpu      int32
	SqlCount int32
	SqlTime  int32
	Ipaddr   []byte
	Kbytes   int32
	Status   int32
	Userid   int64

	UserAgent int32
	Referer   int32
	Group     int32

	ApicallCount int32
	ApicallTime  int32

	CountryCode string
	City        int32

	XType XlogType

	Login int32
	Desc  int32

	WebHash int32
	WebTime int32

	HasDump byte

	Text1 string
	Text2 string

	QueuingHostHash    int32
	QueuingTime        int32
	Queuing2ndHostHash int32
	Queuing2ndTime     int32

	Text3 string
	Text4 string
	Text5 string

	ProfileCount                   int32
	B3Mode                         bool
	ProfileSize                    int32
	DiscardType                    XlogDiscardType
	IgnoreGlobalConsequentSampling bool
}

XlogPack has xlog info

func NewXlogPack 

func NewXlogPack() *XlogPack

func (*XlogPack) GetPackType 

func (pack *XlogPack) GetPackType() byte

GetPackType returns pack type

func (*XlogPack) IsDriving 

func (p *XlogPack) IsDriving() bool

func (*XlogPack) Read 

func (p *XlogPack) Read(in *DataInputX) (Pack, error)

func (*XlogPack) ToString 

func (pack *XlogPack) ToString() string

func (*XlogPack) Write 

func (p *XlogPack) Write(out *DataOutputX) error

type XlogProfilePack 

type XlogProfilePack struct {
	Time    int64
	ObjHash int32
	Service int32
	Txid    int64
	Elapsed int32
	Profile []byte
}

func NewXlogProfilePack 

func NewXlogProfilePack() *XlogProfilePack

func (*XlogProfilePack) GetPackType 

func (pack *XlogProfilePack) GetPackType() byte

func (*XlogProfilePack) Read 

func (p *XlogProfilePack) Read(in *DataInputX) (Pack, error)

func (*XlogProfilePack) ToString 

func (pack *XlogProfilePack) ToString() string

func (*XlogProfilePack) Write 

func (p *XlogProfilePack) Write(out *DataOutputX) error

type XlogType 

type XlogType uint8

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.