Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseMessage ¶
type BaseMessage struct {
EventType string
Deployment string
EventTime time.Time
Job string
Index string
IP string
Tags string
NozzleInstance string
MessageHash string
// for grouping in OMS until multi-field grouping is supported
SourceInstance string
Origin string
}
BaseMessage contains common data elements
func NewBaseMessage ¶
func NewBaseMessage(e *events.Envelope, c caching.CachingClient) *BaseMessage
NewBaseMessage Creates the common attributes of messages
type ContainerMetric ¶
type ContainerMetric struct {
BaseMessage
ApplicationID string
ApplicationName string
InstanceIndex int32
CPUPercentage float64 `json:",omitempty"`
MemoryBytes uint64 `json:",omitempty"`
DiskBytes uint64 `json:",omitempty"`
MemoryBytesQuota uint64 `json:",omitempty"`
DiskBytesQuota uint64 `json:",omitempty"`
}
A ContainerMetric records resource usage of an app in a container.
func NewContainerMetric ¶
func NewContainerMetric(e *events.Envelope, c caching.CachingClient) *ContainerMetric
NewContainerMetric creates a new Container Metric
type CounterEvent ¶
type CounterEvent struct {
BaseMessage
Name string
Delta uint64
Total uint64
CounterKey string
}
A CounterEvent represents the increment of a counter. It contains only the change in the value; it is the responsibility of downstream consumers to maintain the value of the counter.
func NewCounterEvent ¶
func NewCounterEvent(e *events.Envelope, c caching.CachingClient) *CounterEvent
NewCounterEvent creates a new CounterEvent
type Error ¶
type Error struct {
BaseMessage
Source string
Code int32
Message string
}
An Error event represents an error in the originating process.
type HTTPStartStop ¶
type HTTPStartStop struct {
BaseMessage
StartTimestamp int64
StopTimestamp int64
RequestID string
PeerType string // Client/Server
Method string // HTTP method
URI string
RemoteAddress string
UserAgent string
StatusCode int32
ContentLength int64
ApplicationID string
ApplicationName string
InstanceIndex int32
InstanceID string
Forwarded string
}
An HTTPStartStop event represents the whole lifecycle of an HTTP request.
func NewHTTPStartStop ¶
func NewHTTPStartStop(e *events.Envelope, c caching.CachingClient) *HTTPStartStop
NewHTTPStartStop creates a new NewHTTPStartStop
type LogMessage ¶
type LogMessage struct {
BaseMessage
Message string
MessageType string // OUT or ERROR
Timestamp int64
AppID string
ApplicationName string
SourceType string // APP,RTR,DEA,STG,etc
SourceInstance string
SourceTypeKey string // Key for aggregation until multiple levels of grouping supported
}
A LogMessage contains a "log line" and associated metadata.
func NewLogMessage ¶
func NewLogMessage(e *events.Envelope, c caching.CachingClient) *LogMessage
NewLogMessage creates a new NewLogMessage
type ValueMetric ¶
type ValueMetric struct {
BaseMessage
Name string
Value float64
Unit string
MetricKey string
}
A ValueMetric indicates the value of a metric at an instant in time.
func NewValueMetric ¶
func NewValueMetric(e *events.Envelope, c caching.CachingClient) *ValueMetric
NewValueMetric creates a new ValueMetric
Source Files