planner

Documentation

Index

• func RegisterSchedulePlannerServer(s *grpc.Server, srv SchedulePlannerServer)
• type SchedulePlanRequest
  • func (*SchedulePlanRequest) Descriptor() ([]byte, []int)
  • func (m *SchedulePlanRequest) GetEligibleNodes() []string
  • func (m *SchedulePlanRequest) GetNamespace() string
  • func (m *SchedulePlanRequest) GetPodSet() string
  • func (m *SchedulePlanRequest) GetScheduledPod() string
  • func (*SchedulePlanRequest) ProtoMessage()
  • func (m *SchedulePlanRequest) Reset()
  • func (m *SchedulePlanRequest) String() string
  • func (m *SchedulePlanRequest) XXX_DiscardUnknown()
  • func (m *SchedulePlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SchedulePlanRequest) XXX_Merge(src proto.Message)
  • func (m *SchedulePlanRequest) XXX_Size() int
  • func (m *SchedulePlanRequest) XXX_Unmarshal(b []byte) error
• type SchedulePlanResponse
  • func (*SchedulePlanResponse) Descriptor() ([]byte, []int)
  • func (m *SchedulePlanResponse) GetAssignments() map[string]string
  • func (*SchedulePlanResponse) ProtoMessage()
  • func (m *SchedulePlanResponse) Reset()
  • func (m *SchedulePlanResponse) String() string
  • func (m *SchedulePlanResponse) XXX_DiscardUnknown()
  • func (m *SchedulePlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SchedulePlanResponse) XXX_Merge(src proto.Message)
  • func (m *SchedulePlanResponse) XXX_Size() int
  • func (m *SchedulePlanResponse) XXX_Unmarshal(b []byte) error
• type SchedulePlannerClient
  • func NewSchedulePlannerClient(cc *grpc.ClientConn) SchedulePlannerClient
• type SchedulePlannerServer
• type UnimplementedSchedulePlannerServer
  • func (*UnimplementedSchedulePlannerServer) BuildSchedulePlan(ctx context.Context, req *SchedulePlanRequest) (*SchedulePlanResponse, error)

Functions

func RegisterSchedulePlannerServer

func RegisterSchedulePlannerServer(s *grpc.Server, srv SchedulePlannerServer)

Types

type SchedulePlanRequest

type SchedulePlanRequest struct {
	Namespace            string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PodSet               string   `protobuf:"bytes,2,opt,name=podSet,proto3" json:"podSet,omitempty"`
	ScheduledPod         string   `protobuf:"bytes,3,opt,name=scheduledPod,proto3" json:"scheduledPod,omitempty"`
	EligibleNodes        []string `protobuf:"bytes,4,rep,name=eligibleNodes,proto3" json:"eligibleNodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SchedulePlanRequest) Descriptor

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

func (*SchedulePlanRequest) GetEligibleNodes

func (m *SchedulePlanRequest) GetEligibleNodes() []string

func (*SchedulePlanRequest) GetNamespace

func (m *SchedulePlanRequest) GetNamespace() string

func (*SchedulePlanRequest) GetPodSet

func (m *SchedulePlanRequest) GetPodSet() string

func (*SchedulePlanRequest) GetScheduledPod

func (m *SchedulePlanRequest) GetScheduledPod() string

func (*SchedulePlanRequest) ProtoMessage

func (*SchedulePlanRequest) ProtoMessage()

func (*SchedulePlanRequest) Reset

func (m *SchedulePlanRequest) Reset()

func (*SchedulePlanRequest) String

func (m *SchedulePlanRequest) String() string

func (*SchedulePlanRequest) XXX_DiscardUnknown

func (m *SchedulePlanRequest) XXX_DiscardUnknown()

func (*SchedulePlanRequest) XXX_Marshal

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

func (*SchedulePlanRequest) XXX_Merge

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

func (*SchedulePlanRequest) XXX_Size

func (m *SchedulePlanRequest) XXX_Size() int

func (*SchedulePlanRequest) XXX_Unmarshal

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

type SchedulePlanResponse

type SchedulePlanResponse struct {
	Assignments          map[string]string `` /* 163-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SchedulePlanResponse) Descriptor

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

func (*SchedulePlanResponse) GetAssignments

func (m *SchedulePlanResponse) GetAssignments() map[string]string

func (*SchedulePlanResponse) ProtoMessage

func (*SchedulePlanResponse) ProtoMessage()

func (*SchedulePlanResponse) Reset

func (m *SchedulePlanResponse) Reset()

func (*SchedulePlanResponse) String

func (m *SchedulePlanResponse) String() string

func (*SchedulePlanResponse) XXX_DiscardUnknown

func (m *SchedulePlanResponse) XXX_DiscardUnknown()

func (*SchedulePlanResponse) XXX_Marshal

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

func (*SchedulePlanResponse) XXX_Merge

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

func (*SchedulePlanResponse) XXX_Size

func (m *SchedulePlanResponse) XXX_Size() int

func (*SchedulePlanResponse) XXX_Unmarshal

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

type SchedulePlannerClient

type SchedulePlannerClient interface {
	BuildSchedulePlan(ctx context.Context, in *SchedulePlanRequest, opts ...grpc.CallOption) (*SchedulePlanResponse, error)
}

SchedulePlannerClient is the client API for SchedulePlanner service.

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

func NewSchedulePlannerClient

func NewSchedulePlannerClient(cc *grpc.ClientConn) SchedulePlannerClient

type SchedulePlannerServer

type SchedulePlannerServer interface {
	BuildSchedulePlan(context.Context, *SchedulePlanRequest) (*SchedulePlanResponse, error)
}

SchedulePlannerServer is the server API for SchedulePlanner service.

type UnimplementedSchedulePlannerServer

type UnimplementedSchedulePlannerServer struct {
}

UnimplementedSchedulePlannerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSchedulePlannerServer) BuildSchedulePlan

func (*UnimplementedSchedulePlannerServer) BuildSchedulePlan(ctx context.Context, req *SchedulePlanRequest) (*SchedulePlanResponse, error)