proto

Documentation

Index

• Variables
• func RegisterApiServer(s *grpc.Server, srv ApiServer)
• type ApiClient
  • func NewApiClient(cc grpc.ClientConnInterface) ApiClient
• type ApiServer
• type EndTaskRep
  • func (*EndTaskRep) Descriptor() ([]byte, []int)
  • func (*EndTaskRep) ProtoMessage()
  • func (x *EndTaskRep) ProtoReflect() protoreflect.Message
  • func (x *EndTaskRep) Reset()
  • func (x *EndTaskRep) String() string
• type EndTaskReq
  • func (*EndTaskReq) Descriptor() ([]byte, []int)
  • func (x *EndTaskReq) GetError() string
  • func (x *EndTaskReq) GetLogs() []byte
  • func (x *EndTaskReq) GetTaskId() string
  • func (*EndTaskReq) ProtoMessage()
  • func (x *EndTaskReq) ProtoReflect() protoreflect.Message
  • func (x *EndTaskReq) Reset()
  • func (x *EndTaskReq) String() string
• type Job
  • func (*Job) Descriptor() ([]byte, []int)
  • func (x *Job) GetDataset() string
  • func (x *Job) GetDockerImage() string
  • func (x *Job) GetEnv() []string
  • func (*Job) ProtoMessage()
  • func (x *Job) ProtoReflect() protoreflect.Message
  • func (x *Job) Reset()
  • func (x *Job) String() string
• type StartTaskRep
  • func (*StartTaskRep) Descriptor() ([]byte, []int)
  • func (x *StartTaskRep) GetJob() *Job
  • func (x *StartTaskRep) GetTaskId() string
  • func (*StartTaskRep) ProtoMessage()
  • func (x *StartTaskRep) ProtoReflect() protoreflect.Message
  • func (x *StartTaskRep) Reset()
  • func (x *StartTaskRep) String() string
• type StartTaskReq
  • func (*StartTaskReq) Descriptor() ([]byte, []int)
  • func (x *StartTaskReq) GetWithGPU() bool
  • func (*StartTaskReq) ProtoMessage()
  • func (x *StartTaskReq) ProtoReflect() protoreflect.Message
  • func (x *StartTaskReq) Reset()
  • func (x *StartTaskReq) String() string
• type UnimplementedApiServer
  • func (*UnimplementedApiServer) EndTask(context.Context, *EndTaskReq) (*EndTaskRep, error)
  • func (*UnimplementedApiServer) StartTask(context.Context, *StartTaskReq) (*StartTaskRep, error)

Variables

var File_api_proto protoreflect.FileDescriptor

Functions

func RegisterApiServer

func RegisterApiServer(s *grpc.Server, srv ApiServer)

Types

type ApiClient

type ApiClient interface {
	StartTask(ctx context.Context, in *StartTaskReq, opts ...grpc.CallOption) (*StartTaskRep, error)
	EndTask(ctx context.Context, in *EndTaskReq, opts ...grpc.CallOption) (*EndTaskRep, error)
}

ApiClient is the client API for Api service.

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

func NewApiClient

func NewApiClient(cc grpc.ClientConnInterface) ApiClient

type ApiServer

type ApiServer interface {
	StartTask(context.Context, *StartTaskReq) (*StartTaskRep, error)
	EndTask(context.Context, *EndTaskReq) (*EndTaskRep, error)
}

ApiServer is the server API for Api service.

type EndTaskRep

type EndTaskRep struct {
	// contains filtered or unexported fields
}

func (*EndTaskRep) Descriptor

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

Deprecated: Use EndTaskRep.ProtoReflect.Descriptor instead.

func (*EndTaskRep) ProtoMessage

func (*EndTaskRep) ProtoMessage()

func (*EndTaskRep) ProtoReflect

func (x *EndTaskRep) ProtoReflect() protoreflect.Message

func (*EndTaskRep) Reset

func (x *EndTaskRep) Reset()

func (*EndTaskRep) String

func (x *EndTaskRep) String() string

type EndTaskReq

type EndTaskReq struct {
	TaskId string `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId,omitempty"`
	Error  string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Logs   []byte `protobuf:"bytes,3,opt,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*EndTaskReq) Descriptor

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

Deprecated: Use EndTaskReq.ProtoReflect.Descriptor instead.

func (*EndTaskReq) GetError

func (x *EndTaskReq) GetError() string

func (*EndTaskReq) GetLogs

func (x *EndTaskReq) GetLogs() []byte

func (*EndTaskReq) GetTaskId

func (x *EndTaskReq) GetTaskId() string

func (*EndTaskReq) ProtoMessage

func (*EndTaskReq) ProtoMessage()

func (*EndTaskReq) ProtoReflect

func (x *EndTaskReq) ProtoReflect() protoreflect.Message

func (*EndTaskReq) Reset

func (x *EndTaskReq) Reset()

func (*EndTaskReq) String

func (x *EndTaskReq) String() string

type Job

type Job struct {
	DockerImage string   `protobuf:"bytes,1,opt,name=dockerImage,proto3" json:"dockerImage,omitempty"`
	Dataset     string   `protobuf:"bytes,2,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Env         []string `protobuf:"bytes,3,rep,name=env,proto3" json:"env,omitempty"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetDataset

func (x *Job) GetDataset() string

func (*Job) GetDockerImage

func (x *Job) GetDockerImage() string

func (*Job) GetEnv

func (x *Job) GetEnv() []string

func (*Job) ProtoMessage

func (*Job) ProtoMessage()

func (*Job) ProtoReflect

func (x *Job) ProtoReflect() protoreflect.Message

func (*Job) Reset

func (x *Job) Reset()

func (*Job) String

func (x *Job) String() string

type StartTaskRep

type StartTaskRep struct {
	TaskId string `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId,omitempty"`
	Job    *Job   `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*StartTaskRep) Descriptor

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

Deprecated: Use StartTaskRep.ProtoReflect.Descriptor instead.

func (*StartTaskRep) GetJob

func (x *StartTaskRep) GetJob() *Job

func (*StartTaskRep) GetTaskId

func (x *StartTaskRep) GetTaskId() string

func (*StartTaskRep) ProtoMessage

func (*StartTaskRep) ProtoMessage()

func (*StartTaskRep) ProtoReflect

func (x *StartTaskRep) ProtoReflect() protoreflect.Message

func (*StartTaskRep) Reset

func (x *StartTaskRep) Reset()

func (*StartTaskRep) String

func (x *StartTaskRep) String() string

type StartTaskReq

type StartTaskReq struct {
	WithGPU bool `protobuf:"varint,1,opt,name=withGPU,proto3" json:"withGPU,omitempty"`
	// contains filtered or unexported fields
}

func (*StartTaskReq) Descriptor

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

Deprecated: Use StartTaskReq.ProtoReflect.Descriptor instead.

func (*StartTaskReq) GetWithGPU

func (x *StartTaskReq) GetWithGPU() bool

func (*StartTaskReq) ProtoMessage

func (*StartTaskReq) ProtoMessage()

func (*StartTaskReq) ProtoReflect

func (x *StartTaskReq) ProtoReflect() protoreflect.Message

func (*StartTaskReq) Reset

func (x *StartTaskReq) Reset()

func (*StartTaskReq) String

func (x *StartTaskReq) String() string

type UnimplementedApiServer

type UnimplementedApiServer struct {
}

UnimplementedApiServer can be embedded to have forward compatible implementations.

func (*UnimplementedApiServer) EndTask

func (*UnimplementedApiServer) EndTask(context.Context, *EndTaskReq) (*EndTaskRep, error)

func (*UnimplementedApiServer) StartTask

func (*UnimplementedApiServer) StartTask(context.Context, *StartTaskReq) (*StartTaskRep, error)