message

Documentation

Index

• Constants
• type Event
  • func NewEvent(t, name, status, data string, timestampInMillis int64) *Event
  • func (m *Event) GetData() string
  • func (m *Event) GetName() string
  • func (m *Event) GetStatus() string
  • func (m *Event) GetTimestamp() int64
  • func (m *Event) GetType() string
  • func (m *Event) IsSuccess() bool
• type Heartbeat
  • func NewHeartbeat(t, name, status, data string, timestampInMillis int64) *Heartbeat
  • func (m *Heartbeat) GetData() string
  • func (m *Heartbeat) GetName() string
  • func (m *Heartbeat) GetStatus() string
  • func (m *Heartbeat) GetTimestamp() int64
  • func (m *Heartbeat) GetType() string
  • func (m *Heartbeat) IsSuccess() bool
• type Message
• type MessageTree
  • func NewMessageTree() *MessageTree
  • func (tree *MessageTree) CanDiscard() bool
  • func (tree *MessageTree) GetDomain() []byte
  • func (tree *MessageTree) GetMessage() Message
  • func (tree *MessageTree) GetMessageId() []byte
  • func (tree *MessageTree) GetParentMessageId() []byte
  • func (tree *MessageTree) GetRootMessageId() []byte
  • func (tree *MessageTree) GetThreadGroupName() []byte
  • func (tree *MessageTree) GetThreadId() []byte
  • func (tree *MessageTree) GetThreadName() []byte
  • func (tree *MessageTree) SetDiscard(discard bool)
  • func (tree *MessageTree) SetDomain(domain []byte)
  • func (tree *MessageTree) SetMessage(message Message)
  • func (tree *MessageTree) SetMessageId(messageId []byte)
  • func (tree *MessageTree) SetParentMessageId(parentMessageId []byte)
  • func (tree *MessageTree) SetRootMessageId(rootMessageId []byte)
  • func (tree *MessageTree) SetThreadGroupName(threadGroupName []byte)
  • func (tree *MessageTree) SetThreadId(threadId []byte)
  • func (tree *MessageTree) SetThreadName(threadName []byte)
• type Transaction
  • func NewTransaction(t, name, status, data string, timestampInMillis int64, children []Message, ...) *Transaction
  • func (trans *Transaction) AddChild(child Message)
  • func (trans *Transaction) GetChildren() []Message
  • func (m *Transaction) GetData() string
  • func (trans *Transaction) GetDurationInMicros() int64
  • func (m *Transaction) GetName() string
  • func (m *Transaction) GetStatus() string
  • func (m *Transaction) GetTimestamp() int64
  • func (m *Transaction) GetType() string
  • func (m *Transaction) IsSuccess() bool
  • func (trans *Transaction) SetDurationInMicros(durationInMicros int64)

Constants

const SUCCESS = "0"

Types

type Event

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

func NewEvent

func NewEvent(t, name, status, data string, timestampInMillis int64) *Event

func (*Event) GetData

func (m *Event) GetData() string

func (*Event) GetName

func (m *Event) GetName() string

func (*Event) GetStatus

func (m *Event) GetStatus() string

func (*Event) GetTimestamp

func (m *Event) GetTimestamp() int64

func (*Event) GetType

func (m *Event) GetType() string

func (*Event) IsSuccess

func (m *Event) IsSuccess() bool

type Heartbeat

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

func NewHeartbeat

func NewHeartbeat(t, name, status, data string, timestampInMillis int64) *Heartbeat

func (*Heartbeat) GetData

func (m *Heartbeat) GetData() string

func (*Heartbeat) GetName

func (m *Heartbeat) GetName() string

func (*Heartbeat) GetStatus

func (m *Heartbeat) GetStatus() string

func (*Heartbeat) GetTimestamp

func (m *Heartbeat) GetTimestamp() int64

func (*Heartbeat) GetType

func (m *Heartbeat) GetType() string

func (*Heartbeat) IsSuccess

func (m *Heartbeat) IsSuccess() bool

type Message

type Message interface {
	GetType() string
	GetName() string
	GetStatus() string
	GetData() string
	GetTimestamp() int64
	IsSuccess() bool
}

type MessageTree

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

func NewMessageTree

func NewMessageTree() *MessageTree

func (*MessageTree) CanDiscard

func (tree *MessageTree) CanDiscard() bool

func (*MessageTree) GetDomain

func (tree *MessageTree) GetDomain() []byte

func (*MessageTree) GetMessage

func (tree *MessageTree) GetMessage() Message

func (*MessageTree) GetMessageId

func (tree *MessageTree) GetMessageId() []byte

func (*MessageTree) GetParentMessageId

func (tree *MessageTree) GetParentMessageId() []byte

func (*MessageTree) GetRootMessageId

func (tree *MessageTree) GetRootMessageId() []byte

func (*MessageTree) GetThreadGroupName

func (tree *MessageTree) GetThreadGroupName() []byte

func (*MessageTree) GetThreadId

func (tree *MessageTree) GetThreadId() []byte

func (*MessageTree) GetThreadName

func (tree *MessageTree) GetThreadName() []byte

func (*MessageTree) SetDiscard

func (tree *MessageTree) SetDiscard(discard bool)

func (*MessageTree) SetDomain

func (tree *MessageTree) SetDomain(domain []byte)

func (*MessageTree) SetMessage

func (tree *MessageTree) SetMessage(message Message)

func (*MessageTree) SetMessageId

func (tree *MessageTree) SetMessageId(messageId []byte)

func (*MessageTree) SetParentMessageId

func (tree *MessageTree) SetParentMessageId(parentMessageId []byte)

func (*MessageTree) SetRootMessageId

func (tree *MessageTree) SetRootMessageId(rootMessageId []byte)

func (*MessageTree) SetThreadGroupName

func (tree *MessageTree) SetThreadGroupName(threadGroupName []byte)

func (*MessageTree) SetThreadId

func (tree *MessageTree) SetThreadId(threadId []byte)

func (*MessageTree) SetThreadName

func (tree *MessageTree) SetThreadName(threadName []byte)

type Transaction

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

func NewTransaction

func NewTransaction(t, name, status, data string, timestampInMillis int64, children []Message, durationInMicros int64) *Transaction

func (*Transaction) AddChild

func (trans *Transaction) AddChild(child Message)

func (*Transaction) GetChildren

func (trans *Transaction) GetChildren() []Message

func (*Transaction) GetData

func (m *Transaction) GetData() string

func (*Transaction) GetDurationInMicros

func (trans *Transaction) GetDurationInMicros() int64

func (*Transaction) GetName

func (m *Transaction) GetName() string

func (*Transaction) GetStatus

func (m *Transaction) GetStatus() string

func (*Transaction) GetTimestamp

func (m *Transaction) GetTimestamp() int64

func (*Transaction) GetType

func (m *Transaction) GetType() string

func (*Transaction) IsSuccess

func (m *Transaction) IsSuccess() bool

func (*Transaction) SetDurationInMicros

func (trans *Transaction) SetDurationInMicros(durationInMicros int64)