model

package
v0.99.35 Latest Latest
Warning

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

 Go to latest Published: Jul 14, 2017 License: BSD-3-Clause Imports: 10 Imported by: 9

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
	CollectorReqStatus
	CollectorStatus
	Process
	Command
	ProcessUser
	Container
	ProcessStat
	SystemInfo
	OSInfo
	Connection
	Addr
	MemoryStat
	CPUStat
	SingleCPUStat
	CPUInfo
	Host
	HostTags

message.go is a stripped down version of the backend message processing with support for the same MessageVersion and MessageEncoding but with only a limited set of message types.

Index

Constants

View Source 
const (
	MessageV1 MessageVersion = 1
	MessageV2                = 2
	MessageV3                = 3
)
View Source 
const (
	TypeCollectorProc        = 12
	TypeCollectorConnections = 22
	TypeResCollector         = 23
	TypeCollectorRealTime    = 27
)

Variables

View Source 
var (
	ErrInvalidLengthAgent = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAgent   = fmt.Errorf("proto: integer overflow")
)
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 {
	Host *Host  `protobuf:"bytes,1,opt,name=host" json:"host,omitempty"`
	Ip   string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	Port int32  `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
}

func (*Addr) Descriptor 

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

func (*Addr) GetHost 

func (m *Addr) GetHost() *Host

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"`
	Connections []*Connection `protobuf:"bytes,3,rep,name=connections" json:"connections,omitempty"`
	Host        *Host         `protobuf:"bytes,4,opt,name=host" json:"host,omitempty"`
}

func (*CollectorConnections) Descriptor 

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

func (*CollectorConnections) GetConnections 

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

func (*CollectorConnections) GetHost 

func (m *CollectorConnections) GetHost() *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 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"`
}

func (*CollectorProc) Descriptor 

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

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"`
}

func (*CollectorRealTime) Descriptor 

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

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"`
	Fd     int32  `protobuf:"varint,2,opt,name=fd,proto3" json:"fd,omitempty"`
	Family int32  `protobuf:"varint,3,opt,name=family,proto3" json:"family,omitempty"`
	Type   int32  `protobuf:"varint,4,opt,name=type,proto3" json:"type,omitempty"`
	Laddr  *Addr  `protobuf:"bytes,5,opt,name=laddr" json:"laddr,omitempty"`
	Raddr  *Addr  `protobuf:"bytes,6,opt,name=raddr" json:"raddr,omitempty"`
	Status string `protobuf:"bytes,7,opt,name=status,proto3" json:"status,omitempty"`
}

func (*Connection) Descriptor 

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

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 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"`
	// 7 is removed, do not use.
	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"`
	ContainerRbps float32         `protobuf:"fixed32,11,opt,name=containerRbps,proto3" json:"containerRbps,omitempty"`
	ContainerWbps float32         `protobuf:"fixed32,12,opt,name=containerWbps,proto3" json:"containerWbps,omitempty"`
}

func (*Container) Descriptor 

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

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 ContainerHealth added in v0.99.34 

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 added in v0.99.34 

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

func (ContainerHealth) String added in v0.99.34 

func (x ContainerHealth) String() string

type ContainerState added in v0.99.33 

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 added in v0.99.33 

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

func (ContainerState) String added in v0.99.33 

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"`
}

Host and HostTags are used in backend post-resolution

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 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
}

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
}

Message 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
)

type MessageHeader 

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

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

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"`
	// 6 is deprecated
	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"`
}

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) 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"`
	// 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"`
}

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) 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 added in v0.99.33 

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 added in v0.99.33 

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

func (ProcessState) String added in v0.99.33 

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"`
	// 4 is deprecated
	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.