Versions in this module Expand all Collapse all v0 v0.1.3 Jul 28, 2022 v0.1.2 Jul 28, 2022 v0.1.1 Jul 28, 2022 v0.1.0 Jul 28, 2022 v0.0.2 Jul 27, 2022 v0.0.1 Jul 27, 2022 Changes in this version + var File_api_proto protoreflect.FileDescriptor + var KingService_ServiceDesc = grpc.ServiceDesc + func RegisterKingServiceServer(s grpc.ServiceRegistrar, srv KingServiceServer) + type Job struct + MinRamMb int32 + NumWork int32 + OnePerMachine bool + ProjectName string + Wasm []byte + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (x *Job) GetMinRamMb() int32 + func (x *Job) GetNumWork() int32 + func (x *Job) GetOnePerMachine() bool + func (x *Job) GetProjectName() string + func (x *Job) GetWasm() []byte + func (x *Job) ProtoReflect() protoreflect.Message + func (x *Job) Reset() + func (x *Job) String() string + type KingServiceClient interface + SubmitJob func(ctx context.Context, opts ...grpc.CallOption) (KingService_SubmitJobClient, error) + Volunteer func(ctx context.Context, opts ...grpc.CallOption) (KingService_VolunteerClient, error) + func NewKingServiceClient(cc grpc.ClientConnInterface) KingServiceClient + type KingServiceServer interface + SubmitJob func(KingService_SubmitJobServer) error + Volunteer func(KingService_VolunteerServer) error + type KingService_SubmitJobClient interface + Recv func() (*SubmitJobResponse, error) + Send func(*SubmitJobRequest) error + type KingService_SubmitJobServer interface + Recv func() (*SubmitJobRequest, error) + Send func(*SubmitJobResponse) error + type KingService_VolunteerClient interface + Recv func() (*VolunteerResponse, error) + Send func(*VolunteerRequest) error + type KingService_VolunteerServer interface + Recv func() (*VolunteerRequest, error) + Send func(*VolunteerResponse) error + type SubmitJobRequest struct + Req isSubmitJobRequest_Req + func (*SubmitJobRequest) Descriptor() ([]byte, []int) + func (*SubmitJobRequest) ProtoMessage() + func (m *SubmitJobRequest) GetReq() isSubmitJobRequest_Req + func (x *SubmitJobRequest) GetAddWork() *WorkRequest + func (x *SubmitJobRequest) GetJob() *Job + func (x *SubmitJobRequest) ProtoReflect() protoreflect.Message + func (x *SubmitJobRequest) Reset() + func (x *SubmitJobRequest) String() string + type SubmitJobRequest_AddWork struct + AddWork *WorkRequest + type SubmitJobRequest_Job struct + Job *Job + type SubmitJobResponse struct + Resp isSubmitJobResponse_Resp + func (*SubmitJobResponse) Descriptor() ([]byte, []int) + func (*SubmitJobResponse) ProtoMessage() + func (m *SubmitJobResponse) GetResp() isSubmitJobResponse_Resp + func (x *SubmitJobResponse) GetCompletedWork() *WorkResponse + func (x *SubmitJobResponse) ProtoReflect() protoreflect.Message + func (x *SubmitJobResponse) Reset() + func (x *SubmitJobResponse) String() string + type SubmitJobResponse_CompletedWork struct + CompletedWork *WorkResponse + type UnimplementedKingServiceServer struct + func (UnimplementedKingServiceServer) SubmitJob(KingService_SubmitJobServer) error + func (UnimplementedKingServiceServer) Volunteer(KingService_VolunteerServer) error + type UnsafeKingServiceServer interface + type VolunteerRequest struct + Req isVolunteerRequest_Req + func (*VolunteerRequest) Descriptor() ([]byte, []int) + func (*VolunteerRequest) ProtoMessage() + func (m *VolunteerRequest) GetReq() isVolunteerRequest_Req + func (x *VolunteerRequest) GetFinishWork() *WorkResponse + func (x *VolunteerRequest) GetHello() *VolunteerRequest_Hello + func (x *VolunteerRequest) GetJobError() string + func (x *VolunteerRequest) ProtoReflect() protoreflect.Message + func (x *VolunteerRequest) Reset() + func (x *VolunteerRequest) String() string + type VolunteerRequest_FinishWork struct + FinishWork *WorkResponse + type VolunteerRequest_Hello struct + Cpus int32 + Hostname string + RamMbAllocatable int32 + func (*VolunteerRequest_Hello) Descriptor() ([]byte, []int) + func (*VolunteerRequest_Hello) ProtoMessage() + func (x *VolunteerRequest_Hello) GetCpus() int32 + func (x *VolunteerRequest_Hello) GetHostname() string + func (x *VolunteerRequest_Hello) GetRamMbAllocatable() int32 + func (x *VolunteerRequest_Hello) ProtoReflect() protoreflect.Message + func (x *VolunteerRequest_Hello) Reset() + func (x *VolunteerRequest_Hello) String() string + type VolunteerRequest_Hello_ struct + Hello *VolunteerRequest_Hello + type VolunteerRequest_JobError struct + JobError string + type VolunteerResponse struct + Resp isVolunteerResponse_Resp + func (*VolunteerResponse) Descriptor() ([]byte, []int) + func (*VolunteerResponse) ProtoMessage() + func (m *VolunteerResponse) GetResp() isVolunteerResponse_Resp + func (x *VolunteerResponse) GetEndJob() *VolunteerResponse_EndJob + func (x *VolunteerResponse) GetStartJob() *Job + func (x *VolunteerResponse) GetStartWork() *WorkRequest + func (x *VolunteerResponse) ProtoReflect() protoreflect.Message + func (x *VolunteerResponse) Reset() + func (x *VolunteerResponse) String() string + type VolunteerResponse_EndJob struct + func (*VolunteerResponse_EndJob) Descriptor() ([]byte, []int) + func (*VolunteerResponse_EndJob) ProtoMessage() + func (x *VolunteerResponse_EndJob) ProtoReflect() protoreflect.Message + func (x *VolunteerResponse_EndJob) Reset() + func (x *VolunteerResponse_EndJob) String() string + type VolunteerResponse_EndJob_ struct + EndJob *VolunteerResponse_EndJob + type VolunteerResponse_StartJob struct + StartJob *Job + type VolunteerResponse_StartWork struct + StartWork *WorkRequest + type WorkRequest struct + Data []byte + Id int32 + func (*WorkRequest) Descriptor() ([]byte, []int) + func (*WorkRequest) ProtoMessage() + func (x *WorkRequest) GetData() []byte + func (x *WorkRequest) GetId() int32 + func (x *WorkRequest) ProtoReflect() protoreflect.Message + func (x *WorkRequest) Reset() + func (x *WorkRequest) String() string + type WorkResponse struct + ErrorMessage string + Id int32 + Result []byte + func (*WorkResponse) Descriptor() ([]byte, []int) + func (*WorkResponse) ProtoMessage() + func (x *WorkResponse) GetErrorMessage() string + func (x *WorkResponse) GetId() int32 + func (x *WorkResponse) GetResult() []byte + func (x *WorkResponse) ProtoReflect() protoreflect.Message + func (x *WorkResponse) Reset() + func (x *WorkResponse) String() string
Go to main page