messages

package
v1.4.3 Latest Latest
Warning

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

Go to latest
Published: Jan 16, 2020 License: Apache-2.0 Imports: 9 Imported by: 2

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
	Environment    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
	ApplicationOrg     string
	ApplicationOrgID   string
	ApplicationSpace   string
	ApplicationSpaceID 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.

func NewError

func NewError(e *events.Envelope, c caching.CachingClient) *Error

NewError creates a new NewError

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
	ApplicationOrg     string
	ApplicationOrgID   string
	ApplicationSpace   string
	ApplicationSpaceID 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
	ApplicationOrg     string
	ApplicationOrgID   string
	ApplicationSpace   string
	ApplicationSpaceID 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL