pb

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Dec 31, 2021 License: Apache-2.0 Imports: 14 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

func RegisterEstimatorServer 

func RegisterEstimatorServer(s *grpc.Server, srv EstimatorServer)

Types

type EstimatorClient 

type EstimatorClient interface {
	MaxAvailableReplicas(ctx context.Context, in *MaxAvailableReplicasRequest, opts ...grpc.CallOption) (*MaxAvailableReplicasResponse, error)
}

EstimatorClient is the client API for Estimator service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEstimatorClient 

func NewEstimatorClient(cc *grpc.ClientConn) EstimatorClient

type EstimatorServer 

type EstimatorServer interface {
	MaxAvailableReplicas(context.Context, *MaxAvailableReplicasRequest) (*MaxAvailableReplicasResponse, error)
}

EstimatorServer is the server API for Estimator service.

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

type UnimplementedEstimatorServer struct {
}

UnimplementedEstimatorServer can be embedded to have forward compatible implementations.

func (*UnimplementedEstimatorServer) Descriptor 

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

func (*UnimplementedEstimatorServer) Marshal 

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

func (*UnimplementedEstimatorServer) MarshalTo 

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

func (*UnimplementedEstimatorServer) MarshalToSizedBuffer 

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

func (*UnimplementedEstimatorServer) MaxAvailableReplicas 

func (*UnimplementedEstimatorServer) MaxAvailableReplicas(ctx context.Context, req *MaxAvailableReplicasRequest) (*MaxAvailableReplicasResponse, error)

func (*UnimplementedEstimatorServer) ProtoMessage 

func (*UnimplementedEstimatorServer) ProtoMessage()

func (*UnimplementedEstimatorServer) Reset 

func (m *UnimplementedEstimatorServer) Reset()

func (*UnimplementedEstimatorServer) Size 

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

func (*UnimplementedEstimatorServer) String 

func (this *UnimplementedEstimatorServer) String() string

func (*UnimplementedEstimatorServer) Unmarshal 

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

func (*UnimplementedEstimatorServer) XXX_DiscardUnknown 

func (m *UnimplementedEstimatorServer) XXX_DiscardUnknown()

func (*UnimplementedEstimatorServer) XXX_Marshal 

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

func (*UnimplementedEstimatorServer) XXX_Merge 

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

func (*UnimplementedEstimatorServer) XXX_Size 

func (m *UnimplementedEstimatorServer) XXX_Size() int

func (*UnimplementedEstimatorServer) XXX_Unmarshal 

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