process

package
v4.68.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Apr 22, 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
CollectorCluster
CollectorManifest
CollectorJob
CollectorCronJob
CollectorStatus
Process
Command
ProcessUser
ProcessNetworks
ContainerAddr
Container
ProcessStat
ProcStatsWithPerm
ProcStatsWithPermByPID
ContainerStat
ContainerMetadata
SystemInfo
OSInfo
IOStat
Connection
Connections
Addr
Route
Subnet
IPTranslation
MemoryStat
CPUStat
SingleCPUStat
CPUInfo
Host
DNSEntry
Cluster
Metadata
OwnerReference
ObjectReference
ServicePort
ServiceSessionAffinityConfig
Node
NodeStatus
NodeCondition
ContainerImage
Taint
ServiceSpec
ServiceStatus
Service
Deployment
ReplicaSet
LabelSelectorRequirement
Pod
ContainerStatus
Manifest
ResourceRequirements
JobSpec
JobStatus
Job
CronJobSpec
CronJobStatus
CronJob
ConnectionsTelemetry
CollectorConnectionsTelemetry
DNSStats
HTTPAggregations
HTTPStats
RuntimeCompilationTelemetry
RouteMetadata

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
	TypeCollectorCluster           = 46
	TypeCollectorJob               = 47
	TypeCollectorCronJob           = 48
	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 HTTPResponseStatus_name = map[int32]string{
	0: "Info",
	1: "Success",
	2: "Redirect",
	3: "ClientErr",
	4: "ServerErr",
}
View Source
var HTTPResponseStatus_value = map[string]int32{
	"Info":      0,
	"Success":   1,
	"Redirect":  2,
	"ClientErr": 3,
	"ServerErr": 4,
}
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,
}
View Source
var RuntimeCompilationResult_name = map[int32]string{
	0: "NotAttempted",
	1: "CompilationSuccess",
	2: "KernelVersionErr",
	3: "VerificationError",
	4: "OutputDirErr",
	5: "OutputFileErr",
	6: "NewCompilerErr",
	7: "CompilationErr",
	8: "ResultReadErr",
}
View Source
var RuntimeCompilationResult_value = map[string]int32{
	"NotAttempted":       0,
	"CompilationSuccess": 1,
	"KernelVersionErr":   2,
	"VerificationError":  3,
	"OutputDirErr":       4,
	"OutputFileErr":      5,
	"NewCompilerErr":     6,
	"CompilationErr":     7,
	"ResultReadErr":      8,
}

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 Cluster

type Cluster struct {
	NodeCount         int32            `protobuf:"varint,1,opt,name=nodeCount,proto3" json:"nodeCount,omitempty"`
	KubeletVersions   map[string]int32 `` /* 165-byte string literal not displayed */
	ApiServerVersions map[string]int32 `` /* 169-byte string literal not displayed */
	// sum of all nodes capacities and allocatables.
	// Using smallest possible quantity levels.
	// For memory it is bytes, for CPU it is millicore.
	PodCapacity       uint32 `protobuf:"varint,4,opt,name=podCapacity,proto3" json:"podCapacity,omitempty"`
	PodAllocatable    uint32 `protobuf:"varint,5,opt,name=podAllocatable,proto3" json:"podAllocatable,omitempty"`
	MemoryAllocatable uint64 `protobuf:"varint,6,opt,name=memoryAllocatable,proto3" json:"memoryAllocatable,omitempty"`
	MemoryCapacity    uint64 `protobuf:"varint,7,opt,name=memoryCapacity,proto3" json:"memoryCapacity,omitempty"`
	CpuAllocatable    uint64 `protobuf:"varint,8,opt,name=cpuAllocatable,proto3" json:"cpuAllocatable,omitempty"`
	CpuCapacity       uint64 `protobuf:"varint,9,opt,name=cpuCapacity,proto3" json:"cpuCapacity,omitempty"`
	ResourceVersion   string `protobuf:"bytes,10,opt,name=resourceVersion,proto3" json:"resourceVersion,omitempty"`
	CreationTimestamp int64  `protobuf:"varint,11,opt,name=creationTimestamp,proto3" json:"creationTimestamp,omitempty"`
}

func (*Cluster) Descriptor

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

func (*Cluster) GetApiServerVersions

func (m *Cluster) GetApiServerVersions() map[string]int32

func (*Cluster) GetKubeletVersions

func (m *Cluster) GetKubeletVersions() map[string]int32

func (*Cluster) Marshal

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

func (*Cluster) MarshalTo

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

func (*Cluster) ProtoMessage

func (*Cluster) ProtoMessage()

func (*Cluster) Reset

func (m *Cluster) Reset()

func (*Cluster) Size

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

func (*Cluster) String

func (m *Cluster) String() string

func (*Cluster) Unmarshal

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

type CollectorCluster

type CollectorCluster 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"`
	Cluster     *Cluster `protobuf:"bytes,5,opt,name=cluster" json:"cluster,omitempty"`
	Tags        []string `protobuf:"bytes,6,rep,name=tags" json:"tags,omitempty"`
}

func (*CollectorCluster) Descriptor

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

func (*CollectorCluster) GetCluster

func (m *CollectorCluster) GetCluster() *Cluster

func (*CollectorCluster) Marshal

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

func (*CollectorCluster) MarshalTo

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

func (*CollectorCluster) ProtoMessage

func (*CollectorCluster) ProtoMessage()

func (*CollectorCluster) Reset

func (m *CollectorCluster) Reset()

func (*CollectorCluster) Size

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

func (*CollectorCluster) String

func (m *CollectorCluster) String() string

func (*CollectorCluster) Unmarshal

func (m *CollectorCluster) 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 */
	ConnTelemetry     *CollectorConnectionsTelemetry `protobuf:"bytes,16,opt,name=connTelemetry" json:"connTelemetry,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"`
	// host configuration, ephemeral port range
	EphemeralPortRangeStart     int32                                   `protobuf:"varint,32,opt,name=ephemeralPortRangeStart,proto3" json:"ephemeralPortRangeStart,omitempty"`
	EphemeralPortRangeEnd       int32                                   `protobuf:"varint,33,opt,name=ephemeralPortRangeEnd,proto3" json:"ephemeralPortRangeEnd,omitempty"`
	CompilationTelemetryByAsset map[string]*RuntimeCompilationTelemetry `` /* 182-byte string literal not displayed */
	// All queried DNS domains for which we have collected stats
	Domains       []string         `protobuf:"bytes,30,rep,name=domains" json:"domains,omitempty"`
	Routes        []*Route         `protobuf:"bytes,31,rep,name=routes" json:"routes,omitempty"`
	RouteMetadata []*RouteMetadata `protobuf:"bytes,34,rep,name=routeMetadata" json:"routeMetadata,omitempty"`
}

func (*CollectorConnections) Descriptor

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

func (*CollectorConnections) GetCompilationTelemetryByAsset

func (m *CollectorConnections) GetCompilationTelemetryByAsset() map[string]*RuntimeCompilationTelemetry

func (*CollectorConnections) GetConnTelemetry

func (m *CollectorConnections) GetConnTelemetry() *CollectorConnectionsTelemetry

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

func (m *CollectorConnections) GetRouteMetadata() []*RouteMetadata

func (*CollectorConnections) GetRoutes

func (m *CollectorConnections) GetRoutes() []*Route

func (*CollectorConnections) GetTags

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

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 (*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 (*CollectorContainer) GetHost

func (m *CollectorContainer) GetHost() *Host

func (*CollectorContainer) GetInfo

func (m *CollectorContainer) GetInfo() *SystemInfo

func (*CollectorContainer) GetKubernetes

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 CollectorCronJob

type CollectorCronJob 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"`
	CronJobs    []*CronJob `protobuf:"bytes,5,rep,name=cronJobs" json:"cronJobs,omitempty"`
	Tags        []string   `protobuf:"bytes,6,rep,name=tags" json:"tags,omitempty"`
}

func (*CollectorCronJob) Descriptor

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

func (*CollectorCronJob) GetCronJobs

func (m *CollectorCronJob) GetCronJobs() []*CronJob

func (*CollectorCronJob) Marshal

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

func (*CollectorCronJob) MarshalTo

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

func (*CollectorCronJob) ProtoMessage

func (*CollectorCronJob) ProtoMessage()

func (*CollectorCronJob) Reset

func (m *CollectorCronJob) Reset()

func (*CollectorCronJob) Size

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

func (*CollectorCronJob) String

func (m *CollectorCronJob) String() string

func (*CollectorCronJob) Unmarshal

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

type CollectorJob 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"`
	Jobs        []*Job   `protobuf:"bytes,5,rep,name=jobs" json:"jobs,omitempty"`
	Tags        []string `protobuf:"bytes,6,rep,name=tags" json:"tags,omitempty"`
}

func (*CollectorJob) Descriptor

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

func (*CollectorJob) GetJobs

func (m *CollectorJob) GetJobs() []*Job

func (*CollectorJob) Marshal

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

func (*CollectorJob) MarshalTo

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

func (*CollectorJob) ProtoMessage

func (*CollectorJob) ProtoMessage()

func (*CollectorJob) Reset

func (m *CollectorJob) Reset()

func (*CollectorJob) Size

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

func (*CollectorJob) String

func (m *CollectorJob) String() string

func (*CollectorJob) Unmarshal

func (m *CollectorJob) 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 (*CollectorProc) GetHost

func (m *CollectorProc) GetHost() *Host

func (*CollectorProc) GetInfo

func (m *CollectorProc) GetInfo() *SystemInfo

func (*CollectorProc) GetKubernetes

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"`
	LastPacketsSent     uint64              `protobuf:"varint,38,opt,name=lastPacketsSent,proto3" json:"lastPacketsSent,omitempty"`
	LastPacketsReceived uint64              `protobuf:"varint,39,opt,name=lastPacketsReceived,proto3" json:"lastPacketsReceived,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 */
	RouteIdx         int32               `protobuf:"varint,36,opt,name=routeIdx,proto3" json:"routeIdx,omitempty"`
	// the index of the resolved target of the route (post-resolution field)
	RouteTargetIdx int32 `protobuf:"varint,40,opt,name=routeTargetIdx,proto3" json:"routeTargetIdx,omitempty"`
	// serialized HTTPAggregations object summarizing all http transactions recorded for this connection, organized by request path
	HttpAggregations []byte `protobuf:"bytes,37,opt,name=httpAggregations,proto3" json:"httpAggregations,omitempty"`
}

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 */
	ConnTelemetry               *ConnectionsTelemetry                   `protobuf:"bytes,3,opt,name=connTelemetry" json:"connTelemetry,omitempty"`
	Domains                     []string                                `protobuf:"bytes,4,rep,name=domains" json:"domains,omitempty"`
	Routes                      []*Route                                `protobuf:"bytes,5,rep,name=routes" json:"routes,omitempty"`
	CompilationTelemetryByAsset map[string]*RuntimeCompilationTelemetry `` /* 181-byte string literal not displayed */
}

func (*Connections) Descriptor

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

func (*Connections) GetCompilationTelemetryByAsset

func (m *Connections) GetCompilationTelemetryByAsset() map[string]*RuntimeCompilationTelemetry

func (*Connections) GetConnTelemetry

func (m *Connections) GetConnTelemetry() *ConnectionsTelemetry

func (*Connections) GetConns

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

func (*Connections) GetDns

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

func (*Connections) GetRoutes

func (m *Connections) GetRoutes() []*Route

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 CronJob

type CronJob struct {
	Metadata *Metadata      `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
	Spec     *CronJobSpec   `protobuf:"bytes,2,opt,name=spec" json:"spec,omitempty"`
	Status   *CronJobStatus `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/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/batch/v1beta1/types.go#L58

func (*CronJob) Descriptor

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

func (*CronJob) GetMetadata

func (m *CronJob) GetMetadata() *Metadata

func (*CronJob) GetSpec

func (m *CronJob) GetSpec() *CronJobSpec

func (*CronJob) GetStatus

func (m *CronJob) GetStatus() *CronJobStatus

func (*CronJob) Marshal

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

func (*CronJob) MarshalTo

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

func (*CronJob) ProtoMessage

func (*CronJob) ProtoMessage()

func (*CronJob) Reset

func (m *CronJob) Reset()

func (*CronJob) Size

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

func (*CronJob) String

func (m *CronJob) String() string

func (*CronJob) Unmarshal

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

type CronJobSpec

type CronJobSpec struct {
	Schedule                   string `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	StartingDeadlineSeconds    int64  `protobuf:"varint,2,opt,name=startingDeadlineSeconds,proto3" json:"startingDeadlineSeconds,omitempty"`
	ConcurrencyPolicy          string `protobuf:"bytes,3,opt,name=concurrencyPolicy,proto3" json:"concurrencyPolicy,omitempty"`
	Suspend                    bool   `protobuf:"varint,4,opt,name=suspend,proto3" json:"suspend,omitempty"`
	SuccessfulJobsHistoryLimit int32  `protobuf:"varint,5,opt,name=successfulJobsHistoryLimit,proto3" json:"successfulJobsHistoryLimit,omitempty"`
	FailedJobsHistoryLimit     int32  `protobuf:"varint,6,opt,name=failedJobsHistoryLimit,proto3" json:"failedJobsHistoryLimit,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/batch/v1beta1/types.go#L92

func (*CronJobSpec) Descriptor

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

func (*CronJobSpec) Marshal

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

func (*CronJobSpec) MarshalTo

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

func (*CronJobSpec) ProtoMessage

func (*CronJobSpec) ProtoMessage()

func (*CronJobSpec) Reset

func (m *CronJobSpec) Reset()

func (*CronJobSpec) Size

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

func (*CronJobSpec) String

func (m *CronJobSpec) String() string

func (*CronJobSpec) Unmarshal

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

type CronJobStatus

type CronJobStatus struct {
	Active           []*ObjectReference `protobuf:"bytes,1,rep,name=active" json:"active,omitempty"`
	LastScheduleTime int64              `protobuf:"varint,2,opt,name=lastScheduleTime,proto3" json:"lastScheduleTime,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/batch/v1beta1/types.go#L150

func (*CronJobStatus) Descriptor

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

func (*CronJobStatus) GetActive

func (m *CronJobStatus) GetActive() []*ObjectReference

func (*CronJobStatus) Marshal

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

func (*CronJobStatus) MarshalTo

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

func (*CronJobStatus) ProtoMessage

func (*CronJobStatus) ProtoMessage()

func (*CronJobStatus) Reset

func (m *CronJobStatus) Reset()

func (*CronJobStatus) Size

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

func (*CronJobStatus) String

func (m *CronJobStatus) String() string

func (*CronJobStatus) Unmarshal

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

type HTTPAggregations struct {
	ByPath map[string]*HTTPStats `` /* 139-byte string literal not displayed */
}

func (*HTTPAggregations) Descriptor

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

func (*HTTPAggregations) GetByPath

func (m *HTTPAggregations) GetByPath() map[string]*HTTPStats

func (*HTTPAggregations) Marshal

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

func (*HTTPAggregations) MarshalTo

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

func (*HTTPAggregations) ProtoMessage

func (*HTTPAggregations) ProtoMessage()

func (*HTTPAggregations) Reset

func (m *HTTPAggregations) Reset()

func (*HTTPAggregations) Size

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

func (*HTTPAggregations) String

func (m *HTTPAggregations) String() string

func (*HTTPAggregations) Unmarshal

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

type HTTPResponseStatus

type HTTPResponseStatus int32
const (
	HTTPResponseStatus_Info      HTTPResponseStatus = 0
	HTTPResponseStatus_Success   HTTPResponseStatus = 1
	HTTPResponseStatus_Redirect  HTTPResponseStatus = 2
	HTTPResponseStatus_ClientErr HTTPResponseStatus = 3
	HTTPResponseStatus_ServerErr HTTPResponseStatus = 4
)

func (HTTPResponseStatus) EnumDescriptor

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

func (HTTPResponseStatus) String

func (x HTTPResponseStatus) String() string

type HTTPStats

type HTTPStats struct {
	StatsByResponseStatus []*HTTPStats_Data `protobuf:"bytes,1,rep,name=statsByResponseStatus" json:"statsByResponseStatus,omitempty"`
}

func (*HTTPStats) Descriptor

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

func (*HTTPStats) GetStatsByResponseStatus

func (m *HTTPStats) GetStatsByResponseStatus() []*HTTPStats_Data

func (*HTTPStats) Marshal

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

func (*HTTPStats) MarshalTo

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

func (*HTTPStats) ProtoMessage

func (*HTTPStats) ProtoMessage()

func (*HTTPStats) Reset

func (m *HTTPStats) Reset()

func (*HTTPStats) Size

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

func (*HTTPStats) String

func (m *HTTPStats) String() string

func (*HTTPStats) Unmarshal

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

type HTTPStats_Data

type HTTPStats_Data struct {
	Count              uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Latencies          []byte `protobuf:"bytes,2,opt,name=latencies,proto3" json:"latencies,omitempty"`
	FirstLatencySample uint64 `protobuf:"varint,3,opt,name=firstLatencySample,proto3" json:"firstLatencySample,omitempty"`
}

func (*HTTPStats_Data) Descriptor

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

func (*HTTPStats_Data) Marshal

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

func (*HTTPStats_Data) MarshalTo

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

func (*HTTPStats_Data) ProtoMessage

func (*HTTPStats_Data) ProtoMessage()

func (*HTTPStats_Data) Reset

func (m *HTTPStats_Data) Reset()

func (*HTTPStats_Data) Size

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

func (*HTTPStats_Data) String

func (m *HTTPStats_Data) String() string

func (*HTTPStats_Data) Unmarshal

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

type Job struct {
	Metadata *Metadata  `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
	Spec     *JobSpec   `protobuf:"bytes,2,opt,name=spec" json:"spec,omitempty"`
	Status   *JobStatus `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/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/batch/v1/types.go#L28

func (*Job) Descriptor

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

func (*Job) GetMetadata

func (m *Job) GetMetadata() *Metadata

func (*Job) GetSpec

func (m *Job) GetSpec() *JobSpec

func (*Job) GetStatus

func (m *Job) GetStatus() *JobStatus

func (*Job) Marshal

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

func (*Job) MarshalTo

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

func (*Job) ProtoMessage

func (*Job) ProtoMessage()

func (*Job) Reset

func (m *Job) Reset()

func (*Job) Size

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

func (*Job) String

func (m *Job) String() string

func (*Job) Unmarshal

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

type JobSpec

type JobSpec struct {
	Parallelism           int32                       `protobuf:"varint,1,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	Completions           int32                       `protobuf:"varint,2,opt,name=completions,proto3" json:"completions,omitempty"`
	ActiveDeadlineSeconds int64                       `protobuf:"varint,3,opt,name=activeDeadlineSeconds,proto3" json:"activeDeadlineSeconds,omitempty"`
	BackoffLimit          int32                       `protobuf:"varint,4,opt,name=backoffLimit,proto3" json:"backoffLimit,omitempty"`
	Selectors             []*LabelSelectorRequirement `protobuf:"bytes,5,rep,name=selectors" json:"selectors,omitempty"`
	ManualSelector        bool                        `protobuf:"varint,6,opt,name=manualSelector,proto3" json:"manualSelector,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/batch/v1/types.go#L61

func (*JobSpec) Descriptor

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

func (*JobSpec) GetSelectors

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

func (*JobSpec) Marshal

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

func (*JobSpec) MarshalTo

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

func (*JobSpec) ProtoMessage

func (*JobSpec) ProtoMessage()

func (*JobSpec) Reset

func (m *JobSpec) Reset()

func (*JobSpec) Size

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

func (*JobSpec) String

func (m *JobSpec) String() string

func (*JobSpec) Unmarshal

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

type JobStatus

type JobStatus struct {
	ConditionMessage string `protobuf:"bytes,1,opt,name=conditionMessage,proto3" json:"conditionMessage,omitempty"`
	StartTime        int64  `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
	CompletionTime   int64  `protobuf:"varint,3,opt,name=completionTime,proto3" json:"completionTime,omitempty"`
	Active           int32  `protobuf:"varint,4,opt,name=active,proto3" json:"active,omitempty"`
	Succeeded        int32  `protobuf:"varint,5,opt,name=succeeded,proto3" json:"succeeded,omitempty"`
	Failed           int32  `protobuf:"varint,6,opt,name=failed,proto3" json:"failed,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/staging/src/k8s.io/api/batch/v1/types.go#L132

func (*JobStatus) Descriptor

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

func (*JobStatus) Marshal

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

func (*JobStatus) MarshalTo

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

func (*JobStatus) ProtoMessage

func (*JobStatus) ProtoMessage()

func (*JobStatus) Reset

func (m *JobStatus) Reset()

func (*JobStatus) Size

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

func (*JobStatus) String

func (m *JobStatus) String() string

func (*JobStatus) Unmarshal

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

type ObjectReference struct {
	Kind            string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Namespace       string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name            string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Uid             string `protobuf:"bytes,4,opt,name=uid,proto3" json:"uid,omitempty"`
	ApiVersion      string `protobuf:"bytes,5,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
	ResourceVersion string `protobuf:"bytes,6,opt,name=resourceVersion,proto3" json:"resourceVersion,omitempty"`
	FieldPath       string `protobuf:"bytes,7,opt,name=fieldPath,proto3" json:"fieldPath,omitempty"`
}

reference https://github.com/kubernetes/kubernetes/blob/cb19b56831d54d1d31249949318ef0b07bf00df9/pkg/apis/core/types.go#L4317

func (*ObjectReference) Descriptor

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

func (*ObjectReference) Marshal

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

func (*ObjectReference) MarshalTo

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

func (*ObjectReference) ProtoMessage

func (*ObjectReference) ProtoMessage()

func (*ObjectReference) Reset

func (m *ObjectReference) Reset()

func (*ObjectReference) Size

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

func (*ObjectReference) String

func (m *ObjectReference) String() string

func (*ObjectReference) Unmarshal

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

type ProcStatsWithPerm struct {
	OpenFDCount int32 `protobuf:"varint,1,opt,name=openFDCount,proto3" json:"openFDCount,omitempty"`
	ReadCount   int64 `protobuf:"varint,2,opt,name=readCount,proto3" json:"readCount,omitempty"`
	WriteCount  int64 `protobuf:"varint,3,opt,name=writeCount,proto3" json:"writeCount,omitempty"`
	ReadBytes   int64 `protobuf:"varint,4,opt,name=readBytes,proto3" json:"readBytes,omitempty"`
	WriteBytes  int64 `protobuf:"varint,5,opt,name=writeBytes,proto3" json:"writeBytes,omitempty"`
}

ProcStatsWithPerm is holding attributes for processes that requires extra permission to collect. It is used to pass data between system-probe and process-agent

func (*ProcStatsWithPerm) Descriptor

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

func (*ProcStatsWithPerm) Marshal

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

func (*ProcStatsWithPerm) MarshalTo

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

func (*ProcStatsWithPerm) ProtoMessage

func (*ProcStatsWithPerm) ProtoMessage()

func (*ProcStatsWithPerm) Reset

func (m *ProcStatsWithPerm) Reset()

func (*ProcStatsWithPerm) Size

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

func (*ProcStatsWithPerm) String

func (m *ProcStatsWithPerm) String() string

func (*ProcStatsWithPerm) Unmarshal

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

type ProcStatsWithPermByPID

type ProcStatsWithPermByPID struct {
	StatsByPID map[int32]*ProcStatsWithPerm `` /* 148-byte string literal not displayed */
}

ProcStatsWithPermByPID stores ProcStatsWithPerm in a map with key as PIDs

func (*ProcStatsWithPermByPID) Descriptor

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

func (*ProcStatsWithPermByPID) GetStatsByPID

func (m *ProcStatsWithPermByPID) GetStatsByPID() map[int32]*ProcStatsWithPerm

func (*ProcStatsWithPermByPID) Marshal

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

func (*ProcStatsWithPermByPID) MarshalTo

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

func (*ProcStatsWithPermByPID) ProtoMessage

func (*ProcStatsWithPermByPID) ProtoMessage()

func (*ProcStatsWithPermByPID) Reset

func (m *ProcStatsWithPermByPID) Reset()

func (*ProcStatsWithPermByPID) Size

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

func (*ProcStatsWithPermByPID) String

func (m *ProcStatsWithPermByPID) String() string

func (*ProcStatsWithPermByPID) Unmarshal

func (m *ProcStatsWithPermByPID) 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"`
	Networks               *ProcessNetworks `protobuf:"bytes,21,opt,name=networks" json:"networks,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) GetNetworks

func (m *Process) GetNetworks() *ProcessNetworks

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 ProcessNetworks

type ProcessNetworks struct {
	ConnectionRate float32 `protobuf:"fixed32,1,opt,name=connectionRate,proto3" json:"connectionRate,omitempty"`
	BytesRate      float32 `protobuf:"fixed32,2,opt,name=bytesRate,proto3" json:"bytesRate,omitempty"`
}

ProcessNetworks is a structure that holds network related metrics for processes

func (*ProcessNetworks) Descriptor

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

func (*ProcessNetworks) Marshal

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

func (*ProcessNetworks) MarshalTo

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

func (*ProcessNetworks) ProtoMessage

func (*ProcessNetworks) ProtoMessage()

func (*ProcessNetworks) Reset

func (m *ProcessNetworks) Reset()

func (*ProcessNetworks) Size

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

func (*ProcessNetworks) String

func (m *ProcessNetworks) String() string

func (*ProcessNetworks) Unmarshal

func (m *ProcessNetworks) 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"`
	Networks       *ProcessNetworks `protobuf:"bytes,28,opt,name=networks" json:"networks,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) GetNetworks

func (m *ProcessStat) GetNetworks() *ProcessNetworks

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 Route

type Route struct {
	Subnet *Subnet `protobuf:"bytes,1,opt,name=subnet" json:"subnet,omitempty"`
}

func (*Route) Descriptor

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

func (*Route) GetSubnet

func (m *Route) GetSubnet() *Subnet

func (*Route) Marshal

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

func (*Route) MarshalTo

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

func (*Route) ProtoMessage

func (*Route) ProtoMessage()

func (*Route) Reset

func (m *Route) Reset()

func (*Route) Size

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

func (*Route) String

func (m *Route) String() string

func (*Route) Unmarshal

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

type RouteMetadata

type RouteMetadata struct {
	Alias        string `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	TagIndex     int32  `protobuf:"varint,2,opt,name=tagIndex,proto3" json:"tagIndex,omitempty"`
	TagsModified int64  `protobuf:"varint,3,opt,name=tagsModified,proto3" json:"tagsModified,omitempty"`
}

func (*RouteMetadata) Descriptor

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

func (*RouteMetadata) Marshal

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

func (*RouteMetadata) MarshalTo

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

func (*RouteMetadata) ProtoMessage

func (*RouteMetadata) ProtoMessage()

func (*RouteMetadata) Reset

func (m *RouteMetadata) Reset()

func (*RouteMetadata) Size

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

func (*RouteMetadata) String

func (m *RouteMetadata) String() string

func (*RouteMetadata) Unmarshal

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

type RuntimeCompilationResult

type RuntimeCompilationResult int32
const (
	RuntimeCompilationResult_NotAttempted       RuntimeCompilationResult = 0
	RuntimeCompilationResult_CompilationSuccess RuntimeCompilationResult = 1
	RuntimeCompilationResult_KernelVersionErr   RuntimeCompilationResult = 2
	RuntimeCompilationResult_VerificationError  RuntimeCompilationResult = 3
	RuntimeCompilationResult_OutputDirErr       RuntimeCompilationResult = 4
	RuntimeCompilationResult_OutputFileErr      RuntimeCompilationResult = 5
	RuntimeCompilationResult_NewCompilerErr     RuntimeCompilationResult = 6
	RuntimeCompilationResult_CompilationErr     RuntimeCompilationResult = 7
	RuntimeCompilationResult_ResultReadErr      RuntimeCompilationResult = 8
)

func (RuntimeCompilationResult) EnumDescriptor

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

func (RuntimeCompilationResult) String

func (x RuntimeCompilationResult) String() string

type RuntimeCompilationTelemetry

type RuntimeCompilationTelemetry struct {
	RuntimeCompilationEnabled  bool                     `protobuf:"varint,1,opt,name=runtimeCompilationEnabled,proto3" json:"runtimeCompilationEnabled,omitempty"`
	RuntimeCompilationResult   RuntimeCompilationResult `` /* 154-byte string literal not displayed */
	RuntimeCompilationDuration int64                    `protobuf:"varint,3,opt,name=runtimeCompilationDuration,proto3" json:"runtimeCompilationDuration,omitempty"`
}

func (*RuntimeCompilationTelemetry) Descriptor

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

func (*RuntimeCompilationTelemetry) Marshal

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

func (*RuntimeCompilationTelemetry) MarshalTo

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

func (*RuntimeCompilationTelemetry) ProtoMessage

func (*RuntimeCompilationTelemetry) ProtoMessage()

func (*RuntimeCompilationTelemetry) Reset

func (m *RuntimeCompilationTelemetry) Reset()

func (*RuntimeCompilationTelemetry) Size

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

func (*RuntimeCompilationTelemetry) String

func (m *RuntimeCompilationTelemetry) String() string

func (*RuntimeCompilationTelemetry) Unmarshal

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

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 (*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 Subnet

type Subnet struct {
	Alias string `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
}

func (*Subnet) Descriptor

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

func (*Subnet) Marshal

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

func (*Subnet) MarshalTo

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

func (*Subnet) ProtoMessage

func (*Subnet) ProtoMessage()

func (*Subnet) Reset

func (m *Subnet) Reset()

func (*Subnet) Size

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

func (*Subnet) String

func (m *Subnet) String() string

func (*Subnet) Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL