process

package
v4.54.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Jan 19, 2021 License: BSD-3-Clause Imports: 13 Imported by: 8

Documentation

Overview

Package process is a generated protocol buffer package.

It is generated from these files: 

proto/process/agent.proto

It has these top-level messages: 

ResCollector
CollectorProc
CollectorConnections
CollectorRealTime
CollectorContainer
CollectorContainerRealTime
CollectorReqStatus
CollectorPod
CollectorReplicaSet
CollectorDeployment
CollectorService
CollectorNode
CollectorManifest
CollectorStatus
Process
Command
ProcessUser
ContainerAddr
Container
ProcessStat
ContainerStat
ContainerMetadata
SystemInfo
OSInfo
IOStat
Connection
Connections
Addr
IPTranslation
MemoryStat
CPUStat
SingleCPUStat
CPUInfo
Host
DNSEntry
Metadata
OwnerReference
ServicePort
ServiceSessionAffinityConfig
Node
NodeStatus
NodeCondition
ContainerImage
Taint
ServiceSpec
ServiceStatus
Service
Deployment
ReplicaSet
LabelSelectorRequirement
Pod
ContainerStatus
Manifest
ResourceRequirements
ConnectionsTelemetry
CollectorConnectionsTelemetry
DNSStats

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
	TypeCollectorPod               = 41
	TypeCollectorReplicaSet        = 42
	TypeCollectorDeployment        = 43
	TypeCollectorService           = 44
	TypeCollectorNode              = 45
	TypeCollectorManifest          = 80
)

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",
	4: "none",
}
View Source 
var ConnectionDirection_value = map[string]int32{
	"unspecified": 0,
	"incoming":    1,
	"outgoing":    2,
	"local":       3,
	"none":        4,
}
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 ContainerHostType_name = map[int32]string{
	0: "notSpecified",
	1: "fargateECS",
	2: "fargateEKS",
}
View Source 
var ContainerHostType_value = map[string]int32{
	"notSpecified": 0,
	"fargateECS":   1,
	"fargateEKS":   2,
}
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,
}
View Source 
var ResourceRequirementsType_name = map[int32]string{
	0: "unknownType",
	1: "container",
	2: "initContainer",
	3: "ephemeralContainer",
}
View Source 
var ResourceRequirementsType_value = map[string]int32{
	"unknownType":        0,
	"container":          1,
	"initContainer":      2,
	"ephemeralContainer": 3,
}

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.

func GetDNS 

func GetDNS(buf []byte, ip string) (string, []string)

GetDNS gets the DNS entries for the given IP from the given buffer

func IterateDNS 

func IterateDNS(buf []byte, ip string, cb func(i, total int, entry string) bool)

IterateDNS invokes the callback function for each DNS entry for the given IP in the given buffer

func UnsafeIterateDNS 

func UnsafeIterateDNS(buf []byte, ip string, cb func(i, total int, entry []byte) bool)

UnsafeIterateDNS invokes the callback function for each DNS entry for the given IP in the given buffer. Each entry is a the slice from the overall buffer. It should be copied before use

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      int64  `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"`
	NetworkId   string        `protobuf:"bytes,12,opt,name=networkId,proto3" json:"networkId,omitempty"`
	HostId      int64         `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"`
	// Mapping of hostId to Host. Each `connection` has a hostId field which can be mapped here.
	// This should also include an entry for the host on which these connections were gathered.
	ResolvedHosts map[int64]*Host `` /* 154-byte string literal not displayed */
	// Mapping of containerId to container data. Each `connection` has a containerId field which can be mapped here.
	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 */
	EncodedTags       []byte                         `protobuf:"bytes,11,opt,name=encodedTags,proto3" json:"encodedTags,omitempty"`
	EncodedDNS        []byte                         `protobuf:"bytes,14,opt,name=encodedDNS,proto3" json:"encodedDNS,omitempty"`
	ContainerHostType ContainerHostType              `` /* 134-byte string literal not displayed */
	Telemetry         *CollectorConnectionsTelemetry `protobuf:"bytes,16,opt,name=telemetry" json:"telemetry,omitempty"`
	// OS Telemetry
	Architecture    string `protobuf:"bytes,17,opt,name=architecture,proto3" json:"architecture,omitempty"`
	KernelVersion   string `protobuf:"bytes,18,opt,name=kernelVersion,proto3" json:"kernelVersion,omitempty"`
	Platform        string `protobuf:"bytes,19,opt,name=platform,proto3" json:"platform,omitempty"`
	PlatformVersion string `protobuf:"bytes,20,opt,name=platformVersion,proto3" json:"platformVersion,omitempty"`
	// All queried DNS domains for which we have collected stats
	Domains []string `protobuf:"bytes,30,rep,name=domains" json:"domains,omitempty"`
}

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

func (m *CollectorConnections) GetContainerTags(container *ContainerMetadata) []string

func (*CollectorConnections) GetDNS 

func (m *CollectorConnections) GetDNS(addr *Addr) (string, []string)

GetDNS returns the DNS entries for the given addr. The first argument returned is the first DNS entry followed by any additional name resolutions. Most IPs will have a single resolution so this dual format allows us to avoid allocations for the common case. If there are multiple name resolutions, there is no implied priority between the dual values

func (*CollectorConnections) GetDNSNames 

func (m *CollectorConnections) GetDNSNames() []string

GetDNSNames returns all the DNS entries

func (*CollectorConnections) GetHostTags 

func (m *CollectorConnections) GetHostTags(host *Host) []string

func (*CollectorConnections) GetResolvedContainers 

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

func (*CollectorConnections) GetResolvedHosts 

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

func (*CollectorConnections) GetTags 

func (m *CollectorConnections) GetTags(tagIndex int) []string

func (*CollectorConnections) GetTelemetry 

func (m *CollectorConnections) GetTelemetry() *CollectorConnectionsTelemetry

func (*CollectorConnections) IterateContainerTags 

func (m *CollectorConnections) IterateContainerTags(container *ContainerMetadata, cb func(i, total int, tag string) bool)

func (*CollectorConnections) IterateDNS 

func (m *CollectorConnections) IterateDNS(addr *Addr, cb func(i, total int, entry string) bool)

IterateDNS iterates over all of the DNS entries for the given addr, invoking the provided callback for each one

func (*CollectorConnections) IterateHostTags 

func (m *CollectorConnections) IterateHostTags(host *Host, cb func(i, total int, tag string) bool)

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 CollectorConnectionsTelemetry 

type CollectorConnectionsTelemetry struct {
	KprobesTriggered          int64 `protobuf:"varint,1,opt,name=kprobesTriggered,proto3" json:"kprobesTriggered,omitempty"`
	KprobesMissed             int64 `protobuf:"varint,2,opt,name=kprobesMissed,proto3" json:"kprobesMissed,omitempty"`
	ConntrackRegisters        int64 `protobuf:"varint,3,opt,name=conntrackRegisters,proto3" json:"conntrackRegisters,omitempty"`
	ConntrackRegistersDropped int64 `protobuf:"varint,4,opt,name=conntrackRegistersDropped,proto3" json:"conntrackRegistersDropped,omitempty"`
	DnsPacketsProcessed       int64 `protobuf:"varint,5,opt,name=dnsPacketsProcessed,proto3" json:"dnsPacketsProcessed,omitempty"`
	ConnsClosed               int64 `protobuf:"varint,6,opt,name=connsClosed,proto3" json:"connsClosed,omitempty"`
	ConnsBpfMapSize           int64 `protobuf:"varint,7,opt,name=connsBpfMapSize,proto3" json:"connsBpfMapSize,omitempty"`
	UdpSendsProcessed         int64 `protobuf:"varint,8,opt,name=udpSendsProcessed,proto3" json:"udpSendsProcessed,omitempty"`
	UdpSendsMissed            int64 `protobuf:"varint,9,opt,name=udpSendsMissed,proto3" json:"udpSendsMissed,omitempty"`
	ConntrackSamplingPercent  int64 `protobuf:"varint,10,opt,name=conntrackSamplingPercent,proto3" json:"conntrackSamplingPercent,omitempty"`
}

func (*CollectorConnectionsTelemetry) Descriptor 

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

func (*CollectorConnectionsTelemetry) Marshal 

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

func (*CollectorConnectionsTelemetry) MarshalTo 

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

func (*CollectorConnectionsTelemetry) ProtoMessage 

func (*CollectorConnectionsTelemetry) ProtoMessage()

func (*CollectorConnectionsTelemetry) Reset 

func (m *CollectorConnectionsTelemetry) Reset()

func (*CollectorConnectionsTelemetry) Size 

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

func (*CollectorConnectionsTelemetry) String 

func (m *CollectorConnectionsTelemetry) String() string

func (*CollectorConnectionsTelemetry) Unmarshal 

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

type CollectorContainer 

type CollectorContainer struct {
	HostName   string       `protobuf:"bytes,1,opt,name=hostName,proto3" json:"hostName,omitempty"`
	NetworkId  string       `protobuf:"bytes,11,opt,name=networkId,proto3" json:"networkId,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"`
	ContainerHostType ContainerHostType `` /* 133-byte string literal not displayed */
}

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            int64             `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"`
	ContainerHostType ContainerHostType `` /* 133-byte string literal not displayed */
}

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 CollectorDeployment 

type CollectorDeployment struct {
	ClusterName string        `protobuf:"bytes,1,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	ClusterId   string        `protobuf:"bytes,2,opt,name=clusterId,proto3" json:"clusterId,omitempty"`
	GroupId     int32         `protobuf:"varint,3,opt,name=groupId,proto3" json:"groupId,omitempty"`
	GroupSize   int32         `protobuf:"varint,4,opt,name=groupSize,proto3" json:"groupSize,omitempty"`
	Deployments []*Deployment `protobuf:"bytes,5,rep,name=deployments" json:"deployments,omitempty"`
	Tags        []string      `protobuf:"bytes,6,rep,name=tags" json:"tags,omitempty"`
}

func (*CollectorDeployment) Descriptor 

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

func (*CollectorDeployment) GetDeployments 

func (m *CollectorDeployment) GetDeployments() []*Deployment

func (*CollectorDeployment) Marshal 

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

func (*CollectorDeployment) MarshalTo 

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

func (*CollectorDeployment) ProtoMessage 

func (*CollectorDeployment) ProtoMessage()

func (*CollectorDeployment) Reset 

func (m *CollectorDeployment) Reset()

func (*CollectorDeployment) Size 

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

func (*CollectorDeployment) String 

func (m *CollectorDeployment) String() string

func (*CollectorDeployment) Unmarshal 

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

type CollectorManifest 

type CollectorManifest struct {
	ClusterName string      `protobuf:"bytes,1,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	ClusterId   string      `protobuf:"bytes,2,opt,name=clusterId,proto3" json:"clusterId,omitempty"`
	GroupId     int32       `protobuf:"varint,3,opt,name=groupId,proto3" json:"groupId,omitempty"`
	GroupSize   int32       `protobuf:"varint,4,opt,name=groupSize,proto3" json:"groupSize,omitempty"`
	Manifests   []*Manifest `protobuf:"bytes,5,rep,name=manifests" json:"manifests,omitempty"`
}

func (*CollectorManifest) Descriptor 

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

func (*CollectorManifest) GetManifests 

func (m *CollectorManifest) GetManifests() []*Manifest

func (*CollectorManifest) Marshal 

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

func (*CollectorManifest) MarshalTo 

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

func (*CollectorManifest) ProtoMessage 

func (*CollectorManifest) ProtoMessage()

func (*CollectorManifest) Reset 

func (m *CollectorManifest) Reset()

func (*CollectorManifest) Size 

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

func (*CollectorManifest) String 

func (m *CollectorManifest) String() string

func (*CollectorManifest) Unmarshal 

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

type CollectorNode 

type CollectorNode struct {
	ClusterName string   `protobuf:"bytes,1,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	ClusterId   string   `protobuf:"bytes,2,opt,name=clusterId,proto3" json:"clusterId,omitempty"`
	GroupId     int32    `protobuf:"varint,3,opt,name=groupId,proto3" json:"groupId,omitempty"`
	GroupSize   int32    `protobuf:"varint,4,opt,name=groupSize,proto3" json:"groupSize,omitempty"`
	Nodes       []*Node  `protobuf:"bytes,5,rep,name=nodes" json:"nodes,omitempty"`
	Tags        []string `protobuf:"bytes,6,rep,name=tags" json:"tags,omitempty"`
}

func (*CollectorNode) Descriptor 

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

func (*CollectorNode) GetNodes 

func (m *CollectorNode) GetNodes() []*Node

func (*CollectorNode) Marshal 

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

func (*CollectorNode) MarshalTo 

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

func (*CollectorNode) ProtoMessage 

func (*CollectorNode) ProtoMessage()

func (*CollectorNode) Reset 

func (m *CollectorNode) Reset()

func (*CollectorNode) Size 

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

func (*CollectorNode) String 

func (m *CollectorNode) String() string

func (*CollectorNode) Unmarshal 

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

type CollectorPod 

type CollectorPod struct {
	HostName    string   `protobuf:"bytes,1,opt,name=hostName,proto3" json:"hostName,omitempty"`
	ClusterName string   `protobuf:"bytes,2,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	ClusterId   string   `protobuf:"bytes,3,opt,name=clusterId,proto3" json:"clusterId,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"`
	Pods        []*Pod   `protobuf:"bytes,6,rep,name=pods" json:"pods,omitempty"`
	Host        *Host    `protobuf:"bytes,7,opt,name=host" json:"host,omitempty"`
	Tags        []string `protobuf:"bytes,8,rep,name=tags" json:"tags,omitempty"`
}

func (*CollectorPod) Descriptor 

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

func (*CollectorPod) GetHost 

func (m *CollectorPod) GetHost() *Host

func (*CollectorPod) GetPods 

func (m *CollectorPod) GetPods() []*Pod

func (*CollectorPod) Marshal 

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

func (*CollectorPod) MarshalTo 

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

func (*CollectorPod) ProtoMessage 

func (*CollectorPod) ProtoMessage()

func (*CollectorPod) Reset 

func (m *CollectorPod) Reset()

func (*CollectorPod) Size 

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

func (*CollectorPod) String 

func (m *CollectorPod) String() string

func (*CollectorPod) Unmarshal 

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

type CollectorProc 

type CollectorProc struct {
	HostName  string      `protobuf:"bytes,2,opt,name=hostName,proto3" json:"hostName,omitempty"`
	NetworkId string      `protobuf:"bytes,11,opt,name=networkId,proto3" json:"networkId,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"`
	ContainerHostType ContainerHostType                         `` /* 134-byte string literal not displayed */
}

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            int64             `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"`
	ContainerHostType ContainerHostType `` /* 134-byte string literal not displayed */
}

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 CollectorReplicaSet 

type CollectorReplicaSet struct {
	ClusterName string        `protobuf:"bytes,1,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	ClusterId   string        `protobuf:"bytes,2,opt,name=clusterId,proto3" json:"clusterId,omitempty"`
	GroupId     int32         `protobuf:"varint,3,opt,name=groupId,proto3" json:"groupId,omitempty"`
	GroupSize   int32         `protobuf:"varint,4,opt,name=groupSize,proto3" json:"groupSize,omitempty"`
	ReplicaSets []*ReplicaSet `protobuf:"bytes,5,rep,name=replicaSets" json:"replicaSets,omitempty"`
	Tags        []string      `protobuf:"bytes,6,rep,name=tags" json:"tags,omitempty"`
}

func (*CollectorReplicaSet) Descriptor 

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

func (*CollectorReplicaSet) GetReplicaSets 

func (m *CollectorReplicaSet) GetReplicaSets() []*ReplicaSet

func (*CollectorReplicaSet) Marshal 

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

func (*CollectorReplicaSet) MarshalTo 

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

func (*CollectorReplicaSet) ProtoMessage 

func (*CollectorReplicaSet) ProtoMessage()

func (*CollectorReplicaSet) Reset 

func (m *CollectorReplicaSet) Reset()

func (*CollectorReplicaSet) Size 

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

func (*CollectorReplicaSet) String 

func (m *CollectorReplicaSet) String() string

func (*CollectorReplicaSet) Unmarshal 

func (m *CollectorReplicaSet) 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 CollectorService 

type CollectorService struct {
	ClusterName string     `protobuf:"bytes,1,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	ClusterId   string     `protobuf:"bytes,2,opt,name=clusterId,proto3" json:"clusterId,omitempty"`
	GroupId     int32      `protobuf:"varint,3,opt,name=groupId,proto3" json:"groupId,omitempty"`
	GroupSize   int32      `protobuf:"varint,4,opt,name=groupSize,proto3" json:"groupSize,omitempty"`
	Services    []*Service `protobuf:"bytes,5,rep,name=services" json:"services,omitempty"`
	Tags        []string   `protobuf:"bytes,6,rep,name=tags" json:"tags,omitempty"`
}

func (*CollectorService) Descriptor 

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

func (*CollectorService) GetServices 

func (m *CollectorService) GetServices() []*Service

func (*CollectorService) Marshal 

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

func (*CollectorService) MarshalTo 

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

func (*CollectorService) ProtoMessage 

func (*CollectorService) ProtoMessage()

func (*CollectorService) Reset 

func (m *CollectorService) Reset()

func (*CollectorService) Size 

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

func (*CollectorService) String 

func (m *CollectorService) String() string

func (*CollectorService) Unmarshal 

func (m *CollectorService) 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"`
	// 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"`
	// NetworkID of the remote address (post-resolution field)
	RemoteNetworkId string `protobuf:"bytes,32,opt,name=remoteNetworkId,proto3" json:"remoteNetworkId,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"`
	// TCP-specific metrics
	Rtt    uint32 `protobuf:"varint,22,opt,name=rtt,proto3" json:"rtt,omitempty"`
	RttVar uint32 `protobuf:"varint,23,opt,name=rttVar,proto3" json:"rttVar,omitempty"`
	// Indicates that this connection begins and ends on the same host
	IntraHost bool `protobuf:"varint,24,opt,name=intraHost,proto3" json:"intraHost,omitempty"`
	// DNS-specific metrics
	DnsSuccessfulResponses uint32            `protobuf:"varint,25,opt,name=dnsSuccessfulResponses,proto3" json:"dnsSuccessfulResponses,omitempty"`
	DnsFailedResponses     uint32            `protobuf:"varint,26,opt,name=dnsFailedResponses,proto3" json:"dnsFailedResponses,omitempty"`
	DnsTimeouts            uint32            `protobuf:"varint,27,opt,name=dnsTimeouts,proto3" json:"dnsTimeouts,omitempty"`
	DnsSuccessLatencySum   uint64            `protobuf:"varint,28,opt,name=dnsSuccessLatencySum,proto3" json:"dnsSuccessLatencySum,omitempty"`
	DnsFailureLatencySum   uint64            `protobuf:"varint,29,opt,name=dnsFailureLatencySum,proto3" json:"dnsFailureLatencySum,omitempty"`
	DnsCountByRcode        map[uint32]uint32 `` /* 167-byte string literal not displayed */
	// TCP state transition counters relative to last check
	LastTcpEstablished uint32 `protobuf:"varint,30,opt,name=lastTcpEstablished,proto3" json:"lastTcpEstablished,omitempty"`
	LastTcpClosed      uint32 `protobuf:"varint,31,opt,name=lastTcpClosed,proto3" json:"lastTcpClosed,omitempty"`
	// dns stats based on domain queried, the key corresponds to an index into the `domains` field
	DnsStatsByDomain map[int32]*DNSStats `` /* 161-byte string literal not displayed */
}

func (*Connection) Descriptor 

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

func (*Connection) GetDnsCountByRcode 

func (m *Connection) GetDnsCountByRcode() map[uint32]uint32

func (*Connection) GetDnsStatsByDomain 

func (m *Connection) GetDnsStatsByDomain() map[int32]*DNSStats

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
	ConnectionDirection_none        ConnectionDirection = 4
)

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 Connections 

type Connections struct {
	Conns     []*Connection         `protobuf:"bytes,1,rep,name=conns" json:"conns,omitempty"`
	Dns       map[string]*DNSEntry  `` /* 133-byte string literal not displayed */
	Telemetry *ConnectionsTelemetry `protobuf:"bytes,3,opt,name=telemetry" json:"telemetry,omitempty"`
	Domains   []string              `protobuf:"bytes,4,rep,name=domains" json:"domains,omitempty"`
}

func (*Connections) Descriptor 

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

func (*Connections) GetConns 

func (m *Connections) GetConns() []*Connection

func (*Connections) GetDns 

func (m *Connections) GetDns() map[string]*DNSEntry

func (*Connections) GetTelemetry 

func (m *Connections) GetTelemetry() *ConnectionsTelemetry

func (*Connections) Marshal 

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

func (*Connections) MarshalTo 

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

func (*Connections) ProtoMessage 

func (*Connections) ProtoMessage()

func (*Connections) Reset 

func (m *Connections) Reset()

func (*Connections) Size 

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

func (*Connections) String 

func (m *Connections) String() string

func (*Connections) Unmarshal 

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

type ConnectionsTelemetry 

type ConnectionsTelemetry struct {
	MonotonicKprobesTriggered          int64 `protobuf:"varint,1,opt,name=monotonicKprobesTriggered,proto3" json:"monotonicKprobesTriggered,omitempty"`
	MonotonicKprobesMissed             int64 `protobuf:"varint,2,opt,name=monotonicKprobesMissed,proto3" json:"monotonicKprobesMissed,omitempty"`
	MonotonicConntrackRegisters        int64 `protobuf:"varint,3,opt,name=monotonicConntrackRegisters,proto3" json:"monotonicConntrackRegisters,omitempty"`
	MonotonicConntrackRegistersDropped int64 `protobuf:"varint,4,opt,name=monotonicConntrackRegistersDropped,proto3" json:"monotonicConntrackRegistersDropped,omitempty"`
	MonotonicDnsPacketsProcessed       int64 `protobuf:"varint,5,opt,name=monotonicDnsPacketsProcessed,proto3" json:"monotonicDnsPacketsProcessed,omitempty"`
	MonotonicConnsClosed               int64 `protobuf:"varint,6,opt,name=monotonicConnsClosed,proto3" json:"monotonicConnsClosed,omitempty"`
	ConnsBpfMapSize                    int64 `protobuf:"varint,7,opt,name=connsBpfMapSize,proto3" json:"connsBpfMapSize,omitempty"`
	MonotonicUdpSendsProcessed         int64 `protobuf:"varint,8,opt,name=monotonicUdpSendsProcessed,proto3" json:"monotonicUdpSendsProcessed,omitempty"`
	MonotonicUdpSendsMissed            int64 `protobuf:"varint,9,opt,name=monotonicUdpSendsMissed,proto3" json:"monotonicUdpSendsMissed,omitempty"`
	ConntrackSamplingPercent           int64 `protobuf:"varint,10,opt,name=conntrackSamplingPercent,proto3" json:"conntrackSamplingPercent,omitempty"`
}

func (*ConnectionsTelemetry) Descriptor 

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

func (*ConnectionsTelemetry) Marshal 

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

func (*ConnectionsTelemetry) MarshalTo 

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

func (*ConnectionsTelemetry) ProtoMessage 

func (*ConnectionsTelemetry) ProtoMessage()

func (*ConnectionsTelemetry) Reset 

func (m *ConnectionsTelemetry) Reset()

func (*ConnectionsTelemetry) Size 

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

func (*ConnectionsTelemetry) String 

func (m *ConnectionsTelemetry) String() string

func (*ConnectionsTelemetry) Unmarshal 

func (m *ConnectionsTelemetry) 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"`
	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 ContainerHostType 

type ContainerHostType int32

ContainerHostType is a enum that represents the type of host detected for container collection. Sometimes containers are running on host-less environment, we'll need additional information to identify them This will help with the host resolution when we resolve container payloads 

const (
	ContainerHostType_notSpecified ContainerHostType = 0
	ContainerHostType_fargateECS   ContainerHostType = 1
	ContainerHostType_fargateEKS   ContainerHostType = 2
)

func (ContainerHostType) EnumDescriptor 

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

func (ContainerHostType) String 

func (x ContainerHostType) String() string

type ContainerImage 

type ContainerImage struct {
	Names     []string `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`
	SizeBytes int64    `protobuf:"varint,2,opt,name=sizeBytes,proto3" json:"sizeBytes,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/core/v1/generated.proto#L777

func (*ContainerImage) Descriptor 

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

func (*ContainerImage) Marshal 

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

func (*ContainerImage) MarshalTo 

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

func (*ContainerImage) ProtoMessage 

func (*ContainerImage) ProtoMessage()

func (*ContainerImage) Reset 

func (m *ContainerImage) Reset()

func (*ContainerImage) Size 

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

func (*ContainerImage) String 

func (m *ContainerImage) String() string

func (*ContainerImage) Unmarshal 

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

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"`
	TagIndex     int32    `protobuf:"varint,5,opt,name=tagIndex,proto3" json:"tagIndex,omitempty"`
	TagsModified int64    `protobuf:"varint,6,opt,name=tagsModified,proto3" json:"tagsModified,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 ContainerStatus 

type ContainerStatus struct {
	Name         string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ContainerID  string `protobuf:"bytes,2,opt,name=containerID,proto3" json:"containerID,omitempty"`
	Ready        bool   `protobuf:"varint,3,opt,name=ready,proto3" json:"ready,omitempty"`
	RestartCount int32  `protobuf:"varint,4,opt,name=restartCount,proto3" json:"restartCount,omitempty"`
	State        string `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	Message      string `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
}

func (*ContainerStatus) Descriptor 

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

func (*ContainerStatus) Marshal 

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

func (*ContainerStatus) MarshalTo 

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

func (*ContainerStatus) ProtoMessage 

func (*ContainerStatus) ProtoMessage()

func (*ContainerStatus) Reset 

func (m *ContainerStatus) Reset()

func (*ContainerStatus) Size 

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

func (*ContainerStatus) String 

func (m *ContainerStatus) String() string

func (*ContainerStatus) Unmarshal 

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

type DNSEncoder 

type DNSEncoder interface {
	Encode(dns map[string]*DNSEntry) []byte
}

func NewV1DNSEncoder 

func NewV1DNSEncoder() DNSEncoder

type DNSEntry 

type DNSEntry struct {
	Names []string `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`
}

func (*DNSEntry) Descriptor 

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

func (*DNSEntry) Marshal 

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

func (*DNSEntry) MarshalTo 

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

func (*DNSEntry) ProtoMessage 

func (*DNSEntry) ProtoMessage()

func (*DNSEntry) Reset 

func (m *DNSEntry) Reset()

func (*DNSEntry) Size 

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

func (*DNSEntry) String 

func (m *DNSEntry) String() string

func (*DNSEntry) Unmarshal 

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

type DNSStats 

type DNSStats struct {
	DnsTimeouts          uint32            `protobuf:"varint,1,opt,name=dnsTimeouts,proto3" json:"dnsTimeouts,omitempty"`
	DnsSuccessLatencySum uint64            `protobuf:"varint,2,opt,name=dnsSuccessLatencySum,proto3" json:"dnsSuccessLatencySum,omitempty"`
	DnsFailureLatencySum uint64            `protobuf:"varint,3,opt,name=dnsFailureLatencySum,proto3" json:"dnsFailureLatencySum,omitempty"`
	DnsCountByRcode      map[uint32]uint32 `` /* 166-byte string literal not displayed */
}

func (*DNSStats) Descriptor 

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

func (*DNSStats) GetDnsCountByRcode 

func (m *DNSStats) GetDnsCountByRcode() map[uint32]uint32

func (*DNSStats) Marshal 

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

func (*DNSStats) MarshalTo 

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

func (*DNSStats) ProtoMessage 

func (*DNSStats) ProtoMessage()

func (*DNSStats) Reset 

func (m *DNSStats) Reset()

func (*DNSStats) Size 

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

func (*DNSStats) String 

func (m *DNSStats) String() string

func (*DNSStats) Unmarshal 

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

type Deployment 

type Deployment struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
	// spec
	ReplicasDesired    int32                       `protobuf:"varint,2,opt,name=replicasDesired,proto3" json:"replicasDesired,omitempty"`
	DeploymentStrategy string                      `protobuf:"bytes,3,opt,name=deploymentStrategy,proto3" json:"deploymentStrategy,omitempty"`
	MaxUnavailable     string                      `protobuf:"bytes,4,opt,name=maxUnavailable,proto3" json:"maxUnavailable,omitempty"`
	MaxSurge           string                      `protobuf:"bytes,5,opt,name=maxSurge,proto3" json:"maxSurge,omitempty"`
	Paused             bool                        `protobuf:"varint,6,opt,name=paused,proto3" json:"paused,omitempty"`
	Selectors          []*LabelSelectorRequirement `protobuf:"bytes,7,rep,name=selectors" json:"selectors,omitempty"`
	// status
	Replicas            int32    `protobuf:"varint,8,opt,name=replicas,proto3" json:"replicas,omitempty"`
	UpdatedReplicas     int32    `protobuf:"varint,9,opt,name=updatedReplicas,proto3" json:"updatedReplicas,omitempty"`
	ReadyReplicas       int32    `protobuf:"varint,10,opt,name=readyReplicas,proto3" json:"readyReplicas,omitempty"`
	AvailableReplicas   int32    `protobuf:"varint,11,opt,name=availableReplicas,proto3" json:"availableReplicas,omitempty"`
	UnavailableReplicas int32    `protobuf:"varint,12,opt,name=unavailableReplicas,proto3" json:"unavailableReplicas,omitempty"`
	ConditionMessage    string   `protobuf:"bytes,13,opt,name=conditionMessage,proto3" json:"conditionMessage,omitempty"`
	Yaml                []byte   `protobuf:"bytes,14,opt,name=yaml,proto3" json:"yaml,omitempty"`
	Tags                []string `protobuf:"bytes,15,rep,name=tags" json:"tags,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/apps/v1/generated.proto#L221

func (*Deployment) Descriptor 

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

func (*Deployment) GetMetadata 

func (m *Deployment) GetMetadata() *Metadata

func (*Deployment) GetSelectors 

func (m *Deployment) GetSelectors() []*LabelSelectorRequirement

func (*Deployment) Marshal 

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

func (*Deployment) MarshalTo 

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

func (*Deployment) ProtoMessage 

func (*Deployment) ProtoMessage()

func (*Deployment) Reset 

func (m *Deployment) Reset()

func (*Deployment) Size 

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

func (*Deployment) String 

func (m *Deployment) String() string

func (*Deployment) Unmarshal 

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

type Host 

type Host struct {
	Id           int64    `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"`
	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"`
	TagIndex     int32    `protobuf:"varint,9,opt,name=tagIndex,proto3" json:"tagIndex,omitempty"`
	TagsModified int64    `protobuf:"varint,10,opt,name=tagsModified,proto3" json:"tagsModified,omitempty"`
}

func (*Host) Descriptor 

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

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

type LabelSelectorRequirement struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Valid operators are In, NotIn, Exists and DoesNotExist.
	Operator string   `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
	Values   []string `protobuf:"bytes,3,rep,name=values" json:"values,omitempty"`
}

func (*LabelSelectorRequirement) Descriptor 

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

func (*LabelSelectorRequirement) Marshal 

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

func (*LabelSelectorRequirement) MarshalTo 

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

func (*LabelSelectorRequirement) ProtoMessage 

func (*LabelSelectorRequirement) ProtoMessage()

func (*LabelSelectorRequirement) Reset 

func (m *LabelSelectorRequirement) Reset()

func (*LabelSelectorRequirement) Size 

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

func (*LabelSelectorRequirement) String 

func (m *LabelSelectorRequirement) String() string

func (*LabelSelectorRequirement) Unmarshal 

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

type Manifest 

type Manifest struct {
	Orchestrator string `protobuf:"bytes,1,opt,name=orchestrator,proto3" json:"orchestrator,omitempty"`
	Type         string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Uid          string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"`
	Content      []byte `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	ContentType  string `protobuf:"bytes,5,opt,name=contentType,proto3" json:"contentType,omitempty"`
	Version      string `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"`
}

func (*Manifest) Descriptor 

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

func (*Manifest) Marshal 

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

func (*Manifest) MarshalTo 

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

func (*Manifest) ProtoMessage 

func (*Manifest) ProtoMessage()

func (*Manifest) Reset 

func (m *Manifest) Reset()

func (*Manifest) Size 

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

func (*Manifest) String 

func (m *Manifest) String() string

func (*Manifest) Unmarshal 

func (m *Manifest) 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

func (MessageType) String 

func (m MessageType) String() string

type MessageVersion 

type MessageVersion uint8

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

type Metadata 

type Metadata struct {
	Name              string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace         string            `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Uid               string            `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"`
	CreationTimestamp int64             `protobuf:"varint,4,opt,name=creationTimestamp,proto3" json:"creationTimestamp,omitempty"`
	DeletionTimestamp int64             `protobuf:"varint,5,opt,name=deletionTimestamp,proto3" json:"deletionTimestamp,omitempty"`
	Labels            []string          `protobuf:"bytes,6,rep,name=labels" json:"labels,omitempty"`
	Annotations       []string          `protobuf:"bytes,7,rep,name=annotations" json:"annotations,omitempty"`
	OwnerReferences   []*OwnerReference `protobuf:"bytes,8,rep,name=ownerReferences" json:"ownerReferences,omitempty"`
	ResourceVersion   string            `protobuf:"bytes,9,opt,name=resourceVersion,proto3" json:"resourceVersion,omitempty"`
}

reference https://github.com/kubernetes/apimachinery/blob/2373d029717c4d169463414a6127cd1d0d12680e/pkg/apis/meta/v1/generated.proto#L521

func (*Metadata) Descriptor 

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

func (*Metadata) GetOwnerReferences 

func (m *Metadata) GetOwnerReferences() []*OwnerReference

func (*Metadata) Marshal 

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

func (*Metadata) MarshalTo 

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

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) Size 

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

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) Unmarshal 

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

type Node 

type Node struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
	// spec reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/core/v1/generated.proto#L2312
	PodCIDR       string      `protobuf:"bytes,2,opt,name=podCIDR,proto3" json:"podCIDR,omitempty"`
	PodCIDRs      []string    `protobuf:"bytes,3,rep,name=podCIDRs" json:"podCIDRs,omitempty"`
	Unschedulable bool        `protobuf:"varint,4,opt,name=unschedulable,proto3" json:"unschedulable,omitempty"`
	Taints        []*Taint    `protobuf:"bytes,5,rep,name=taints" json:"taints,omitempty"`
	Status        *NodeStatus `protobuf:"bytes,6,opt,name=status" json:"status,omitempty"`
	Yaml          []byte      `protobuf:"bytes,7,opt,name=yaml,proto3" json:"yaml,omitempty"`
	// we parse it from the labels. Similar to upstream https://github.com/kubernetes/kubernetes/blob/1e12d92a5179dbfeb455c79dbf9120c8536e5f9c/pkg/printers/internalversion/printers.go#L1487
	Roles      []string `protobuf:"bytes,8,rep,name=roles" json:"roles,omitempty"`
	Tags       []string `protobuf:"bytes,9,rep,name=tags" json:"tags,omitempty"`
	ProviderID string   `protobuf:"bytes,10,opt,name=providerID,proto3" json:"providerID,omitempty"`
	Host       *Host    `protobuf:"bytes,11,opt,name=host" json:"host,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/core/v1/generated.proto#L2107

func (*Node) Descriptor 

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

func (*Node) GetHost 

func (m *Node) GetHost() *Host

func (*Node) GetMetadata 

func (m *Node) GetMetadata() *Metadata

func (*Node) GetStatus 

func (m *Node) GetStatus() *NodeStatus

func (*Node) GetTaints 

func (m *Node) GetTaints() []*Taint

func (*Node) Marshal 

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

func (*Node) MarshalTo 

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

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

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

func (*Node) String 

func (m *Node) String() string

func (*Node) Unmarshal 

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

type NodeCondition 

type NodeCondition struct {
	Type               string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Status             string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	LastTransitionTime int64  `protobuf:"varint,3,opt,name=lastTransitionTime,proto3" json:"lastTransitionTime,omitempty"`
	Reason             string `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	Message            string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
}

reference: https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/core/v1/generated.proto#L2158

func (*NodeCondition) Descriptor 

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

func (*NodeCondition) Marshal 

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

func (*NodeCondition) MarshalTo 

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

func (*NodeCondition) ProtoMessage 

func (*NodeCondition) ProtoMessage()

func (*NodeCondition) Reset 

func (m *NodeCondition) Reset()

func (*NodeCondition) Size 

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

func (*NodeCondition) String 

func (m *NodeCondition) String() string

func (*NodeCondition) Unmarshal 

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

type NodeStatus 

type NodeStatus struct {
	// Key/Value of a resource type and a corresponding quantity as an int64.
	Capacity map[string]int64 `` /* 151-byte string literal not displayed */
	// Key/Value of a resource type and a corresponding quantity as an int64.
	Allocatable map[string]int64 `` /* 157-byte string literal not displayed */
	// https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/core/v1/generated.proto#L2127
	// these are valid types https://github.com/kubernetes/api/blob/master/core/v1/types.go#L4739-L4753
	NodeAddresses map[string]string `` /* 160-byte string literal not displayed */
	// node status displayed by "kubectl get node"
	// mostly based on NodeCondition
	// and https://github.com/kubernetes/kubernetes/blob/1e12d92a5179dbfeb455c79dbf9120c8536e5f9c/pkg/printers/internalversion/printers.go#L1410
	Status         string            `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	KubeletVersion string            `protobuf:"bytes,5,opt,name=kubeletVersion,proto3" json:"kubeletVersion,omitempty"`
	Conditions     []*NodeCondition  `protobuf:"bytes,6,rep,name=conditions" json:"conditions,omitempty"`
	Images         []*ContainerImage `protobuf:"bytes,7,rep,name=images" json:"images,omitempty"`
	// node system info reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/core/v1/generated.proto#L2411
	KubeProxyVersion        string `protobuf:"bytes,8,opt,name=kubeProxyVersion,proto3" json:"kubeProxyVersion,omitempty"`
	OperatingSystem         string `protobuf:"bytes,9,opt,name=operatingSystem,proto3" json:"operatingSystem,omitempty"`
	Architecture            string `protobuf:"bytes,10,opt,name=architecture,proto3" json:"architecture,omitempty"`
	KernelVersion           string `protobuf:"bytes,11,opt,name=kernelVersion,proto3" json:"kernelVersion,omitempty"`
	OsImage                 string `protobuf:"bytes,12,opt,name=osImage,proto3" json:"osImage,omitempty"`
	ContainerRuntimeVersion string `protobuf:"bytes,13,opt,name=containerRuntimeVersion,proto3" json:"containerRuntimeVersion,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/core/v1/generated.proto#L2348

func (*NodeStatus) Descriptor 

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

func (*NodeStatus) GetAllocatable 

func (m *NodeStatus) GetAllocatable() map[string]int64

func (*NodeStatus) GetCapacity 

func (m *NodeStatus) GetCapacity() map[string]int64

func (*NodeStatus) GetConditions 

func (m *NodeStatus) GetConditions() []*NodeCondition

func (*NodeStatus) GetImages 

func (m *NodeStatus) GetImages() []*ContainerImage

func (*NodeStatus) GetNodeAddresses 

func (m *NodeStatus) GetNodeAddresses() map[string]string

func (*NodeStatus) Marshal 

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

func (*NodeStatus) MarshalTo 

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

func (*NodeStatus) ProtoMessage 

func (*NodeStatus) ProtoMessage()

func (*NodeStatus) Reset 

func (m *NodeStatus) Reset()

func (*NodeStatus) Size 

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

func (*NodeStatus) String 

func (m *NodeStatus) String() string

func (*NodeStatus) Unmarshal 

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

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 OwnerReference 

type OwnerReference struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Uid  string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Kind string `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
}

func (*OwnerReference) Descriptor 

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

func (*OwnerReference) Marshal 

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

func (*OwnerReference) MarshalTo 

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

func (*OwnerReference) ProtoMessage 

func (*OwnerReference) ProtoMessage()

func (*OwnerReference) Reset 

func (m *OwnerReference) Reset()

func (*OwnerReference) Size 

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

func (*OwnerReference) String 

func (m *OwnerReference) String() string

func (*OwnerReference) Unmarshal 

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

type Pod 

type Pod struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
	// status
	IP                    string                  `protobuf:"bytes,2,opt,name=IP,proto3" json:"IP,omitempty"`
	NominatedNodeName     string                  `protobuf:"bytes,3,opt,name=nominatedNodeName,proto3" json:"nominatedNodeName,omitempty"`
	NodeName              string                  `protobuf:"bytes,4,opt,name=nodeName,proto3" json:"nodeName,omitempty"`
	Phase                 string                  `protobuf:"bytes,5,opt,name=phase,proto3" json:"phase,omitempty"`
	RestartCount          int32                   `protobuf:"varint,6,opt,name=restartCount,proto3" json:"restartCount,omitempty"`
	ContainerStatuses     []*ContainerStatus      `protobuf:"bytes,7,rep,name=containerStatuses" json:"containerStatuses,omitempty"`
	InitContainerStatuses []*ContainerStatus      `protobuf:"bytes,14,rep,name=initContainerStatuses" json:"initContainerStatuses,omitempty"`
	ConditionMessage      string                  `protobuf:"bytes,8,opt,name=conditionMessage,proto3" json:"conditionMessage,omitempty"`
	Status                string                  `protobuf:"bytes,9,opt,name=status,proto3" json:"status,omitempty"`
	Yaml                  []byte                  `protobuf:"bytes,10,opt,name=yaml,proto3" json:"yaml,omitempty"`
	Tags                  []string                `protobuf:"bytes,11,rep,name=tags" json:"tags,omitempty"`
	Host                  *Host                   `protobuf:"bytes,12,opt,name=host" json:"host,omitempty"`
	ResourceRequirements  []*ResourceRequirements `protobuf:"bytes,13,rep,name=resourceRequirements" json:"resourceRequirements,omitempty"`
	QOSClass              string                  `protobuf:"bytes,15,opt,name=QOSClass,proto3" json:"QOSClass,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/core/v1/generated.proto

func (*Pod) Descriptor 

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

func (*Pod) GetContainerStatuses 

func (m *Pod) GetContainerStatuses() []*ContainerStatus

func (*Pod) GetHost 

func (m *Pod) GetHost() *Host

func (*Pod) GetInitContainerStatuses 

func (m *Pod) GetInitContainerStatuses() []*ContainerStatus

func (*Pod) GetMetadata 

func (m *Pod) GetMetadata() *Metadata

func (*Pod) GetResourceRequirements 

func (m *Pod) GetResourceRequirements() []*ResourceRequirements

func (*Pod) Marshal 

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

func (*Pod) MarshalTo 

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

func (*Pod) ProtoMessage 

func (*Pod) ProtoMessage()

func (*Pod) Reset 

func (m *Pod) Reset()

func (*Pod) Size 

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

func (*Pod) String 

func (m *Pod) String() string

func (*Pod) Unmarshal 

func (m *Pod) 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"`
	NsPid                  int32        `protobuf:"varint,20,opt,name=nsPid,proto3" json:"nsPid,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 ReplicaSet 

type ReplicaSet struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
	// spec
	ReplicasDesired int32                       `protobuf:"varint,2,opt,name=replicasDesired,proto3" json:"replicasDesired,omitempty"`
	Selectors       []*LabelSelectorRequirement `protobuf:"bytes,3,rep,name=selectors" json:"selectors,omitempty"`
	// status
	Replicas             int32    `protobuf:"varint,4,opt,name=replicas,proto3" json:"replicas,omitempty"`
	FullyLabeledReplicas int32    `protobuf:"varint,5,opt,name=fullyLabeledReplicas,proto3" json:"fullyLabeledReplicas,omitempty"`
	ReadyReplicas        int32    `protobuf:"varint,6,opt,name=readyReplicas,proto3" json:"readyReplicas,omitempty"`
	AvailableReplicas    int32    `protobuf:"varint,7,opt,name=availableReplicas,proto3" json:"availableReplicas,omitempty"`
	Yaml                 []byte   `protobuf:"bytes,8,opt,name=yaml,proto3" json:"yaml,omitempty"`
	Tags                 []string `protobuf:"bytes,9,rep,name=tags" json:"tags,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/apps/v1/generated.proto#L366

func (*ReplicaSet) Descriptor 

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

func (*ReplicaSet) GetMetadata 

func (m *ReplicaSet) GetMetadata() *Metadata

func (*ReplicaSet) GetSelectors 

func (m *ReplicaSet) GetSelectors() []*LabelSelectorRequirement

func (*ReplicaSet) Marshal 

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

func (*ReplicaSet) MarshalTo 

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

func (*ReplicaSet) ProtoMessage 

func (*ReplicaSet) ProtoMessage()

func (*ReplicaSet) Reset 

func (m *ReplicaSet) Reset()

func (*ReplicaSet) Size 

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

func (*ReplicaSet) String 

func (m *ReplicaSet) String() string

func (*ReplicaSet) Unmarshal 

func (m *ReplicaSet) 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 ResourceRequirements 

type ResourceRequirements struct {
	// Limits describes the maximum amount of compute resources allowed.
	// Key/Value of a resource type and a corresponding quantity as an int64.
	Limits map[string]int64 `` /* 147-byte string literal not displayed */
	// Requests describes the minimum amount of compute resources required.
	// Key/Value of a resource type and a corresponding quantity as an int64.
	Requests map[string]int64 `` /* 151-byte string literal not displayed */
	// Name describes the name of the holder of the resource requirements (e.g. a container name).
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// ResourceRequirementsType describes the type which uses the ResourceRequirements.
	Type ResourceRequirementsType `protobuf:"varint,4,opt,name=type,proto3,enum=datadog.process_agent.ResourceRequirementsType" json:"type,omitempty"`
}

https://github.com/kubernetes/kubernetes/blob/4112d8db20c5550cc27d30d3cee2723db0f8e1c4/staging/src/k8s.io/api/core/v1/types.go#L2097 Using smallest possible quantity levels. For memory it is bytes, for CPU it is millicore.

func (*ResourceRequirements) Descriptor 

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

func (*ResourceRequirements) GetLimits 

func (m *ResourceRequirements) GetLimits() map[string]int64

func (*ResourceRequirements) GetRequests 

func (m *ResourceRequirements) GetRequests() map[string]int64

func (*ResourceRequirements) Marshal 

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

func (*ResourceRequirements) MarshalTo 

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

func (*ResourceRequirements) ProtoMessage 

func (*ResourceRequirements) ProtoMessage()

func (*ResourceRequirements) Reset 

func (m *ResourceRequirements) Reset()

func (*ResourceRequirements) Size 

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

func (*ResourceRequirements) String 

func (m *ResourceRequirements) String() string

func (*ResourceRequirements) Unmarshal 

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

type ResourceRequirementsType 

type ResourceRequirementsType int32
const (
	ResourceRequirementsType_unknownType        ResourceRequirementsType = 0
	ResourceRequirementsType_container          ResourceRequirementsType = 1
	ResourceRequirementsType_initContainer      ResourceRequirementsType = 2
	ResourceRequirementsType_ephemeralContainer ResourceRequirementsType = 3
)

func (ResourceRequirementsType) EnumDescriptor 

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

func (ResourceRequirementsType) String 

func (x ResourceRequirementsType) String() string

type Service 

type Service struct {
	Metadata *Metadata      `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
	Spec     *ServiceSpec   `protobuf:"bytes,2,opt,name=spec" json:"spec,omitempty"`
	Status   *ServiceStatus `protobuf:"bytes,3,opt,name=status" json:"status,omitempty"`
	Yaml     []byte         `protobuf:"bytes,4,opt,name=yaml,proto3" json:"yaml,omitempty"`
	Tags     []string       `protobuf:"bytes,5,rep,name=tags" json:"tags,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/release-1.19/staging/src/k8s.io/api/core/v1/generated.proto

func (*Service) Descriptor 

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

func (*Service) GetMetadata 

func (m *Service) GetMetadata() *Metadata

func (*Service) GetSpec 

func (m *Service) GetSpec() *ServiceSpec

func (*Service) GetStatus 

func (m *Service) GetStatus() *ServiceStatus

func (*Service) Marshal 

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

func (*Service) MarshalTo 

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

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) Size 

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

func (*Service) String 

func (m *Service) String() string

func (*Service) Unmarshal 

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

type ServicePort 

type ServicePort struct {
	Name       string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Protocol   string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Port       int32  `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	TargetPort string `protobuf:"bytes,4,opt,name=targetPort,proto3" json:"targetPort,omitempty"`
	NodePort   int32  `protobuf:"varint,5,opt,name=nodePort,proto3" json:"nodePort,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/core/v1/generated.proto#L4571

func (*ServicePort) Descriptor 

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

func (*ServicePort) Marshal 

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

func (*ServicePort) MarshalTo 

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

func (*ServicePort) ProtoMessage 

func (*ServicePort) ProtoMessage()

func (*ServicePort) Reset 

func (m *ServicePort) Reset()

func (*ServicePort) Size 

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

func (*ServicePort) String 

func (m *ServicePort) String() string

func (*ServicePort) Unmarshal 

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

type ServiceSessionAffinityConfig 

type ServiceSessionAffinityConfig struct {
	ClientIPTimeoutSeconds int32 `protobuf:"varint,1,opt,name=clientIPTimeoutSeconds,proto3" json:"clientIPTimeoutSeconds,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/core/v1/generated.proto#L4756

func (*ServiceSessionAffinityConfig) Descriptor 

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

func (*ServiceSessionAffinityConfig) Marshal 

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

func (*ServiceSessionAffinityConfig) MarshalTo 

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

func (*ServiceSessionAffinityConfig) ProtoMessage 

func (*ServiceSessionAffinityConfig) ProtoMessage()

func (*ServiceSessionAffinityConfig) Reset 

func (m *ServiceSessionAffinityConfig) Reset()

func (*ServiceSessionAffinityConfig) Size 

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

func (*ServiceSessionAffinityConfig) String 

func (m *ServiceSessionAffinityConfig) String() string

func (*ServiceSessionAffinityConfig) Unmarshal 

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

type ServiceSpec 

type ServiceSpec struct {
	Ports                    []*ServicePort                `protobuf:"bytes,1,rep,name=ports" json:"ports,omitempty"`
	Selectors                []*LabelSelectorRequirement   `protobuf:"bytes,2,rep,name=selectors" json:"selectors,omitempty"`
	ClusterIP                string                        `protobuf:"bytes,3,opt,name=clusterIP,proto3" json:"clusterIP,omitempty"`
	Type                     string                        `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	ExternalIPs              []string                      `protobuf:"bytes,5,rep,name=externalIPs" json:"externalIPs,omitempty"`
	SessionAffinity          string                        `protobuf:"bytes,6,opt,name=sessionAffinity,proto3" json:"sessionAffinity,omitempty"`
	LoadBalancerIP           string                        `protobuf:"bytes,7,opt,name=loadBalancerIP,proto3" json:"loadBalancerIP,omitempty"`
	LoadBalancerSourceRanges []string                      `protobuf:"bytes,8,rep,name=loadBalancerSourceRanges" json:"loadBalancerSourceRanges,omitempty"`
	ExternalName             string                        `protobuf:"bytes,9,opt,name=externalName,proto3" json:"externalName,omitempty"`
	ExternalTrafficPolicy    string                        `protobuf:"bytes,10,opt,name=externalTrafficPolicy,proto3" json:"externalTrafficPolicy,omitempty"`
	HealthCheckNodePort      int32                         `protobuf:"varint,11,opt,name=healthCheckNodePort,proto3" json:"healthCheckNodePort,omitempty"`
	PublishNotReadyAddresses bool                          `protobuf:"varint,12,opt,name=publishNotReadyAddresses,proto3" json:"publishNotReadyAddresses,omitempty"`
	SessionAffinityConfig    *ServiceSessionAffinityConfig `protobuf:"bytes,13,opt,name=sessionAffinityConfig" json:"sessionAffinityConfig,omitempty"`
	IpFamily                 string                        `protobuf:"bytes,14,opt,name=ipFamily,proto3" json:"ipFamily,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/core/v1/generated.proto#L4620

func (*ServiceSpec) Descriptor 

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

func (*ServiceSpec) GetPorts 

func (m *ServiceSpec) GetPorts() []*ServicePort

func (*ServiceSpec) GetSelectors 

func (m *ServiceSpec) GetSelectors() []*LabelSelectorRequirement

func (*ServiceSpec) GetSessionAffinityConfig 

func (m *ServiceSpec) GetSessionAffinityConfig() *ServiceSessionAffinityConfig

func (*ServiceSpec) Marshal 

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

func (*ServiceSpec) MarshalTo 

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

func (*ServiceSpec) ProtoMessage 

func (*ServiceSpec) ProtoMessage()

func (*ServiceSpec) Reset 

func (m *ServiceSpec) Reset()

func (*ServiceSpec) Size 

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

func (*ServiceSpec) String 

func (m *ServiceSpec) String() string

func (*ServiceSpec) Unmarshal 

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

type ServiceStatus 

type ServiceStatus struct {
	LoadBalancerIngress []string `protobuf:"bytes,17,rep,name=loadBalancerIngress" json:"loadBalancerIngress,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/core/v1/generated.proto#L4748

func (*ServiceStatus) Descriptor 

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

func (*ServiceStatus) Marshal 

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

func (*ServiceStatus) MarshalTo 

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

func (*ServiceStatus) ProtoMessage 

func (*ServiceStatus) ProtoMessage()

func (*ServiceStatus) Reset 

func (m *ServiceStatus) Reset()

func (*ServiceStatus) Size 

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

func (*ServiceStatus) String 

func (m *ServiceStatus) String() string

func (*ServiceStatus) Unmarshal 

func (m *ServiceStatus) 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

type TagEncoder 

type TagEncoder interface {
	// Buffer returns the underlying byte buffer that the tags were encoded in to
	Buffer() []byte

	// Encode encodes the given tags in to the buffer and returns the index in the buffer where the data begins
	Encode(tags []string) int
}

func NewTagEncoder 

func NewTagEncoder() TagEncoder

NewTagEncoder creates an empty tag encoder

func NewV2TagEncoder 

func NewV2TagEncoder() TagEncoder

type Taint 

type Taint struct {
	Key       string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value     string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Effect    string `protobuf:"bytes,3,opt,name=effect,proto3" json:"effect,omitempty"`
	TimeAdded int64  `protobuf:"varint,4,opt,name=timeAdded,proto3" json:"timeAdded,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/core/v1/generated.proto#L4849

func (*Taint) Descriptor 

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

func (*Taint) Marshal 

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

func (*Taint) MarshalTo 

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

func (*Taint) ProtoMessage 

func (*Taint) ProtoMessage()

func (*Taint) Reset 

func (m *Taint) Reset()

func (*Taint) Size 

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

func (*Taint) String 

func (m *Taint) String() string

func (*Taint) Unmarshal 

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

type V1DNSEncoder 

type V1DNSEncoder struct {
	BucketFactor float64
	// contains filtered or unexported fields
}

DNS data is encoded as a very basic bucketed hash table. There are three blocks, or buffers, of data: 

The "name" block is all of the unique DNS names.  The length of the name is stored as a varint
followed by the name itself

The "bucket" block contains all of the hash buckets.  The format of each bucket is:
	varint for number of entries in bucket
	For each entry in the bucket:
		varint for length of ip
		ip bytes
		varint for number of names associated with the ip
		Each associated name is encoded as a varint which is the position of the actual name string in the name block

The "position" block is a list of varints, one for each bucket, where each varint is a pointer to the start
of the bucket in the bucket block

The overall buffer is encoded as: 

1 byte indicating version
2 bytes indicating the number of buckets
varint indicating the length of the name buffer.
varint indicating the length of the position buffer
varint indicating the position of the "middle" (bucketCount / 2) bucket in the position block
	We will use this to skip the half of the buckets when searching for the target bucket index
position block
bucket block
name block

Notes: 

Using varints saves space at the cost of not having random access to certain sections of data, particularly the
bucket position mapping.  This was a deliberate trade off to reduce the size of the payload and thus memory usage

Varints are also more finicky to deal with in terms of calculating required space ahead of time.  This increases
the implementation complexity, or at least the line count, but we reduce allocations & memory usage by
pre-sizing the output buffers

This type is not thread safe

func (*V1DNSEncoder) Encode 

func (e *V1DNSEncoder) Encode(dns map[string]*DNSEntry) []byte

type V2TagEncoder 

type V2TagEncoder struct {
	// contains filtered or unexported fields
}

V2TagEncoder operates on the theory that a good portion of the tags for an overall message across connections will be duplicated.

Each tag is encoded exactly once in the message at a given position. Each collection of tags is a list of integers representing the position of each tag. The collection of tag positions is referred to as the footer and is appended to the end of the buffer

The format of the buffer is:

  • 1 byte for meta (currently used for specifying version)
  • 4 bytes for position of footer blob in overall buffer
  • N bytes for all tags, stored sequentially. Each tag is 2 bytes for the length of the tag and N bytes for the tag itself
  • N bytes for the footer blob. Each entry in the footer is 2 bytes for the number of tags and then N 4 byte integers, each representing the location of the tag in the tag blob

func (*V2TagEncoder) Buffer 

func (t *V2TagEncoder) Buffer() []byte

func (*V2TagEncoder) Encode 

func (t *V2TagEncoder) Encode(tags []string) int

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.