message

package
v0.0.0-...-34dcc44 Latest Latest
Warning

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

 Go to latest Published: Aug 13, 2021 License: Apache-2.0 Imports: 6 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	ReadableProtocol = "PT1"
	BinaryProtocol   = "NT1"
)
View Source 
const (
	CatSuccess = "0"
	CatError   = "-1"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type BinaryEncoder 

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

func NewBinaryEncoder 

func NewBinaryEncoder() *BinaryEncoder

func (*BinaryEncoder) EncodeEvent 

func (e *BinaryEncoder) EncodeEvent(buf *bytes.Buffer, m *Event) (err error)

func (*BinaryEncoder) EncodeHeader 

func (e *BinaryEncoder) EncodeHeader(buf *bytes.Buffer, header *Header) (err error)

func (*BinaryEncoder) EncodeHeartbeat 

func (e *BinaryEncoder) EncodeHeartbeat(buf *bytes.Buffer, m *Heartbeat) (err error)

func (*BinaryEncoder) EncodeMessage 

func (e *BinaryEncoder) EncodeMessage(buf *bytes.Buffer, message Messager) (err error)

func (*BinaryEncoder) EncodeMetric 

func (e *BinaryEncoder) EncodeMetric(buf *bytes.Buffer, m *Metric) (err error)

func (*BinaryEncoder) EncodeTransaction 

func (e *BinaryEncoder) EncodeTransaction(buf *bytes.Buffer, trans *Transaction) (err error)

type Encoder 

type Encoder interface {
	EncodeHeader(*bytes.Buffer, *Header) error
	EncodeMessage(*bytes.Buffer, Messager) error
	EncodeTransaction(*bytes.Buffer, *Transaction) error
	EncodeEvent(*bytes.Buffer, *Event) error
	EncodeHeartbeat(*bytes.Buffer, *Heartbeat) error
	EncodeMetric(*bytes.Buffer, *Metric) error
}

type Event 

type Event struct {
	Message
}

func NewEvent 

func NewEvent(mtype, name string, flush Flush, initHeader InitHeader) *Event

func (*Event) Complete 

func (e *Event) Complete()

type Flush 

type Flush func(m Messager)
type Header struct {
	Domain   string
	Hostname string
	Ip       string

	MessageId       string
	ParentMessageId string
	RootMessageId   string
}

type Heartbeat 

type Heartbeat struct {
	Message
}

func NewHeartbeat 

func NewHeartbeat(mtype, name string, flush Flush, initHeader InitHeader) *Heartbeat

func (*Heartbeat) Complete 

func (e *Heartbeat) Complete()

type InitHeader 

type InitHeader func(m Messager)

初始化header 信息

type Message 

type Message struct {
	Type   string
	Name   string
	Status string

	Header *Header
	// contains filtered or unexported fields
}

func NewMessage 

func NewMessage(mtype, name string, flush Flush, initHeader InitHeader) Message

func (*Message) AddData 

func (m *Message) AddData(k string, v ...string)

func (*Message) Complete 

func (m *Message) Complete()

func (*Message) GetData 

func (m *Message) GetData() *bytes.Buffer

func (*Message) GetDomain 

func (m *Message) GetDomain() (domain string)

func (*Message) GetFlushStatus 

func (t *Message) GetFlushStatus() bool

func (*Message) GetHeader 

func (m *Message) GetHeader() (header *Header)

func (*Message) GetHostname 

func (m *Message) GetHostname() (hostname string)

func (*Message) GetIp 

func (m *Message) GetIp() (messageId string)

func (*Message) GetMessageId 

func (m *Message) GetMessageId() (messageId string)

func (*Message) GetName 

func (m *Message) GetName() string

func (*Message) GetParentMessageId 

func (m *Message) GetParentMessageId() (parentMessageId string)

func (*Message) GetRootMessageId 

func (m *Message) GetRootMessageId() (rootMessageId string)

func (*Message) GetStatus 

func (m *Message) GetStatus() string

func (*Message) GetTime 

func (m *Message) GetTime() time.Time

func (*Message) GetType 

func (m *Message) GetType() string

func (*Message) SetData 

func (m *Message) SetData(v string)

func (*Message) SetDomain 

func (m *Message) SetDomain(domain string)

func (*Message) SetFlushStatus 

func (t *Message) SetFlushStatus(flushStatus bool)

func (*Message) SetHeader 

func (m *Message) SetHeader(header *Header)

func (*Message) SetHostname 

func (m *Message) SetHostname(hostname string)

func (*Message) SetIp 

func (m *Message) SetIp(ip string)

func (*Message) SetMessageId 

func (m *Message) SetMessageId(messageId string)

func (*Message) SetParentMessageId 

func (m *Message) SetParentMessageId(parentMessageId string)

func (*Message) SetRootMessageId 

func (m *Message) SetRootMessageId(rootMessageId string)

func (*Message) SetStatus 

func (m *Message) SetStatus(status string)

func (*Message) SetSuccessStatus 

func (m *Message) SetSuccessStatus()

func (*Message) SetTime 

func (m *Message) SetTime(t time.Time)

type MessageGetter 

type MessageGetter interface {
	GetType() string
	GetName() string
	GetStatus() string
	GetData() *bytes.Buffer
	GetTime() time.Time
	GetDomain() string
	GetHostname() string
	GetIp() string
	GetMessageId() string
	GetParentMessageId() string
	GetRootMessageId() string
	GetHeader() *Header
	GetFlushStatus() bool
}

noinspection GoNameStartsWithPackageName

type Messager 

type Messager interface {
	MessageGetter
	AddData(k string, v ...string)
	SetData(v string)
	SetStatus(status string)
	SetTime(time time.Time)
	Complete()
	SetDomain(domain string)
	SetHostname(hostname string)
	SetIp(ip string)
	SetMessageId(messageId string)
	SetParentMessageId(parentMessageId string)
	SetRootMessageId(rootMessageId string)
	SetHeader(header *Header)
	SetFlushStatus(status bool)
}

type Metric 

type Metric struct {
	Message
}

func NewMetric 

func NewMetric(mtype, name string, flush Flush, initHeader InitHeader) *Metric

func (*Metric) Complete 

func (e *Metric) Complete()

type NullMessage 

type NullMessage struct {
}

func (*NullMessage) AddData 

func (m *NullMessage) AddData(k string, v ...string)

func (*NullMessage) Complete 

func (m *NullMessage) Complete()

func (*NullMessage) GetData 

func (m *NullMessage) GetData() *bytes.Buffer

func (*NullMessage) GetDomain 

func (m *NullMessage) GetDomain() (domain string)

func (*NullMessage) GetFlushStatus 

func (t *NullMessage) GetFlushStatus() bool

func (*NullMessage) GetHeader 

func (m *NullMessage) GetHeader() (header *Header)

func (*NullMessage) GetHostname 

func (m *NullMessage) GetHostname() (hostname string)

func (*NullMessage) GetIp 

func (m *NullMessage) GetIp() (messageId string)

func (*NullMessage) GetMessageId 

func (m *NullMessage) GetMessageId() (messageId string)

func (*NullMessage) GetName 

func (m *NullMessage) GetName() string

func (*NullMessage) GetParentMessageId 

func (m *NullMessage) GetParentMessageId() (parentMessageId string)

func (*NullMessage) GetRootMessageId 

func (m *NullMessage) GetRootMessageId() (rootMessageId string)

func (*NullMessage) GetStatus 

func (m *NullMessage) GetStatus() string

func (*NullMessage) GetTime 

func (m *NullMessage) GetTime() time.Time

func (*NullMessage) GetType 

func (m *NullMessage) GetType() string

func (*NullMessage) SetData 

func (m *NullMessage) SetData(v string)

func (*NullMessage) SetDomain 

func (m *NullMessage) SetDomain(domain string)

func (*NullMessage) SetFlushStatus 

func (t *NullMessage) SetFlushStatus(flushStatus bool)

func (*NullMessage) SetHeader 

func (m *NullMessage) SetHeader(header *Header)

func (*NullMessage) SetHostname 

func (m *NullMessage) SetHostname(hostname string)

func (*NullMessage) SetIp 

func (m *NullMessage) SetIp(ip string)

func (*NullMessage) SetMessageId 

func (m *NullMessage) SetMessageId(messageId string)

func (*NullMessage) SetParentMessageId 

func (m *NullMessage) SetParentMessageId(parentMessageId string)

func (*NullMessage) SetRootMessageId 

func (m *NullMessage) SetRootMessageId(rootMessageId string)

func (*NullMessage) SetStatus 

func (m *NullMessage) SetStatus(status string)

func (*NullMessage) SetTime 

func (m *NullMessage) SetTime(time time.Time)

func (*NullMessage) SetTimestamp 

func (m *NullMessage) SetTimestamp(timestampMs int64)

type NullTransaction 

type NullTransaction struct {
	NullMessage
}

func (*NullTransaction) AddChild 

func (t *NullTransaction) AddChild(m Messager)

func (*NullTransaction) GetChildren 

func (t *NullTransaction) GetChildren() []Messager

func (*NullTransaction) GetDuration 

func (t *NullTransaction) GetDuration() time.Duration

func (*NullTransaction) LogEvent 

func (t *NullTransaction) LogEvent(mtype, name string, args ...string)

func (*NullTransaction) NewEvent 

func (t *NullTransaction) NewEvent(mtype, name string) Messager

func (*NullTransaction) SetDuration 

func (t *NullTransaction) SetDuration(duration time.Duration)

func (*NullTransaction) SetDurationStart 

func (t *NullTransaction) SetDurationStart(duration time.Time)

type Transaction 

type Transaction struct {
	Message
	// contains filtered or unexported fields
}

func NewTransaction 

func NewTransaction(mtype, name string, flush Flush, initHeader InitHeader) *Transaction

需要设置header

func (*Transaction) AddChild 

func (t *Transaction) AddChild(m Messager)

func (*Transaction) Complete 

func (t *Transaction) Complete()

func (*Transaction) GetChildren 

func (t *Transaction) GetChildren() []Messager

func (*Transaction) GetDuration 

func (t *Transaction) GetDuration() time.Duration

func (*Transaction) LogEvent 

func (t *Transaction) LogEvent(mtype, name string, args ...string)

func (*Transaction) NewEvent 

func (t *Transaction) NewEvent(mtype, name string) Messager

func (*Transaction) SetDuration 

func (t *Transaction) SetDuration(duration time.Duration)

func (*Transaction) SetDurationStart 

func (t *Transaction) SetDurationStart(time time.Time)

type TransactionGetter 

type TransactionGetter interface {
	GetDuration() time.Duration
}

type Transactor 

type Transactor interface {
	Messager
	TransactionGetter
	SetDuration(duration time.Duration)
	SetDurationStart(time time.Time)
	NewEvent(mtype, name string) Messager
	LogEvent(mtype, name string, args ...string)
	AddChild(m Messager)
	GetChildren() []Messager
}

type TxtEncoder 

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

func NewTxtEncoder 

func NewTxtEncoder() *TxtEncoder

func (*TxtEncoder) EncodeEvent 

func (e *TxtEncoder) EncodeEvent(buf *bytes.Buffer, m *Event) (err error)

func (*TxtEncoder) EncodeHeader 

func (e *TxtEncoder) EncodeHeader(buf *bytes.Buffer, header *Header) (err error)

func (*TxtEncoder) EncodeHeartbeat 

func (e *TxtEncoder) EncodeHeartbeat(buf *bytes.Buffer, m *Heartbeat) (err error)

func (*TxtEncoder) EncodeMessage 

func (e *TxtEncoder) EncodeMessage(buf *bytes.Buffer, message Messager) (err error)

func (*TxtEncoder) EncodeMetric 

func (e *TxtEncoder) EncodeMetric(buf *bytes.Buffer, m *Metric) (err error)

func (*TxtEncoder) EncodeTransaction 

func (e *TxtEncoder) EncodeTransaction(buf *bytes.Buffer, trans *Transaction) (err error)

Source Files

View all Source files

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.