Versions in this module Expand all Collapse all v0 v0.99.35 Jul 14, 2017 v0.99.34 Jul 12, 2017 Changes in this version + var ContainerHealth_name = map[int32]string + var ContainerHealth_value = map[string]int32 type Container + ContainerRbps float32 + ContainerWbps float32 + Health ContainerHealth + type ContainerHealth int32 + const ContainerHealth_healthy + const ContainerHealth_starting + const ContainerHealth_unhealthy + const ContainerHealth_unknownHealth + func (ContainerHealth) EnumDescriptor() ([]byte, []int) + func (x ContainerHealth) String() string type Process + State ProcessState type ProcessStat + ContainerHealth ContainerHealth + ContainerRbps float32 + ContainerWbps float32 v0.99.33 Jul 10, 2017 Changes in this version + var ContainerState_name = map[int32]string + var ContainerState_value = map[string]int32 + var ProcessState_name = map[int32]string + var ProcessState_value = map[string]int32 type Container + Created int64 + State ContainerState + type ContainerState int32 + const ContainerState_created + const ContainerState_dead + const ContainerState_exited + const ContainerState_paused + const ContainerState_restarting + const ContainerState_running + const ContainerState_unknown + func (ContainerState) EnumDescriptor() ([]byte, []int) + func (x ContainerState) String() string type ProcessStat + ContainerState ContainerState + ProcessState ProcessState + type ProcessState int32 + const ProcessState_D + const ProcessState_R + const ProcessState_S + const ProcessState_T + const ProcessState_U + const ProcessState_W + const ProcessState_X + const ProcessState_Z + func (ProcessState) EnumDescriptor() ([]byte, []int) + func (x ProcessState) String() string v0.99.32 Jul 6, 2017 Changes in this version type Container + Status string v0.99.31 Jun 29, 2017 Changes in this version type ProcessStat + ContainerId string v0.99.29 Jun 27, 2017 Changes in this version + const MessageV1 + const MessageV2 + const MessageV3 + const TypeCollectorConnections + const TypeCollectorProc + const TypeCollectorRealTime + const TypeResCollector + var ErrIntOverflowAgent = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthAgent = fmt.Errorf("proto: negative length found during unmarshaling") + func EncodeMessage(m Message) ([]byte, error) + type Addr struct + Host *Host + Ip string + Port int32 + func (*Addr) Descriptor() ([]byte, []int) + func (*Addr) ProtoMessage() + func (m *Addr) GetHost() *Host + func (m *Addr) Marshal() (data []byte, err error) + func (m *Addr) MarshalTo(data []byte) (int, error) + func (m *Addr) Reset() + func (m *Addr) Size() (n int) + func (m *Addr) String() string + func (m *Addr) Unmarshal(data []byte) error + type CPUInfo struct + CacheSize int32 + CoreId string + Cores int32 + Family string + Mhz int64 + Model string + Number int32 + PhysicalId string + Vendor string + func (*CPUInfo) Descriptor() ([]byte, []int) + func (*CPUInfo) ProtoMessage() + func (m *CPUInfo) Marshal() (data []byte, err error) + func (m *CPUInfo) MarshalTo(data []byte) (int, error) + func (m *CPUInfo) Reset() + func (m *CPUInfo) Size() (n int) + func (m *CPUInfo) String() string + func (m *CPUInfo) Unmarshal(data []byte) error + type CPUStat struct + Cpus []*SingleCPUStat + LastCpu string + Nice int32 + NumThreads int32 + SystemPct float32 + SystemTime int64 + TotalPct float32 + UserPct float32 + UserTime int64 + func (*CPUStat) Descriptor() ([]byte, []int) + func (*CPUStat) ProtoMessage() + func (m *CPUStat) GetCpus() []*SingleCPUStat + func (m *CPUStat) Marshal() (data []byte, err error) + func (m *CPUStat) MarshalTo(data []byte) (int, error) + func (m *CPUStat) Reset() + func (m *CPUStat) Size() (n int) + func (m *CPUStat) String() string + func (m *CPUStat) Unmarshal(data []byte) error + type CollectorConnections struct + Connections []*Connection + Host *Host + HostName string + func (*CollectorConnections) Descriptor() ([]byte, []int) + func (*CollectorConnections) ProtoMessage() + func (m *CollectorConnections) GetConnections() []*Connection + func (m *CollectorConnections) GetHost() *Host + func (m *CollectorConnections) Marshal() (data []byte, err error) + func (m *CollectorConnections) MarshalTo(data []byte) (int, error) + func (m *CollectorConnections) Reset() + func (m *CollectorConnections) Size() (n int) + func (m *CollectorConnections) String() string + func (m *CollectorConnections) Unmarshal(data []byte) error + type CollectorProc struct + GroupId int32 + GroupSize int32 + Host *Host + HostName string + Info *SystemInfo + Kubernetes *datadog_agentpayload.KubeMetadataPayload + Processes []*Process + func (*CollectorProc) Descriptor() ([]byte, []int) + func (*CollectorProc) ProtoMessage() + func (m *CollectorProc) GetHost() *Host + func (m *CollectorProc) GetInfo() *SystemInfo + func (m *CollectorProc) GetKubernetes() *datadog_agentpayload.KubeMetadataPayload + func (m *CollectorProc) GetProcesses() []*Process + func (m *CollectorProc) Marshal() (data []byte, err error) + func (m *CollectorProc) MarshalTo(data []byte) (int, error) + func (m *CollectorProc) Reset() + func (m *CollectorProc) Size() (n int) + func (m *CollectorProc) String() string + func (m *CollectorProc) Unmarshal(data []byte) error + type CollectorRealTime struct + GroupId int32 + GroupSize int32 + HostId int32 + HostName string + NumCpus int32 + OrgId int32 + Stats []*ProcessStat + TotalMemory int64 + func (*CollectorRealTime) Descriptor() ([]byte, []int) + func (*CollectorRealTime) ProtoMessage() + func (m *CollectorRealTime) GetStats() []*ProcessStat + func (m *CollectorRealTime) Marshal() (data []byte, err error) + func (m *CollectorRealTime) MarshalTo(data []byte) (int, error) + func (m *CollectorRealTime) Reset() + func (m *CollectorRealTime) Size() (n int) + func (m *CollectorRealTime) String() string + func (m *CollectorRealTime) Unmarshal(data []byte) error + type CollectorReqStatus struct + HostName string + func (*CollectorReqStatus) Descriptor() ([]byte, []int) + func (*CollectorReqStatus) ProtoMessage() + func (m *CollectorReqStatus) Marshal() (data []byte, err error) + func (m *CollectorReqStatus) MarshalTo(data []byte) (int, error) + func (m *CollectorReqStatus) Reset() + func (m *CollectorReqStatus) Size() (n int) + func (m *CollectorReqStatus) String() string + func (m *CollectorReqStatus) Unmarshal(data []byte) error + type CollectorStatus struct + ActiveClients int32 + Interval int32 + func (*CollectorStatus) Descriptor() ([]byte, []int) + func (*CollectorStatus) ProtoMessage() + func (m *CollectorStatus) Marshal() (data []byte, err error) + func (m *CollectorStatus) MarshalTo(data []byte) (int, error) + func (m *CollectorStatus) Reset() + func (m *CollectorStatus) Size() (n int) + func (m *CollectorStatus) String() string + func (m *CollectorStatus) Unmarshal(data []byte) error + type Command struct + Args []string + Cwd string + Exe string + OnDisk bool + Pgroup int32 + Ppid int32 + Root string + State string + func (*Command) Descriptor() ([]byte, []int) + func (*Command) ProtoMessage() + func (m *Command) Marshal() (data []byte, err error) + func (m *Command) MarshalTo(data []byte) (int, error) + func (m *Command) Reset() + func (m *Command) Size() (n int) + func (m *Command) String() string + func (m *Command) Unmarshal(data []byte) error + type Connection struct + Family int32 + Fd int32 + Laddr *Addr + Pid int32 + Raddr *Addr + Status string + Type int32 + func (*Connection) Descriptor() ([]byte, []int) + func (*Connection) ProtoMessage() + func (m *Connection) GetLaddr() *Addr + func (m *Connection) GetRaddr() *Addr + func (m *Connection) Marshal() (data []byte, err error) + func (m *Connection) MarshalTo(data []byte) (int, error) + func (m *Connection) Reset() + func (m *Connection) Size() (n int) + func (m *Connection) String() string + func (m *Connection) Unmarshal(data []byte) error + type Container struct + CpuLimit float32 + Id string + Image string + MemoryLimit uint64 + Name string + Type string + func (*Container) Descriptor() ([]byte, []int) + func (*Container) ProtoMessage() + func (m *Container) Marshal() (data []byte, err error) + func (m *Container) MarshalTo(data []byte) (int, error) + func (m *Container) Reset() + func (m *Container) Size() (n int) + func (m *Container) String() string + func (m *Container) Unmarshal(data []byte) error + type Host struct + AllTags []string + Id int32 + Name string + NumCpus int32 + OrgId int32 + Tags []*HostTags + TotalMemory int64 + func (*Host) Descriptor() ([]byte, []int) + func (*Host) ProtoMessage() + func (m *Host) GetTags() []*HostTags + func (m *Host) Marshal() (data []byte, err error) + func (m *Host) MarshalTo(data []byte) (int, error) + func (m *Host) Reset() + func (m *Host) Size() (n int) + func (m *Host) String() string + func (m *Host) Unmarshal(data []byte) error + type HostTags struct + SourceType uint32 + Tags []string + func (*HostTags) Descriptor() ([]byte, []int) + func (*HostTags) ProtoMessage() + func (m *HostTags) Marshal() (data []byte, err error) + func (m *HostTags) MarshalTo(data []byte) (int, error) + func (m *HostTags) Reset() + func (m *HostTags) Size() (n int) + func (m *HostTags) String() string + func (m *HostTags) Unmarshal(data []byte) error + type MemoryStat struct + Data uint64 + Dirty uint64 + Lib uint64 + Rss uint64 + Shared uint64 + Swap uint64 + Text uint64 + Vms uint64 + func (*MemoryStat) Descriptor() ([]byte, []int) + func (*MemoryStat) ProtoMessage() + func (m *MemoryStat) Marshal() (data []byte, err error) + func (m *MemoryStat) MarshalTo(data []byte) (int, error) + func (m *MemoryStat) Reset() + func (m *MemoryStat) Size() (n int) + func (m *MemoryStat) String() string + func (m *MemoryStat) Unmarshal(data []byte) error + type Message struct + Body MessageBody + Header MessageHeader + func DecodeMessage(data []byte) (Message, error) + type MessageBody interface + ProtoMessage func() + Reset func() + Size func() int + String func() string + type MessageEncoding uint8 + const MessageEncodingJSON + const MessageEncodingProtobuf + const MessageEncodingZstdPB + type MessageHeader struct + Encoding MessageEncoding + OrgID int32 + SubscriptionID uint8 + Timestamp int64 + Type MessageType + Version MessageVersion + func ReadHeader(data []byte) (MessageHeader, int, error) + type MessageType uint8 + func DetectMessageType(b MessageBody) (MessageType, error) + type MessageVersion uint8 + type OSInfo struct + Family string + KernelVersion string + Name string + Platform string + Version string + func (*OSInfo) Descriptor() ([]byte, []int) + func (*OSInfo) ProtoMessage() + func (m *OSInfo) Marshal() (data []byte, err error) + func (m *OSInfo) MarshalTo(data []byte) (int, error) + func (m *OSInfo) Reset() + func (m *OSInfo) Size() (n int) + func (m *OSInfo) String() string + func (m *OSInfo) Unmarshal(data []byte) error + type Process struct + Command *Command + Container *Container + Cpu *CPUStat + CreateTime int64 + Host *Host + Key uint32 + Memory *MemoryStat + OpenFdCount int32 + Pid int32 + User *ProcessUser + func (*Process) Descriptor() ([]byte, []int) + func (*Process) ProtoMessage() + func (m *Process) GetCommand() *Command + func (m *Process) GetContainer() *Container + func (m *Process) GetCpu() *CPUStat + func (m *Process) GetHost() *Host + func (m *Process) GetMemory() *MemoryStat + func (m *Process) GetUser() *ProcessUser + func (m *Process) Marshal() (data []byte, err error) + func (m *Process) MarshalTo(data []byte) (int, error) + func (m *Process) Reset() + func (m *Process) Size() (n int) + func (m *Process) String() string + func (m *Process) Unmarshal(data []byte) error + type ProcessStat struct + Cpu *CPUStat + CreateTime int64 + Key uint32 + Memory *MemoryStat + Nice int32 + OpenFdCount int32 + Pid int32 + State int32 + Threads int32 + func (*ProcessStat) Descriptor() ([]byte, []int) + func (*ProcessStat) ProtoMessage() + func (m *ProcessStat) GetCpu() *CPUStat + func (m *ProcessStat) GetMemory() *MemoryStat + func (m *ProcessStat) Marshal() (data []byte, err error) + func (m *ProcessStat) MarshalTo(data []byte) (int, error) + func (m *ProcessStat) Reset() + func (m *ProcessStat) Size() (n int) + func (m *ProcessStat) String() string + func (m *ProcessStat) Unmarshal(data []byte) error + type ProcessUser struct + Egid int32 + Euid int32 + Gid int32 + Name string + Sgid int32 + Suid int32 + Uid int32 + func (*ProcessUser) Descriptor() ([]byte, []int) + func (*ProcessUser) ProtoMessage() + func (m *ProcessUser) Marshal() (data []byte, err error) + func (m *ProcessUser) MarshalTo(data []byte) (int, error) + func (m *ProcessUser) Reset() + func (m *ProcessUser) Size() (n int) + func (m *ProcessUser) String() string + func (m *ProcessUser) Unmarshal(data []byte) error + type ResCollector struct + Header *ResCollector_Header + Message string + Status *CollectorStatus + func (*ResCollector) Descriptor() ([]byte, []int) + func (*ResCollector) ProtoMessage() + func (m *ResCollector) GetHeader() *ResCollector_Header + func (m *ResCollector) GetStatus() *CollectorStatus + func (m *ResCollector) Marshal() (data []byte, err error) + func (m *ResCollector) MarshalTo(data []byte) (int, error) + func (m *ResCollector) Reset() + func (m *ResCollector) Size() (n int) + func (m *ResCollector) String() string + func (m *ResCollector) Unmarshal(data []byte) error + type ResCollector_Header struct + Type int32 + func (*ResCollector_Header) Descriptor() ([]byte, []int) + func (*ResCollector_Header) ProtoMessage() + func (m *ResCollector_Header) Marshal() (data []byte, err error) + func (m *ResCollector_Header) MarshalTo(data []byte) (int, error) + func (m *ResCollector_Header) Reset() + func (m *ResCollector_Header) Size() (n int) + func (m *ResCollector_Header) String() string + func (m *ResCollector_Header) Unmarshal(data []byte) error + type SingleCPUStat struct + Name string + TotalPct float32 + func (*SingleCPUStat) Descriptor() ([]byte, []int) + func (*SingleCPUStat) ProtoMessage() + func (m *SingleCPUStat) Marshal() (data []byte, err error) + func (m *SingleCPUStat) MarshalTo(data []byte) (int, error) + func (m *SingleCPUStat) Reset() + func (m *SingleCPUStat) Size() (n int) + func (m *SingleCPUStat) String() string + func (m *SingleCPUStat) Unmarshal(data []byte) error + type SystemInfo struct + Cpus []*CPUInfo + Os *OSInfo + TotalMemory int64 + Uuid string + func (*SystemInfo) Descriptor() ([]byte, []int) + func (*SystemInfo) ProtoMessage() + func (m *SystemInfo) GetCpus() []*CPUInfo + func (m *SystemInfo) GetOs() *OSInfo + func (m *SystemInfo) Marshal() (data []byte, err error) + func (m *SystemInfo) MarshalTo(data []byte) (int, error) + func (m *SystemInfo) Reset() + func (m *SystemInfo) Size() (n int) + func (m *SystemInfo) String() string + func (m *SystemInfo) Unmarshal(data []byte) error