pubsubv1

package
v0.20.6 Latest Latest
Warning

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

 Go to latest Published: Dec 24, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_chalk_pubsub_v1_heartbeat_proto protoreflect.FileDescriptor
View Source 
var File_chalk_pubsub_v1_node_status_proto protoreflect.FileDescriptor
View Source 
var File_chalk_pubsub_v1_pod_status_proto protoreflect.FileDescriptor
View Source 
var File_chalk_pubsub_v1_queries_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type HeartbeatPubSub added in v0.4.7 

type HeartbeatPubSub struct {
	OperationId   string                 `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	ProjectId     string                 `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	EnvironmentId string                 `protobuf:"bytes,3,opt,name=environment_id,json=environmentId,proto3" json:"environment_id,omitempty"`
	TeamId        string                 `protobuf:"bytes,4,opt,name=team_id,json=teamId,proto3" json:"team_id,omitempty"`
	DeploymentId  string                 `protobuf:"bytes,5,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	GeneratedAt   *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=generated_at,json=generatedAt,proto3" json:"generated_at,omitempty"`
	ComputerId    uint32                 `protobuf:"varint,7,opt,name=computer_id,json=computerId,proto3" json:"computer_id,omitempty"`
	ShardId       uint32                 `protobuf:"varint,8,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatPubSub) Descriptor deprecated added in v0.4.7 

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

Deprecated: Use HeartbeatPubSub.ProtoReflect.Descriptor instead.

func (*HeartbeatPubSub) GetComputerId added in v0.4.7 

func (x *HeartbeatPubSub) GetComputerId() uint32

func (*HeartbeatPubSub) GetDeploymentId added in v0.4.7 

func (x *HeartbeatPubSub) GetDeploymentId() string

func (*HeartbeatPubSub) GetEnvironmentId added in v0.4.7 

func (x *HeartbeatPubSub) GetEnvironmentId() string

func (*HeartbeatPubSub) GetGeneratedAt added in v0.4.7 

func (x *HeartbeatPubSub) GetGeneratedAt() *timestamppb.Timestamp

func (*HeartbeatPubSub) GetOperationId added in v0.4.7 

func (x *HeartbeatPubSub) GetOperationId() string

func (*HeartbeatPubSub) GetProjectId added in v0.4.7 

func (x *HeartbeatPubSub) GetProjectId() string

func (*HeartbeatPubSub) GetShardId added in v0.4.7 

func (x *HeartbeatPubSub) GetShardId() uint32

func (*HeartbeatPubSub) GetTeamId added in v0.4.7 

func (x *HeartbeatPubSub) GetTeamId() string

func (*HeartbeatPubSub) ProtoMessage added in v0.4.7 

func (*HeartbeatPubSub) ProtoMessage()

func (*HeartbeatPubSub) ProtoReflect added in v0.4.7 

func (x *HeartbeatPubSub) ProtoReflect() protoreflect.Message

func (*HeartbeatPubSub) Reset added in v0.4.7 

func (x *HeartbeatPubSub) Reset()

func (*HeartbeatPubSub) String added in v0.4.7 

func (x *HeartbeatPubSub) String() string

type NodeStatusPubSub 

type NodeStatusPubSub struct {

	// The Chalk team name that incurred the usage.
	Team string `protobuf:"bytes,1,opt,name=team,proto3" json:"team,omitempty"`
	// node.Name
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// node.UID
	Uid string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"`
	// node.kubernetes.io/instance-type
	InstanceType string `protobuf:"bytes,4,opt,name=instance_type,json=instanceType,proto3" json:"instance_type,omitempty"`
	// topology.kubernetes.io/region
	Region string `protobuf:"bytes,5,opt,name=region,proto3" json:"region,omitempty"`
	// topology.kubernetes.io/zone
	Zone string `protobuf:"bytes,6,opt,name=zone,proto3" json:"zone,omitempty"`
	// The time that the instance was created.
	// node.CreationTimestamp.Unix()
	CreationTimestamp int64 `protobuf:"varint,8,opt,name=creation_timestamp,json=creationTimestamp,proto3" json:"creation_timestamp,omitempty"`
	// node.DeletionTimestamp.Unix()
	// The time that the instance was deleted. May be 0 if the instance is still running.
	DeletionTimestamp int64 `protobuf:"varint,9,opt,name=deletion_timestamp,json=deletionTimestamp,proto3" json:"deletion_timestamp,omitempty"`
	// The time that we polled the instance for usage.
	ObservedTimestamp int64 `protobuf:"varint,10,opt,name=observed_timestamp,json=observedTimestamp,proto3" json:"observed_timestamp,omitempty"`
	// node.Labels
	Labels map[string]string `` /* 154-byte string literal not displayed */
	// node.Annotations
	Annotations   map[string]string `` /* 164-byte string literal not displayed */
	MachineId     string            `protobuf:"bytes,13,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
	SystemUuid    string            `protobuf:"bytes,14,opt,name=system_uuid,json=systemUuid,proto3" json:"system_uuid,omitempty"`
	BootId        string            `protobuf:"bytes,15,opt,name=boot_id,json=bootId,proto3" json:"boot_id,omitempty"`
	Unschedulable bool              `protobuf:"varint,16,opt,name=unschedulable,proto3" json:"unschedulable,omitempty"`
	Namespace     string            `protobuf:"bytes,17,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// container.googleapis.com/instance_id
	InstanceId        string `protobuf:"bytes,18,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Cluster           string `protobuf:"bytes,19,opt,name=cluster,proto3" json:"cluster,omitempty"`
	TotalCpu          string `protobuf:"bytes,20,opt,name=total_cpu,json=totalCpu,proto3" json:"total_cpu,omitempty"`
	TotalMemory       string `protobuf:"bytes,21,opt,name=total_memory,json=totalMemory,proto3" json:"total_memory,omitempty"`
	AllocatableCpu    string `protobuf:"bytes,22,opt,name=allocatable_cpu,json=allocatableCpu,proto3" json:"allocatable_cpu,omitempty"`
	AllocatableMemory string `protobuf:"bytes,23,opt,name=allocatable_memory,json=allocatableMemory,proto3" json:"allocatable_memory,omitempty"`
	// contains filtered or unexported fields
}

InstanceUsage is a message that represents the usage of a single instance.

func (*NodeStatusPubSub) Descriptor deprecated 

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

Deprecated: Use NodeStatusPubSub.ProtoReflect.Descriptor instead.

func (*NodeStatusPubSub) GetAllocatableCpu added in v0.14.8 

func (x *NodeStatusPubSub) GetAllocatableCpu() string

func (*NodeStatusPubSub) GetAllocatableMemory added in v0.14.8 

func (x *NodeStatusPubSub) GetAllocatableMemory() string

func (*NodeStatusPubSub) GetAnnotations 

func (x *NodeStatusPubSub) GetAnnotations() map[string]string

func (*NodeStatusPubSub) GetBootId 

func (x *NodeStatusPubSub) GetBootId() string

func (*NodeStatusPubSub) GetCluster added in v0.4.7 

func (x *NodeStatusPubSub) GetCluster() string

func (*NodeStatusPubSub) GetCreationTimestamp 

func (x *NodeStatusPubSub) GetCreationTimestamp() int64

func (*NodeStatusPubSub) GetDeletionTimestamp 

func (x *NodeStatusPubSub) GetDeletionTimestamp() int64

func (*NodeStatusPubSub) GetInstanceId 

func (x *NodeStatusPubSub) GetInstanceId() string

func (*NodeStatusPubSub) GetInstanceType 

func (x *NodeStatusPubSub) GetInstanceType() string

func (*NodeStatusPubSub) GetLabels 

func (x *NodeStatusPubSub) GetLabels() map[string]string

func (*NodeStatusPubSub) GetMachineId 

func (x *NodeStatusPubSub) GetMachineId() string

func (*NodeStatusPubSub) GetName 

func (x *NodeStatusPubSub) GetName() string

func (*NodeStatusPubSub) GetNamespace 

func (x *NodeStatusPubSub) GetNamespace() string

func (*NodeStatusPubSub) GetObservedTimestamp 

func (x *NodeStatusPubSub) GetObservedTimestamp() int64

func (*NodeStatusPubSub) GetRegion 

func (x *NodeStatusPubSub) GetRegion() string

func (*NodeStatusPubSub) GetSystemUuid 

func (x *NodeStatusPubSub) GetSystemUuid() string

func (*NodeStatusPubSub) GetTeam 

func (x *NodeStatusPubSub) GetTeam() string

func (*NodeStatusPubSub) GetTotalCpu added in v0.14.8 

func (x *NodeStatusPubSub) GetTotalCpu() string

func (*NodeStatusPubSub) GetTotalMemory added in v0.14.8 

func (x *NodeStatusPubSub) GetTotalMemory() string

func (*NodeStatusPubSub) GetUid 

func (x *NodeStatusPubSub) GetUid() string

func (*NodeStatusPubSub) GetUnschedulable 

func (x *NodeStatusPubSub) GetUnschedulable() bool

func (*NodeStatusPubSub) GetZone 

func (x *NodeStatusPubSub) GetZone() string

func (*NodeStatusPubSub) ProtoMessage 

func (*NodeStatusPubSub) ProtoMessage()

func (*NodeStatusPubSub) ProtoReflect 

func (x *NodeStatusPubSub) ProtoReflect() protoreflect.Message

func (*NodeStatusPubSub) Reset 

func (x *NodeStatusPubSub) Reset()

func (*NodeStatusPubSub) String 

func (x *NodeStatusPubSub) String() string

type PodStatusPubSub 

type PodStatusPubSub struct {

	// The Chalk team name that incurred the usage.
	Team            string `protobuf:"bytes,1,opt,name=team,proto3" json:"team,omitempty"`
	App             string `protobuf:"bytes,2,opt,name=app,proto3" json:"app,omitempty"`
	Component       string `protobuf:"bytes,3,opt,name=component,proto3" json:"component,omitempty"`
	DatadogService  string `protobuf:"bytes,4,opt,name=datadog_service,json=datadogService,proto3" json:"datadog_service,omitempty"`
	DatadogVersion  string `protobuf:"bytes,5,opt,name=datadog_version,json=datadogVersion,proto3" json:"datadog_version,omitempty"`
	PodTemplateHash string `protobuf:"bytes,6,opt,name=pod_template_hash,json=podTemplateHash,proto3" json:"pod_template_hash,omitempty"`
	// string status = 7;
	Status *PodStatusPubSub_PodStatus `protobuf:"bytes,7,opt,name=status,proto3" json:"status,omitempty"`
	Spec   *PodStatusPubSub_PodSpec   `protobuf:"bytes,8,opt,name=spec,proto3" json:"spec,omitempty"`
	// The time that the instance was created.
	// pod.CreationTimestamp.Unix()
	CreationTimestamp int64 `protobuf:"varint,18,opt,name=creation_timestamp,json=creationTimestamp,proto3" json:"creation_timestamp,omitempty"`
	// pod.DeletionTimestamp.Unix()
	// The time that the instance was deleted. May be 0 if the instance is still running.
	DeletionTimestamp int64 `protobuf:"varint,19,opt,name=deletion_timestamp,json=deletionTimestamp,proto3" json:"deletion_timestamp,omitempty"`
	// The time that we polled the instance for usage.
	ObservedTimestamp int64 `protobuf:"varint,20,opt,name=observed_timestamp,json=observedTimestamp,proto3" json:"observed_timestamp,omitempty"`
	// pod.Labels
	Labels map[string]string `` /* 154-byte string literal not displayed */
	// pod.Annotations
	Annotations map[string]string `` /* 164-byte string literal not displayed */
	Cluster     string            `protobuf:"bytes,23,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// // node.UID
	Uid string `protobuf:"bytes,24,opt,name=uid,proto3" json:"uid,omitempty"`
	// // node.Name
	Name      string `protobuf:"bytes,25,opt,name=name,proto3" json:"name,omitempty"`
	Namespace string `protobuf:"bytes,26,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

PodStatusPubSub captures the state of a kubernetes pod.

func (*PodStatusPubSub) Descriptor deprecated 

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

Deprecated: Use PodStatusPubSub.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub) GetAnnotations 

func (x *PodStatusPubSub) GetAnnotations() map[string]string

func (*PodStatusPubSub) GetApp 

func (x *PodStatusPubSub) GetApp() string

func (*PodStatusPubSub) GetCluster added in v0.4.7 

func (x *PodStatusPubSub) GetCluster() string

func (*PodStatusPubSub) GetComponent 

func (x *PodStatusPubSub) GetComponent() string

func (*PodStatusPubSub) GetCreationTimestamp 

func (x *PodStatusPubSub) GetCreationTimestamp() int64

func (*PodStatusPubSub) GetDatadogService 

func (x *PodStatusPubSub) GetDatadogService() string

func (*PodStatusPubSub) GetDatadogVersion 

func (x *PodStatusPubSub) GetDatadogVersion() string

func (*PodStatusPubSub) GetDeletionTimestamp 

func (x *PodStatusPubSub) GetDeletionTimestamp() int64

func (*PodStatusPubSub) GetLabels 

func (x *PodStatusPubSub) GetLabels() map[string]string

func (*PodStatusPubSub) GetName added in v0.13.6 

func (x *PodStatusPubSub) GetName() string

func (*PodStatusPubSub) GetNamespace added in v0.13.6 

func (x *PodStatusPubSub) GetNamespace() string

func (*PodStatusPubSub) GetObservedTimestamp 

func (x *PodStatusPubSub) GetObservedTimestamp() int64

func (*PodStatusPubSub) GetPodTemplateHash 

func (x *PodStatusPubSub) GetPodTemplateHash() string

func (*PodStatusPubSub) GetSpec 

func (x *PodStatusPubSub) GetSpec() *PodStatusPubSub_PodSpec

func (*PodStatusPubSub) GetStatus 

func (x *PodStatusPubSub) GetStatus() *PodStatusPubSub_PodStatus

func (*PodStatusPubSub) GetTeam 

func (x *PodStatusPubSub) GetTeam() string

func (*PodStatusPubSub) GetUid added in v0.13.6 

func (x *PodStatusPubSub) GetUid() string

func (*PodStatusPubSub) ProtoMessage 

func (*PodStatusPubSub) ProtoMessage()

func (*PodStatusPubSub) ProtoReflect 

func (x *PodStatusPubSub) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub) Reset 

func (x *PodStatusPubSub) Reset()

func (*PodStatusPubSub) String 

func (x *PodStatusPubSub) String() string

type PodStatusPubSub_ClaimSource 

type PodStatusPubSub_ClaimSource struct {

	// ResourceClaimName is the name of a ResourceClaim object in the same
	// namespace as this pod.
	ResourceClaimName *string `protobuf:"bytes,1,opt,name=resource_claim_name,json=resourceClaimName,proto3,oneof" json:"resource_claim_name,omitempty"`
	// ResourceClaimTemplateName is the name of a ResourceClaimTemplate
	// object in the same namespace as this pod.
	//
	// The template will be used to create a new ResourceClaim, which will
	// be bound to this pod. When this pod is deleted, the ResourceClaim
	// will also be deleted. The pod name and resource name, along with a
	// generated component, will be used to form a unique name for the
	// ResourceClaim, which will be recorded in pod.status.resourceClaimStatuses.
	//
	// This field is immutable and no changes will be made to the
	// corresponding ResourceClaim by the control plane after creating the
	// ResourceClaim.
	ResourceClaimTemplateName *string `` /* 146-byte string literal not displayed */
	// contains filtered or unexported fields
}

ClaimSource describes a reference to a ResourceClaim.

Exactly one of these fields should be set. Consumers of this type must treat an empty object as if it has an unknown value.

func (*PodStatusPubSub_ClaimSource) Descriptor deprecated 

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

Deprecated: Use PodStatusPubSub_ClaimSource.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_ClaimSource) GetResourceClaimName 

func (x *PodStatusPubSub_ClaimSource) GetResourceClaimName() string

func (*PodStatusPubSub_ClaimSource) GetResourceClaimTemplateName 

func (x *PodStatusPubSub_ClaimSource) GetResourceClaimTemplateName() string

func (*PodStatusPubSub_ClaimSource) ProtoMessage 

func (*PodStatusPubSub_ClaimSource) ProtoMessage()

func (*PodStatusPubSub_ClaimSource) ProtoReflect 

func (x *PodStatusPubSub_ClaimSource) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_ClaimSource) Reset 

func (x *PodStatusPubSub_ClaimSource) Reset()

func (*PodStatusPubSub_ClaimSource) String 

func (x *PodStatusPubSub_ClaimSource) String() string

type PodStatusPubSub_Container 

type PodStatusPubSub_Container struct {

	// Name of the container specified as a DNS_LABEL.
	// Each container in a pod must have a unique name (DNS_LABEL).
	// Cannot be updated.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Container image name.
	// More info: https://kubernetes.io/docs/concepts/containers/images
	// This field is optional to allow higher level config management to default or override
	// container images in workload controllers like Deployments and StatefulSets.
	// +optional
	Image *string `protobuf:"bytes,2,opt,name=image,proto3,oneof" json:"image,omitempty"`
	// Entrypoint array. Not executed within a shell.
	// The container image's ENTRYPOINT is used if this is not provided.
	// Variable references $(VAR_NAME) are expanded using the container's environment. If a variable
	// cannot be resolved, the reference in the input string will be unchanged. Double $$ are reduced
	// to a single $, which allows for escaping the $(VAR_NAME) syntax: i.e. "$$(VAR_NAME)" will
	// produce the string literal "$(VAR_NAME)". Escaped references will never be expanded, regardless
	// of whether the variable exists or not. Cannot be updated.
	// More info: https://kubernetes.io/docs/tasks/inject-data-application/define-command-argument-container/#running-a-command-in-a-shell
	// +optional
	// +listType=atomic
	Command []string `protobuf:"bytes,3,rep,name=command,proto3" json:"command,omitempty"`
	// Arguments to the entrypoint.
	// The container image's CMD is used if this is not provided.
	// Variable references $(VAR_NAME) are expanded using the container's environment. If a variable
	// cannot be resolved, the reference in the input string will be unchanged. Double $$ are reduced
	// to a single $, which allows for escaping the $(VAR_NAME) syntax: i.e. "$$(VAR_NAME)" will
	// produce the string literal "$(VAR_NAME)". Escaped references will never be expanded, regardless
	// of whether the variable exists or not. Cannot be updated.
	// More info: https://kubernetes.io/docs/tasks/inject-data-application/define-command-argument-container/#running-a-command-in-a-shell
	// +optional
	// +listType=atomic
	Args []string `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	// Container's working directory.
	// If not specified, the container runtime's default will be used, which
	// might be configured in the container image.
	// Cannot be updated.
	// +optional
	WorkingDir *string `protobuf:"bytes,5,opt,name=working_dir,json=workingDir,proto3,oneof" json:"working_dir,omitempty"`
	// List of environment variables to set in the container.
	// Cannot be updated.
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=name
	Env []*PodStatusPubSub_EnvVar `protobuf:"bytes,7,rep,name=env,proto3" json:"env,omitempty"`
	// Compute Resources required by this container.
	// Cannot be updated.
	// More info: https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/
	// +optional
	Resources *PodStatusPubSub_ResourceRequirements `protobuf:"bytes,8,opt,name=resources,proto3,oneof" json:"resources,omitempty"`
	// RestartPolicy defines the restart behavior of individual containers in a pod.
	// This field may only be set for init containers, and the only allowed value is "Always".
	// For non-init containers or when this field is not specified,
	// the restart behavior is defined by the Pod's restart policy and the container type.
	// Setting the RestartPolicy as "Always" for the init container will have the following effect:
	// this init container will be continually restarted on
	// exit until all regular containers have terminated. Once all regular
	// containers have completed, all init containers with restartPolicy "Always"
	// will be shut down. This lifecycle differs from normal init containers and
	// is often referred to as a "sidecar" container. Although this init
	// container still starts in the init container sequence, it does not wait
	// for the container to complete before proceeding to the next init
	// container. Instead, the next init container starts immediately after this
	// init container is started, or after any startupProbe has successfully
	// completed.
	// +featureGate=SidecarContainers
	// +optional
	RestartPolicy *string `protobuf:"bytes,24,opt,name=restart_policy,json=restartPolicy,proto3,oneof" json:"restart_policy,omitempty"`
	// Optional: Path at which the file to which the container's termination message
	// will be written is mounted into the container's filesystem.
	// Message written is intended to be brief final status, such as an assertion failure message.
	// Will be truncated by the node if greater than 4096 bytes. The total message length across
	// all containers will be limited to 12kb.
	// Defaults to /dev/termination-log.
	// Cannot be updated.
	// +optional
	TerminationMessagePath *string `` /* 136-byte string literal not displayed */
	// Indicate how the termination message should be populated. File will use the contents of
	// terminationMessagePath to populate the container status message on both success and failure.
	// FallbackToLogsOnError will use the last chunk of container log output if the termination
	// message file is empty and the container exited with an error.
	// The log output is limited to 2048 bytes or 80 lines, whichever is smaller.
	// Defaults to File.
	// Cannot be updated.
	// +optional
	TerminationMessagePolicy *string `` /* 142-byte string literal not displayed */
	// Image pull policy.
	// One of Always, Never, IfNotPresent.
	// Defaults to Always if :latest tag is specified, or IfNotPresent otherwise.
	// Cannot be updated.
	// More info: https://kubernetes.io/docs/concepts/containers/images#updating-images
	// +optional
	ImagePullPolicy *string `protobuf:"bytes,14,opt,name=image_pull_policy,json=imagePullPolicy,proto3,oneof" json:"image_pull_policy,omitempty"`
	// Whether this container should allocate a buffer for stdin in the container runtime. If this
	// is not set, reads from stdin in the container will always result in EOF.
	Stdin bool `protobuf:"varint,16,opt,name=stdin,proto3" json:"stdin,omitempty"`
	// Whether the container runtime should close the stdin channel after it has been opened by
	// a single attach. When stdin is true the stdin stream will remain open across multiple attach
	// sessions. If stdinOnce is set to true, stdin is opened on container start, is empty until the
	// first client attaches to stdin, and then remains open and accepts data until the client disconnects,
	// at which time stdin is closed and remains closed until the container is restarted. If this
	// flag is false, a container processes that reads from stdin will never receive an EOF.
	StdinOnce bool `protobuf:"varint,17,opt,name=stdin_once,json=stdinOnce,proto3" json:"stdin_once,omitempty"`
	// Whether this container should allocate a TTY for itself, also requires 'stdin' to be true.
	Tty bool `protobuf:"varint,18,opt,name=tty,proto3" json:"tty,omitempty"`
	// contains filtered or unexported fields
}

A single application container that you want to run within a pod.

func (*PodStatusPubSub_Container) Descriptor deprecated 

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

Deprecated: Use PodStatusPubSub_Container.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_Container) GetArgs 

func (x *PodStatusPubSub_Container) GetArgs() []string

func (*PodStatusPubSub_Container) GetCommand 

func (x *PodStatusPubSub_Container) GetCommand() []string

func (*PodStatusPubSub_Container) GetEnv 

func (x *PodStatusPubSub_Container) GetEnv() []*PodStatusPubSub_EnvVar

func (*PodStatusPubSub_Container) GetImage 

func (x *PodStatusPubSub_Container) GetImage() string

func (*PodStatusPubSub_Container) GetImagePullPolicy 

func (x *PodStatusPubSub_Container) GetImagePullPolicy() string

func (*PodStatusPubSub_Container) GetName 

func (x *PodStatusPubSub_Container) GetName() string

func (*PodStatusPubSub_Container) GetResources added in v0.12.2 

func (x *PodStatusPubSub_Container) GetResources() *PodStatusPubSub_ResourceRequirements

func (*PodStatusPubSub_Container) GetRestartPolicy 

func (x *PodStatusPubSub_Container) GetRestartPolicy() string

func (*PodStatusPubSub_Container) GetStdin 

func (x *PodStatusPubSub_Container) GetStdin() bool

func (*PodStatusPubSub_Container) GetStdinOnce 

func (x *PodStatusPubSub_Container) GetStdinOnce() bool

func (*PodStatusPubSub_Container) GetTerminationMessagePath 

func (x *PodStatusPubSub_Container) GetTerminationMessagePath() string

func (*PodStatusPubSub_Container) GetTerminationMessagePolicy 

func (x *PodStatusPubSub_Container) GetTerminationMessagePolicy() string

func (*PodStatusPubSub_Container) GetTty 

func (x *PodStatusPubSub_Container) GetTty() bool

func (*PodStatusPubSub_Container) GetWorkingDir 

func (x *PodStatusPubSub_Container) GetWorkingDir() string

func (*PodStatusPubSub_Container) ProtoMessage 

func (*PodStatusPubSub_Container) ProtoMessage()

func (*PodStatusPubSub_Container) ProtoReflect 

func (x *PodStatusPubSub_Container) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_Container) Reset 

func (x *PodStatusPubSub_Container) Reset()

func (*PodStatusPubSub_Container) String 

func (x *PodStatusPubSub_Container) String() string

type PodStatusPubSub_ContainerState 

type PodStatusPubSub_ContainerState struct {

	// Details about a waiting container
	// +optional
	Waiting *PodStatusPubSub_ContainerStateWaiting `protobuf:"bytes,1,opt,name=waiting,proto3,oneof" json:"waiting,omitempty"`
	// Details about a running container
	// +optional
	Running *PodStatusPubSub_ContainerStateRunning `protobuf:"bytes,2,opt,name=running,proto3,oneof" json:"running,omitempty"`
	// Details about a terminated container
	// +optional
	Terminated *PodStatusPubSub_ContainerStateTerminated `protobuf:"bytes,3,opt,name=terminated,proto3,oneof" json:"terminated,omitempty"`
	// contains filtered or unexported fields
}

ContainerState holds a possible state of container. Only one of its members may be specified. If none of them is specified, the default one is ContainerStateWaiting.

func (*PodStatusPubSub_ContainerState) Descriptor deprecated 

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

Deprecated: Use PodStatusPubSub_ContainerState.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_ContainerState) GetRunning 

func (x *PodStatusPubSub_ContainerState) GetRunning() *PodStatusPubSub_ContainerStateRunning

func (*PodStatusPubSub_ContainerState) GetTerminated 

func (x *PodStatusPubSub_ContainerState) GetTerminated() *PodStatusPubSub_ContainerStateTerminated

func (*PodStatusPubSub_ContainerState) GetWaiting 

func (x *PodStatusPubSub_ContainerState) GetWaiting() *PodStatusPubSub_ContainerStateWaiting

func (*PodStatusPubSub_ContainerState) ProtoMessage 

func (*PodStatusPubSub_ContainerState) ProtoMessage()

func (*PodStatusPubSub_ContainerState) ProtoReflect 

func (x *PodStatusPubSub_ContainerState) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_ContainerState) Reset 

func (x *PodStatusPubSub_ContainerState) Reset()

func (*PodStatusPubSub_ContainerState) String 

func (x *PodStatusPubSub_ContainerState) String() string

type PodStatusPubSub_ContainerStateRunning 

type PodStatusPubSub_ContainerStateRunning struct {

	// Time at which the container was last (re-)started
	// +optional
	StartedAt int64 `protobuf:"varint,1,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// contains filtered or unexported fields
}

ContainerStateRunning is a running state of a container.

func (*PodStatusPubSub_ContainerStateRunning) Descriptor deprecated 

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

Deprecated: Use PodStatusPubSub_ContainerStateRunning.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_ContainerStateRunning) GetStartedAt 

func (x *PodStatusPubSub_ContainerStateRunning) GetStartedAt() int64

func (*PodStatusPubSub_ContainerStateRunning) ProtoMessage 

func (*PodStatusPubSub_ContainerStateRunning) ProtoMessage()

func (*PodStatusPubSub_ContainerStateRunning) ProtoReflect 

func (x *PodStatusPubSub_ContainerStateRunning) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_ContainerStateRunning) Reset 

func (x *PodStatusPubSub_ContainerStateRunning) Reset()

func (*PodStatusPubSub_ContainerStateRunning) String 

func (x *PodStatusPubSub_ContainerStateRunning) String() string

type PodStatusPubSub_ContainerStateTerminated 

type PodStatusPubSub_ContainerStateTerminated struct {

	// Exit status from the last termination of the container
	ExitCode int32 `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// Signal from the last termination of the container
	// +optional
	Signal *int32 `protobuf:"varint,2,opt,name=signal,proto3,oneof" json:"signal,omitempty"`
	// (brief) reason from the last termination of the container
	// +optional
	Reason *string `protobuf:"bytes,3,opt,name=reason,proto3,oneof" json:"reason,omitempty"`
	// Message regarding the last termination of the container
	// +optional
	Message *string `protobuf:"bytes,4,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// Time at which previous execution of the container started
	// +optional
	StartedAt *int64 `protobuf:"varint,5,opt,name=started_at,json=startedAt,proto3,oneof" json:"started_at,omitempty"`
	// Time at which the container last terminated
	// +optional
	FinishedAt *int64 `protobuf:"varint,6,opt,name=finished_at,json=finishedAt,proto3,oneof" json:"finished_at,omitempty"`
	// Container's ID in the format '<type>://<container_id>'
	// +optional
	ContainerId *string `protobuf:"bytes,7,opt,name=container_id,json=containerId,proto3,oneof" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

ContainerStateTerminated is a terminated state of a container.

func (*PodStatusPubSub_ContainerStateTerminated) Descriptor deprecated 

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

Deprecated: Use PodStatusPubSub_ContainerStateTerminated.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_ContainerStateTerminated) GetContainerId 

func (x *PodStatusPubSub_ContainerStateTerminated) GetContainerId() string

func (*PodStatusPubSub_ContainerStateTerminated) GetExitCode 

func (x *PodStatusPubSub_ContainerStateTerminated) GetExitCode() int32

func (*PodStatusPubSub_ContainerStateTerminated) GetFinishedAt 

func (x *PodStatusPubSub_ContainerStateTerminated) GetFinishedAt() int64

func (*PodStatusPubSub_ContainerStateTerminated) GetMessage 

func (x *PodStatusPubSub_ContainerStateTerminated) GetMessage() string

func (*PodStatusPubSub_ContainerStateTerminated) GetReason 

func (x *PodStatusPubSub_ContainerStateTerminated) GetReason() string

func (*PodStatusPubSub_ContainerStateTerminated) GetSignal 

func (x *PodStatusPubSub_ContainerStateTerminated) GetSignal() int32

func (*PodStatusPubSub_ContainerStateTerminated) GetStartedAt 

func (x *PodStatusPubSub_ContainerStateTerminated) GetStartedAt() int64

func (*PodStatusPubSub_ContainerStateTerminated) ProtoMessage 

func (*PodStatusPubSub_ContainerStateTerminated) ProtoMessage()

func (*PodStatusPubSub_ContainerStateTerminated) ProtoReflect 

func (x *PodStatusPubSub_ContainerStateTerminated) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_ContainerStateTerminated) Reset 

func (x *PodStatusPubSub_ContainerStateTerminated) Reset()

func (*PodStatusPubSub_ContainerStateTerminated) String 

func (x *PodStatusPubSub_ContainerStateTerminated) String() string

type PodStatusPubSub_ContainerStateWaiting 

type PodStatusPubSub_ContainerStateWaiting struct {

	// (brief) reason the container is not yet running.
	// +optional
	Reason *string `protobuf:"bytes,1,opt,name=reason,proto3,oneof" json:"reason,omitempty"`
	// Message regarding why the container is not yet running.
	// +optional
	Message *string `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// contains filtered or unexported fields
}

ContainerStateWaiting is a waiting state of a container.

func (*PodStatusPubSub_ContainerStateWaiting) Descriptor deprecated 

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

Deprecated: Use PodStatusPubSub_ContainerStateWaiting.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_ContainerStateWaiting) GetMessage 

func (x *PodStatusPubSub_ContainerStateWaiting) GetMessage() string

func (*PodStatusPubSub_ContainerStateWaiting) GetReason 

func (x *PodStatusPubSub_ContainerStateWaiting) GetReason() string

func (*PodStatusPubSub_ContainerStateWaiting) ProtoMessage 

func (*PodStatusPubSub_ContainerStateWaiting) ProtoMessage()

func (*PodStatusPubSub_ContainerStateWaiting) ProtoReflect 

func (x *PodStatusPubSub_ContainerStateWaiting) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_ContainerStateWaiting) Reset 

func (x *PodStatusPubSub_ContainerStateWaiting) Reset()

func (*PodStatusPubSub_ContainerStateWaiting) String 

func (x *PodStatusPubSub_ContainerStateWaiting) String() string

type PodStatusPubSub_ContainerStatus 

type PodStatusPubSub_ContainerStatus struct {

	// Name is a DNS_LABEL representing the unique name of the container.
	// Each container in a pod must have a unique name across all container types.
	// Cannot be updated.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// State holds details about the container's current condition.
	// +optional
	State *PodStatusPubSub_ContainerState `protobuf:"bytes,2,opt,name=state,proto3,oneof" json:"state,omitempty"`
	// LastTerminationState holds the last termination state of the container to
	// help debug container crashes and restarts. This field is not
	// populated if the container is still running and RestartCount is 0.
	// +optional
	LastState *PodStatusPubSub_ContainerState `protobuf:"bytes,3,opt,name=last_state,json=lastState,proto3,oneof" json:"last_state,omitempty"`
	// Ready specifies whether the container is currently passing its readiness check.
	// The value will change as readiness probes keep executing. If no readiness
	// probes are specified, this field defaults to true once the container is
	// fully started (see Started field).
	//
	// The value is typically used to determine whether a container is ready to
	// accept traffic.
	Ready *bool `protobuf:"varint,4,opt,name=ready,proto3,oneof" json:"ready,omitempty"`
	// RestartCount holds the number of times the container has been restarted.
	// Kubelet makes an effort to always increment the value, but there
	// are cases when the state may be lost due to node restarts and then the value
	// may be reset to 0. The value is never negative.
	RestartCount int32 `protobuf:"varint,5,opt,name=restart_count,json=restartCount,proto3" json:"restart_count,omitempty"`
	// Image is the name of container image that the container is running.
	// The container image may not match the image used in the PodSpec,
	// as it may have been resolved by the runtime.
	// More info: https://kubernetes.io/docs/concepts/containers/images.
	Image string `protobuf:"bytes,6,opt,name=image,proto3" json:"image,omitempty"`
	// ImageID is the image ID of the container's image. The image ID may not
	// match the image ID of the image used in the PodSpec, as it may have been
	// resolved by the runtime.
	ImageId string `protobuf:"bytes,7,opt,name=image_id,json=imageId,proto3" json:"image_id,omitempty"`
	// ContainerID is the ID of the container in the format '<type>://<container_id>'.
	// Where type is a container runtime identifier, returned from Version call of CRI API
	// (for example "containerd").
	// +optional
	ContainerId string `protobuf:"bytes,8,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// Started indicates whether the container has finished its postStart lifecycle hook
	// and passed its startup probe.
	// Initialized as false, becomes true after startupProbe is considered
	// successful. Resets to false when the container is restarted, or if kubelet
	// loses state temporarily. In both cases, startup probes will run again.
	// Is always true when no startupProbe is defined and container is running and
	// has passed the postStart lifecycle hook.
	Started bool `protobuf:"varint,9,opt,name=started,proto3" json:"started,omitempty"`
	// contains filtered or unexported fields
}

ContainerStatus contains details for the current status of this container.

func (*PodStatusPubSub_ContainerStatus) Descriptor deprecated 

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

Deprecated: Use PodStatusPubSub_ContainerStatus.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_ContainerStatus) GetContainerId 

func (x *PodStatusPubSub_ContainerStatus) GetContainerId() string

func (*PodStatusPubSub_ContainerStatus) GetImage 

func (x *PodStatusPubSub_ContainerStatus) GetImage() string

func (*PodStatusPubSub_ContainerStatus) GetImageId 

func (x *PodStatusPubSub_ContainerStatus) GetImageId() string

func (*PodStatusPubSub_ContainerStatus) GetLastState 

func (x *PodStatusPubSub_ContainerStatus) GetLastState() *PodStatusPubSub_ContainerState

func (*PodStatusPubSub_ContainerStatus) GetName 

func (x *PodStatusPubSub_ContainerStatus) GetName() string

func (*PodStatusPubSub_ContainerStatus) GetReady 

func (x *PodStatusPubSub_ContainerStatus) GetReady() bool

func (*PodStatusPubSub_ContainerStatus) GetRestartCount 

func (x *PodStatusPubSub_ContainerStatus) GetRestartCount() int32

func (*PodStatusPubSub_ContainerStatus) GetStarted 

func (x *PodStatusPubSub_ContainerStatus) GetStarted() bool

func (*PodStatusPubSub_ContainerStatus) GetState 

func (x *PodStatusPubSub_ContainerStatus) GetState() *PodStatusPubSub_ContainerState

func (*PodStatusPubSub_ContainerStatus) ProtoMessage 

func (*PodStatusPubSub_ContainerStatus) ProtoMessage()

func (*PodStatusPubSub_ContainerStatus) ProtoReflect 

func (x *PodStatusPubSub_ContainerStatus) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_ContainerStatus) Reset 

func (x *PodStatusPubSub_ContainerStatus) Reset()

func (*PodStatusPubSub_ContainerStatus) String 

func (x *PodStatusPubSub_ContainerStatus) String() string

type PodStatusPubSub_EnvVar 

type PodStatusPubSub_EnvVar struct {

	// Name of the environment variable. Must be a C_IDENTIFIER.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Variable references $(VAR_NAME) are expanded
	// using the previously defined environment variables in the container and
	// any service environment variables. If a variable cannot be resolved,
	// the reference in the input string will be unchanged. Double $$ are reduced
	// to a single $, which allows for escaping the $(VAR_NAME) syntax: i.e.
	// "$$(VAR_NAME)" will produce the string literal "$(VAR_NAME)".
	// Escaped references will never be expanded, regardless of whether the variable
	// exists or not.
	// Defaults to "".
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

EnvVar represents an environment variable present in a Container.

func (*PodStatusPubSub_EnvVar) Descriptor deprecated 

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

Deprecated: Use PodStatusPubSub_EnvVar.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_EnvVar) GetName 

func (x *PodStatusPubSub_EnvVar) GetName() string

func (*PodStatusPubSub_EnvVar) GetValue 

func (x *PodStatusPubSub_EnvVar) GetValue() string

func (*PodStatusPubSub_EnvVar) ProtoMessage 

func (*PodStatusPubSub_EnvVar) ProtoMessage()

func (*PodStatusPubSub_EnvVar) ProtoReflect 

func (x *PodStatusPubSub_EnvVar) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_EnvVar) Reset 

func (x *PodStatusPubSub_EnvVar) Reset()

func (*PodStatusPubSub_EnvVar) String 

func (x *PodStatusPubSub_EnvVar) String() string

type PodStatusPubSub_HostIP 

type PodStatusPubSub_HostIP struct {

	// IP is the IP address assigned to the host
	Ip *string `protobuf:"bytes,1,opt,name=ip,proto3,oneof" json:"ip,omitempty"`
	// contains filtered or unexported fields
}

HostIP represents a single IP address allocated to the host.

func (*PodStatusPubSub_HostIP) Descriptor deprecated 

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

Deprecated: Use PodStatusPubSub_HostIP.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_HostIP) GetIp 

func (x *PodStatusPubSub_HostIP) GetIp() string

func (*PodStatusPubSub_HostIP) ProtoMessage 

func (*PodStatusPubSub_HostIP) ProtoMessage()

func (*PodStatusPubSub_HostIP) ProtoReflect 

func (x *PodStatusPubSub_HostIP) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_HostIP) Reset 

func (x *PodStatusPubSub_HostIP) Reset()

func (*PodStatusPubSub_HostIP) String 

func (x *PodStatusPubSub_HostIP) String() string

type PodStatusPubSub_PodCondition 

type PodStatusPubSub_PodCondition struct {

	// Type is the type of the condition.
	// More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#pod-conditions
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Status is the status of the condition.
	// Can be True, False, Unknown.
	// More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#pod-conditions
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// Last time we probed the condition.
	// +optional
	LastProbeTime int64 `protobuf:"varint,3,opt,name=last_probe_time,json=lastProbeTime,proto3" json:"last_probe_time,omitempty"`
	// Last time the condition transitioned from one status to another.
	// +optional
	LastTransitionTime int64 `protobuf:"varint,4,opt,name=last_transition_time,json=lastTransitionTime,proto3" json:"last_transition_time,omitempty"`
	// Unique, one-word, CamelCase reason for the condition's last transition.
	// +optional
	Reason *string `protobuf:"bytes,5,opt,name=reason,proto3,oneof" json:"reason,omitempty"`
	// Human-readable message indicating details about last transition.
	// +optional
	Message *string `protobuf:"bytes,6,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// contains filtered or unexported fields
}

PodCondition contains details for the current condition of this pod.

func (*PodStatusPubSub_PodCondition) Descriptor deprecated 

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

Deprecated: Use PodStatusPubSub_PodCondition.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_PodCondition) GetLastProbeTime 

func (x *PodStatusPubSub_PodCondition) GetLastProbeTime() int64

func (*PodStatusPubSub_PodCondition) GetLastTransitionTime 

func (x *PodStatusPubSub_PodCondition) GetLastTransitionTime() int64

func (*PodStatusPubSub_PodCondition) GetMessage 

func (x *PodStatusPubSub_PodCondition) GetMessage() string

func (*PodStatusPubSub_PodCondition) GetReason 

func (x *PodStatusPubSub_PodCondition) GetReason() string

func (*PodStatusPubSub_PodCondition) GetStatus 

func (x *PodStatusPubSub_PodCondition) GetStatus() string

func (*PodStatusPubSub_PodCondition) GetType 

func (x *PodStatusPubSub_PodCondition) GetType() string

func (*PodStatusPubSub_PodCondition) ProtoMessage 

func (*PodStatusPubSub_PodCondition) ProtoMessage()

func (*PodStatusPubSub_PodCondition) ProtoReflect 

func (x *PodStatusPubSub_PodCondition) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_PodCondition) Reset 

func (x *PodStatusPubSub_PodCondition) Reset()

func (*PodStatusPubSub_PodCondition) String 

func (x *PodStatusPubSub_PodCondition) String() string

type PodStatusPubSub_PodResourceClaim 

type PodStatusPubSub_PodResourceClaim struct {

	// Name uniquely identifies this resource claim inside the pod.
	// This must be a DNS_LABEL.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Source describes where to find the ResourceClaim.
	Source *PodStatusPubSub_ClaimSource `protobuf:"bytes,2,opt,name=source,proto3,oneof" json:"source,omitempty"`
	// contains filtered or unexported fields
}

PodResourceClaim references exactly one ResourceClaim through a ClaimSource. It adds a name to it that uniquely identifies the ResourceClaim inside the Pod. Containers that need access to the ResourceClaim reference it with this name.

func (*PodStatusPubSub_PodResourceClaim) Descriptor deprecated 

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

Deprecated: Use PodStatusPubSub_PodResourceClaim.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_PodResourceClaim) GetName 

func (x *PodStatusPubSub_PodResourceClaim) GetName() string

func (*PodStatusPubSub_PodResourceClaim) GetSource 

func (x *PodStatusPubSub_PodResourceClaim) GetSource() *PodStatusPubSub_ClaimSource

func (*PodStatusPubSub_PodResourceClaim) ProtoMessage 

func (*PodStatusPubSub_PodResourceClaim) ProtoMessage()

func (*PodStatusPubSub_PodResourceClaim) ProtoReflect 

func (x *PodStatusPubSub_PodResourceClaim) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_PodResourceClaim) Reset 

func (x *PodStatusPubSub_PodResourceClaim) Reset()

func (*PodStatusPubSub_PodResourceClaim) String 

func (x *PodStatusPubSub_PodResourceClaim) String() string

type PodStatusPubSub_PodSpec 

type PodStatusPubSub_PodSpec struct {

	// List of volumes that can be mounted by containers belonging to the pod.
	// More info: https://kubernetes.io/docs/concepts/storage/volumes
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge,retainKeys
	// +listType=map
	// +listMapKey=name
	Volumes []*PodStatusPubSub_Volume `protobuf:"bytes,1,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// List of initialization containers belonging to the pod.
	// Init containers are executed in order prior to containers being started. If any
	// init container fails, the pod is considered to have failed and is handled according
	// to its restartPolicy. The name for an init container or normal container must be
	// unique among all containers.
	// Init containers may not have Lifecycle actions, Readiness probes, Liveness probes, or Startup probes.
	// The resourceRequirements of an init container are taken into account during scheduling
	// by finding the highest request/limit for each resource type, and then using the max of
	// of that value or the sum of the normal containers. Limits are applied to init containers
	// in a similar fashion.
	// Init containers cannot currently be added or removed.
	// Cannot be updated.
	// More info: https://kubernetes.io/docs/concepts/workloads/pods/init-containers/
	// +patchMergeKey=name
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=name
	InitContainers []*PodStatusPubSub_Container `protobuf:"bytes,20,rep,name=init_containers,json=initContainers,proto3" json:"init_containers,omitempty"`
	// List of containers belonging to the pod.
	// Containers cannot currently be added or removed.
	// There must be at least one container in a Pod.
	// Cannot be updated.
	// +patchMergeKey=name
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=name
	Containers []*PodStatusPubSub_Container `protobuf:"bytes,2,rep,name=containers,proto3" json:"containers,omitempty"`
	// Restart policy for all containers within the pod.
	// One of Always, OnFailure, Never. In some contexts, only a subset of those values may be permitted.
	// Default to Always.
	// More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle/#restart-policy
	// +optional
	RestartPolicy *string `protobuf:"bytes,3,opt,name=restart_policy,json=restartPolicy,proto3,oneof" json:"restart_policy,omitempty"`
	// Optional duration in seconds the pod needs to terminate gracefully. May be decreased in delete request.
	// Value must be non-negative integer. The value zero indicates stop immediately via
	// the kill signal (no opportunity to shut down).
	// If this value is nil, the default grace period will be used instead.
	// The grace period is the duration in seconds after the processes running in the pod are sent
	// a termination signal and the time when the processes are forcibly halted with a kill signal.
	// Set this value longer than the expected cleanup time for your process.
	// Defaults to 30 seconds.
	// +optional
	TerminationGracePeriodSeconds *int64 `` /* 159-byte string literal not displayed */
	// Optional duration in seconds the pod may be active on the node relative to
	// start_time before the system will actively try to mark it failed and kill associated containers.
	// Value must be a positive integer.
	// +optional
	ActiveDeadlineSeconds *int64 `` /* 133-byte string literal not displayed */
	// Set DNS policy for the pod.
	// Defaults to "ClusterFirst".
	// Valid values are 'ClusterFirstWithHostNet', 'ClusterFirst', 'Default' or 'None'.
	// DNS parameters given in DNSConfig will be merged with the policy selected with DNSPolicy.
	// To have DNS options set along with hostNetwork, you have to specify DNS policy
	// explicitly to 'ClusterFirstWithHostNet'.
	// +optional
	DnsPolicy *string `protobuf:"bytes,6,opt,name=dns_policy,json=dnsPolicy,proto3,oneof" json:"dns_policy,omitempty"`
	// NodeSelector is a selector which must be true for the pod to fit on a node.
	// Selector which must match a node's labels for the pod to be scheduled on that node.
	// More info: https://kubernetes.io/docs/concepts/configuration/assign-pod-node/
	// +optional
	// +mapType=atomic
	NodeSelector map[string]string `` /* 185-byte string literal not displayed */
	// ServiceAccountName is the name of the ServiceAccount to use to run this pod.
	// More info: https://kubernetes.io/docs/tasks/configure-pod-container/configure-service-account/
	// +optional
	ServiceAccountName *string `protobuf:"bytes,8,opt,name=service_account_name,json=serviceAccountName,proto3,oneof" json:"service_account_name,omitempty"`
	// AutomountServiceAccountToken indicates whether a service account token should be automatically mounted.
	// +optional
	AutomountServiceAccountToken *bool `` /* 157-byte string literal not displayed */
	// NodeName is a request to schedule this pod onto a specific node. If it is non-empty,
	// the scheduler simply schedules this pod onto that node, assuming that it fits resource
	// requirements.
	// +optional
	NodeName *string `protobuf:"bytes,10,opt,name=node_name,json=nodeName,proto3,oneof" json:"node_name,omitempty"`
	// Host networking requested for this pod. Use the host's network namespace.
	// If this option is set, the ports that will be used must be specified.
	// Default to false.
	// +k8s:conversion-gen=false
	// +optional
	HostNetwork bool `protobuf:"varint,11,opt,name=host_network,json=hostNetwork,proto3" json:"host_network,omitempty"`
	// Use the host's pid namespace.
	// Optional: Default to false.
	// +k8s:conversion-gen=false
	// +optional
	HostPid bool `protobuf:"varint,12,opt,name=host_pid,json=hostPid,proto3" json:"host_pid,omitempty"`
	// Use the host's ipc namespace.
	// Optional: Default to false.
	// +k8s:conversion-gen=false
	// +optional
	HostIpc bool `protobuf:"varint,13,opt,name=host_ipc,json=hostIpc,proto3" json:"host_ipc,omitempty"`
	// Share a single process namespace between all of the containers in a pod.
	// When this is set containers will be able to view and signal processes from other containers
	// in the same pod, and the first process in each container will not be assigned PID 1.
	// HostPID and ShareProcessNamespace cannot both be set.
	// Optional: Default to false.
	// +k8s:conversion-gen=false
	// +optional
	ShareProcessNamespace bool `` /* 128-byte string literal not displayed */
	// Specifies the hostname of the Pod
	// If not specified, the pod's hostname will be set to a system-defined value.
	// +optional
	Hostname *string `protobuf:"bytes,16,opt,name=hostname,proto3,oneof" json:"hostname,omitempty"`
	// If specified, the fully qualified Pod hostname will be "<hostname>.<subdomain>.<pod namespace>.svc.<cluster domain>".
	// If not specified, the pod will not have a domainname at all.
	// +optional
	Subdomain *string `protobuf:"bytes,17,opt,name=subdomain,proto3,oneof" json:"subdomain,omitempty"`
	// If specified, the pod will be dispatched by specified scheduler.
	// If not specified, the pod will be dispatched by default scheduler.
	// +optional
	SchedulerName *string `protobuf:"bytes,19,opt,name=scheduler_name,json=schedulerName,proto3,oneof" json:"scheduler_name,omitempty"`
	// If specified, indicates the pod's priority. "system-node-critical" and
	// "system-cluster-critical" are two special keywords which indicate the
	// highest priorities with the former being the highest priority. Any other
	// name must be defined by creating a PriorityClass object with that name.
	// If not specified, the pod priority will be default or zero if there is no
	// default.
	// +optional
	PriorityClassName *string `protobuf:"bytes,24,opt,name=priority_class_name,json=priorityClassName,proto3,oneof" json:"priority_class_name,omitempty"`
	// The priority value. Various system components use this field to find the
	// priority of the pod. When Priority Admission Controller is enabled, it
	// prevents users from setting this field. The admission controller populates
	// this field from priority_class_name.
	// The higher the value, the higher the priority.
	// +optional
	Priority *int32 `protobuf:"varint,25,opt,name=priority,proto3,oneof" json:"priority,omitempty"`
	// RuntimeClassName refers to a RuntimeClass object in the node.k8s.io group, which should be used
	// to run this pod.  If no RuntimeClass resource matches the named class, the pod will not be run.
	// If unset or empty, the "legacy" RuntimeClass will be used, which is an implicit class with an
	// empty definition that uses the default runtime handler.
	// More info: https://git.k8s.io/enhancements/keps/sig-node/585-runtime-class
	// +optional
	RuntimeClassName *string `protobuf:"bytes,29,opt,name=runtime_class_name,json=runtimeClassName,proto3,oneof" json:"runtime_class_name,omitempty"`
	// EnableServiceLinks indicates whether information about services should be injected into pod's
	// environment variables, matching the syntax of Docker links.
	// Optional: Defaults to true.
	// +optional
	EnableServiceLinks *bool `protobuf:"varint,30,opt,name=enable_service_links,json=enableServiceLinks,proto3,oneof" json:"enable_service_links,omitempty"`
	// PreemptionPolicy is the Policy for preempting pods with lower priority.
	// One of Never, PreemptLowerPriority.
	// Defaults to PreemptLowerPriority if unset.
	// +optional
	PreemptionPolicy *string `protobuf:"bytes,31,opt,name=preemption_policy,json=preemptionPolicy,proto3,oneof" json:"preemption_policy,omitempty"`
	// Use the host's user namespace.
	// Optional: Default to true.
	// If set to true or not present, the pod will be run in the host user namespace, useful
	// for when the pod needs a feature only available to the host user namespace, such as
	// loading a kernel module with CAP_SYS_MODULE.
	// When set to false, a new userns is created for the pod. Setting false is useful for
	// mitigating container breakout vulnerabilities even allowing users to run their
	// containers as root without actually having root privileges on the host.
	// This field is alpha-level and is only honored by servers that enable the UserNamespacesSupport feature.
	// +k8s:conversion-gen=false
	// +optional
	HostUsers *bool `protobuf:"varint,37,opt,name=host_users,json=hostUsers,proto3,oneof" json:"host_users,omitempty"`
	// ResourceClaims defines which ResourceClaims must be allocated
	// and reserved before the Pod is allowed to start. The resources
	// will be made available to those containers which consume them
	// by name.
	//
	// This is an alpha field and requires enabling the
	// DynamicResourceAllocation feature gate.
	//
	// This field is immutable.
	//
	// +patchMergeKey=name
	// +patchStrategy=merge,retainKeys
	// +listType=map
	// +listMapKey=name
	// +featureGate=DynamicResourceAllocation
	// +optional
	ResourceClaims []*PodStatusPubSub_PodResourceClaim `protobuf:"bytes,39,rep,name=resource_claims,json=resourceClaims,proto3" json:"resource_claims,omitempty"`
	// contains filtered or unexported fields
}

PodSpec is a description of a pod.

func (*PodStatusPubSub_PodSpec) Descriptor deprecated 

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

Deprecated: Use PodStatusPubSub_PodSpec.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_PodSpec) GetActiveDeadlineSeconds 

func (x *PodStatusPubSub_PodSpec) GetActiveDeadlineSeconds() int64

func (*PodStatusPubSub_PodSpec) GetAutomountServiceAccountToken 

func (x *PodStatusPubSub_PodSpec) GetAutomountServiceAccountToken() bool

func (*PodStatusPubSub_PodSpec) GetContainers 

func (x *PodStatusPubSub_PodSpec) GetContainers() []*PodStatusPubSub_Container

func (*PodStatusPubSub_PodSpec) GetDnsPolicy 

func (x *PodStatusPubSub_PodSpec) GetDnsPolicy() string
func (x *PodStatusPubSub_PodSpec) GetEnableServiceLinks() bool

func (*PodStatusPubSub_PodSpec) GetHostIpc 

func (x *PodStatusPubSub_PodSpec) GetHostIpc() bool

func (*PodStatusPubSub_PodSpec) GetHostNetwork 

func (x *PodStatusPubSub_PodSpec) GetHostNetwork() bool

func (*PodStatusPubSub_PodSpec) GetHostPid 

func (x *PodStatusPubSub_PodSpec) GetHostPid() bool

func (*PodStatusPubSub_PodSpec) GetHostUsers 

func (x *PodStatusPubSub_PodSpec) GetHostUsers() bool

func (*PodStatusPubSub_PodSpec) GetHostname 

func (x *PodStatusPubSub_PodSpec) GetHostname() string

func (*PodStatusPubSub_PodSpec) GetInitContainers 

func (x *PodStatusPubSub_PodSpec) GetInitContainers() []*PodStatusPubSub_Container

func (*PodStatusPubSub_PodSpec) GetNodeName 

func (x *PodStatusPubSub_PodSpec) GetNodeName() string

func (*PodStatusPubSub_PodSpec) GetNodeSelector 

func (x *PodStatusPubSub_PodSpec) GetNodeSelector() map[string]string

func (*PodStatusPubSub_PodSpec) GetPreemptionPolicy 

func (x *PodStatusPubSub_PodSpec) GetPreemptionPolicy() string

func (*PodStatusPubSub_PodSpec) GetPriority 

func (x *PodStatusPubSub_PodSpec) GetPriority() int32

func (*PodStatusPubSub_PodSpec) GetPriorityClassName 

func (x *PodStatusPubSub_PodSpec) GetPriorityClassName() string

func (*PodStatusPubSub_PodSpec) GetResourceClaims 

func (x *PodStatusPubSub_PodSpec) GetResourceClaims() []*PodStatusPubSub_PodResourceClaim

func (*PodStatusPubSub_PodSpec) GetRestartPolicy 

func (x *PodStatusPubSub_PodSpec) GetRestartPolicy() string

func (*PodStatusPubSub_PodSpec) GetRuntimeClassName 

func (x *PodStatusPubSub_PodSpec) GetRuntimeClassName() string

func (*PodStatusPubSub_PodSpec) GetSchedulerName 

func (x *PodStatusPubSub_PodSpec) GetSchedulerName() string

func (*PodStatusPubSub_PodSpec) GetServiceAccountName 

func (x *PodStatusPubSub_PodSpec) GetServiceAccountName() string

func (*PodStatusPubSub_PodSpec) GetShareProcessNamespace 

func (x *PodStatusPubSub_PodSpec) GetShareProcessNamespace() bool

func (*PodStatusPubSub_PodSpec) GetSubdomain 

func (x *PodStatusPubSub_PodSpec) GetSubdomain() string

func (*PodStatusPubSub_PodSpec) GetTerminationGracePeriodSeconds 

func (x *PodStatusPubSub_PodSpec) GetTerminationGracePeriodSeconds() int64

func (*PodStatusPubSub_PodSpec) GetVolumes 

func (x *PodStatusPubSub_PodSpec) GetVolumes() []*PodStatusPubSub_Volume

func (*PodStatusPubSub_PodSpec) ProtoMessage 

func (*PodStatusPubSub_PodSpec) ProtoMessage()

func (*PodStatusPubSub_PodSpec) ProtoReflect 

func (x *PodStatusPubSub_PodSpec) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_PodSpec) Reset 

func (x *PodStatusPubSub_PodSpec) Reset()

func (*PodStatusPubSub_PodSpec) String 

func (x *PodStatusPubSub_PodSpec) String() string

type PodStatusPubSub_PodStatus 

type PodStatusPubSub_PodStatus struct {

	// The phase of a Pod is a simple, high-level summary of where the Pod is in its lifecycle.
	// The conditions array, the reason and message fields, and the individual container status
	// arrays contain more detail about the pod's status.
	// There are five possible phase values:
	//
	// Pending: The pod has been accepted by the Kubernetes system, but one or more of the
	// container images has not been created. This includes time before being scheduled as
	// well as time spent downloading images over the network, which could take a while.
	// Running: The pod has been bound to a node, and all of the containers have been created.
	// At least one container is still running, or is in the process of starting or restarting.
	// Succeeded: All containers in the pod have terminated in success, and will not be restarted.
	// Failed: All containers in the pod have terminated, and at least one container has
	// terminated in failure. The container either exited with non-zero status or was terminated
	// by the system.
	// Unknown: For some reason the state of the pod could not be obtained, typically due to an
	// error in communicating with the host of the pod.
	//
	// More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#pod-phase
	// +optional
	Phase *string `protobuf:"bytes,1,opt,name=phase,proto3,oneof" json:"phase,omitempty"`
	// Current service state of pod.
	// More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#pod-conditions
	// +optional
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	Conditions []*PodStatusPubSub_PodCondition `protobuf:"bytes,2,rep,name=conditions,proto3" json:"conditions,omitempty"`
	// A human readable message indicating details about why the pod is in this condition.
	// +optional
	Message *string `protobuf:"bytes,3,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// A brief CamelCase message indicating details about why the pod is in this state.
	// e.g. 'Evicted'
	// +optional
	Reason *string `protobuf:"bytes,4,opt,name=reason,proto3,oneof" json:"reason,omitempty"`
	// nominatedNodeName is set only when this pod preempts other pods on the node, but it cannot be
	// scheduled right away as preemption victims receive their graceful termination periods.
	// This field does not guarantee that the pod will be scheduled on this node. Scheduler may decide
	// to place the pod elsewhere if other nodes become available sooner. Scheduler may also decide to
	// give the resources on this node to a higher priority pod that is created after preemption.
	// As a result, this field may be different than PodSpec.nodeName when the pod is
	// scheduled.
	// +optional
	NominatedNodeName *string `protobuf:"bytes,11,opt,name=nominated_node_name,json=nominatedNodeName,proto3,oneof" json:"nominated_node_name,omitempty"`
	// hostIP holds the IP address of the host to which the pod is assigned. Empty if the pod has not started yet.
	// A pod can be assigned to a node that has a problem in kubelet which in turns mean that HostIP will
	// not be updated even if there is a node is assigned to pod
	// +optional
	HostIp *string `protobuf:"bytes,5,opt,name=host_ip,json=hostIp,proto3,oneof" json:"host_ip,omitempty"`
	// hostIPs holds the IP addresses allocated to the host. If this field is specified, the first entry must
	// match the hostIP field. This list is empty if the pod has not started yet.
	// A pod can be assigned to a node that has a problem in kubelet which in turns means that HostIPs will
	// not be updated even if there is a node is assigned to this pod.
	// +optional
	// +patchStrategy=merge
	// +patchMergeKey=ip
	// +listType=atomic
	HostIps []*PodStatusPubSub_HostIP `protobuf:"bytes,16,rep,name=host_ips,json=hostIps,proto3" json:"host_ips,omitempty"`
	// podIP address allocated to the pod. Routable at least within the cluster.
	// Empty if not yet allocated.
	// +optional
	PodIp *string `protobuf:"bytes,6,opt,name=pod_ip,json=podIp,proto3,oneof" json:"pod_ip,omitempty"`
	// RFC 3339 date and time at which the object was acknowledged by the Kubelet.
	// This is before the Kubelet pulled the container image(s) for the pod.
	// +optional
	StartTime *int64 `protobuf:"varint,7,opt,name=start_time,json=startTime,proto3,oneof" json:"start_time,omitempty"`
	// The list has one entry per init container in the manifest. The most recent successful
	// init container will have ready = true, the most recently started container will have
	// startTime set.
	// More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#pod-and-container-status
	// +listType=atomic
	InitContainerStatuses []*PodStatusPubSub_ContainerStatus `` /* 127-byte string literal not displayed */
	// The list has one entry per container in the manifest.
	// More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#pod-and-container-status
	// +optional
	// +listType=atomic
	ContainerStatuses []*PodStatusPubSub_ContainerStatus `protobuf:"bytes,8,rep,name=container_statuses,json=containerStatuses,proto3" json:"container_statuses,omitempty"`
	// The Quality of Service (QOS) classification assigned to the pod based on resource requirements
	// See PodQOSClass type for available QOS classes
	// More info: https://kubernetes.io/docs/concepts/workloads/pods/pod-qos/#quality-of-service-classes
	// +optional
	QosClass *string `protobuf:"bytes,9,opt,name=qos_class,json=qosClass,proto3,oneof" json:"qos_class,omitempty"`
	// Status for any ephemeral containers that have run in this pod.
	// +optional
	// +listType=atomic
	EphemeralContainerStatuses []*PodStatusPubSub_ContainerStatus `` /* 142-byte string literal not displayed */
	// Status of resources resize desired for pod's containers.
	// It is empty if no resources resize is pending.
	// Any changes to container resources will automatically set this to "Proposed"
	// +featureGate=InPlacePodVerticalScaling
	// +optional
	Resize *string `protobuf:"bytes,14,opt,name=resize,proto3,oneof" json:"resize,omitempty"`
	// contains filtered or unexported fields
}

PodStatus represents information about the status of a pod. Status may trail the actual state of a system, especially if the node that hosts the pod cannot contact the control plane.

func (*PodStatusPubSub_PodStatus) Descriptor deprecated 

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

Deprecated: Use PodStatusPubSub_PodStatus.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_PodStatus) GetConditions 

func (x *PodStatusPubSub_PodStatus) GetConditions() []*PodStatusPubSub_PodCondition

func (*PodStatusPubSub_PodStatus) GetContainerStatuses 

func (x *PodStatusPubSub_PodStatus) GetContainerStatuses() []*PodStatusPubSub_ContainerStatus

func (*PodStatusPubSub_PodStatus) GetEphemeralContainerStatuses 

func (x *PodStatusPubSub_PodStatus) GetEphemeralContainerStatuses() []*PodStatusPubSub_ContainerStatus

func (*PodStatusPubSub_PodStatus) GetHostIp 

func (x *PodStatusPubSub_PodStatus) GetHostIp() string

func (*PodStatusPubSub_PodStatus) GetHostIps 

func (x *PodStatusPubSub_PodStatus) GetHostIps() []*PodStatusPubSub_HostIP

func (*PodStatusPubSub_PodStatus) GetInitContainerStatuses 

func (x *PodStatusPubSub_PodStatus) GetInitContainerStatuses() []*PodStatusPubSub_ContainerStatus

func (*PodStatusPubSub_PodStatus) GetMessage 

func (x *PodStatusPubSub_PodStatus) GetMessage() string

func (*PodStatusPubSub_PodStatus) GetNominatedNodeName 

func (x *PodStatusPubSub_PodStatus) GetNominatedNodeName() string

func (*PodStatusPubSub_PodStatus) GetPhase 

func (x *PodStatusPubSub_PodStatus) GetPhase() string

func (*PodStatusPubSub_PodStatus) GetPodIp 

func (x *PodStatusPubSub_PodStatus) GetPodIp() string

func (*PodStatusPubSub_PodStatus) GetQosClass 

func (x *PodStatusPubSub_PodStatus) GetQosClass() string

func (*PodStatusPubSub_PodStatus) GetReason 

func (x *PodStatusPubSub_PodStatus) GetReason() string

func (*PodStatusPubSub_PodStatus) GetResize 

func (x *PodStatusPubSub_PodStatus) GetResize() string

func (*PodStatusPubSub_PodStatus) GetStartTime 

func (x *PodStatusPubSub_PodStatus) GetStartTime() int64

func (*PodStatusPubSub_PodStatus) ProtoMessage 

func (*PodStatusPubSub_PodStatus) ProtoMessage()

func (*PodStatusPubSub_PodStatus) ProtoReflect 

func (x *PodStatusPubSub_PodStatus) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_PodStatus) Reset 

func (x *PodStatusPubSub_PodStatus) Reset()

func (*PodStatusPubSub_PodStatus) String 

func (x *PodStatusPubSub_PodStatus) String() string

type PodStatusPubSub_Quantity added in v0.12.2 

type PodStatusPubSub_Quantity struct {
	String_ *string `protobuf:"bytes,1,opt,name=string,proto3,oneof" json:"string,omitempty"`
	// contains filtered or unexported fields
}

func (*PodStatusPubSub_Quantity) Descriptor deprecated added in v0.12.2 

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

Deprecated: Use PodStatusPubSub_Quantity.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_Quantity) GetString_ added in v0.12.2 

func (x *PodStatusPubSub_Quantity) GetString_() string

func (*PodStatusPubSub_Quantity) ProtoMessage added in v0.12.2 

func (*PodStatusPubSub_Quantity) ProtoMessage()

func (*PodStatusPubSub_Quantity) ProtoReflect added in v0.12.2 

func (x *PodStatusPubSub_Quantity) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_Quantity) Reset added in v0.12.2 

func (x *PodStatusPubSub_Quantity) Reset()

func (*PodStatusPubSub_Quantity) String added in v0.12.2 

func (x *PodStatusPubSub_Quantity) String() string

type PodStatusPubSub_ResourceRequirements added in v0.12.2 

type PodStatusPubSub_ResourceRequirements struct {

	// Limits describes the maximum amount of compute resources allowed.
	// More info: https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/
	// +optional
	Limits map[string]*PodStatusPubSub_Quantity `` /* 153-byte string literal not displayed */
	// Requests describes the minimum amount of compute resources required.
	// If Requests is omitted for a container, it defaults to Limits if that is explicitly specified,
	// otherwise to an implementation-defined value. Requests cannot exceed Limits.
	// More info: https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/
	// +optional
	Requests map[string]*PodStatusPubSub_Quantity `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PodStatusPubSub_ResourceRequirements) Descriptor deprecated added in v0.12.2 

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

Deprecated: Use PodStatusPubSub_ResourceRequirements.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_ResourceRequirements) GetLimits added in v0.12.2 

func (x *PodStatusPubSub_ResourceRequirements) GetLimits() map[string]*PodStatusPubSub_Quantity

func (*PodStatusPubSub_ResourceRequirements) GetRequests added in v0.12.2 

func (x *PodStatusPubSub_ResourceRequirements) GetRequests() map[string]*PodStatusPubSub_Quantity

func (*PodStatusPubSub_ResourceRequirements) ProtoMessage added in v0.12.2 

func (*PodStatusPubSub_ResourceRequirements) ProtoMessage()

func (*PodStatusPubSub_ResourceRequirements) ProtoReflect added in v0.12.2 

func (x *PodStatusPubSub_ResourceRequirements) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_ResourceRequirements) Reset added in v0.12.2 

func (x *PodStatusPubSub_ResourceRequirements) Reset()

func (*PodStatusPubSub_ResourceRequirements) String added in v0.12.2 

func (x *PodStatusPubSub_ResourceRequirements) String() string

type PodStatusPubSub_Volume 

type PodStatusPubSub_Volume struct {

	// name of the volume.
	// Must be a DNS_LABEL and unique within the pod.
	// More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Volume represents a named volume in a pod that may be accessed by any container in the pod.

func (*PodStatusPubSub_Volume) Descriptor deprecated 

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

Deprecated: Use PodStatusPubSub_Volume.ProtoReflect.Descriptor instead.

func (*PodStatusPubSub_Volume) GetName 

func (x *PodStatusPubSub_Volume) GetName() string

func (*PodStatusPubSub_Volume) ProtoMessage 

func (*PodStatusPubSub_Volume) ProtoMessage()

func (*PodStatusPubSub_Volume) ProtoReflect 

func (x *PodStatusPubSub_Volume) ProtoReflect() protoreflect.Message

func (*PodStatusPubSub_Volume) Reset 

func (x *PodStatusPubSub_Volume) Reset()

func (*PodStatusPubSub_Volume) String 

func (x *PodStatusPubSub_Volume) String() string

type QueryMessagePubSub added in v0.4.7 

type QueryMessagePubSub struct {

	// Operation unique identifier
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// Environment query belongs to
	EnvironmentId string `protobuf:"bytes,2,opt,name=environment_id,json=environmentId,proto3" json:"environment_id,omitempty"`
	// maps to FeatherRequestHeader.meta which can be specified via the client
	QueryMeta map[string]string `` /* 176-byte string literal not displayed */
	// maps to FeatherRequestHeader.query_name which can be specified via the client
	QueryName *string `protobuf:"bytes,4,opt,name=query_name,json=queryName,proto3,oneof" json:"query_name,omitempty"`
	// maps to FeatherRequestHeader.query_name_version which can be specified via the client
	QueryNameVersion *string `protobuf:"bytes,5,opt,name=query_name_version,json=queryNameVersion,proto3,oneof" json:"query_name_version,omitempty"`
	// maps to FeatherRequestHeader.correlation_id which can be specified via the client
	CorrelationId *string `protobuf:"bytes,6,opt,name=correlation_id,json=correlationId,proto3,oneof" json:"correlation_id,omitempty"`
	// parsed input feature fqns
	InputFeatures []string `protobuf:"bytes,7,rep,name=input_features,json=inputFeatures,proto3" json:"input_features,omitempty"`
	// parsed output feature fqns
	OutputFeatures []string `protobuf:"bytes,8,rep,name=output_features,json=outputFeatures,proto3" json:"output_features,omitempty"`
	// parsed output feature root fqns
	OutputRootFqns []string `protobuf:"bytes,9,rep,name=output_root_fqns,json=outputRootFqns,proto3" json:"output_root_fqns,omitempty"`
	// intermediate feature fqns currently empty
	IntermediateFeatures []string `protobuf:"bytes,10,rep,name=intermediate_features,json=intermediateFeatures,proto3" json:"intermediate_features,omitempty"`
	// resolver fqns used in plan
	Resolvers []string `protobuf:"bytes,11,rep,name=resolvers,proto3" json:"resolvers,omitempty"`
	// id of final plan
	QueryPlanId *string `protobuf:"bytes,12,opt,name=query_plan_id,json=queryPlanId,proto3,oneof" json:"query_plan_id,omitempty"`
	// timestamp
	CreatedAt int64 `protobuf:"varint,13,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// if query had errors
	HasErrors *bool `protobuf:"varint,14,opt,name=has_errors,json=hasErrors,proto3,oneof" json:"has_errors,omitempty"`
	// aka as requester_id from run context
	AgentId *string `protobuf:"bytes,15,opt,name=agent_id,json=agentId,proto3,oneof" json:"agent_id,omitempty"`
	// branch query was run on
	BranchName *string `protobuf:"bytes,16,opt,name=branch_name,json=branchName,proto3,oneof" json:"branch_name,omitempty"`
	// deployment query was run on
	DeploymentId *string `protobuf:"bytes,17,opt,name=deployment_id,json=deploymentId,proto3,oneof" json:"deployment_id,omitempty"`
	// if query was run with plan_stages
	HasPlanStages *bool `protobuf:"varint,18,opt,name=has_plan_stages,json=hasPlanStages,proto3,oneof" json:"has_plan_stages,omitempty"`
	// the meta query hash
	MetaQueryHash *string `protobuf:"bytes,19,opt,name=meta_query_hash,json=metaQueryHash,proto3,oneof" json:"meta_query_hash,omitempty"`
	// contains filtered or unexported fields
}

QueryMessagePubSub corresponds exactly to the QueryStorageMessage pydantic model, which in turn mostly corresponds to the QueryStorageRequest pydantic model. It captures information about an online query from the header, plan, parsed metadata, and more.

func (*QueryMessagePubSub) Descriptor deprecated added in v0.4.7 

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

Deprecated: Use QueryMessagePubSub.ProtoReflect.Descriptor instead.

func (*QueryMessagePubSub) GetAgentId added in v0.4.7 

func (x *QueryMessagePubSub) GetAgentId() string

func (*QueryMessagePubSub) GetBranchName added in v0.4.7 

func (x *QueryMessagePubSub) GetBranchName() string

func (*QueryMessagePubSub) GetCorrelationId added in v0.4.7 

func (x *QueryMessagePubSub) GetCorrelationId() string

func (*QueryMessagePubSub) GetCreatedAt added in v0.4.7 

func (x *QueryMessagePubSub) GetCreatedAt() int64

func (*QueryMessagePubSub) GetDeploymentId added in v0.4.7 

func (x *QueryMessagePubSub) GetDeploymentId() string

func (*QueryMessagePubSub) GetEnvironmentId added in v0.4.7 

func (x *QueryMessagePubSub) GetEnvironmentId() string

func (*QueryMessagePubSub) GetHasErrors added in v0.4.7 

func (x *QueryMessagePubSub) GetHasErrors() bool

func (*QueryMessagePubSub) GetHasPlanStages added in v0.4.7 

func (x *QueryMessagePubSub) GetHasPlanStages() bool

func (*QueryMessagePubSub) GetInputFeatures added in v0.4.7 

func (x *QueryMessagePubSub) GetInputFeatures() []string

func (*QueryMessagePubSub) GetIntermediateFeatures added in v0.4.7 

func (x *QueryMessagePubSub) GetIntermediateFeatures() []string

func (*QueryMessagePubSub) GetMetaQueryHash added in v0.13.8 

func (x *QueryMessagePubSub) GetMetaQueryHash() string

func (*QueryMessagePubSub) GetOperationId added in v0.4.7 

func (x *QueryMessagePubSub) GetOperationId() string

func (*QueryMessagePubSub) GetOutputFeatures added in v0.4.7 

func (x *QueryMessagePubSub) GetOutputFeatures() []string

func (*QueryMessagePubSub) GetOutputRootFqns added in v0.4.7 

func (x *QueryMessagePubSub) GetOutputRootFqns() []string

func (*QueryMessagePubSub) GetQueryMeta added in v0.4.7 

func (x *QueryMessagePubSub) GetQueryMeta() map[string]string

func (*QueryMessagePubSub) GetQueryName added in v0.4.7 

func (x *QueryMessagePubSub) GetQueryName() string

func (*QueryMessagePubSub) GetQueryNameVersion added in v0.4.7 

func (x *QueryMessagePubSub) GetQueryNameVersion() string

func (*QueryMessagePubSub) GetQueryPlanId added in v0.4.7 

func (x *QueryMessagePubSub) GetQueryPlanId() string

func (*QueryMessagePubSub) GetResolvers added in v0.4.7 

func (x *QueryMessagePubSub) GetResolvers() []string

func (*QueryMessagePubSub) ProtoMessage added in v0.4.7 

func (*QueryMessagePubSub) ProtoMessage()

func (*QueryMessagePubSub) ProtoReflect added in v0.4.7 

func (x *QueryMessagePubSub) ProtoReflect() protoreflect.Message

func (*QueryMessagePubSub) Reset added in v0.4.7 

func (x *QueryMessagePubSub) Reset()

func (*QueryMessagePubSub) String added in v0.4.7 

func (x *QueryMessagePubSub) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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