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.

      Source Files

      View all