v1

package
v1.2.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 9, 2025 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
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"
)
View Source
const (
	AgentService_CreateTask_FullMethodName = "/v1.AgentService/CreateTask"
)

Variables

View Source
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.

View Source
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.

View Source
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)

View Source
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)

View Source
var File_agent_service_proto protoreflect.FileDescriptor
View Source
var File_data_provider_service_proto protoreflect.FileDescriptor
View Source
var File_difficulty_proto protoreflect.FileDescriptor
View Source
var File_status_proto protoreflect.FileDescriptor
View Source
var File_status_value_proto protoreflect.FileDescriptor
View Source
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.

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.

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

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) Descriptor() ([]byte, []int)

Deprecated: Use Status.ProtoReflect.Descriptor instead.

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

func (*Status) Reset

func (x *Status) Reset()

func (*Status) String

func (x *Status) String() string

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) 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

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) Descriptor() ([]byte, []int)

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetDifficulty

func (x *Task) GetDifficulty() Difficulty

func (*Task) GetId

func (x *Task) GetId() int64

func (*Task) GetName

func (x *Task) GetName() string

func (*Task) GetStatusHistory

func (x *Task) GetStatusHistory() []*Status

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) ProtoReflect

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

func (*Task) Reset

func (x *Task) Reset()

func (*Task) String

func (x *Task) String() string

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

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) GetTask

func (UnimplementedDataProviderServiceServer) SearchTask

func (UnimplementedDataProviderServiceServer) UpdateStatus

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL