Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)
- func RegisterDataProviderServiceServer(s grpc.ServiceRegistrar, srv DataProviderServiceServer)
- type AgentServiceClient
- type AgentServiceServer
- type CreateTaskRequest
- func (*CreateTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTaskRequest) GetDifficulty() Difficulty
- func (x *CreateTaskRequest) GetName() string
- func (*CreateTaskRequest) ProtoMessage()
- func (x *CreateTaskRequest) ProtoReflect() protoreflect.Message
- func (x *CreateTaskRequest) Reset()
- func (x *CreateTaskRequest) String() string
- type CreateTaskResponse
- type DataProviderServiceClient
- type DataProviderServiceServer
- type Difficulty
- type GetTaskRequest
- type GetTaskResponse
- type SearchTaskRequest
- func (*SearchTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SearchTaskRequest) GetPage() int64
- func (x *SearchTaskRequest) GetPerPage() int64
- func (*SearchTaskRequest) ProtoMessage()
- func (x *SearchTaskRequest) ProtoReflect() protoreflect.Message
- func (x *SearchTaskRequest) Reset()
- func (x *SearchTaskRequest) String() string
- type SearchTaskResponse
- func (*SearchTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SearchTaskResponse) GetPages() int64
- func (x *SearchTaskResponse) GetTasks() []*Task
- func (*SearchTaskResponse) ProtoMessage()
- func (x *SearchTaskResponse) ProtoReflect() protoreflect.Message
- func (x *SearchTaskResponse) Reset()
- func (x *SearchTaskResponse) String() string
- type Status
- type StatusValue
- func (StatusValue) Descriptor() protoreflect.EnumDescriptor
- func (x StatusValue) Enum() *StatusValue
- func (StatusValue) EnumDescriptor() ([]byte, []int)deprecated
- func (x StatusValue) Number() protoreflect.EnumNumber
- func (x StatusValue) String() string
- func (StatusValue) Type() protoreflect.EnumType
- type Task
- func (*Task) Descriptor() ([]byte, []int)deprecated
- func (x *Task) GetDifficulty() Difficulty
- func (x *Task) GetId() int64
- func (x *Task) GetName() string
- func (x *Task) GetStatusHistory() []*Status
- func (*Task) ProtoMessage()
- func (x *Task) ProtoReflect() protoreflect.Message
- func (x *Task) Reset()
- func (x *Task) String() string
- type UnimplementedAgentServiceServer
- type UnimplementedDataProviderServiceServer
- func (UnimplementedDataProviderServiceServer) CreateTask(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error)
- func (UnimplementedDataProviderServiceServer) GetTask(context.Context, *GetTaskRequest) (*GetTaskResponse, error)
- func (UnimplementedDataProviderServiceServer) SearchTask(context.Context, *SearchTaskRequest) (*SearchTaskResponse, error)
- func (UnimplementedDataProviderServiceServer) UpdateStatus(context.Context, *UpdateStatusRequest) (*emptypb.Empty, error)
- type UnsafeAgentServiceServer
- type UnsafeDataProviderServiceServer
- type UpdateStatusRequest
- func (*UpdateStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateStatusRequest) GetId() int64
- func (x *UpdateStatusRequest) GetStatus() *Status
- func (*UpdateStatusRequest) ProtoMessage()
- func (x *UpdateStatusRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateStatusRequest) Reset()
- func (x *UpdateStatusRequest) String() string
- type WorkerTask
Constants ¶
const ( DataProviderService_SearchTask_FullMethodName = "/v1.DataProviderService/SearchTask" DataProviderService_CreateTask_FullMethodName = "/v1.DataProviderService/CreateTask" DataProviderService_GetTask_FullMethodName = "/v1.DataProviderService/GetTask" DataProviderService_UpdateStatus_FullMethodName = "/v1.DataProviderService/UpdateStatus" )
const (
AgentService_CreateTask_FullMethodName = "/v1.AgentService/CreateTask"
)
Variables ¶
var ( Difficulty_name = map[int32]string{ 0: "UNSPECIFIED", 1: "EASY", 2: "NORMAL", 3: "HARD", } Difficulty_value = map[string]int32{ "UNSPECIFIED": 0, "EASY": 1, "NORMAL": 2, "HARD": 3, } )
Enum value maps for Difficulty.
var ( StatusValue_name = map[int32]string{ 0: "STATUS_UNSPECIFIED", 1: "STATUS_CREATED", 2: "STATUS_PENDING", 3: "STATUS_INPROGRESS", 4: "STATUS_DONE", } StatusValue_value = map[string]int32{ "STATUS_UNSPECIFIED": 0, "STATUS_CREATED": 1, "STATUS_PENDING": 2, "STATUS_INPROGRESS": 3, "STATUS_DONE": 4, } )
Enum value maps for StatusValue.
var AgentService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "v1.AgentService", HandlerType: (*AgentServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateTask", Handler: _AgentService_CreateTask_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "agent_service.proto", }
AgentService_ServiceDesc is the grpc.ServiceDesc for AgentService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var DataProviderService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "v1.DataProviderService", HandlerType: (*DataProviderServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SearchTask", Handler: _DataProviderService_SearchTask_Handler, }, { MethodName: "CreateTask", Handler: _DataProviderService_CreateTask_Handler, }, { MethodName: "GetTask", Handler: _DataProviderService_GetTask_Handler, }, { MethodName: "UpdateStatus", Handler: _DataProviderService_UpdateStatus_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "data_provider_service.proto", }
DataProviderService_ServiceDesc is the grpc.ServiceDesc for DataProviderService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_agent_service_proto protoreflect.FileDescriptor
var File_api_proto protoreflect.FileDescriptor
var File_data_provider_service_proto protoreflect.FileDescriptor
var File_difficulty_proto protoreflect.FileDescriptor
var File_status_proto protoreflect.FileDescriptor
var File_status_value_proto protoreflect.FileDescriptor
var File_task_proto protoreflect.FileDescriptor
var File_worker_task_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAgentServiceServer ¶
func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)
func RegisterDataProviderServiceServer ¶
func RegisterDataProviderServiceServer(s grpc.ServiceRegistrar, srv DataProviderServiceServer)
Types ¶
type AgentServiceClient ¶
type AgentServiceClient interface {
CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*CreateTaskResponse, error)
}
AgentServiceClient is the client API for AgentService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAgentServiceClient ¶
func NewAgentServiceClient(cc grpc.ClientConnInterface) AgentServiceClient
type AgentServiceServer ¶
type AgentServiceServer interface { CreateTask(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error) // contains filtered or unexported methods }
AgentServiceServer is the server API for AgentService service. All implementations must embed UnimplementedAgentServiceServer for forward compatibility.
type CreateTaskRequest ¶
type CreateTaskRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Difficulty Difficulty `protobuf:"varint,2,opt,name=difficulty,proto3,enum=v1.Difficulty" json:"difficulty,omitempty"` // contains filtered or unexported fields }
func (*CreateTaskRequest) Descriptor
deprecated
func (*CreateTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateTaskRequest.ProtoReflect.Descriptor instead.
func (*CreateTaskRequest) GetDifficulty ¶
func (x *CreateTaskRequest) GetDifficulty() Difficulty
func (*CreateTaskRequest) GetName ¶
func (x *CreateTaskRequest) GetName() string
func (*CreateTaskRequest) ProtoMessage ¶
func (*CreateTaskRequest) ProtoMessage()
func (*CreateTaskRequest) ProtoReflect ¶
func (x *CreateTaskRequest) ProtoReflect() protoreflect.Message
func (*CreateTaskRequest) Reset ¶
func (x *CreateTaskRequest) Reset()
func (*CreateTaskRequest) String ¶
func (x *CreateTaskRequest) String() string
type CreateTaskResponse ¶
type CreateTaskResponse struct { Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` // contains filtered or unexported fields }
func (*CreateTaskResponse) Descriptor
deprecated
func (*CreateTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateTaskResponse.ProtoReflect.Descriptor instead.
func (*CreateTaskResponse) GetTask ¶
func (x *CreateTaskResponse) GetTask() *Task
func (*CreateTaskResponse) ProtoMessage ¶
func (*CreateTaskResponse) ProtoMessage()
func (*CreateTaskResponse) ProtoReflect ¶
func (x *CreateTaskResponse) ProtoReflect() protoreflect.Message
func (*CreateTaskResponse) Reset ¶
func (x *CreateTaskResponse) Reset()
func (*CreateTaskResponse) String ¶
func (x *CreateTaskResponse) String() string
type DataProviderServiceClient ¶
type DataProviderServiceClient interface { SearchTask(ctx context.Context, in *SearchTaskRequest, opts ...grpc.CallOption) (*SearchTaskResponse, error) CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*CreateTaskResponse, error) GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*GetTaskResponse, error) UpdateStatus(ctx context.Context, in *UpdateStatusRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) }
DataProviderServiceClient is the client API for DataProviderService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewDataProviderServiceClient ¶
func NewDataProviderServiceClient(cc grpc.ClientConnInterface) DataProviderServiceClient
type DataProviderServiceServer ¶
type DataProviderServiceServer interface { SearchTask(context.Context, *SearchTaskRequest) (*SearchTaskResponse, error) CreateTask(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error) GetTask(context.Context, *GetTaskRequest) (*GetTaskResponse, error) UpdateStatus(context.Context, *UpdateStatusRequest) (*emptypb.Empty, error) // contains filtered or unexported methods }
DataProviderServiceServer is the server API for DataProviderService service. All implementations must embed UnimplementedDataProviderServiceServer for forward compatibility.
type Difficulty ¶
type Difficulty int32
const ( Difficulty_UNSPECIFIED Difficulty = 0 Difficulty_EASY Difficulty = 1 Difficulty_NORMAL Difficulty = 2 Difficulty_HARD Difficulty = 3 )
func (Difficulty) Descriptor ¶
func (Difficulty) Descriptor() protoreflect.EnumDescriptor
func (Difficulty) Enum ¶
func (x Difficulty) Enum() *Difficulty
func (Difficulty) EnumDescriptor
deprecated
func (Difficulty) EnumDescriptor() ([]byte, []int)
Deprecated: Use Difficulty.Descriptor instead.
func (Difficulty) Number ¶
func (x Difficulty) Number() protoreflect.EnumNumber
func (Difficulty) String ¶
func (x Difficulty) String() string
func (Difficulty) Type ¶
func (Difficulty) Type() protoreflect.EnumType
type GetTaskRequest ¶
type GetTaskRequest struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetTaskRequest) Descriptor
deprecated
func (*GetTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead.
func (*GetTaskRequest) GetId ¶
func (x *GetTaskRequest) GetId() int64
func (*GetTaskRequest) ProtoMessage ¶
func (*GetTaskRequest) ProtoMessage()
func (*GetTaskRequest) ProtoReflect ¶
func (x *GetTaskRequest) ProtoReflect() protoreflect.Message
func (*GetTaskRequest) Reset ¶
func (x *GetTaskRequest) Reset()
func (*GetTaskRequest) String ¶
func (x *GetTaskRequest) String() string
type GetTaskResponse ¶
type GetTaskResponse struct { Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` // contains filtered or unexported fields }
func (*GetTaskResponse) Descriptor
deprecated
func (*GetTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTaskResponse.ProtoReflect.Descriptor instead.
func (*GetTaskResponse) GetTask ¶
func (x *GetTaskResponse) GetTask() *Task
func (*GetTaskResponse) ProtoMessage ¶
func (*GetTaskResponse) ProtoMessage()
func (*GetTaskResponse) ProtoReflect ¶
func (x *GetTaskResponse) ProtoReflect() protoreflect.Message
func (*GetTaskResponse) Reset ¶
func (x *GetTaskResponse) Reset()
func (*GetTaskResponse) String ¶
func (x *GetTaskResponse) String() string
type SearchTaskRequest ¶
type SearchTaskRequest struct { Page int64 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"` PerPage int64 `protobuf:"varint,2,opt,name=per_page,json=perPage,proto3" json:"per_page,omitempty"` // contains filtered or unexported fields }
func (*SearchTaskRequest) Descriptor
deprecated
func (*SearchTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchTaskRequest.ProtoReflect.Descriptor instead.
func (*SearchTaskRequest) GetPage ¶
func (x *SearchTaskRequest) GetPage() int64
func (*SearchTaskRequest) GetPerPage ¶
func (x *SearchTaskRequest) GetPerPage() int64
func (*SearchTaskRequest) ProtoMessage ¶
func (*SearchTaskRequest) ProtoMessage()
func (*SearchTaskRequest) ProtoReflect ¶
func (x *SearchTaskRequest) ProtoReflect() protoreflect.Message
func (*SearchTaskRequest) Reset ¶
func (x *SearchTaskRequest) Reset()
func (*SearchTaskRequest) String ¶
func (x *SearchTaskRequest) String() string
type SearchTaskResponse ¶
type SearchTaskResponse struct { Pages int64 `protobuf:"varint,1,opt,name=pages,proto3" json:"pages,omitempty"` Tasks []*Task `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"` // contains filtered or unexported fields }
func (*SearchTaskResponse) Descriptor
deprecated
func (*SearchTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use SearchTaskResponse.ProtoReflect.Descriptor instead.
func (*SearchTaskResponse) GetPages ¶
func (x *SearchTaskResponse) GetPages() int64
func (*SearchTaskResponse) GetTasks ¶
func (x *SearchTaskResponse) GetTasks() []*Task
func (*SearchTaskResponse) ProtoMessage ¶
func (*SearchTaskResponse) ProtoMessage()
func (*SearchTaskResponse) ProtoReflect ¶
func (x *SearchTaskResponse) ProtoReflect() protoreflect.Message
func (*SearchTaskResponse) Reset ¶
func (x *SearchTaskResponse) Reset()
func (*SearchTaskResponse) String ¶
func (x *SearchTaskResponse) String() string
type Status ¶
type Status struct { Status StatusValue `protobuf:"varint,1,opt,name=status,proto3,enum=v1.StatusValue" json:"status,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*Status) Descriptor
deprecated
func (*Status) GetStatus ¶
func (x *Status) GetStatus() StatusValue
func (*Status) GetTimestamp ¶
func (x *Status) GetTimestamp() *timestamppb.Timestamp
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) ProtoReflect ¶
func (x *Status) ProtoReflect() protoreflect.Message
type StatusValue ¶
type StatusValue int32
const ( StatusValue_STATUS_UNSPECIFIED StatusValue = 0 StatusValue_STATUS_CREATED StatusValue = 1 StatusValue_STATUS_PENDING StatusValue = 2 StatusValue_STATUS_INPROGRESS StatusValue = 3 StatusValue_STATUS_DONE StatusValue = 4 )
func (StatusValue) Descriptor ¶
func (StatusValue) Descriptor() protoreflect.EnumDescriptor
func (StatusValue) Enum ¶
func (x StatusValue) Enum() *StatusValue
func (StatusValue) EnumDescriptor
deprecated
func (StatusValue) EnumDescriptor() ([]byte, []int)
Deprecated: Use StatusValue.Descriptor instead.
func (StatusValue) Number ¶
func (x StatusValue) Number() protoreflect.EnumNumber
func (StatusValue) String ¶
func (x StatusValue) String() string
func (StatusValue) Type ¶
func (StatusValue) Type() protoreflect.EnumType
type Task ¶
type Task struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Difficulty Difficulty `protobuf:"varint,3,opt,name=difficulty,proto3,enum=v1.Difficulty" json:"difficulty,omitempty"` StatusHistory []*Status `protobuf:"bytes,4,rep,name=status_history,json=statusHistory,proto3" json:"status_history,omitempty"` // contains filtered or unexported fields }
func (*Task) Descriptor
deprecated
func (*Task) GetDifficulty ¶
func (x *Task) GetDifficulty() Difficulty
func (*Task) GetStatusHistory ¶
func (*Task) ProtoMessage ¶
func (*Task) ProtoMessage()
func (*Task) ProtoReflect ¶
func (x *Task) ProtoReflect() protoreflect.Message
type UnimplementedAgentServiceServer ¶
type UnimplementedAgentServiceServer struct{}
UnimplementedAgentServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedAgentServiceServer) CreateTask ¶ added in v1.2.6
func (UnimplementedAgentServiceServer) CreateTask(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error)
type UnimplementedDataProviderServiceServer ¶
type UnimplementedDataProviderServiceServer struct{}
UnimplementedDataProviderServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedDataProviderServiceServer) CreateTask ¶
func (UnimplementedDataProviderServiceServer) CreateTask(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error)
func (UnimplementedDataProviderServiceServer) GetTask ¶
func (UnimplementedDataProviderServiceServer) GetTask(context.Context, *GetTaskRequest) (*GetTaskResponse, error)
func (UnimplementedDataProviderServiceServer) SearchTask ¶
func (UnimplementedDataProviderServiceServer) SearchTask(context.Context, *SearchTaskRequest) (*SearchTaskResponse, error)
func (UnimplementedDataProviderServiceServer) UpdateStatus ¶
func (UnimplementedDataProviderServiceServer) UpdateStatus(context.Context, *UpdateStatusRequest) (*emptypb.Empty, error)
type UnsafeAgentServiceServer ¶
type UnsafeAgentServiceServer interface {
// contains filtered or unexported methods
}
UnsafeAgentServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServiceServer will result in compilation errors.
type UnsafeDataProviderServiceServer ¶
type UnsafeDataProviderServiceServer interface {
// contains filtered or unexported methods
}
UnsafeDataProviderServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DataProviderServiceServer will result in compilation errors.
type UpdateStatusRequest ¶
type UpdateStatusRequest struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Status *Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*UpdateStatusRequest) Descriptor
deprecated
func (*UpdateStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateStatusRequest.ProtoReflect.Descriptor instead.
func (*UpdateStatusRequest) GetId ¶
func (x *UpdateStatusRequest) GetId() int64
func (*UpdateStatusRequest) GetStatus ¶
func (x *UpdateStatusRequest) GetStatus() *Status
func (*UpdateStatusRequest) ProtoMessage ¶
func (*UpdateStatusRequest) ProtoMessage()
func (*UpdateStatusRequest) ProtoReflect ¶
func (x *UpdateStatusRequest) ProtoReflect() protoreflect.Message
func (*UpdateStatusRequest) Reset ¶
func (x *UpdateStatusRequest) Reset()
func (*UpdateStatusRequest) String ¶
func (x *UpdateStatusRequest) String() string
type WorkerTask ¶ added in v1.2.5
type WorkerTask struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Difficulty Difficulty `protobuf:"varint,2,opt,name=difficulty,proto3,enum=v1.Difficulty" json:"difficulty,omitempty"` // contains filtered or unexported fields }
func (*WorkerTask) Descriptor
deprecated
added in
v1.2.5
func (*WorkerTask) Descriptor() ([]byte, []int)
Deprecated: Use WorkerTask.ProtoReflect.Descriptor instead.
func (*WorkerTask) GetDifficulty ¶ added in v1.2.5
func (x *WorkerTask) GetDifficulty() Difficulty
func (*WorkerTask) GetId ¶ added in v1.2.5
func (x *WorkerTask) GetId() int64
func (*WorkerTask) ProtoMessage ¶ added in v1.2.5
func (*WorkerTask) ProtoMessage()
func (*WorkerTask) ProtoReflect ¶ added in v1.2.5
func (x *WorkerTask) ProtoReflect() protoreflect.Message
func (*WorkerTask) Reset ¶ added in v1.2.5
func (x *WorkerTask) Reset()
func (*WorkerTask) String ¶ added in v1.2.5
func (x *WorkerTask) String() string