Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterSchedulerServer

func RegisterSchedulerServer(s *grpc.Server, srv SchedulerServer)

Types

type ScheduleRequest

type ScheduleRequest struct {
	Service              *v1.Service `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	AvailableNodes       []*v11.Node `protobuf:"bytes,2,rep,name=available_nodes,json=availableNodes,proto3" json:"available_nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ScheduleRequest) Descriptor

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

func (*ScheduleRequest) GetAvailableNodes

func (m *ScheduleRequest) GetAvailableNodes() []*v11.Node

func (*ScheduleRequest) GetService

func (m *ScheduleRequest) GetService() *v1.Service

func (*ScheduleRequest) ProtoMessage

func (*ScheduleRequest) ProtoMessage()

func (*ScheduleRequest) Reset

func (m *ScheduleRequest) Reset()

func (*ScheduleRequest) String

func (m *ScheduleRequest) String() string

func (*ScheduleRequest) XXX_DiscardUnknown

func (m *ScheduleRequest) XXX_DiscardUnknown()

func (*ScheduleRequest) XXX_Marshal

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

func (*ScheduleRequest) XXX_Merge

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

func (*ScheduleRequest) XXX_Size

func (m *ScheduleRequest) XXX_Size() int

func (*ScheduleRequest) XXX_Unmarshal

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

type ScheduleResponse

type ScheduleResponse struct {
	Nodes                []*v11.Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ScheduleResponse) Descriptor

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

func (*ScheduleResponse) GetNodes

func (m *ScheduleResponse) GetNodes() []*v11.Node

func (*ScheduleResponse) ProtoMessage

func (*ScheduleResponse) ProtoMessage()

func (*ScheduleResponse) Reset

func (m *ScheduleResponse) Reset()

func (*ScheduleResponse) String

func (m *ScheduleResponse) String() string

func (*ScheduleResponse) XXX_DiscardUnknown

func (m *ScheduleResponse) XXX_DiscardUnknown()

func (*ScheduleResponse) XXX_Marshal

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

func (*ScheduleResponse) XXX_Merge

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

func (*ScheduleResponse) XXX_Size

func (m *ScheduleResponse) XXX_Size() int

func (*ScheduleResponse) XXX_Unmarshal

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

type SchedulerClient

type SchedulerClient interface {
	Schedule(ctx context.Context, in *ScheduleRequest, opts ...grpc.CallOption) (*ScheduleResponse, error)
}

    SchedulerClient is the client API for Scheduler service.

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

    func NewSchedulerClient

    func NewSchedulerClient(cc *grpc.ClientConn) SchedulerClient

    type SchedulerServer

    type SchedulerServer interface {
    	Schedule(context.Context, *ScheduleRequest) (*ScheduleResponse, error)
    }

      SchedulerServer is the server API for Scheduler service.