Documentation ¶
Overview ¶
Package events is a generated protocol buffer package.
It is generated from these files:
envelope.proto error.proto http.proto log.proto metric.proto uuid.proto
It has these top-level messages:
Envelope
Index ¶
- Variables
- type ContainerMetric
- func (m *ContainerMetric) GetApplicationId() string
- func (m *ContainerMetric) GetCpuPercentage() float64
- func (m *ContainerMetric) GetDiskBytes() uint64
- func (m *ContainerMetric) GetInstanceIndex() int32
- func (m *ContainerMetric) GetMemoryBytes() uint64
- func (m *ContainerMetric) Marshal() (data []byte, err error)
- func (m *ContainerMetric) MarshalTo(data []byte) (n int, err error)
- func (*ContainerMetric) ProtoMessage()
- func (m *ContainerMetric) Reset()
- func (m *ContainerMetric) Size() (n int)
- func (m *ContainerMetric) String() string
- func (m *ContainerMetric) Unmarshal(data []byte) error
- type CounterEvent
- func (m *CounterEvent) GetDelta() uint64
- func (m *CounterEvent) GetName() string
- func (m *CounterEvent) GetTotal() uint64
- func (m *CounterEvent) Marshal() (data []byte, err error)
- func (m *CounterEvent) MarshalTo(data []byte) (n int, err error)
- func (*CounterEvent) ProtoMessage()
- func (m *CounterEvent) Reset()
- func (m *CounterEvent) Size() (n int)
- func (m *CounterEvent) String() string
- func (m *CounterEvent) Unmarshal(data []byte) error
- type Envelope
- func (m *Envelope) GetContainerMetric() *ContainerMetric
- func (m *Envelope) GetCounterEvent() *CounterEvent
- func (m *Envelope) GetDeployment() string
- func (m *Envelope) GetError() *Error
- func (m *Envelope) GetEventType() Envelope_EventType
- func (m *Envelope) GetHttpStart() *HttpStart
- func (m *Envelope) GetHttpStartStop() *HttpStartStop
- func (m *Envelope) GetHttpStop() *HttpStop
- func (m *Envelope) GetIndex() string
- func (m *Envelope) GetIp() string
- func (m *Envelope) GetJob() string
- func (m *Envelope) GetLogMessage() *LogMessage
- func (m *Envelope) GetOrigin() string
- func (m *Envelope) GetTimestamp() int64
- func (m *Envelope) GetValueMetric() *ValueMetric
- func (m *Envelope) Marshal() (data []byte, err error)
- func (m *Envelope) MarshalTo(data []byte) (n int, err error)
- func (*Envelope) ProtoMessage()
- func (m *Envelope) Reset()
- func (m *Envelope) Size() (n int)
- func (m *Envelope) String() string
- func (m *Envelope) Unmarshal(data []byte) error
- type Envelope_EventType
- type Error
- func (m *Error) GetCode() int32
- func (m *Error) GetMessage() string
- func (m *Error) GetSource() string
- func (m *Error) Marshal() (data []byte, err error)
- func (m *Error) MarshalTo(data []byte) (n int, err error)
- func (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (m *Error) Size() (n int)
- func (m *Error) String() string
- func (m *Error) Unmarshal(data []byte) error
- type Event
- type Heartbeat
- func (m *Heartbeat) GetControlMessageIdentifier() *UUID
- func (m *Heartbeat) GetErrorCount() uint64
- func (m *Heartbeat) GetReceivedCount() uint64
- func (m *Heartbeat) GetSentCount() uint64
- func (m *Heartbeat) Marshal() (data []byte, err error)
- func (m *Heartbeat) MarshalTo(data []byte) (n int, err error)
- func (*Heartbeat) ProtoMessage()
- func (m *Heartbeat) Reset()
- func (m *Heartbeat) Size() (n int)
- func (m *Heartbeat) String() string
- func (m *Heartbeat) Unmarshal(data []byte) error
- type HttpStart
- func (m *HttpStart) GetApplicationId() *UUID
- func (m *HttpStart) GetInstanceId() string
- func (m *HttpStart) GetInstanceIndex() int32
- func (m *HttpStart) GetMethod() Method
- func (m *HttpStart) GetParentRequestId() *UUID
- func (m *HttpStart) GetPeerType() PeerType
- func (m *HttpStart) GetRemoteAddress() string
- func (m *HttpStart) GetRequestId() *UUID
- func (m *HttpStart) GetTimestamp() int64
- func (m *HttpStart) GetUri() string
- func (m *HttpStart) GetUserAgent() string
- func (m *HttpStart) Marshal() (data []byte, err error)
- func (m *HttpStart) MarshalTo(data []byte) (n int, err error)
- func (*HttpStart) ProtoMessage()
- func (m *HttpStart) Reset()
- func (m *HttpStart) Size() (n int)
- func (m *HttpStart) String() string
- func (m *HttpStart) Unmarshal(data []byte) error
- type HttpStartStop
- func (m *HttpStartStop) GetApplicationId() *UUID
- func (m *HttpStartStop) GetContentLength() int64
- func (m *HttpStartStop) GetInstanceId() string
- func (m *HttpStartStop) GetInstanceIndex() int32
- func (m *HttpStartStop) GetMethod() Method
- func (m *HttpStartStop) GetParentRequestId() *UUID
- func (m *HttpStartStop) GetPeerType() PeerType
- func (m *HttpStartStop) GetRemoteAddress() string
- func (m *HttpStartStop) GetRequestId() *UUID
- func (m *HttpStartStop) GetStartTimestamp() int64
- func (m *HttpStartStop) GetStatusCode() int32
- func (m *HttpStartStop) GetStopTimestamp() int64
- func (m *HttpStartStop) GetUri() string
- func (m *HttpStartStop) GetUserAgent() string
- func (m *HttpStartStop) Marshal() (data []byte, err error)
- func (m *HttpStartStop) MarshalTo(data []byte) (n int, err error)
- func (*HttpStartStop) ProtoMessage()
- func (m *HttpStartStop) Reset()
- func (m *HttpStartStop) Size() (n int)
- func (m *HttpStartStop) String() string
- func (m *HttpStartStop) Unmarshal(data []byte) error
- type HttpStop
- func (m *HttpStop) GetApplicationId() *UUID
- func (m *HttpStop) GetContentLength() int64
- func (m *HttpStop) GetPeerType() PeerType
- func (m *HttpStop) GetRequestId() *UUID
- func (m *HttpStop) GetStatusCode() int32
- func (m *HttpStop) GetTimestamp() int64
- func (m *HttpStop) GetUri() string
- func (m *HttpStop) Marshal() (data []byte, err error)
- func (m *HttpStop) MarshalTo(data []byte) (n int, err error)
- func (*HttpStop) ProtoMessage()
- func (m *HttpStop) Reset()
- func (m *HttpStop) Size() (n int)
- func (m *HttpStop) String() string
- func (m *HttpStop) Unmarshal(data []byte) error
- type LogMessage
- func (m *LogMessage) GetAppId() string
- func (m *LogMessage) GetMessage() []byte
- func (m *LogMessage) GetMessageType() LogMessage_MessageType
- func (m *LogMessage) GetSourceInstance() string
- func (m *LogMessage) GetSourceType() string
- func (m *LogMessage) GetTimestamp() int64
- func (m *LogMessage) Marshal() (data []byte, err error)
- func (m *LogMessage) MarshalTo(data []byte) (n int, err error)
- func (*LogMessage) ProtoMessage()
- func (m *LogMessage) Reset()
- func (m *LogMessage) Size() (n int)
- func (m *LogMessage) String() string
- func (m *LogMessage) Unmarshal(data []byte) error
- type LogMessage_MessageType
- type Method
- type PeerType
- type UUID
- func (m *UUID) GetHigh() uint64
- func (m *UUID) GetLow() uint64
- func (m *UUID) Marshal() (data []byte, err error)
- func (m *UUID) MarshalTo(data []byte) (n int, err error)
- func (*UUID) ProtoMessage()
- func (m *UUID) Reset()
- func (m *UUID) Size() (n int)
- func (m *UUID) String() string
- func (m *UUID) Unmarshal(data []byte) error
- type ValueMetric
- func (m *ValueMetric) GetName() string
- func (m *ValueMetric) GetUnit() string
- func (m *ValueMetric) GetValue() float64
- func (m *ValueMetric) Marshal() (data []byte, err error)
- func (m *ValueMetric) MarshalTo(data []byte) (n int, err error)
- func (*ValueMetric) ProtoMessage()
- func (m *ValueMetric) Reset()
- func (m *ValueMetric) Size() (n int)
- func (m *ValueMetric) String() string
- func (m *ValueMetric) Unmarshal(data []byte) error
Constants ¶
This section is empty.
Variables ¶
var Envelope_EventType_name = map[int32]string{
2: "HttpStart",
3: "HttpStop",
4: "HttpStartStop",
5: "LogMessage",
6: "ValueMetric",
7: "CounterEvent",
8: "Error",
9: "ContainerMetric",
}
var Envelope_EventType_value = map[string]int32{
"HttpStart": 2,
"HttpStop": 3,
"HttpStartStop": 4,
"LogMessage": 5,
"ValueMetric": 6,
"CounterEvent": 7,
"Error": 8,
"ContainerMetric": 9,
}
var LogMessage_MessageType_name = map[int32]string{
1: "OUT",
2: "ERR",
}
var LogMessage_MessageType_value = map[string]int32{
"OUT": 1,
"ERR": 2,
}
var Method_name = map[int32]string{
1: "GET",
2: "POST",
3: "PUT",
4: "DELETE",
5: "HEAD",
}
var Method_value = map[string]int32{
"GET": 1,
"POST": 2,
"PUT": 3,
"DELETE": 4,
"HEAD": 5,
}
var PeerType_name = map[int32]string{
1: "Client",
2: "Server",
}
var PeerType_value = map[string]int32{
"Client": 1,
"Server": 2,
}
Functions ¶
This section is empty.
Types ¶
type ContainerMetric ¶
type ContainerMetric struct { ApplicationId *string `protobuf:"bytes,1,req,name=applicationId" json:"applicationId,omitempty"` InstanceIndex *int32 `protobuf:"varint,2,req,name=instanceIndex" json:"instanceIndex,omitempty"` CpuPercentage *float64 `protobuf:"fixed64,3,req,name=cpuPercentage" json:"cpuPercentage,omitempty"` MemoryBytes *uint64 `protobuf:"varint,4,req,name=memoryBytes" json:"memoryBytes,omitempty"` DiskBytes *uint64 `protobuf:"varint,5,req,name=diskBytes" json:"diskBytes,omitempty"` XXX_unrecognized []byte `json:"-"` }
/ A ContainerMetric records resource usage of an app in a container.
func (*ContainerMetric) GetApplicationId ¶
func (m *ContainerMetric) GetApplicationId() string
func (*ContainerMetric) GetCpuPercentage ¶
func (m *ContainerMetric) GetCpuPercentage() float64
func (*ContainerMetric) GetDiskBytes ¶
func (m *ContainerMetric) GetDiskBytes() uint64
func (*ContainerMetric) GetInstanceIndex ¶
func (m *ContainerMetric) GetInstanceIndex() int32
func (*ContainerMetric) GetMemoryBytes ¶
func (m *ContainerMetric) GetMemoryBytes() uint64
func (*ContainerMetric) Marshal ¶
func (m *ContainerMetric) Marshal() (data []byte, err error)
func (*ContainerMetric) MarshalTo ¶
func (m *ContainerMetric) MarshalTo(data []byte) (n int, err error)
func (*ContainerMetric) ProtoMessage ¶
func (*ContainerMetric) ProtoMessage()
func (*ContainerMetric) Reset ¶
func (m *ContainerMetric) Reset()
func (*ContainerMetric) Size ¶
func (m *ContainerMetric) Size() (n int)
func (*ContainerMetric) String ¶
func (m *ContainerMetric) String() string
func (*ContainerMetric) Unmarshal ¶
func (m *ContainerMetric) Unmarshal(data []byte) error
type CounterEvent ¶
type CounterEvent struct { Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"` Delta *uint64 `protobuf:"varint,2,req,name=delta" json:"delta,omitempty"` Total *uint64 `protobuf:"varint,3,opt,name=total" json:"total,omitempty"` XXX_unrecognized []byte `json:"-"` }
/ 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 (*CounterEvent) GetDelta ¶
func (m *CounterEvent) GetDelta() uint64
func (*CounterEvent) GetName ¶
func (m *CounterEvent) GetName() string
func (*CounterEvent) GetTotal ¶
func (m *CounterEvent) GetTotal() uint64
func (*CounterEvent) Marshal ¶
func (m *CounterEvent) Marshal() (data []byte, err error)
func (*CounterEvent) ProtoMessage ¶
func (*CounterEvent) ProtoMessage()
func (*CounterEvent) Reset ¶
func (m *CounterEvent) Reset()
func (*CounterEvent) Size ¶
func (m *CounterEvent) Size() (n int)
func (*CounterEvent) String ¶
func (m *CounterEvent) String() string
func (*CounterEvent) Unmarshal ¶
func (m *CounterEvent) Unmarshal(data []byte) error
type Envelope ¶
type Envelope struct { Origin *string `protobuf:"bytes,1,req,name=origin" json:"origin,omitempty"` EventType *Envelope_EventType `protobuf:"varint,2,req,name=eventType,enum=events.Envelope_EventType" json:"eventType,omitempty"` Timestamp *int64 `protobuf:"varint,6,opt,name=timestamp" json:"timestamp,omitempty"` Deployment *string `protobuf:"bytes,13,opt,name=deployment" json:"deployment,omitempty"` Job *string `protobuf:"bytes,14,opt,name=job" json:"job,omitempty"` Index *string `protobuf:"bytes,15,opt,name=index" json:"index,omitempty"` Ip *string `protobuf:"bytes,16,opt,name=ip" json:"ip,omitempty"` // Removed Heartbeat at position 3 HttpStart *HttpStart `protobuf:"bytes,4,opt,name=httpStart" json:"httpStart,omitempty"` HttpStop *HttpStop `protobuf:"bytes,5,opt,name=httpStop" json:"httpStop,omitempty"` HttpStartStop *HttpStartStop `protobuf:"bytes,7,opt,name=httpStartStop" json:"httpStartStop,omitempty"` LogMessage *LogMessage `protobuf:"bytes,8,opt,name=logMessage" json:"logMessage,omitempty"` ValueMetric *ValueMetric `protobuf:"bytes,9,opt,name=valueMetric" json:"valueMetric,omitempty"` CounterEvent *CounterEvent `protobuf:"bytes,10,opt,name=counterEvent" json:"counterEvent,omitempty"` Error *Error `protobuf:"bytes,11,opt,name=error" json:"error,omitempty"` ContainerMetric *ContainerMetric `protobuf:"bytes,12,opt,name=containerMetric" json:"containerMetric,omitempty"` XXX_unrecognized []byte `json:"-"` }
/ Envelope wraps an Event and adds metadata.
func (*Envelope) GetContainerMetric ¶
func (m *Envelope) GetContainerMetric() *ContainerMetric
func (*Envelope) GetCounterEvent ¶
func (m *Envelope) GetCounterEvent() *CounterEvent
func (*Envelope) GetDeployment ¶
func (*Envelope) GetEventType ¶
func (m *Envelope) GetEventType() Envelope_EventType
func (*Envelope) GetHttpStart ¶
func (*Envelope) GetHttpStartStop ¶
func (m *Envelope) GetHttpStartStop() *HttpStartStop
func (*Envelope) GetHttpStop ¶
func (*Envelope) GetLogMessage ¶
func (m *Envelope) GetLogMessage() *LogMessage
func (*Envelope) GetTimestamp ¶
func (*Envelope) GetValueMetric ¶
func (m *Envelope) GetValueMetric() *ValueMetric
func (*Envelope) ProtoMessage ¶
func (*Envelope) ProtoMessage()
type Envelope_EventType ¶
type Envelope_EventType int32
/ Type of the wrapped event.
const ( // Removed Heartbeat at position 1 Envelope_HttpStart Envelope_EventType = 2 Envelope_HttpStop Envelope_EventType = 3 Envelope_HttpStartStop Envelope_EventType = 4 Envelope_LogMessage Envelope_EventType = 5 Envelope_ValueMetric Envelope_EventType = 6 Envelope_CounterEvent Envelope_EventType = 7 Envelope_Error Envelope_EventType = 8 Envelope_ContainerMetric Envelope_EventType = 9 )
func (Envelope_EventType) Enum ¶
func (x Envelope_EventType) Enum() *Envelope_EventType
func (Envelope_EventType) String ¶
func (x Envelope_EventType) String() string
func (*Envelope_EventType) UnmarshalJSON ¶
func (x *Envelope_EventType) UnmarshalJSON(data []byte) error
type Error ¶
type Error struct { Source *string `protobuf:"bytes,1,req,name=source" json:"source,omitempty"` Code *int32 `protobuf:"varint,2,req,name=code" json:"code,omitempty"` Message *string `protobuf:"bytes,3,req,name=message" json:"message,omitempty"` XXX_unrecognized []byte `json:"-"` }
/ An Error event represents an error in the originating process.
func (*Error) GetMessage ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
type Heartbeat ¶
type Heartbeat struct { SentCount *uint64 `protobuf:"varint,1,req,name=sentCount" json:"sentCount,omitempty"` ReceivedCount *uint64 `protobuf:"varint,2,req,name=receivedCount" json:"receivedCount,omitempty"` ErrorCount *uint64 `protobuf:"varint,3,req,name=errorCount" json:"errorCount,omitempty"` ControlMessageIdentifier *UUID `protobuf:"bytes,4,opt,name=controlMessageIdentifier" json:"controlMessageIdentifier,omitempty"` XXX_unrecognized []byte `json:"-"` }
/ A Heartbeat event both indicates liveness of the emitter, and communicates counts of events processed.
func (*Heartbeat) GetControlMessageIdentifier ¶
func (*Heartbeat) GetErrorCount ¶
func (*Heartbeat) GetReceivedCount ¶
func (*Heartbeat) GetSentCount ¶
func (*Heartbeat) ProtoMessage ¶
func (*Heartbeat) ProtoMessage()
type HttpStart ¶
type HttpStart struct { Timestamp *int64 `protobuf:"varint,1,req,name=timestamp" json:"timestamp,omitempty"` RequestId *UUID `protobuf:"bytes,2,req,name=requestId" json:"requestId,omitempty"` PeerType *PeerType `protobuf:"varint,3,req,name=peerType,enum=events.PeerType" json:"peerType,omitempty"` Method *Method `protobuf:"varint,4,req,name=method,enum=events.Method" json:"method,omitempty"` Uri *string `protobuf:"bytes,5,req,name=uri" json:"uri,omitempty"` RemoteAddress *string `protobuf:"bytes,6,req,name=remoteAddress" json:"remoteAddress,omitempty"` UserAgent *string `protobuf:"bytes,7,req,name=userAgent" json:"userAgent,omitempty"` ParentRequestId *UUID `protobuf:"bytes,8,opt,name=parentRequestId" json:"parentRequestId,omitempty"` ApplicationId *UUID `protobuf:"bytes,9,opt,name=applicationId" json:"applicationId,omitempty"` InstanceIndex *int32 `protobuf:"varint,10,opt,name=instanceIndex" json:"instanceIndex,omitempty"` InstanceId *string `protobuf:"bytes,11,opt,name=instanceId" json:"instanceId,omitempty"` XXX_unrecognized []byte `json:"-"` }
/ An HttpStart event is emitted when a client sends a request (or immediately when a server receives the request).
func (*HttpStart) GetApplicationId ¶
func (*HttpStart) GetInstanceId ¶
func (*HttpStart) GetInstanceIndex ¶
func (*HttpStart) GetParentRequestId ¶
func (*HttpStart) GetPeerType ¶
func (*HttpStart) GetRemoteAddress ¶
func (*HttpStart) GetRequestId ¶
func (*HttpStart) GetTimestamp ¶
func (*HttpStart) GetUserAgent ¶
func (*HttpStart) ProtoMessage ¶
func (*HttpStart) ProtoMessage()
type HttpStartStop ¶
type HttpStartStop struct { StartTimestamp *int64 `protobuf:"varint,1,req,name=startTimestamp" json:"startTimestamp,omitempty"` StopTimestamp *int64 `protobuf:"varint,2,req,name=stopTimestamp" json:"stopTimestamp,omitempty"` RequestId *UUID `protobuf:"bytes,3,req,name=requestId" json:"requestId,omitempty"` PeerType *PeerType `protobuf:"varint,4,req,name=peerType,enum=events.PeerType" json:"peerType,omitempty"` Method *Method `protobuf:"varint,5,req,name=method,enum=events.Method" json:"method,omitempty"` Uri *string `protobuf:"bytes,6,req,name=uri" json:"uri,omitempty"` RemoteAddress *string `protobuf:"bytes,7,req,name=remoteAddress" json:"remoteAddress,omitempty"` UserAgent *string `protobuf:"bytes,8,req,name=userAgent" json:"userAgent,omitempty"` StatusCode *int32 `protobuf:"varint,9,req,name=statusCode" json:"statusCode,omitempty"` ContentLength *int64 `protobuf:"varint,10,req,name=contentLength" json:"contentLength,omitempty"` ParentRequestId *UUID `protobuf:"bytes,11,opt,name=parentRequestId" json:"parentRequestId,omitempty"` ApplicationId *UUID `protobuf:"bytes,12,opt,name=applicationId" json:"applicationId,omitempty"` InstanceIndex *int32 `protobuf:"varint,13,opt,name=instanceIndex" json:"instanceIndex,omitempty"` InstanceId *string `protobuf:"bytes,14,opt,name=instanceId" json:"instanceId,omitempty"` XXX_unrecognized []byte `json:"-"` }
/ An HttpStartStop event represents the whole lifecycle of an HTTP request.
func (*HttpStartStop) GetApplicationId ¶
func (m *HttpStartStop) GetApplicationId() *UUID
func (*HttpStartStop) GetContentLength ¶
func (m *HttpStartStop) GetContentLength() int64
func (*HttpStartStop) GetInstanceId ¶
func (m *HttpStartStop) GetInstanceId() string
func (*HttpStartStop) GetInstanceIndex ¶
func (m *HttpStartStop) GetInstanceIndex() int32
func (*HttpStartStop) GetMethod ¶
func (m *HttpStartStop) GetMethod() Method
func (*HttpStartStop) GetParentRequestId ¶
func (m *HttpStartStop) GetParentRequestId() *UUID
func (*HttpStartStop) GetPeerType ¶
func (m *HttpStartStop) GetPeerType() PeerType
func (*HttpStartStop) GetRemoteAddress ¶
func (m *HttpStartStop) GetRemoteAddress() string
func (*HttpStartStop) GetRequestId ¶
func (m *HttpStartStop) GetRequestId() *UUID
func (*HttpStartStop) GetStartTimestamp ¶
func (m *HttpStartStop) GetStartTimestamp() int64
func (*HttpStartStop) GetStatusCode ¶
func (m *HttpStartStop) GetStatusCode() int32
func (*HttpStartStop) GetStopTimestamp ¶
func (m *HttpStartStop) GetStopTimestamp() int64
func (*HttpStartStop) GetUri ¶
func (m *HttpStartStop) GetUri() string
func (*HttpStartStop) GetUserAgent ¶
func (m *HttpStartStop) GetUserAgent() string
func (*HttpStartStop) Marshal ¶
func (m *HttpStartStop) Marshal() (data []byte, err error)
func (*HttpStartStop) ProtoMessage ¶
func (*HttpStartStop) ProtoMessage()
func (*HttpStartStop) Reset ¶
func (m *HttpStartStop) Reset()
func (*HttpStartStop) Size ¶
func (m *HttpStartStop) Size() (n int)
func (*HttpStartStop) String ¶
func (m *HttpStartStop) String() string
func (*HttpStartStop) Unmarshal ¶
func (m *HttpStartStop) Unmarshal(data []byte) error
type HttpStop ¶
type HttpStop struct { Timestamp *int64 `protobuf:"varint,1,req,name=timestamp" json:"timestamp,omitempty"` Uri *string `protobuf:"bytes,2,req,name=uri" json:"uri,omitempty"` RequestId *UUID `protobuf:"bytes,3,req,name=requestId" json:"requestId,omitempty"` PeerType *PeerType `protobuf:"varint,4,req,name=peerType,enum=events.PeerType" json:"peerType,omitempty"` StatusCode *int32 `protobuf:"varint,5,req,name=statusCode" json:"statusCode,omitempty"` ContentLength *int64 `protobuf:"varint,6,req,name=contentLength" json:"contentLength,omitempty"` ApplicationId *UUID `protobuf:"bytes,7,opt,name=applicationId" json:"applicationId,omitempty"` XXX_unrecognized []byte `json:"-"` }
/ An HttpStop event is emitted when a client receives a response to its request (or when a server completes its handling and returns a response).
func (*HttpStop) GetApplicationId ¶
func (*HttpStop) GetContentLength ¶
func (*HttpStop) GetPeerType ¶
func (*HttpStop) GetRequestId ¶
func (*HttpStop) GetStatusCode ¶
func (*HttpStop) GetTimestamp ¶
func (*HttpStop) ProtoMessage ¶
func (*HttpStop) ProtoMessage()
type LogMessage ¶
type LogMessage struct { Message []byte `protobuf:"bytes,1,req,name=message" json:"message,omitempty"` MessageType *LogMessage_MessageType `protobuf:"varint,2,req,name=message_type,enum=events.LogMessage_MessageType" json:"message_type,omitempty"` Timestamp *int64 `protobuf:"varint,3,req,name=timestamp" json:"timestamp,omitempty"` AppId *string `protobuf:"bytes,4,opt,name=app_id" json:"app_id,omitempty"` SourceType *string `protobuf:"bytes,5,opt,name=source_type" json:"source_type,omitempty"` SourceInstance *string `protobuf:"bytes,6,opt,name=source_instance" json:"source_instance,omitempty"` XXX_unrecognized []byte `json:"-"` }
/ A LogMessage contains a "log line" and associated metadata.
func (*LogMessage) GetAppId ¶
func (m *LogMessage) GetAppId() string
func (*LogMessage) GetMessage ¶
func (m *LogMessage) GetMessage() []byte
func (*LogMessage) GetMessageType ¶
func (m *LogMessage) GetMessageType() LogMessage_MessageType
func (*LogMessage) GetSourceInstance ¶
func (m *LogMessage) GetSourceInstance() string
func (*LogMessage) GetSourceType ¶
func (m *LogMessage) GetSourceType() string
func (*LogMessage) GetTimestamp ¶
func (m *LogMessage) GetTimestamp() int64
func (*LogMessage) Marshal ¶
func (m *LogMessage) Marshal() (data []byte, err error)
func (*LogMessage) ProtoMessage ¶
func (*LogMessage) ProtoMessage()
func (*LogMessage) Reset ¶
func (m *LogMessage) Reset()
func (*LogMessage) Size ¶
func (m *LogMessage) Size() (n int)
func (*LogMessage) String ¶
func (m *LogMessage) String() string
func (*LogMessage) Unmarshal ¶
func (m *LogMessage) Unmarshal(data []byte) error
type LogMessage_MessageType ¶
type LogMessage_MessageType int32
/ MessageType stores the destination of the message (corresponding to STDOUT or STDERR).
const ( LogMessage_OUT LogMessage_MessageType = 1 LogMessage_ERR LogMessage_MessageType = 2 )
func (LogMessage_MessageType) Enum ¶
func (x LogMessage_MessageType) Enum() *LogMessage_MessageType
func (LogMessage_MessageType) String ¶
func (x LogMessage_MessageType) String() string
func (*LogMessage_MessageType) UnmarshalJSON ¶
func (x *LogMessage_MessageType) UnmarshalJSON(data []byte) error
type PeerType ¶
type PeerType int32
/ Type of peer handling request.
func (*PeerType) UnmarshalJSON ¶
type UUID ¶
type UUID struct { Low *uint64 `protobuf:"varint,1,req,name=low" json:"low,omitempty"` High *uint64 `protobuf:"varint,2,req,name=high" json:"high,omitempty"` XXX_unrecognized []byte `json:"-"` }
/ Type representing a 128-bit UUID.
The bytes of the UUID should be packed in little-endian **byte** (not bit) order. For example, the UUID `f47ac10b-58cc-4372-a567-0e02b2c3d479` should be encoded as `UUID{ low: 0x7243cc580bc17af4, high: 0x79d4c3b2020e67a5 }`
func (*UUID) ProtoMessage ¶
func (*UUID) ProtoMessage()
type ValueMetric ¶
type ValueMetric struct { Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"` Value *float64 `protobuf:"fixed64,2,req,name=value" json:"value,omitempty"` Unit *string `protobuf:"bytes,3,req,name=unit" json:"unit,omitempty"` XXX_unrecognized []byte `json:"-"` }
/ A ValueMetric indicates the value of a metric at an instant in time.
func (*ValueMetric) GetName ¶
func (m *ValueMetric) GetName() string
func (*ValueMetric) GetUnit ¶
func (m *ValueMetric) GetUnit() string
func (*ValueMetric) GetValue ¶
func (m *ValueMetric) GetValue() float64
func (*ValueMetric) Marshal ¶
func (m *ValueMetric) Marshal() (data []byte, err error)
func (*ValueMetric) ProtoMessage ¶
func (*ValueMetric) ProtoMessage()
func (*ValueMetric) Reset ¶
func (m *ValueMetric) Reset()
func (*ValueMetric) Size ¶
func (m *ValueMetric) Size() (n int)
func (*ValueMetric) String ¶
func (m *ValueMetric) String() string
func (*ValueMetric) Unmarshal ¶
func (m *ValueMetric) Unmarshal(data []byte) error