model

package
v0.0.0-...-3dd6856 Latest Latest
Warning

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

 Go to latest Published: May 20, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Package model is a generated protocol buffer package.

It is generated from these files: 

agent.proto

It has these top-level messages: 

ResCollector
CollectorProc
CollectorConnections
CollectorRealTime
CollectorContainer
CollectorContainerRealTime
CollectorReqStatus
CollectorStatus
Process
Command
ProcessUser
ContainerAddr
Container
ProcessStat
ContainerStat
ContainerMetadata
SystemInfo
OSInfo
IOStat
Connection
Addr
IPTranslation
MemoryStat
CPUStat
SingleCPUStat
CPUInfo
Host
HostTags

Index

Constants

View Source 
const (
	MessageV1 MessageVersion = 1
	MessageV2                = 2
	MessageV3                = 3
)

Message versioning constants.

View Source 
const (
	TypeCollectorProc              = 12
	TypeCollectorConnections       = 22
	TypeResCollector               = 23
	TypeCollectorRealTime          = 27
	TypeCollectorContainer         = 39
	TypeCollectorContainerRealTime = 40
)

Message type constants for MessageType. Note: Ordering my seem unusual, this is just to match the backend where there are additional types that aren't covered here.

Variables

View Source 
var (
	ErrInvalidLengthAgent = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAgent   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ConnectionDirection_name = map[int32]string{
	0: "unspecified",
	1: "incoming",
	2: "outgoing",
	3: "local",
}
View Source 
var ConnectionDirection_value = map[string]int32{
	"unspecified": 0,
	"incoming":    1,
	"outgoing":    2,
	"local":       3,
}
View Source 
var ConnectionFamily_name = map[int32]string{
	0: "v4",
	1: "v6",
}
View Source 
var ConnectionFamily_value = map[string]int32{
	"v4": 0,
	"v6": 1,
}
View Source 
var ConnectionType_name = map[int32]string{
	0: "tcp",
	1: "udp",
}
View Source 
var ConnectionType_value = map[string]int32{
	"tcp": 0,
	"udp": 1,
}
View Source 
var ContainerHealth_name = map[int32]string{
	0: "unknownHealth",
	1: "starting",
	2: "healthy",
	3: "unhealthy",
}
View Source 
var ContainerHealth_value = map[string]int32{
	"unknownHealth": 0,
	"starting":      1,
	"healthy":       2,
	"unhealthy":     3,
}
View Source 
var ContainerState_name = map[int32]string{
	0: "unknown",
	1: "created",
	2: "restarting",
	3: "running",
	4: "paused",
	5: "exited",
	6: "dead",
}
View Source 
var ContainerState_value = map[string]int32{
	"unknown":    0,
	"created":    1,
	"restarting": 2,
	"running":    3,
	"paused":     4,
	"exited":     5,
	"dead":       6,
}
View Source 
var ProcessState_name = map[int32]string{
	0: "U",
	1: "D",
	2: "R",
	3: "S",
	4: "T",
	5: "W",
	6: "X",
	7: "Z",
}
View Source 
var ProcessState_value = map[string]int32{
	"U": 0,
	"D": 1,
	"R": 2,
	"S": 3,
	"T": 4,
	"W": 5,
	"X": 6,
	"Z": 7,
}

Functions

func EncodeMessage 

func EncodeMessage(m Message) ([]byte, error)

EncodeMessage encodes a message object into bytes with protobuf. A type header is added for ease of decoding.

Types

type Addr 

type Addr struct {
	Ip          string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	Port        int32  `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	ContainerId string `protobuf:"bytes,5,opt,name=containerId,proto3" json:"containerId,omitempty"`
	HostId      int32  `protobuf:"varint,6,opt,name=hostId,proto3" json:"hostId,omitempty"`
}

func (*Addr) Descriptor 

func (*Addr) Descriptor() ([]byte, []int)

func (*Addr) Marshal 

func (m *Addr) Marshal() (data []byte, err error)

func (*Addr) MarshalTo 

func (m *Addr) MarshalTo(data []byte) (int, error)

func (*Addr) ProtoMessage 

func (*Addr) ProtoMessage()

func (*Addr) Reset 

func (m *Addr) Reset()

func (*Addr) Size 

func (m *Addr) Size() (n int)

func (*Addr) String 

func (m *Addr) String() string

func (*Addr) Unmarshal 

func (m *Addr) Unmarshal(data []byte) error

type CPUInfo 

type CPUInfo struct {
	Number     int32  `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	Vendor     string `protobuf:"bytes,2,opt,name=vendor,proto3" json:"vendor,omitempty"`
	Family     string `protobuf:"bytes,3,opt,name=family,proto3" json:"family,omitempty"`
	Model      string `protobuf:"bytes,4,opt,name=model,proto3" json:"model,omitempty"`
	PhysicalId string `protobuf:"bytes,5,opt,name=physicalId,proto3" json:"physicalId,omitempty"`
	CoreId     string `protobuf:"bytes,6,opt,name=coreId,proto3" json:"coreId,omitempty"`
	Cores      int32  `protobuf:"varint,7,opt,name=cores,proto3" json:"cores,omitempty"`
	Mhz        int64  `protobuf:"varint,8,opt,name=mhz,proto3" json:"mhz,omitempty"`
	CacheSize  int32  `protobuf:"varint,9,opt,name=cacheSize,proto3" json:"cacheSize,omitempty"`
}

func (*CPUInfo) Descriptor 

func (*CPUInfo) Descriptor() ([]byte, []int)

func (*CPUInfo) Marshal 

func (m *CPUInfo) Marshal() (data []byte, err error)

func (*CPUInfo) MarshalTo 

func (m *CPUInfo) MarshalTo(data []byte) (int, error)

func (*CPUInfo) ProtoMessage 

func (*CPUInfo) ProtoMessage()

func (*CPUInfo) Reset 

func (m *CPUInfo) Reset()

func (*CPUInfo) Size 

func (m *CPUInfo) Size() (n int)

func (*CPUInfo) String 

func (m *CPUInfo) String() string

func (*CPUInfo) Unmarshal 

func (m *CPUInfo) Unmarshal(data []byte) error

type CPUStat 

type CPUStat struct {
	LastCpu    string           `protobuf:"bytes,1,opt,name=lastCpu,proto3" json:"lastCpu,omitempty"`
	TotalPct   float32          `protobuf:"fixed32,2,opt,name=totalPct,proto3" json:"totalPct,omitempty"`
	UserPct    float32          `protobuf:"fixed32,3,opt,name=userPct,proto3" json:"userPct,omitempty"`
	SystemPct  float32          `protobuf:"fixed32,4,opt,name=systemPct,proto3" json:"systemPct,omitempty"`
	NumThreads int32            `protobuf:"varint,5,opt,name=numThreads,proto3" json:"numThreads,omitempty"`
	Cpus       []*SingleCPUStat `protobuf:"bytes,6,rep,name=cpus" json:"cpus,omitempty"`
	Nice       int32            `protobuf:"varint,7,opt,name=nice,proto3" json:"nice,omitempty"`
	UserTime   int64            `protobuf:"varint,8,opt,name=userTime,proto3" json:"userTime,omitempty"`
	SystemTime int64            `protobuf:"varint,9,opt,name=systemTime,proto3" json:"systemTime,omitempty"`
}

func (*CPUStat) Descriptor 

func (*CPUStat) Descriptor() ([]byte, []int)

func (*CPUStat) GetCpus 

func (m *CPUStat) GetCpus() []*SingleCPUStat

func (*CPUStat) Marshal 

func (m *CPUStat) Marshal() (data []byte, err error)

func (*CPUStat) MarshalTo 

func (m *CPUStat) MarshalTo(data []byte) (int, error)

func (*CPUStat) ProtoMessage 

func (*CPUStat) ProtoMessage()

func (*CPUStat) Reset 

func (m *CPUStat) Reset()

func (*CPUStat) Size 

func (m *CPUStat) Size() (n int)

func (*CPUStat) String 

func (m *CPUStat) String() string

func (*CPUStat) Unmarshal 

func (m *CPUStat) Unmarshal(data []byte) error

type CollectorConnections 

type CollectorConnections struct {
	HostName    string        `protobuf:"bytes,2,opt,name=hostName,proto3" json:"hostName,omitempty"`
	HostId      int32         `protobuf:"varint,9,opt,name=hostId,proto3" json:"hostId,omitempty"`
	Connections []*Connection `protobuf:"bytes,3,rep,name=connections" json:"connections,omitempty"`
	// Message batching metadata
	GroupId   int32 `protobuf:"varint,5,opt,name=groupId,proto3" json:"groupId,omitempty"`
	GroupSize int32 `protobuf:"varint,6,opt,name=groupSize,proto3" json:"groupSize,omitempty"`
	// post-resolution field; all the hosts referenced in `connections` keyed by
	// hostId. This should also include an entry for the host on which these connections
	// were gathered.
	ResolvedHosts map[int32]*Host `` /* 154-byte string literal not displayed */
	// post-resolution field: all of the containers referenced in `connections` keyed by
	// containerId
	ResolvedContainers map[string]*ContainerMetadata `` /* 163-byte string literal not displayed */
	// mapping of processes running in each container
	ContainerForPid map[int32]string `` /* 166-byte string literal not displayed */
}

func (*CollectorConnections) Descriptor 

func (*CollectorConnections) Descriptor() ([]byte, []int)

func (*CollectorConnections) GetConnections 

func (m *CollectorConnections) GetConnections() []*Connection

func (*CollectorConnections) GetContainerForPid 

func (m *CollectorConnections) GetContainerForPid() map[int32]string

func (*CollectorConnections) GetResolvedContainers 

func (m *CollectorConnections) GetResolvedContainers() map[string]*ContainerMetadata

func (*CollectorConnections) GetResolvedHosts 

func (m *CollectorConnections) GetResolvedHosts() map[int32]*Host

func (*CollectorConnections) Marshal 

func (m *CollectorConnections) Marshal() (data []byte, err error)

func (*CollectorConnections) MarshalTo 

func (m *CollectorConnections) MarshalTo(data []byte) (int, error)

func (*CollectorConnections) ProtoMessage 

func (*CollectorConnections) ProtoMessage()

func (*CollectorConnections) Reset 

func (m *CollectorConnections) Reset()

func (*CollectorConnections) Size 

func (m *CollectorConnections) Size() (n int)

func (*CollectorConnections) String 

func (m *CollectorConnections) String() string

func (*CollectorConnections) Unmarshal 

func (m *CollectorConnections) Unmarshal(data []byte) error

type CollectorContainer 

type CollectorContainer struct {
	HostName   string       `protobuf:"bytes,1,opt,name=hostName,proto3" json:"hostName,omitempty"`
	Info       *SystemInfo  `protobuf:"bytes,2,opt,name=info" json:"info,omitempty"`
	Containers []*Container `protobuf:"bytes,3,rep,name=containers" json:"containers,omitempty"`
	GroupId    int32        `protobuf:"varint,4,opt,name=groupId,proto3" json:"groupId,omitempty"`
	GroupSize  int32        `protobuf:"varint,5,opt,name=groupSize,proto3" json:"groupSize,omitempty"`
	// Optional metadata fields
	Kubernetes *datadog_agentpayload.KubeMetadataPayload `protobuf:"bytes,6,opt,name=kubernetes" json:"kubernetes,omitempty"`
	Ecs        *datadog_agentpayload.ECSMetadataPayload  `protobuf:"bytes,7,opt,name=ecs" json:"ecs,omitempty"`
	// Post-resolved fields
	Host *Host `protobuf:"bytes,8,opt,name=host" json:"host,omitempty"`
}

func (*CollectorContainer) Descriptor 

func (*CollectorContainer) Descriptor() ([]byte, []int)

func (*CollectorContainer) GetContainers 

func (m *CollectorContainer) GetContainers() []*Container

func (*CollectorContainer) GetEcs 

func (m *CollectorContainer) GetEcs() *datadog_agentpayload.ECSMetadataPayload

func (*CollectorContainer) GetHost 

func (m *CollectorContainer) GetHost() *Host

func (*CollectorContainer) GetInfo 

func (m *CollectorContainer) GetInfo() *SystemInfo

func (*CollectorContainer) GetKubernetes 

func (m *CollectorContainer) GetKubernetes() *datadog_agentpayload.KubeMetadataPayload

func (*CollectorContainer) Marshal 

func (m *CollectorContainer) Marshal() (data []byte, err error)

func (*CollectorContainer) MarshalTo 

func (m *CollectorContainer) MarshalTo(data []byte) (int, error)

func (*CollectorContainer) ProtoMessage 

func (*CollectorContainer) ProtoMessage()

func (*CollectorContainer) Reset 

func (m *CollectorContainer) Reset()

func (*CollectorContainer) Size 

func (m *CollectorContainer) Size() (n int)

func (*CollectorContainer) String 

func (m *CollectorContainer) String() string

func (*CollectorContainer) Unmarshal 

func (m *CollectorContainer) Unmarshal(data []byte) error

type CollectorContainerRealTime 

type CollectorContainerRealTime struct {
	HostName string           `protobuf:"bytes,1,opt,name=hostName,proto3" json:"hostName,omitempty"`
	Stats    []*ContainerStat `protobuf:"bytes,2,rep,name=stats" json:"stats,omitempty"`
	// Used for normalization at host-level.
	NumCpus     int32 `protobuf:"varint,3,opt,name=numCpus,proto3" json:"numCpus,omitempty"`
	TotalMemory int64 `protobuf:"varint,4,opt,name=totalMemory,proto3" json:"totalMemory,omitempty"`
	// Post-resolved fields
	HostId    int32 `protobuf:"varint,5,opt,name=hostId,proto3" json:"hostId,omitempty"`
	GroupId   int32 `protobuf:"varint,6,opt,name=groupId,proto3" json:"groupId,omitempty"`
	GroupSize int32 `protobuf:"varint,7,opt,name=groupSize,proto3" json:"groupSize,omitempty"`
}

func (*CollectorContainerRealTime) Descriptor 

func (*CollectorContainerRealTime) Descriptor() ([]byte, []int)

func (*CollectorContainerRealTime) GetStats 

func (m *CollectorContainerRealTime) GetStats() []*ContainerStat

func (*CollectorContainerRealTime) Marshal 

func (m *CollectorContainerRealTime) Marshal() (data []byte, err error)

func (*CollectorContainerRealTime) MarshalTo 

func (m *CollectorContainerRealTime) MarshalTo(data []byte) (int, error)

func (*CollectorContainerRealTime) ProtoMessage 

func (*CollectorContainerRealTime) ProtoMessage()

func (*CollectorContainerRealTime) Reset 

func (m *CollectorContainerRealTime) Reset()

func (*CollectorContainerRealTime) Size 

func (m *CollectorContainerRealTime) Size() (n int)

func (*CollectorContainerRealTime) String 

func (m *CollectorContainerRealTime) String() string

func (*CollectorContainerRealTime) Unmarshal 

func (m *CollectorContainerRealTime) Unmarshal(data []byte) error

type CollectorProc 

type CollectorProc struct {
	HostName  string      `protobuf:"bytes,2,opt,name=hostName,proto3" json:"hostName,omitempty"`
	Processes []*Process  `protobuf:"bytes,3,rep,name=processes" json:"processes,omitempty"`
	Host      *Host       `protobuf:"bytes,4,opt,name=host" json:"host,omitempty"`
	Info      *SystemInfo `protobuf:"bytes,5,opt,name=info" json:"info,omitempty"`
	GroupId   int32       `protobuf:"varint,6,opt,name=groupId,proto3" json:"groupId,omitempty"`
	GroupSize int32       `protobuf:"varint,7,opt,name=groupSize,proto3" json:"groupSize,omitempty"`
	// Optional metadata fields
	Kubernetes *datadog_agentpayload.KubeMetadataPayload `protobuf:"bytes,8,opt,name=kubernetes" json:"kubernetes,omitempty"`
	Ecs        *datadog_agentpayload.ECSMetadataPayload  `protobuf:"bytes,9,opt,name=ecs" json:"ecs,omitempty"`
	Containers []*Container                              `protobuf:"bytes,10,rep,name=containers" json:"containers,omitempty"`
}

func (*CollectorProc) Descriptor 

func (*CollectorProc) Descriptor() ([]byte, []int)

func (*CollectorProc) GetContainers 

func (m *CollectorProc) GetContainers() []*Container

func (*CollectorProc) GetEcs 

func (m *CollectorProc) GetEcs() *datadog_agentpayload.ECSMetadataPayload

func (*CollectorProc) GetHost 

func (m *CollectorProc) GetHost() *Host

func (*CollectorProc) GetInfo 

func (m *CollectorProc) GetInfo() *SystemInfo

func (*CollectorProc) GetKubernetes 

func (m *CollectorProc) GetKubernetes() *datadog_agentpayload.KubeMetadataPayload

func (*CollectorProc) GetProcesses 

func (m *CollectorProc) GetProcesses() []*Process

func (*CollectorProc) Marshal 

func (m *CollectorProc) Marshal() (data []byte, err error)

func (*CollectorProc) MarshalTo 

func (m *CollectorProc) MarshalTo(data []byte) (int, error)

func (*CollectorProc) ProtoMessage 

func (*CollectorProc) ProtoMessage()

func (*CollectorProc) Reset 

func (m *CollectorProc) Reset()

func (*CollectorProc) Size 

func (m *CollectorProc) Size() (n int)

func (*CollectorProc) String 

func (m *CollectorProc) String() string

func (*CollectorProc) Unmarshal 

func (m *CollectorProc) Unmarshal(data []byte) error

type CollectorRealTime 

type CollectorRealTime struct {
	HostName string         `protobuf:"bytes,2,opt,name=hostName,proto3" json:"hostName,omitempty"`
	Stats    []*ProcessStat `protobuf:"bytes,3,rep,name=stats" json:"stats,omitempty"`
	// Post-resolved fields
	HostId         int32            `protobuf:"varint,4,opt,name=hostId,proto3" json:"hostId,omitempty"`
	OrgId          int32            `protobuf:"varint,5,opt,name=orgId,proto3" json:"orgId,omitempty"`
	GroupId        int32            `protobuf:"varint,6,opt,name=groupId,proto3" json:"groupId,omitempty"`
	GroupSize      int32            `protobuf:"varint,7,opt,name=groupSize,proto3" json:"groupSize,omitempty"`
	NumCpus        int32            `protobuf:"varint,8,opt,name=numCpus,proto3" json:"numCpus,omitempty"`
	TotalMemory    int64            `protobuf:"varint,9,opt,name=totalMemory,proto3" json:"totalMemory,omitempty"`
	ContainerStats []*ContainerStat `protobuf:"bytes,10,rep,name=containerStats" json:"containerStats,omitempty"`
}

func (*CollectorRealTime) Descriptor 

func (*CollectorRealTime) Descriptor() ([]byte, []int)

func (*CollectorRealTime) GetContainerStats 

func (m *CollectorRealTime) GetContainerStats() []*ContainerStat

func (*CollectorRealTime) GetStats 

func (m *CollectorRealTime) GetStats() []*ProcessStat

func (*CollectorRealTime) Marshal 

func (m *CollectorRealTime) Marshal() (data []byte, err error)

func (*CollectorRealTime) MarshalTo 

func (m *CollectorRealTime) MarshalTo(data []byte) (int, error)

func (*CollectorRealTime) ProtoMessage 

func (*CollectorRealTime) ProtoMessage()

func (*CollectorRealTime) Reset 

func (m *CollectorRealTime) Reset()

func (*CollectorRealTime) Size 

func (m *CollectorRealTime) Size() (n int)

func (*CollectorRealTime) String 

func (m *CollectorRealTime) String() string

func (*CollectorRealTime) Unmarshal 

func (m *CollectorRealTime) Unmarshal(data []byte) error

type CollectorReqStatus 

type CollectorReqStatus struct {
	HostName string `protobuf:"bytes,2,opt,name=hostName,proto3" json:"hostName,omitempty"`
}

func (*CollectorReqStatus) Descriptor 

func (*CollectorReqStatus) Descriptor() ([]byte, []int)

func (*CollectorReqStatus) Marshal 

func (m *CollectorReqStatus) Marshal() (data []byte, err error)

func (*CollectorReqStatus) MarshalTo 

func (m *CollectorReqStatus) MarshalTo(data []byte) (int, error)

func (*CollectorReqStatus) ProtoMessage 

func (*CollectorReqStatus) ProtoMessage()

func (*CollectorReqStatus) Reset 

func (m *CollectorReqStatus) Reset()

func (*CollectorReqStatus) Size 

func (m *CollectorReqStatus) Size() (n int)

func (*CollectorReqStatus) String 

func (m *CollectorReqStatus) String() string

func (*CollectorReqStatus) Unmarshal 

func (m *CollectorReqStatus) Unmarshal(data []byte) error

type CollectorStatus 

type CollectorStatus struct {
	ActiveClients int32 `protobuf:"varint,1,opt,name=activeClients,proto3" json:"activeClients,omitempty"`
	Interval      int32 `protobuf:"varint,2,opt,name=interval,proto3" json:"interval,omitempty"`
}

func (*CollectorStatus) Descriptor 

func (*CollectorStatus) Descriptor() ([]byte, []int)

func (*CollectorStatus) Marshal 

func (m *CollectorStatus) Marshal() (data []byte, err error)

func (*CollectorStatus) MarshalTo 

func (m *CollectorStatus) MarshalTo(data []byte) (int, error)

func (*CollectorStatus) ProtoMessage 

func (*CollectorStatus) ProtoMessage()

func (*CollectorStatus) Reset 

func (m *CollectorStatus) Reset()

func (*CollectorStatus) Size 

func (m *CollectorStatus) Size() (n int)

func (*CollectorStatus) String 

func (m *CollectorStatus) String() string

func (*CollectorStatus) Unmarshal 

func (m *CollectorStatus) Unmarshal(data []byte) error

type Command 

type Command struct {
	Args   []string `protobuf:"bytes,1,rep,name=args" json:"args,omitempty"`
	Cwd    string   `protobuf:"bytes,3,opt,name=cwd,proto3" json:"cwd,omitempty"`
	Root   string   `protobuf:"bytes,4,opt,name=root,proto3" json:"root,omitempty"`
	OnDisk bool     `protobuf:"varint,5,opt,name=onDisk,proto3" json:"onDisk,omitempty"`
	Ppid   int32    `protobuf:"varint,6,opt,name=ppid,proto3" json:"ppid,omitempty"`
	Pgroup int32    `protobuf:"varint,7,opt,name=pgroup,proto3" json:"pgroup,omitempty"`
	Exe    string   `protobuf:"bytes,8,opt,name=exe,proto3" json:"exe,omitempty"`
}

func (*Command) Descriptor 

func (*Command) Descriptor() ([]byte, []int)

func (*Command) Marshal 

func (m *Command) Marshal() (data []byte, err error)

func (*Command) MarshalTo 

func (m *Command) MarshalTo(data []byte) (int, error)

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) Reset 

func (m *Command) Reset()

func (*Command) Size 

func (m *Command) Size() (n int)

func (*Command) String 

func (m *Command) String() string

func (*Command) Unmarshal 

func (m *Command) Unmarshal(data []byte) error

type Connection 

type Connection struct {
	Pid           int32            `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Laddr         *Addr            `protobuf:"bytes,5,opt,name=laddr" json:"laddr,omitempty"`
	Raddr         *Addr            `protobuf:"bytes,6,opt,name=raddr" json:"raddr,omitempty"`
	Family        ConnectionFamily `protobuf:"varint,10,opt,name=family,proto3,enum=datadog.process_agent.ConnectionFamily" json:"family,omitempty"`
	Type          ConnectionType   `protobuf:"varint,11,opt,name=type,proto3,enum=datadog.process_agent.ConnectionType" json:"type,omitempty"`
	PidCreateTime int64            `protobuf:"varint,12,opt,name=pidCreateTime,proto3" json:"pidCreateTime,omitempty"`
	// Monotonic counters
	TotalBytesSent     uint64 `protobuf:"varint,13,opt,name=totalBytesSent,proto3" json:"totalBytesSent,omitempty"`
	TotalBytesReceived uint64 `protobuf:"varint,14,opt,name=totalBytesReceived,proto3" json:"totalBytesReceived,omitempty"`
	TotalRetransmits   uint32 `protobuf:"varint,15,opt,name=totalRetransmits,proto3" json:"totalRetransmits,omitempty"`
	// Relative counters since last check
	LastBytesSent     uint64              `protobuf:"varint,16,opt,name=lastBytesSent,proto3" json:"lastBytesSent,omitempty"`
	LastBytesReceived uint64              `protobuf:"varint,17,opt,name=lastBytesReceived,proto3" json:"lastBytesReceived,omitempty"`
	LastRetransmits   uint32              `protobuf:"varint,18,opt,name=lastRetransmits,proto3" json:"lastRetransmits,omitempty"`
	Direction         ConnectionDirection `protobuf:"varint,19,opt,name=direction,proto3,enum=datadog.process_agent.ConnectionDirection" json:"direction,omitempty"`
	// Network namespace
	NetNS uint32 `protobuf:"varint,20,opt,name=netNS,proto3" json:"netNS,omitempty"`
	// the conntrack entry associated with the connection. May be null on systems which don't support querying conntrack.
	IpTranslation *IPTranslation `protobuf:"bytes,21,opt,name=ipTranslation" json:"ipTranslation,omitempty"`
}

func (*Connection) Descriptor 

func (*Connection) Descriptor() ([]byte, []int)

func (*Connection) GetIpTranslation 

func (m *Connection) GetIpTranslation() *IPTranslation

func (*Connection) GetLaddr 

func (m *Connection) GetLaddr() *Addr

func (*Connection) GetRaddr 

func (m *Connection) GetRaddr() *Addr

func (*Connection) Marshal 

func (m *Connection) Marshal() (data []byte, err error)

func (*Connection) MarshalTo 

func (m *Connection) MarshalTo(data []byte) (int, error)

func (*Connection) ProtoMessage 

func (*Connection) ProtoMessage()

func (*Connection) Reset 

func (m *Connection) Reset()

func (*Connection) Size 

func (m *Connection) Size() (n int)

func (*Connection) String 

func (m *Connection) String() string

func (*Connection) Unmarshal 

func (m *Connection) Unmarshal(data []byte) error

type ConnectionDirection 

type ConnectionDirection int32
const (
	ConnectionDirection_unspecified ConnectionDirection = 0
	ConnectionDirection_incoming    ConnectionDirection = 1
	ConnectionDirection_outgoing    ConnectionDirection = 2
	ConnectionDirection_local       ConnectionDirection = 3
)

func (ConnectionDirection) EnumDescriptor 

func (ConnectionDirection) EnumDescriptor() ([]byte, []int)

func (ConnectionDirection) String 

func (x ConnectionDirection) String() string

type ConnectionFamily 

type ConnectionFamily int32
const (
	ConnectionFamily_v4 ConnectionFamily = 0
	ConnectionFamily_v6 ConnectionFamily = 1
)

func (ConnectionFamily) EnumDescriptor 

func (ConnectionFamily) EnumDescriptor() ([]byte, []int)

func (ConnectionFamily) String 

func (x ConnectionFamily) String() string

type ConnectionType 

type ConnectionType int32
const (
	ConnectionType_tcp ConnectionType = 0
	ConnectionType_udp ConnectionType = 1
)

func (ConnectionType) EnumDescriptor 

func (ConnectionType) EnumDescriptor() ([]byte, []int)

func (ConnectionType) String 

func (x ConnectionType) String() string

type Container 

type Container struct {
	Type        string           `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Id          string           `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Name        string           `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Image       string           `protobuf:"bytes,4,opt,name=image,proto3" json:"image,omitempty"`
	CpuLimit    float32          `protobuf:"fixed32,5,opt,name=cpuLimit,proto3" json:"cpuLimit,omitempty"`
	MemoryLimit uint64           `protobuf:"varint,6,opt,name=memoryLimit,proto3" json:"memoryLimit,omitempty"`
	State       ContainerState   `protobuf:"varint,8,opt,name=state,proto3,enum=datadog.process_agent.ContainerState" json:"state,omitempty"`
	Health      ContainerHealth  `protobuf:"varint,9,opt,name=health,proto3,enum=datadog.process_agent.ContainerHealth" json:"health,omitempty"`
	Created     int64            `protobuf:"varint,10,opt,name=created,proto3" json:"created,omitempty"`
	Rbps        float32          `protobuf:"fixed32,11,opt,name=rbps,proto3" json:"rbps,omitempty"`
	Wbps        float32          `protobuf:"fixed32,12,opt,name=wbps,proto3" json:"wbps,omitempty"`
	Key         uint32           `protobuf:"varint,13,opt,name=key,proto3" json:"key,omitempty"`
	NetRcvdPs   float32          `protobuf:"fixed32,14,opt,name=netRcvdPs,proto3" json:"netRcvdPs,omitempty"`
	NetSentPs   float32          `protobuf:"fixed32,15,opt,name=netSentPs,proto3" json:"netSentPs,omitempty"`
	NetRcvdBps  float32          `protobuf:"fixed32,16,opt,name=netRcvdBps,proto3" json:"netRcvdBps,omitempty"`
	NetSentBps  float32          `protobuf:"fixed32,17,opt,name=netSentBps,proto3" json:"netSentBps,omitempty"`
	UserPct     float32          `protobuf:"fixed32,18,opt,name=userPct,proto3" json:"userPct,omitempty"`
	SystemPct   float32          `protobuf:"fixed32,19,opt,name=systemPct,proto3" json:"systemPct,omitempty"`
	TotalPct    float32          `protobuf:"fixed32,20,opt,name=totalPct,proto3" json:"totalPct,omitempty"`
	MemRss      uint64           `protobuf:"varint,21,opt,name=memRss,proto3" json:"memRss,omitempty"`
	MemCache    uint64           `protobuf:"varint,22,opt,name=memCache,proto3" json:"memCache,omitempty"`
	Host        *Host            `protobuf:"bytes,23,opt,name=host" json:"host,omitempty"`
	Started     int64            `protobuf:"varint,24,opt,name=started,proto3" json:"started,omitempty"`
	ByteKey     []byte           `protobuf:"bytes,25,opt,name=byteKey,proto3" json:"byteKey,omitempty"`
	Tags        []string         `protobuf:"bytes,26,rep,name=tags" json:"tags,omitempty"`
	Addresses   []*ContainerAddr `protobuf:"bytes,27,rep,name=addresses" json:"addresses,omitempty"`
	ThreadCount uint64           `protobuf:"varint,28,opt,name=threadCount,proto3" json:"threadCount,omitempty"`
	ThreadLimit uint64           `protobuf:"varint,29,opt,name=threadLimit,proto3" json:"threadLimit,omitempty"`
}

func (*Container) Descriptor 

func (*Container) Descriptor() ([]byte, []int)

func (*Container) GetAddresses 

func (m *Container) GetAddresses() []*ContainerAddr

func (*Container) GetHost 

func (m *Container) GetHost() *Host

func (*Container) Marshal 

func (m *Container) Marshal() (data []byte, err error)

func (*Container) MarshalTo 

func (m *Container) MarshalTo(data []byte) (int, error)

func (*Container) ProtoMessage 

func (*Container) ProtoMessage()

func (*Container) Reset 

func (m *Container) Reset()

func (*Container) Size 

func (m *Container) Size() (n int)

func (*Container) String 

func (m *Container) String() string

func (*Container) Unmarshal 

func (m *Container) Unmarshal(data []byte) error

type ContainerAddr 

type ContainerAddr struct {
	Ip       string         `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Port     int32          `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Protocol ConnectionType `protobuf:"varint,3,opt,name=protocol,proto3,enum=datadog.process_agent.ConnectionType" json:"protocol,omitempty"`
}

ContainerAddr records the IPs, Ports and Protocols for each container

func (*ContainerAddr) Descriptor 

func (*ContainerAddr) Descriptor() ([]byte, []int)

func (*ContainerAddr) Marshal 

func (m *ContainerAddr) Marshal() (data []byte, err error)

func (*ContainerAddr) MarshalTo 

func (m *ContainerAddr) MarshalTo(data []byte) (int, error)

func (*ContainerAddr) ProtoMessage 

func (*ContainerAddr) ProtoMessage()

func (*ContainerAddr) Reset 

func (m *ContainerAddr) Reset()

func (*ContainerAddr) Size 

func (m *ContainerAddr) Size() (n int)

func (*ContainerAddr) String 

func (m *ContainerAddr) String() string

func (*ContainerAddr) Unmarshal 

func (m *ContainerAddr) Unmarshal(data []byte) error

type ContainerHealth 

type ContainerHealth int32

https://blog.couchbase.com/docker-health-check-keeping-containers-healthy/ health can be: starting, healthy, unhealthy 

const (
	ContainerHealth_unknownHealth ContainerHealth = 0
	ContainerHealth_starting      ContainerHealth = 1
	ContainerHealth_healthy       ContainerHealth = 2
	ContainerHealth_unhealthy     ContainerHealth = 3
)

func (ContainerHealth) EnumDescriptor 

func (ContainerHealth) EnumDescriptor() ([]byte, []int)

func (ContainerHealth) String 

func (x ContainerHealth) String() string

type ContainerMetadata 

type ContainerMetadata struct {
	Id      string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Key     uint32   `protobuf:"varint,2,opt,name=key,proto3" json:"key,omitempty"`
	ByteKey []byte   `protobuf:"bytes,3,opt,name=byteKey,proto3" json:"byteKey,omitempty"`
	Tags    []string `protobuf:"bytes,4,rep,name=tags" json:"tags,omitempty"`
}

ContainerMetadata only holds enough information to identify a container in connection data

func (*ContainerMetadata) Descriptor 

func (*ContainerMetadata) Descriptor() ([]byte, []int)

func (*ContainerMetadata) Marshal 

func (m *ContainerMetadata) Marshal() (data []byte, err error)

func (*ContainerMetadata) MarshalTo 

func (m *ContainerMetadata) MarshalTo(data []byte) (int, error)

func (*ContainerMetadata) ProtoMessage 

func (*ContainerMetadata) ProtoMessage()

func (*ContainerMetadata) Reset 

func (m *ContainerMetadata) Reset()

func (*ContainerMetadata) Size 

func (m *ContainerMetadata) Size() (n int)

func (*ContainerMetadata) String 

func (m *ContainerMetadata) String() string

func (*ContainerMetadata) Unmarshal 

func (m *ContainerMetadata) Unmarshal(data []byte) error

type ContainerStat 

type ContainerStat struct {
	Id         string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	UserPct    float32         `protobuf:"fixed32,2,opt,name=userPct,proto3" json:"userPct,omitempty"`
	SystemPct  float32         `protobuf:"fixed32,3,opt,name=systemPct,proto3" json:"systemPct,omitempty"`
	TotalPct   float32         `protobuf:"fixed32,4,opt,name=totalPct,proto3" json:"totalPct,omitempty"`
	CpuLimit   float32         `protobuf:"fixed32,5,opt,name=cpuLimit,proto3" json:"cpuLimit,omitempty"`
	MemRss     uint64          `protobuf:"varint,6,opt,name=memRss,proto3" json:"memRss,omitempty"`
	MemCache   uint64          `protobuf:"varint,7,opt,name=memCache,proto3" json:"memCache,omitempty"`
	MemLimit   uint64          `protobuf:"varint,8,opt,name=memLimit,proto3" json:"memLimit,omitempty"`
	Rbps       float32         `protobuf:"fixed32,9,opt,name=rbps,proto3" json:"rbps,omitempty"`
	Wbps       float32         `protobuf:"fixed32,10,opt,name=wbps,proto3" json:"wbps,omitempty"`
	NetRcvdPs  float32         `protobuf:"fixed32,11,opt,name=netRcvdPs,proto3" json:"netRcvdPs,omitempty"`
	NetSentPs  float32         `protobuf:"fixed32,12,opt,name=netSentPs,proto3" json:"netSentPs,omitempty"`
	NetRcvdBps float32         `protobuf:"fixed32,13,opt,name=netRcvdBps,proto3" json:"netRcvdBps,omitempty"`
	NetSentBps float32         `protobuf:"fixed32,14,opt,name=netSentBps,proto3" json:"netSentBps,omitempty"`
	State      ContainerState  `protobuf:"varint,15,opt,name=state,proto3,enum=datadog.process_agent.ContainerState" json:"state,omitempty"`
	Health     ContainerHealth `protobuf:"varint,16,opt,name=health,proto3,enum=datadog.process_agent.ContainerHealth" json:"health,omitempty"`
	// Post-resolved fields
	Key         uint32 `protobuf:"varint,17,opt,name=key,proto3" json:"key,omitempty"`
	Started     int64  `protobuf:"varint,18,opt,name=started,proto3" json:"started,omitempty"`
	ByteKey     []byte `protobuf:"bytes,19,opt,name=byteKey,proto3" json:"byteKey,omitempty"`
	ThreadCount uint64 `protobuf:"varint,20,opt,name=threadCount,proto3" json:"threadCount,omitempty"`
	ThreadLimit uint64 `protobuf:"varint,21,opt,name=threadLimit,proto3" json:"threadLimit,omitempty"`
}

ContainerStat is used for real-time container messages. It should only contain data that can change for a running container (and relevant information to generate a key). We will send a lot of these in the real-time messages so it's critical to keep this small (basically no strings except ID)

func (*ContainerStat) Descriptor 

func (*ContainerStat) Descriptor() ([]byte, []int)

func (*ContainerStat) Marshal 

func (m *ContainerStat) Marshal() (data []byte, err error)

func (*ContainerStat) MarshalTo 

func (m *ContainerStat) MarshalTo(data []byte) (int, error)

func (*ContainerStat) ProtoMessage 

func (*ContainerStat) ProtoMessage()

func (*ContainerStat) Reset 

func (m *ContainerStat) Reset()

func (*ContainerStat) Size 

func (m *ContainerStat) Size() (n int)

func (*ContainerStat) String 

func (m *ContainerStat) String() string

func (*ContainerStat) Unmarshal 

func (m *ContainerStat) Unmarshal(data []byte) error

type ContainerState 

type ContainerState int32

status section in https://docs.docker.com/engine/api/v1.29/#tag/Container 

const (
	ContainerState_unknown    ContainerState = 0
	ContainerState_created    ContainerState = 1
	ContainerState_restarting ContainerState = 2
	ContainerState_running    ContainerState = 3
	ContainerState_paused     ContainerState = 4
	ContainerState_exited     ContainerState = 5
	ContainerState_dead       ContainerState = 6
)

func (ContainerState) EnumDescriptor 

func (ContainerState) EnumDescriptor() ([]byte, []int)

func (ContainerState) String 

func (x ContainerState) String() string

type Host 

type Host struct {
	Id          int32       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	OrgId       int32       `protobuf:"varint,2,opt,name=orgId,proto3" json:"orgId,omitempty"`
	Name        string      `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Tags        []*HostTags `protobuf:"bytes,4,rep,name=tags" json:"tags,omitempty"`
	AllTags     []string    `protobuf:"bytes,6,rep,name=allTags" json:"allTags,omitempty"`
	NumCpus     int32       `protobuf:"varint,7,opt,name=numCpus,proto3" json:"numCpus,omitempty"`
	TotalMemory int64       `protobuf:"varint,8,opt,name=totalMemory,proto3" json:"totalMemory,omitempty"`
}

func (*Host) Descriptor 

func (*Host) Descriptor() ([]byte, []int)

func (*Host) GetTags 

func (m *Host) GetTags() []*HostTags

func (*Host) Marshal 

func (m *Host) Marshal() (data []byte, err error)

func (*Host) MarshalTo 

func (m *Host) MarshalTo(data []byte) (int, error)

func (*Host) ProtoMessage 

func (*Host) ProtoMessage()

func (*Host) Reset 

func (m *Host) Reset()

func (*Host) Size 

func (m *Host) Size() (n int)

func (*Host) String 

func (m *Host) String() string

func (*Host) Unmarshal 

func (m *Host) Unmarshal(data []byte) error

type HostTags 

type HostTags struct {
	SourceType uint32   `protobuf:"varint,1,opt,name=sourceType,proto3" json:"sourceType,omitempty"`
	Tags       []string `protobuf:"bytes,2,rep,name=tags" json:"tags,omitempty"`
}

func (*HostTags) Descriptor 

func (*HostTags) Descriptor() ([]byte, []int)

func (*HostTags) Marshal 

func (m *HostTags) Marshal() (data []byte, err error)

func (*HostTags) MarshalTo 

func (m *HostTags) MarshalTo(data []byte) (int, error)

func (*HostTags) ProtoMessage 

func (*HostTags) ProtoMessage()

func (*HostTags) Reset 

func (m *HostTags) Reset()

func (*HostTags) Size 

func (m *HostTags) Size() (n int)

func (*HostTags) String 

func (m *HostTags) String() string

func (*HostTags) Unmarshal 

func (m *HostTags) Unmarshal(data []byte) error

type IOStat 

type IOStat struct {
	ReadRate       float32 `protobuf:"fixed32,1,opt,name=readRate,proto3" json:"readRate,omitempty"`
	WriteRate      float32 `protobuf:"fixed32,2,opt,name=writeRate,proto3" json:"writeRate,omitempty"`
	ReadBytesRate  float32 `protobuf:"fixed32,3,opt,name=readBytesRate,proto3" json:"readBytesRate,omitempty"`
	WriteBytesRate float32 `protobuf:"fixed32,4,opt,name=writeBytesRate,proto3" json:"writeBytesRate,omitempty"`
}

func (*IOStat) Descriptor 

func (*IOStat) Descriptor() ([]byte, []int)

func (*IOStat) Marshal 

func (m *IOStat) Marshal() (data []byte, err error)

func (*IOStat) MarshalTo 

func (m *IOStat) MarshalTo(data []byte) (int, error)

func (*IOStat) ProtoMessage 

func (*IOStat) ProtoMessage()

func (*IOStat) Reset 

func (m *IOStat) Reset()

func (*IOStat) Size 

func (m *IOStat) Size() (n int)

func (*IOStat) String 

func (m *IOStat) String() string

func (*IOStat) Unmarshal 

func (m *IOStat) Unmarshal(data []byte) error

type IPTranslation 

type IPTranslation struct {
	ReplSrcIP   string `protobuf:"bytes,1,opt,name=replSrcIP,proto3" json:"replSrcIP,omitempty"`
	ReplDstIP   string `protobuf:"bytes,2,opt,name=replDstIP,proto3" json:"replDstIP,omitempty"`
	ReplSrcPort int32  `protobuf:"varint,3,opt,name=replSrcPort,proto3" json:"replSrcPort,omitempty"`
	ReplDstPort int32  `protobuf:"varint,4,opt,name=replDstPort,proto3" json:"replDstPort,omitempty"`
}

func (*IPTranslation) Descriptor 

func (*IPTranslation) Descriptor() ([]byte, []int)

func (*IPTranslation) Marshal 

func (m *IPTranslation) Marshal() (data []byte, err error)

func (*IPTranslation) MarshalTo 

func (m *IPTranslation) MarshalTo(data []byte) (int, error)

func (*IPTranslation) ProtoMessage 

func (*IPTranslation) ProtoMessage()

func (*IPTranslation) Reset 

func (m *IPTranslation) Reset()

func (*IPTranslation) Size 

func (m *IPTranslation) Size() (n int)

func (*IPTranslation) String 

func (m *IPTranslation) String() string

func (*IPTranslation) Unmarshal 

func (m *IPTranslation) Unmarshal(data []byte) error

type MemoryStat 

type MemoryStat struct {
	Rss    uint64 `protobuf:"varint,1,opt,name=rss,proto3" json:"rss,omitempty"`
	Vms    uint64 `protobuf:"varint,2,opt,name=vms,proto3" json:"vms,omitempty"`
	Swap   uint64 `protobuf:"varint,3,opt,name=swap,proto3" json:"swap,omitempty"`
	Shared uint64 `protobuf:"varint,4,opt,name=shared,proto3" json:"shared,omitempty"`
	Text   uint64 `protobuf:"varint,5,opt,name=text,proto3" json:"text,omitempty"`
	Lib    uint64 `protobuf:"varint,6,opt,name=lib,proto3" json:"lib,omitempty"`
	Data   uint64 `protobuf:"varint,7,opt,name=data,proto3" json:"data,omitempty"`
	Dirty  uint64 `protobuf:"varint,8,opt,name=dirty,proto3" json:"dirty,omitempty"`
}

func (*MemoryStat) Descriptor 

func (*MemoryStat) Descriptor() ([]byte, []int)

func (*MemoryStat) Marshal 

func (m *MemoryStat) Marshal() (data []byte, err error)

func (*MemoryStat) MarshalTo 

func (m *MemoryStat) MarshalTo(data []byte) (int, error)

func (*MemoryStat) ProtoMessage 

func (*MemoryStat) ProtoMessage()

func (*MemoryStat) Reset 

func (m *MemoryStat) Reset()

func (*MemoryStat) Size 

func (m *MemoryStat) Size() (n int)

func (*MemoryStat) String 

func (m *MemoryStat) String() string

func (*MemoryStat) Unmarshal 

func (m *MemoryStat) Unmarshal(data []byte) error

type Message 

type Message struct {
	Header MessageHeader
	Body   MessageBody
}

Message is a generic type for all messages with a Header and Body.

func DecodeMessage 

func DecodeMessage(data []byte) (Message, error)

DecodeMessage decodes raw message bytes into a specific type that satisfies the Message interface. If we can't decode, an error is returned.

type MessageBody 

type MessageBody interface {
	ProtoMessage()
	Reset()
	String() string
	Size() int
}

MessageBody is a common interface used by all message types.

type MessageEncoding 

type MessageEncoding uint8

MessageEncoding represents how messages will be encoded or decoded for over-the-wire transfer. Protobuf should be used for server-side messages (e.g. from collector <-> server) and JSON should be used for client-side. 

const (
	MessageEncodingProtobuf MessageEncoding = 0
	MessageEncodingJSON     MessageEncoding = 1
	MessageEncodingZstdPB   MessageEncoding = 2
)

Message encoding constants.

type MessageHeader 

type MessageHeader struct {
	Version        MessageVersion
	Encoding       MessageEncoding
	Type           MessageType
	SubscriptionID uint8 // Unused in Agent
	OrgID          int32 // Unused in Agent
	Timestamp      int64
}

MessageHeader is attached to all messages at the head of the message. Some fields are added in later versions so make sure you're only using fields that are available in the defined Version.

func ReadHeader 

func ReadHeader(data []byte) (MessageHeader, int, error)

ReadHeader reads the header off raw message bytes.

type MessageType 

type MessageType uint8

MessageType is a string representing the type of a message.

func DetectMessageType 

func DetectMessageType(b MessageBody) (MessageType, error)

DetectMessageType returns the message type for the given MessageBody

type MessageVersion 

type MessageVersion uint8

MessageVersion is the version of the message. It should always be the first byte in the encoded version.

type OSInfo 

type OSInfo struct {
	Name          string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Platform      string `protobuf:"bytes,2,opt,name=platform,proto3" json:"platform,omitempty"`
	Family        string `protobuf:"bytes,3,opt,name=family,proto3" json:"family,omitempty"`
	Version       string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	KernelVersion string `protobuf:"bytes,5,opt,name=kernelVersion,proto3" json:"kernelVersion,omitempty"`
}

func (*OSInfo) Descriptor 

func (*OSInfo) Descriptor() ([]byte, []int)

func (*OSInfo) Marshal 

func (m *OSInfo) Marshal() (data []byte, err error)

func (*OSInfo) MarshalTo 

func (m *OSInfo) MarshalTo(data []byte) (int, error)

func (*OSInfo) ProtoMessage 

func (*OSInfo) ProtoMessage()

func (*OSInfo) Reset 

func (m *OSInfo) Reset()

func (*OSInfo) Size 

func (m *OSInfo) Size() (n int)

func (*OSInfo) String 

func (m *OSInfo) String() string

func (*OSInfo) Unmarshal 

func (m *OSInfo) Unmarshal(data []byte) error

type Process 

type Process struct {
	Key                    uint32       `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"`
	Pid                    int32        `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	Host                   *Host        `protobuf:"bytes,3,opt,name=host" json:"host,omitempty"`
	Command                *Command     `protobuf:"bytes,4,opt,name=command" json:"command,omitempty"`
	User                   *ProcessUser `protobuf:"bytes,5,opt,name=user" json:"user,omitempty"`
	Memory                 *MemoryStat  `protobuf:"bytes,7,opt,name=memory" json:"memory,omitempty"`
	Cpu                    *CPUStat     `protobuf:"bytes,8,opt,name=cpu" json:"cpu,omitempty"`
	CreateTime             int64        `protobuf:"varint,9,opt,name=createTime,proto3" json:"createTime,omitempty"`
	Container              *Container   `protobuf:"bytes,10,opt,name=container" json:"container,omitempty"`
	OpenFdCount            int32        `protobuf:"varint,11,opt,name=openFdCount,proto3" json:"openFdCount,omitempty"`
	State                  ProcessState `protobuf:"varint,12,opt,name=state,proto3,enum=datadog.process_agent.ProcessState" json:"state,omitempty"`
	IoStat                 *IOStat      `protobuf:"bytes,13,opt,name=ioStat" json:"ioStat,omitempty"`
	ContainerId            string       `protobuf:"bytes,14,opt,name=containerId,proto3" json:"containerId,omitempty"`
	ContainerKey           uint32       `protobuf:"varint,15,opt,name=containerKey,proto3" json:"containerKey,omitempty"`
	VoluntaryCtxSwitches   uint64       `protobuf:"varint,16,opt,name=voluntaryCtxSwitches,proto3" json:"voluntaryCtxSwitches,omitempty"`
	InvoluntaryCtxSwitches uint64       `protobuf:"varint,17,opt,name=involuntaryCtxSwitches,proto3" json:"involuntaryCtxSwitches,omitempty"`
	ByteKey                []byte       `protobuf:"bytes,18,opt,name=byteKey,proto3" json:"byteKey,omitempty"`
	ContainerByteKey       []byte       `protobuf:"bytes,19,opt,name=containerByteKey,proto3" json:"containerByteKey,omitempty"`
}

func (*Process) Descriptor 

func (*Process) Descriptor() ([]byte, []int)

func (*Process) GetCommand 

func (m *Process) GetCommand() *Command

func (*Process) GetContainer 

func (m *Process) GetContainer() *Container

func (*Process) GetCpu 

func (m *Process) GetCpu() *CPUStat

func (*Process) GetHost 

func (m *Process) GetHost() *Host

func (*Process) GetIoStat 

func (m *Process) GetIoStat() *IOStat

func (*Process) GetMemory 

func (m *Process) GetMemory() *MemoryStat

func (*Process) GetUser 

func (m *Process) GetUser() *ProcessUser

func (*Process) Marshal 

func (m *Process) Marshal() (data []byte, err error)

func (*Process) MarshalTo 

func (m *Process) MarshalTo(data []byte) (int, error)

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) Reset 

func (m *Process) Reset()

func (*Process) Size 

func (m *Process) Size() (n int)

func (*Process) String 

func (m *Process) String() string

func (*Process) Unmarshal 

func (m *Process) Unmarshal(data []byte) error

type ProcessStat 

type ProcessStat struct {
	Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	// In milliseconds
	CreateTime  int64       `protobuf:"varint,2,opt,name=createTime,proto3" json:"createTime,omitempty"`
	Memory      *MemoryStat `protobuf:"bytes,3,opt,name=memory" json:"memory,omitempty"`
	Cpu         *CPUStat    `protobuf:"bytes,4,opt,name=cpu" json:"cpu,omitempty"`
	Nice        int32       `protobuf:"varint,5,opt,name=nice,proto3" json:"nice,omitempty"`
	Threads     int32       `protobuf:"varint,7,opt,name=threads,proto3" json:"threads,omitempty"`
	OpenFdCount int32       `protobuf:"varint,8,opt,name=openFdCount,proto3" json:"openFdCount,omitempty"`
	Key         uint32      `protobuf:"varint,9,opt,name=key,proto3" json:"key,omitempty"`
	// we need container id because we need to do the scoring by container
	ContainerId    string         `protobuf:"bytes,10,opt,name=containerId,proto3" json:"containerId,omitempty"`
	ContainerState ContainerState `protobuf:"varint,11,opt,name=containerState,proto3,enum=datadog.process_agent.ContainerState" json:"containerState,omitempty"`
	ProcessState   ProcessState   `protobuf:"varint,12,opt,name=processState,proto3,enum=datadog.process_agent.ProcessState" json:"processState,omitempty"`
	IoStat         *IOStat        `protobuf:"bytes,19,opt,name=ioStat" json:"ioStat,omitempty"`
	// DEPRECATED: All container-level stats (except ID) have moved into ContainerStat.
	// These will be removed in the future.
	// These stats are from the container level but are stored per-process
	// because we don't send a container primitive yet.
	ContainerHealth        ContainerHealth `` /* 128-byte string literal not displayed */
	ContainerRbps          float32         `protobuf:"fixed32,16,opt,name=containerRbps,proto3" json:"containerRbps,omitempty"`
	ContainerWbps          float32         `protobuf:"fixed32,17,opt,name=containerWbps,proto3" json:"containerWbps,omitempty"`
	ContainerKey           uint32          `protobuf:"varint,18,opt,name=containerKey,proto3" json:"containerKey,omitempty"`
	ContainerNetRcvdPs     float32         `protobuf:"fixed32,20,opt,name=containerNetRcvdPs,proto3" json:"containerNetRcvdPs,omitempty"`
	ContainerNetSentPs     float32         `protobuf:"fixed32,21,opt,name=containerNetSentPs,proto3" json:"containerNetSentPs,omitempty"`
	ContainerNetRcvdBps    float32         `protobuf:"fixed32,22,opt,name=containerNetRcvdBps,proto3" json:"containerNetRcvdBps,omitempty"`
	ContainerNetSentBps    float32         `protobuf:"fixed32,23,opt,name=containerNetSentBps,proto3" json:"containerNetSentBps,omitempty"`
	VoluntaryCtxSwitches   uint64          `protobuf:"varint,24,opt,name=voluntaryCtxSwitches,proto3" json:"voluntaryCtxSwitches,omitempty"`
	InvoluntaryCtxSwitches uint64          `protobuf:"varint,25,opt,name=involuntaryCtxSwitches,proto3" json:"involuntaryCtxSwitches,omitempty"`
	ByteKey                []byte          `protobuf:"bytes,26,opt,name=byteKey,proto3" json:"byteKey,omitempty"`
	ContainerByteKey       []byte          `protobuf:"bytes,27,opt,name=containerByteKey,proto3" json:"containerByteKey,omitempty"`
}

ProcessStat is used for real-time process messages. It should only contain data that can change for a running process (and relevant information to generate a key). We will send a lot of these in the real-time messages so it's critical to keep this small.

func (*ProcessStat) Descriptor 

func (*ProcessStat) Descriptor() ([]byte, []int)

func (*ProcessStat) GetCpu 

func (m *ProcessStat) GetCpu() *CPUStat

func (*ProcessStat) GetIoStat 

func (m *ProcessStat) GetIoStat() *IOStat

func (*ProcessStat) GetMemory 

func (m *ProcessStat) GetMemory() *MemoryStat

func (*ProcessStat) Marshal 

func (m *ProcessStat) Marshal() (data []byte, err error)

func (*ProcessStat) MarshalTo 

func (m *ProcessStat) MarshalTo(data []byte) (int, error)

func (*ProcessStat) ProtoMessage 

func (*ProcessStat) ProtoMessage()

func (*ProcessStat) Reset 

func (m *ProcessStat) Reset()

func (*ProcessStat) Size 

func (m *ProcessStat) Size() (n int)

func (*ProcessStat) String 

func (m *ProcessStat) String() string

func (*ProcessStat) Unmarshal 

func (m *ProcessStat) Unmarshal(data []byte) error

type ProcessState 

type ProcessState int32

Process state codes in http://wiki.preshweb.co.uk/doku.php?id=linux:psflags 

const (
	ProcessState_U ProcessState = 0
	ProcessState_D ProcessState = 1
	ProcessState_R ProcessState = 2
	ProcessState_S ProcessState = 3
	ProcessState_T ProcessState = 4
	ProcessState_W ProcessState = 5
	ProcessState_X ProcessState = 6
	ProcessState_Z ProcessState = 7
)

func (ProcessState) EnumDescriptor 

func (ProcessState) EnumDescriptor() ([]byte, []int)

func (ProcessState) String 

func (x ProcessState) String() string

type ProcessUser 

type ProcessUser struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Uid  int32  `protobuf:"varint,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Gid  int32  `protobuf:"varint,3,opt,name=gid,proto3" json:"gid,omitempty"`
	Euid int32  `protobuf:"varint,4,opt,name=euid,proto3" json:"euid,omitempty"`
	Egid int32  `protobuf:"varint,5,opt,name=egid,proto3" json:"egid,omitempty"`
	Suid int32  `protobuf:"varint,6,opt,name=suid,proto3" json:"suid,omitempty"`
	Sgid int32  `protobuf:"varint,7,opt,name=sgid,proto3" json:"sgid,omitempty"`
}

func (*ProcessUser) Descriptor 

func (*ProcessUser) Descriptor() ([]byte, []int)

func (*ProcessUser) Marshal 

func (m *ProcessUser) Marshal() (data []byte, err error)

func (*ProcessUser) MarshalTo 

func (m *ProcessUser) MarshalTo(data []byte) (int, error)

func (*ProcessUser) ProtoMessage 

func (*ProcessUser) ProtoMessage()

func (*ProcessUser) Reset 

func (m *ProcessUser) Reset()

func (*ProcessUser) Size 

func (m *ProcessUser) Size() (n int)

func (*ProcessUser) String 

func (m *ProcessUser) String() string

func (*ProcessUser) Unmarshal 

func (m *ProcessUser) Unmarshal(data []byte) error

type ResCollector 

type ResCollector struct {
	Header  *ResCollector_Header `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Message string               `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Status  *CollectorStatus     `protobuf:"bytes,3,opt,name=status" json:"status,omitempty"`
}

func (*ResCollector) Descriptor 

func (*ResCollector) Descriptor() ([]byte, []int)

func (*ResCollector) GetHeader 

func (m *ResCollector) GetHeader() *ResCollector_Header

func (*ResCollector) GetStatus 

func (m *ResCollector) GetStatus() *CollectorStatus

func (*ResCollector) Marshal 

func (m *ResCollector) Marshal() (data []byte, err error)

func (*ResCollector) MarshalTo 

func (m *ResCollector) MarshalTo(data []byte) (int, error)

func (*ResCollector) ProtoMessage 

func (*ResCollector) ProtoMessage()

func (*ResCollector) Reset 

func (m *ResCollector) Reset()

func (*ResCollector) Size 

func (m *ResCollector) Size() (n int)

func (*ResCollector) String 

func (m *ResCollector) String() string

func (*ResCollector) Unmarshal 

func (m *ResCollector) Unmarshal(data []byte) error

type ResCollector_Header 

type ResCollector_Header struct {
	Type int32 `protobuf:"varint,4,opt,name=type,proto3" json:"type,omitempty"`
}

Header must exist at position 1 for compatibility with older version of the Agent. We should be able to drop this at some point.

func (*ResCollector_Header) Descriptor 

func (*ResCollector_Header) Descriptor() ([]byte, []int)

func (*ResCollector_Header) Marshal 

func (m *ResCollector_Header) Marshal() (data []byte, err error)

func (*ResCollector_Header) MarshalTo 

func (m *ResCollector_Header) MarshalTo(data []byte) (int, error)

func (*ResCollector_Header) ProtoMessage 

func (*ResCollector_Header) ProtoMessage()

func (*ResCollector_Header) Reset 

func (m *ResCollector_Header) Reset()

func (*ResCollector_Header) Size 

func (m *ResCollector_Header) Size() (n int)

func (*ResCollector_Header) String 

func (m *ResCollector_Header) String() string

func (*ResCollector_Header) Unmarshal 

func (m *ResCollector_Header) Unmarshal(data []byte) error

type SingleCPUStat 

type SingleCPUStat struct {
	Name     string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	TotalPct float32 `protobuf:"fixed32,2,opt,name=totalPct,proto3" json:"totalPct,omitempty"`
}

func (*SingleCPUStat) Descriptor 

func (*SingleCPUStat) Descriptor() ([]byte, []int)

func (*SingleCPUStat) Marshal 

func (m *SingleCPUStat) Marshal() (data []byte, err error)

func (*SingleCPUStat) MarshalTo 

func (m *SingleCPUStat) MarshalTo(data []byte) (int, error)

func (*SingleCPUStat) ProtoMessage 

func (*SingleCPUStat) ProtoMessage()

func (*SingleCPUStat) Reset 

func (m *SingleCPUStat) Reset()

func (*SingleCPUStat) Size 

func (m *SingleCPUStat) Size() (n int)

func (*SingleCPUStat) String 

func (m *SingleCPUStat) String() string

func (*SingleCPUStat) Unmarshal 

func (m *SingleCPUStat) Unmarshal(data []byte) error

type SystemInfo 

type SystemInfo struct {
	Uuid        string     `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Os          *OSInfo    `protobuf:"bytes,2,opt,name=os" json:"os,omitempty"`
	Cpus        []*CPUInfo `protobuf:"bytes,3,rep,name=cpus" json:"cpus,omitempty"`
	TotalMemory int64      `protobuf:"varint,5,opt,name=totalMemory,proto3" json:"totalMemory,omitempty"`
}

func (*SystemInfo) Descriptor 

func (*SystemInfo) Descriptor() ([]byte, []int)

func (*SystemInfo) GetCpus 

func (m *SystemInfo) GetCpus() []*CPUInfo

func (*SystemInfo) GetOs 

func (m *SystemInfo) GetOs() *OSInfo

func (*SystemInfo) Marshal 

func (m *SystemInfo) Marshal() (data []byte, err error)

func (*SystemInfo) MarshalTo 

func (m *SystemInfo) MarshalTo(data []byte) (int, error)

func (*SystemInfo) ProtoMessage 

func (*SystemInfo) ProtoMessage()

func (*SystemInfo) Reset 

func (m *SystemInfo) Reset()

func (*SystemInfo) Size 

func (m *SystemInfo) Size() (n int)

func (*SystemInfo) String 

func (m *SystemInfo) String() string

func (*SystemInfo) Unmarshal 

func (m *SystemInfo) Unmarshal(data []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.