scheduler_protos

Documentation

Overview

Package scheduler_protos is a generated protocol buffer package.

It is generated from these files:

scheduler.proto

It has these top-level messages:

AllocateNodesRequest
AllocateNodesResponse
DeallocateNodesRequest
DeallocateNodesResponse
EligibleNodesRequest
EligibleNodesResponse

Index

• func RegisterP2SchedulerServer(s *grpc.Server, srv P2SchedulerServer)
• type AllocateNodesRequest
  • func (*AllocateNodesRequest) Descriptor() ([]byte, []int)
  • func (m *AllocateNodesRequest) GetForce() bool
  • func (m *AllocateNodesRequest) GetManifest() string
  • func (m *AllocateNodesRequest) GetNodeSelector() string
  • func (m *AllocateNodesRequest) GetNodesRequested() int64
  • func (*AllocateNodesRequest) ProtoMessage()
  • func (m *AllocateNodesRequest) Reset()
  • func (m *AllocateNodesRequest) String() string
• type AllocateNodesResponse
  • func (*AllocateNodesResponse) Descriptor() ([]byte, []int)
  • func (m *AllocateNodesResponse) GetAllocatedNodes() []string
  • func (*AllocateNodesResponse) ProtoMessage()
  • func (m *AllocateNodesResponse) Reset()
  • func (m *AllocateNodesResponse) String() string
• type DeallocateNodesRequest
  • func (*DeallocateNodesRequest) Descriptor() ([]byte, []int)
  • func (m *DeallocateNodesRequest) GetNodeSelector() string
  • func (m *DeallocateNodesRequest) GetNodesReleased() []string
  • func (*DeallocateNodesRequest) ProtoMessage()
  • func (m *DeallocateNodesRequest) Reset()
  • func (m *DeallocateNodesRequest) String() string
• type DeallocateNodesResponse
  • func (*DeallocateNodesResponse) Descriptor() ([]byte, []int)
  • func (*DeallocateNodesResponse) ProtoMessage()
  • func (m *DeallocateNodesResponse) Reset()
  • func (m *DeallocateNodesResponse) String() string
• type EligibleNodesRequest
  • func (*EligibleNodesRequest) Descriptor() ([]byte, []int)
  • func (m *EligibleNodesRequest) GetManifest() string
  • func (m *EligibleNodesRequest) GetNodeSelector() string
  • func (*EligibleNodesRequest) ProtoMessage()
  • func (m *EligibleNodesRequest) Reset()
  • func (m *EligibleNodesRequest) String() string
• type EligibleNodesResponse
  • func (*EligibleNodesResponse) Descriptor() ([]byte, []int)
  • func (m *EligibleNodesResponse) GetEligibleNodes() []string
  • func (*EligibleNodesResponse) ProtoMessage()
  • func (m *EligibleNodesResponse) Reset()
  • func (m *EligibleNodesResponse) String() string
• type P2SchedulerClient
  • func NewP2SchedulerClient(cc *grpc.ClientConn) P2SchedulerClient
• type P2SchedulerServer

Functions

func RegisterP2SchedulerServer

func RegisterP2SchedulerServer(s *grpc.Server, srv P2SchedulerServer)

Types

type AllocateNodesRequest

type AllocateNodesRequest struct {
	Manifest       string `protobuf:"bytes,1,opt,name=manifest" json:"manifest,omitempty"`
	NodeSelector   string `protobuf:"bytes,2,opt,name=node_selector,json=nodeSelector" json:"node_selector,omitempty"`
	NodesRequested int64  `protobuf:"varint,3,opt,name=nodes_requested,json=nodesRequested" json:"nodes_requested,omitempty"`
	Force          bool   `protobuf:"varint,4,opt,name=force" json:"force,omitempty"`
}

func (*AllocateNodesRequest) Descriptor

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

func (*AllocateNodesRequest) GetForce

func (m *AllocateNodesRequest) GetForce() bool

func (*AllocateNodesRequest) GetManifest

func (m *AllocateNodesRequest) GetManifest() string

func (*AllocateNodesRequest) GetNodeSelector

func (m *AllocateNodesRequest) GetNodeSelector() string

func (*AllocateNodesRequest) GetNodesRequested

func (m *AllocateNodesRequest) GetNodesRequested() int64

func (*AllocateNodesRequest) ProtoMessage

func (*AllocateNodesRequest) ProtoMessage()

func (*AllocateNodesRequest) Reset

func (m *AllocateNodesRequest) Reset()

func (*AllocateNodesRequest) String

func (m *AllocateNodesRequest) String() string

type AllocateNodesResponse

type AllocateNodesResponse struct {
	AllocatedNodes []string `protobuf:"bytes,1,rep,name=allocated_nodes,json=allocatedNodes" json:"allocated_nodes,omitempty"`
}

func (*AllocateNodesResponse) Descriptor

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

func (*AllocateNodesResponse) GetAllocatedNodes

func (m *AllocateNodesResponse) GetAllocatedNodes() []string

func (*AllocateNodesResponse) ProtoMessage

func (*AllocateNodesResponse) ProtoMessage()

func (*AllocateNodesResponse) Reset

func (m *AllocateNodesResponse) Reset()

func (*AllocateNodesResponse) String

func (m *AllocateNodesResponse) String() string

type DeallocateNodesRequest

type DeallocateNodesRequest struct {
	NodesReleased []string `protobuf:"bytes,1,rep,name=nodes_released,json=nodesReleased" json:"nodes_released,omitempty"`
	NodeSelector  string   `protobuf:"bytes,2,opt,name=node_selector,json=nodeSelector" json:"node_selector,omitempty"`
}

func (*DeallocateNodesRequest) Descriptor

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

func (*DeallocateNodesRequest) GetNodeSelector

func (m *DeallocateNodesRequest) GetNodeSelector() string

func (*DeallocateNodesRequest) GetNodesReleased

func (m *DeallocateNodesRequest) GetNodesReleased() []string

func (*DeallocateNodesRequest) ProtoMessage

func (*DeallocateNodesRequest) ProtoMessage()

func (*DeallocateNodesRequest) Reset

func (m *DeallocateNodesRequest) Reset()

func (*DeallocateNodesRequest) String

func (m *DeallocateNodesRequest) String() string

type DeallocateNodesResponse

type DeallocateNodesResponse struct {
}

func (*DeallocateNodesResponse) Descriptor

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

func (*DeallocateNodesResponse) ProtoMessage

func (*DeallocateNodesResponse) ProtoMessage()

func (*DeallocateNodesResponse) Reset

func (m *DeallocateNodesResponse) Reset()

func (*DeallocateNodesResponse) String

func (m *DeallocateNodesResponse) String() string

type EligibleNodesRequest

type EligibleNodesRequest struct {
	Manifest     string `protobuf:"bytes,1,opt,name=manifest" json:"manifest,omitempty"`
	NodeSelector string `protobuf:"bytes,2,opt,name=node_selector,json=nodeSelector" json:"node_selector,omitempty"`
}

func (*EligibleNodesRequest) Descriptor

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

func (*EligibleNodesRequest) GetManifest

func (m *EligibleNodesRequest) GetManifest() string

func (*EligibleNodesRequest) GetNodeSelector

func (m *EligibleNodesRequest) GetNodeSelector() string

func (*EligibleNodesRequest) ProtoMessage

func (*EligibleNodesRequest) ProtoMessage()

func (*EligibleNodesRequest) Reset

func (m *EligibleNodesRequest) Reset()

func (*EligibleNodesRequest) String

func (m *EligibleNodesRequest) String() string

type EligibleNodesResponse

type EligibleNodesResponse struct {
	EligibleNodes []string `protobuf:"bytes,1,rep,name=eligible_nodes,json=eligibleNodes" json:"eligible_nodes,omitempty"`
}

func (*EligibleNodesResponse) Descriptor

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

func (*EligibleNodesResponse) GetEligibleNodes

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

func (*EligibleNodesResponse) ProtoMessage

func (*EligibleNodesResponse) ProtoMessage()

func (*EligibleNodesResponse) Reset

func (m *EligibleNodesResponse) Reset()

func (*EligibleNodesResponse) String

func (m *EligibleNodesResponse) String() string

type P2SchedulerClient

type P2SchedulerClient interface {
	AllocateNodes(ctx context.Context, in *AllocateNodesRequest, opts ...grpc.CallOption) (*AllocateNodesResponse, error)
	DeallocateNodes(ctx context.Context, in *DeallocateNodesRequest, opts ...grpc.CallOption) (*DeallocateNodesResponse, error)
	EligibleNodes(ctx context.Context, in *EligibleNodesRequest, opts ...grpc.CallOption) (*EligibleNodesResponse, error)
}

func NewP2SchedulerClient

func NewP2SchedulerClient(cc *grpc.ClientConn) P2SchedulerClient

type P2SchedulerServer

type P2SchedulerServer interface {
	AllocateNodes(context.Context, *AllocateNodesRequest) (*AllocateNodesResponse, error)
	DeallocateNodes(context.Context, *DeallocateNodesRequest) (*DeallocateNodesResponse, error)
	EligibleNodes(context.Context, *EligibleNodesRequest) (*EligibleNodesResponse, error)
}