pb

package
v1.1.3 Latest Latest
Warning

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

 Go to latest Published: Jul 5, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type MaxAvailableReplicasRequest 

type MaxAvailableReplicasRequest struct {
	// Cluster represents the cluster name.
	// +required
	Cluster string `json:"cluster" protobuf:"bytes,1,opt,name=cluster"`
	// ReplicaRequirements represents the requirements required by each replica.
	// +required
	ReplicaRequirements ReplicaRequirements `json:"replicaRequirements" protobuf:"bytes,2,opt,name=replicaRequirements"`
}

MaxAvailableReplicasRequest represents the request that sent by gRPC client to calculate max available replicas.

func (*MaxAvailableReplicasRequest) Descriptor 

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

func (*MaxAvailableReplicasRequest) Marshal 

func (m *MaxAvailableReplicasRequest) Marshal() (dAtA []byte, err error)

func (*MaxAvailableReplicasRequest) MarshalTo 

func (m *MaxAvailableReplicasRequest) MarshalTo(dAtA []byte) (int, error)

func (*MaxAvailableReplicasRequest) MarshalToSizedBuffer 

func (m *MaxAvailableReplicasRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MaxAvailableReplicasRequest) ProtoMessage 

func (*MaxAvailableReplicasRequest) ProtoMessage()

func (*MaxAvailableReplicasRequest) Reset 

func (m *MaxAvailableReplicasRequest) Reset()

func (*MaxAvailableReplicasRequest) Size 

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

func (*MaxAvailableReplicasRequest) String 

func (this *MaxAvailableReplicasRequest) String() string

func (*MaxAvailableReplicasRequest) Unmarshal 

func (m *MaxAvailableReplicasRequest) Unmarshal(dAtA []byte) error

func (*MaxAvailableReplicasRequest) XXX_DiscardUnknown 

func (m *MaxAvailableReplicasRequest) XXX_DiscardUnknown()

func (*MaxAvailableReplicasRequest) XXX_Marshal 

func (m *MaxAvailableReplicasRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MaxAvailableReplicasRequest) XXX_Merge 

func (m *MaxAvailableReplicasRequest) XXX_Merge(src proto.Message)

func (*MaxAvailableReplicasRequest) XXX_Size 

func (m *MaxAvailableReplicasRequest) XXX_Size() int

func (*MaxAvailableReplicasRequest) XXX_Unmarshal 

func (m *MaxAvailableReplicasRequest) XXX_Unmarshal(b []byte) error

type MaxAvailableReplicasResponse 

type MaxAvailableReplicasResponse struct {
	// MaxReplicas represents the max replica that the cluster can produce.
	// +required
	MaxReplicas int32 `json:"maxReplicas" protobuf:"varint,1,opt,name=maxReplicas"`
}

MaxAvailableReplicasResponse represents the response that sent by gRPC server to calculate max available replicas.

func (*MaxAvailableReplicasResponse) Descriptor 

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

func (*MaxAvailableReplicasResponse) Marshal 

func (m *MaxAvailableReplicasResponse) Marshal() (dAtA []byte, err error)

func (*MaxAvailableReplicasResponse) MarshalTo 

func (m *MaxAvailableReplicasResponse) MarshalTo(dAtA []byte) (int, error)

func (*MaxAvailableReplicasResponse) MarshalToSizedBuffer 

func (m *MaxAvailableReplicasResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MaxAvailableReplicasResponse) ProtoMessage 

func (*MaxAvailableReplicasResponse) ProtoMessage()

func (*MaxAvailableReplicasResponse) Reset 

func (m *MaxAvailableReplicasResponse) Reset()

func (*MaxAvailableReplicasResponse) Size 

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

func (*MaxAvailableReplicasResponse) String 

func (this *MaxAvailableReplicasResponse) String() string

func (*MaxAvailableReplicasResponse) Unmarshal 

func (m *MaxAvailableReplicasResponse) Unmarshal(dAtA []byte) error

func (*MaxAvailableReplicasResponse) XXX_DiscardUnknown 

func (m *MaxAvailableReplicasResponse) XXX_DiscardUnknown()

func (*MaxAvailableReplicasResponse) XXX_Marshal 

func (m *MaxAvailableReplicasResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MaxAvailableReplicasResponse) XXX_Merge 

func (m *MaxAvailableReplicasResponse) XXX_Merge(src proto.Message)

func (*MaxAvailableReplicasResponse) XXX_Size 

func (m *MaxAvailableReplicasResponse) XXX_Size() int

func (*MaxAvailableReplicasResponse) XXX_Unmarshal 

func (m *MaxAvailableReplicasResponse) XXX_Unmarshal(b []byte) error

type NodeClaim 

type NodeClaim struct {
	// A node selector represents the union of the results of one or more label queries over a set of
	// nodes; that is, it represents the OR of the selectors represented by the node selector terms.
	// Note that only PodSpec.Affinity.NodeAffinity.RequiredDuringSchedulingIgnoredDuringExecution
	// is included here because it has a hard limit on pod scheduling.
	// +optional
	NodeAffinity *corev1.NodeSelector `json:"nodeAffinity,omitempty" protobuf:"bytes,1,opt,name=nodeAffinity"`
	// 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.
	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,2,rep,name=nodeSelector"`
	// If specified, the pod's tolerations.
	// +optional
	Tolerations []corev1.Toleration `json:"tolerations,omitempty" protobuf:"bytes,3,rep,name=tolerations"`
}

NodeClaim represents the NodeAffinity, NodeSelector and Tolerations required by each replica.

func (*NodeClaim) Descriptor 

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

func (*NodeClaim) Marshal 

func (m *NodeClaim) Marshal() (dAtA []byte, err error)

func (*NodeClaim) MarshalTo 

func (m *NodeClaim) MarshalTo(dAtA []byte) (int, error)

func (*NodeClaim) MarshalToSizedBuffer 

func (m *NodeClaim) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeClaim) ProtoMessage 

func (*NodeClaim) ProtoMessage()

func (*NodeClaim) Reset 

func (m *NodeClaim) Reset()

func (*NodeClaim) Size 

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

func (*NodeClaim) String 

func (this *NodeClaim) String() string

func (*NodeClaim) Unmarshal 

func (m *NodeClaim) Unmarshal(dAtA []byte) error

func (*NodeClaim) XXX_DiscardUnknown 

func (m *NodeClaim) XXX_DiscardUnknown()

func (*NodeClaim) XXX_Marshal 

func (m *NodeClaim) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeClaim) XXX_Merge 

func (m *NodeClaim) XXX_Merge(src proto.Message)

func (*NodeClaim) XXX_Size 

func (m *NodeClaim) XXX_Size() int

func (*NodeClaim) XXX_Unmarshal 

func (m *NodeClaim) XXX_Unmarshal(b []byte) error

type ObjectReference added in v1.1.0 

type ObjectReference struct {
	// APIVersion represents the API version of the referent.
	// +required
	APIVersion string `json:"apiVersion" protobuf:"bytes,1,opt,name=apiVersion"`

	// Kind represents the Kind of the referent.
	// +required
	Kind string `json:"kind" protobuf:"bytes,2,opt,name=kind"`

	// Namespace represents the namespace for the referent.
	// For non-namespace scoped resources(e.g. 'ClusterRole')，do not need specify Namespace,
	// and for namespace scoped resources, Namespace is required.
	// If Namespace is not specified, means the resource is non-namespace scoped.
	// +required
	Namespace string `json:"namespace" protobuf:"bytes,3,opt,name=namespace"`

	// Name represents the name of the referent.
	// +required
	Name string `json:"name" protobuf:"bytes,4,opt,name=name"`
}

ObjectReference contains enough information to locate the referenced object inside current cluster.

func (*ObjectReference) Descriptor added in v1.1.0 

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

func (*ObjectReference) Marshal added in v1.1.0 

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

func (*ObjectReference) MarshalTo added in v1.1.0 

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

func (*ObjectReference) MarshalToSizedBuffer added in v1.1.0 

func (m *ObjectReference) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ObjectReference) ProtoMessage added in v1.1.0 

func (*ObjectReference) ProtoMessage()

func (*ObjectReference) Reset added in v1.1.0 

func (m *ObjectReference) Reset()

func (*ObjectReference) Size added in v1.1.0 

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

func (*ObjectReference) String added in v1.1.0 

func (this *ObjectReference) String() string

func (*ObjectReference) Unmarshal added in v1.1.0 

func (m *ObjectReference) Unmarshal(dAtA []byte) error

func (*ObjectReference) XXX_DiscardUnknown added in v1.1.0 

func (m *ObjectReference) XXX_DiscardUnknown()

func (*ObjectReference) XXX_Marshal added in v1.1.0 

func (m *ObjectReference) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ObjectReference) XXX_Merge added in v1.1.0 

func (m *ObjectReference) XXX_Merge(src proto.Message)

func (*ObjectReference) XXX_Size added in v1.1.0 

func (m *ObjectReference) XXX_Size() int

func (*ObjectReference) XXX_Unmarshal added in v1.1.0 

func (m *ObjectReference) XXX_Unmarshal(b []byte) error

type ReplicaRequirements 

type ReplicaRequirements struct {
	// NodeClaim represents the NodeAffinity, NodeSelector and Tolerations required by each replica.
	// +optional
	NodeClaim *NodeClaim `json:"nodeClaim,omitempty" protobuf:"bytes,1,opt,name=nodeClaim"`
	// ResourceRequest represents the resources required by each replica.
	// +optional
	ResourceRequest corev1.ResourceList `` /* 157-byte string literal not displayed */
}

ReplicaRequirements represents the requirements required by each replica.

func (*ReplicaRequirements) Descriptor 

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

func (*ReplicaRequirements) Marshal 

func (m *ReplicaRequirements) Marshal() (dAtA []byte, err error)

func (*ReplicaRequirements) MarshalTo 

func (m *ReplicaRequirements) MarshalTo(dAtA []byte) (int, error)

func (*ReplicaRequirements) MarshalToSizedBuffer 

func (m *ReplicaRequirements) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicaRequirements) ProtoMessage 

func (*ReplicaRequirements) ProtoMessage()

func (*ReplicaRequirements) Reset 

func (m *ReplicaRequirements) Reset()

func (*ReplicaRequirements) Size 

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

func (*ReplicaRequirements) String 

func (this *ReplicaRequirements) String() string

func (*ReplicaRequirements) Unmarshal 

func (m *ReplicaRequirements) Unmarshal(dAtA []byte) error

func (*ReplicaRequirements) XXX_DiscardUnknown 

func (m *ReplicaRequirements) XXX_DiscardUnknown()

func (*ReplicaRequirements) XXX_Marshal 

func (m *ReplicaRequirements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicaRequirements) XXX_Merge 

func (m *ReplicaRequirements) XXX_Merge(src proto.Message)

func (*ReplicaRequirements) XXX_Size 

func (m *ReplicaRequirements) XXX_Size() int

func (*ReplicaRequirements) XXX_Unmarshal 

func (m *ReplicaRequirements) XXX_Unmarshal(b []byte) error

type UnschedulableReplicasRequest added in v1.1.0 

type UnschedulableReplicasRequest struct {
	// Cluster represents the cluster name.
	// +required
	Cluster string `json:"cluster" protobuf:"bytes,1,opt,name=cluster"`
	// Resource represents the Kubernetes resource to be propagated.
	// +required
	Resource ObjectReference `json:"resource" protobuf:"bytes,2,opt,name=resource"`
	// UnschedulableThreshold represents the period threshold of pod unschedulable condition.
	// This value is considered as a classification standard of unschedulable replicas.
	// +optional
	UnschedulableThreshold time.Duration `json:"unschedulableThreshold,omitempty" protobuf:"varint,3,opt,name=unschedulableThreshold,casttype=time.Duration"`
}

UnschedulableReplicasRequest represents the request that sent by gRPC client to calculate unschedulable replicas.

func (*UnschedulableReplicasRequest) Descriptor added in v1.1.0 

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

func (*UnschedulableReplicasRequest) Marshal added in v1.1.0 

func (m *UnschedulableReplicasRequest) Marshal() (dAtA []byte, err error)

func (*UnschedulableReplicasRequest) MarshalTo added in v1.1.0 

func (m *UnschedulableReplicasRequest) MarshalTo(dAtA []byte) (int, error)

func (*UnschedulableReplicasRequest) MarshalToSizedBuffer added in v1.1.0 

func (m *UnschedulableReplicasRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnschedulableReplicasRequest) ProtoMessage added in v1.1.0 

func (*UnschedulableReplicasRequest) ProtoMessage()

func (*UnschedulableReplicasRequest) Reset added in v1.1.0 

func (m *UnschedulableReplicasRequest) Reset()

func (*UnschedulableReplicasRequest) Size added in v1.1.0 

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

func (*UnschedulableReplicasRequest) String added in v1.1.0 

func (this *UnschedulableReplicasRequest) String() string

func (*UnschedulableReplicasRequest) Unmarshal added in v1.1.0 

func (m *UnschedulableReplicasRequest) Unmarshal(dAtA []byte) error

func (*UnschedulableReplicasRequest) XXX_DiscardUnknown added in v1.1.0 

func (m *UnschedulableReplicasRequest) XXX_DiscardUnknown()

func (*UnschedulableReplicasRequest) XXX_Marshal added in v1.1.0 

func (m *UnschedulableReplicasRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnschedulableReplicasRequest) XXX_Merge added in v1.1.0 

func (m *UnschedulableReplicasRequest) XXX_Merge(src proto.Message)

func (*UnschedulableReplicasRequest) XXX_Size added in v1.1.0 

func (m *UnschedulableReplicasRequest) XXX_Size() int

func (*UnschedulableReplicasRequest) XXX_Unmarshal added in v1.1.0 

func (m *UnschedulableReplicasRequest) XXX_Unmarshal(b []byte) error

type UnschedulableReplicasResponse added in v1.1.0 

type UnschedulableReplicasResponse struct {
	// UnschedulableReplicas represents the unschedulable replicas that the object contains.
	// +required
	UnschedulableReplicas int32 `json:"unschedulableReplicas" protobuf:"varint,1,opt,name=unschedulableReplicas"`
}

UnschedulableReplicasResponse represents the response that sent by gRPC server to calculate unschedulable replicas.

func (*UnschedulableReplicasResponse) Descriptor added in v1.1.0 

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

func (*UnschedulableReplicasResponse) Marshal added in v1.1.0 

func (m *UnschedulableReplicasResponse) Marshal() (dAtA []byte, err error)

func (*UnschedulableReplicasResponse) MarshalTo added in v1.1.0 

func (m *UnschedulableReplicasResponse) MarshalTo(dAtA []byte) (int, error)

func (*UnschedulableReplicasResponse) MarshalToSizedBuffer added in v1.1.0 

func (m *UnschedulableReplicasResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnschedulableReplicasResponse) ProtoMessage added in v1.1.0 

func (*UnschedulableReplicasResponse) ProtoMessage()

func (*UnschedulableReplicasResponse) Reset added in v1.1.0 

func (m *UnschedulableReplicasResponse) Reset()

func (*UnschedulableReplicasResponse) Size added in v1.1.0 

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

func (*UnschedulableReplicasResponse) String added in v1.1.0 

func (this *UnschedulableReplicasResponse) String() string

func (*UnschedulableReplicasResponse) Unmarshal added in v1.1.0 

func (m *UnschedulableReplicasResponse) Unmarshal(dAtA []byte) error

func (*UnschedulableReplicasResponse) XXX_DiscardUnknown added in v1.1.0 

func (m *UnschedulableReplicasResponse) XXX_DiscardUnknown()

func (*UnschedulableReplicasResponse) XXX_Marshal added in v1.1.0 

func (m *UnschedulableReplicasResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnschedulableReplicasResponse) XXX_Merge added in v1.1.0 

func (m *UnschedulableReplicasResponse) XXX_Merge(src proto.Message)

func (*UnschedulableReplicasResponse) XXX_Size added in v1.1.0 

func (m *UnschedulableReplicasResponse) XXX_Size() int

func (*UnschedulableReplicasResponse) XXX_Unmarshal added in v1.1.0 

func (m *UnschedulableReplicasResponse) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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