message

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

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 struct {
	Message
}

type Flush func(m Messager)

type Header struct {
	Domain   string
	Hostname string
	Ip       string

	MessageId       string
	ParentMessageId string
	RootMessageId   string
}

type Heartbeat struct {
	Message
}

type Message struct {
	Type   string
	Name   string
	Status string
	// contains filtered or unexported fields
}

type MessageGetter interface {
	GetType() string
	GetName() string
	GetStatus() string
	GetData() *bytes.Buffer
	GetTime() time.Time
}

type Messager interface {
	MessageGetter
	AddData(k string, v ...string)
	SetData(v string)
	SetStatus(status string)
	SetTime(time time.Time)
	Complete()
}

type Metric struct {
	Message
}

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

type TransactionGetter interface {
	GetDuration() time.Duration
}

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