Documentation ¶
Index ¶
- Constants
- Variables
- func GetParamByKind(kind string) (msg proto.Message)
- func NewTaskServiceEndpoints() []*api.Endpoint
- func RegisterTaskServiceHandler(s server.Server, hdlr TaskServiceHandler, opts ...server.HandlerOption) error
- type BWH
- type BiLiBiLi
- type CreateTaskRequest
- type CreateTaskResponse
- func (*CreateTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTaskResponse) GetTaskId() int64
- func (*CreateTaskResponse) ProtoMessage()
- func (x *CreateTaskResponse) ProtoReflect() protoreflect.Message
- func (x *CreateTaskResponse) Reset()
- func (x *CreateTaskResponse) String() string
- type CustomMessage
- type DeleteTaskRequest
- func (*DeleteTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteTaskRequest) GetTaskId() int64
- func (x *DeleteTaskRequest) GetUserId() int64
- func (*DeleteTaskRequest) ProtoMessage()
- func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteTaskRequest) Reset()
- func (x *DeleteTaskRequest) String() string
- type DispatchTasksRequest
- func (*DispatchTasksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DispatchTasksRequest) GetSpec() string
- func (*DispatchTasksRequest) ProtoMessage()
- func (x *DispatchTasksRequest) ProtoReflect() protoreflect.Message
- func (x *DispatchTasksRequest) Reset()
- func (x *DispatchTasksRequest) String() string
- type Evolution
- type GetTaskRequest
- func (*GetTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTaskRequest) GetTaskId() int64
- func (x *GetTaskRequest) GetUserId() int64
- func (*GetTaskRequest) ProtoMessage()
- func (x *GetTaskRequest) ProtoReflect() protoreflect.Message
- func (x *GetTaskRequest) Reset()
- func (x *GetTaskRequest) String() string
- type GetTaskResponse
- type GetTasksRequest
- func (*GetTasksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTasksRequest) GetCreatedAt() *timestamppb.Timestamp
- func (x *GetTasksRequest) GetDescription() string
- func (x *GetTasksRequest) GetKind() string
- func (x *GetTasksRequest) GetLimit() int64
- func (x *GetTasksRequest) GetOffset() int64
- func (x *GetTasksRequest) GetSpec() string
- func (x *GetTasksRequest) GetTaskId() int64
- func (x *GetTasksRequest) GetUserId() int64
- func (*GetTasksRequest) ProtoMessage()
- func (x *GetTasksRequest) ProtoReflect() protoreflect.Message
- func (x *GetTasksRequest) Reset()
- func (x *GetTasksRequest) String() string
- type GetTasksResponse
- func (*GetTasksResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTasksResponse) GetCount() int64
- func (x *GetTasksResponse) GetTasks() []*Task
- func (*GetTasksResponse) ProtoMessage()
- func (x *GetTasksResponse) ProtoReflect() protoreflect.Message
- func (x *GetTasksResponse) Reset()
- func (x *GetTasksResponse) String() string
- type GithubRelease
- func (*GithubRelease) Descriptor() ([]byte, []int)deprecated
- func (x *GithubRelease) GetOwner() string
- func (x *GithubRelease) GetRepo() string
- func (*GithubRelease) ProtoMessage()
- func (x *GithubRelease) ProtoReflect() protoreflect.Message
- func (x *GithubRelease) Reset()
- func (x *GithubRelease) String() string
- type HPI
- type JueJin
- type Kind
- type ReadyTasks
- type STG
- type Task
- func (*Task) Descriptor() ([]byte, []int)deprecated
- func (x *Task) GetCreatedAt() *timestamppb.Timestamp
- func (x *Task) GetDescription() string
- func (x *Task) GetKind() string
- func (x *Task) GetParam() []byte
- func (x *Task) GetSpec() string
- func (x *Task) GetTaskId() int64
- func (x *Task) GetUserId() int64
- func (*Task) ProtoMessage()
- func (x *Task) ProtoReflect() protoreflect.Message
- func (x *Task) Reset()
- func (x *Task) String() string
- type TaskService
- type TaskServiceHandler
- type UpdateTaskRequest
- type V2Ex
Constants ¶
const ( ServiceName = "task" Topic = "task-dispatch" Queue = "consume-task" )
Variables ¶
var ( Kind_name = map[int32]string{ 0: "UNKNOWN_KIND", 12: "MOCK", 1: "BILIBILI_SIGN_IN", 2: "BILIBILI_B_COUNT", 3: "STG_SIGN_IN", 4: "V2EX_SIGN_IN", 5: "EVOLUTION_RELEASE", 6: "GITHUB_RELEASE", 7: "JUEJIN_SIGN_IN", 8: "JUEJIN_COUNT", 9: "JUEJIN_POINT", 10: "JUEJIN_CALENDAR", 11: "CUSTOM_MESSAGE", 13: "HPI_SIGN_IN", 14: "BWH_NETWORK", 15: "BWH_CPU", } Kind_value = map[string]int32{ "UNKNOWN_KIND": 0, "MOCK": 12, "BILIBILI_SIGN_IN": 1, "BILIBILI_B_COUNT": 2, "STG_SIGN_IN": 3, "V2EX_SIGN_IN": 4, "EVOLUTION_RELEASE": 5, "GITHUB_RELEASE": 6, "JUEJIN_SIGN_IN": 7, "JUEJIN_COUNT": 8, "JUEJIN_POINT": 9, "JUEJIN_CALENDAR": 10, "CUSTOM_MESSAGE": 11, "HPI_SIGN_IN": 13, "BWH_NETWORK": 14, "BWH_CPU": 15, } )
Enum value maps for Kind.
var File_internal_proto_task_param_proto protoreflect.FileDescriptor
var File_internal_proto_task_task_proto protoreflect.FileDescriptor
Functions ¶
func GetParamByKind ¶
func NewTaskServiceEndpoints ¶
func RegisterTaskServiceHandler ¶
func RegisterTaskServiceHandler(s server.Server, hdlr TaskServiceHandler, opts ...server.HandlerOption) error
Types ¶
type BWH ¶ added in v0.8.0
type BWH struct { VeId string `protobuf:"bytes,1,opt,name=ve_id,json=veId,proto3" json:"ve_id,omitempty"` ApiKey string `protobuf:"bytes,2,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"` // contains filtered or unexported fields }
func (*BWH) Descriptor
deprecated
added in
v0.8.0
func (*BWH) ProtoMessage ¶ added in v0.8.0
func (*BWH) ProtoMessage()
func (*BWH) ProtoReflect ¶ added in v0.8.0
func (x *BWH) ProtoReflect() protoreflect.Message
type BiLiBiLi ¶
type BiLiBiLi struct { Cookie string `protobuf:"bytes,1,opt,name=cookie,proto3" json:"cookie,omitempty"` // contains filtered or unexported fields }
func (*BiLiBiLi) Descriptor
deprecated
func (*BiLiBiLi) ProtoMessage ¶
func (*BiLiBiLi) ProtoMessage()
func (*BiLiBiLi) ProtoReflect ¶
func (x *BiLiBiLi) ProtoReflect() protoreflect.Message
type CreateTaskRequest ¶
type CreateTaskRequest struct { Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` // contains filtered or unexported fields }
func (*CreateTaskRequest) Descriptor
deprecated
func (*CreateTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateTaskRequest.ProtoReflect.Descriptor instead.
func (*CreateTaskRequest) GetTask ¶
func (x *CreateTaskRequest) GetTask() *Task
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 { TaskId int64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // contains filtered or unexported fields }
func (*CreateTaskResponse) Descriptor
deprecated
func (*CreateTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateTaskResponse.ProtoReflect.Descriptor instead.
func (*CreateTaskResponse) GetTaskId ¶
func (x *CreateTaskResponse) GetTaskId() int64
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 CustomMessage ¶
type CustomMessage struct { Content string `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*CustomMessage) Descriptor
deprecated
func (*CustomMessage) Descriptor() ([]byte, []int)
Deprecated: Use CustomMessage.ProtoReflect.Descriptor instead.
func (*CustomMessage) GetContent ¶
func (x *CustomMessage) GetContent() string
func (*CustomMessage) ProtoMessage ¶
func (*CustomMessage) ProtoMessage()
func (*CustomMessage) ProtoReflect ¶
func (x *CustomMessage) ProtoReflect() protoreflect.Message
func (*CustomMessage) Reset ¶
func (x *CustomMessage) Reset()
func (*CustomMessage) String ¶
func (x *CustomMessage) String() string
type DeleteTaskRequest ¶
type DeleteTaskRequest struct { TaskId int64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` UserId int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // contains filtered or unexported fields }
func (*DeleteTaskRequest) Descriptor
deprecated
func (*DeleteTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.
func (*DeleteTaskRequest) GetTaskId ¶
func (x *DeleteTaskRequest) GetTaskId() int64
func (*DeleteTaskRequest) GetUserId ¶
func (x *DeleteTaskRequest) GetUserId() int64
func (*DeleteTaskRequest) ProtoMessage ¶
func (*DeleteTaskRequest) ProtoMessage()
func (*DeleteTaskRequest) ProtoReflect ¶
func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message
func (*DeleteTaskRequest) Reset ¶
func (x *DeleteTaskRequest) Reset()
func (*DeleteTaskRequest) String ¶
func (x *DeleteTaskRequest) String() string
type DispatchTasksRequest ¶
type DispatchTasksRequest struct { Spec string `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` // contains filtered or unexported fields }
func (*DispatchTasksRequest) Descriptor
deprecated
func (*DispatchTasksRequest) Descriptor() ([]byte, []int)
Deprecated: Use DispatchTasksRequest.ProtoReflect.Descriptor instead.
func (*DispatchTasksRequest) GetSpec ¶
func (x *DispatchTasksRequest) GetSpec() string
func (*DispatchTasksRequest) ProtoMessage ¶
func (*DispatchTasksRequest) ProtoMessage()
func (*DispatchTasksRequest) ProtoReflect ¶
func (x *DispatchTasksRequest) ProtoReflect() protoreflect.Message
func (*DispatchTasksRequest) Reset ¶
func (x *DispatchTasksRequest) Reset()
func (*DispatchTasksRequest) String ¶
func (x *DispatchTasksRequest) String() string
type Evolution ¶
type Evolution struct { Device string `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"` // contains filtered or unexported fields }
func (*Evolution) Descriptor
deprecated
func (*Evolution) ProtoMessage ¶
func (*Evolution) ProtoMessage()
func (*Evolution) ProtoReflect ¶
func (x *Evolution) ProtoReflect() protoreflect.Message
type GetTaskRequest ¶
type GetTaskRequest struct { TaskId int64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` UserId int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // contains filtered or unexported fields }
func (*GetTaskRequest) Descriptor
deprecated
func (*GetTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead.
func (*GetTaskRequest) GetTaskId ¶
func (x *GetTaskRequest) GetTaskId() int64
func (*GetTaskRequest) GetUserId ¶
func (x *GetTaskRequest) GetUserId() 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 GetTasksRequest ¶
type GetTasksRequest struct { TaskId int64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` UserId int64 `protobuf:"varint,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Kind string `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"` Spec string `protobuf:"bytes,5,opt,name=spec,proto3" json:"spec,omitempty"` CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` Offset int64 `protobuf:"varint,7,opt,name=offset,proto3" json:"offset,omitempty"` Limit int64 `protobuf:"varint,8,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*GetTasksRequest) Descriptor
deprecated
func (*GetTasksRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTasksRequest.ProtoReflect.Descriptor instead.
func (*GetTasksRequest) GetCreatedAt ¶
func (x *GetTasksRequest) GetCreatedAt() *timestamppb.Timestamp
func (*GetTasksRequest) GetDescription ¶
func (x *GetTasksRequest) GetDescription() string
func (*GetTasksRequest) GetKind ¶
func (x *GetTasksRequest) GetKind() string
func (*GetTasksRequest) GetLimit ¶
func (x *GetTasksRequest) GetLimit() int64
func (*GetTasksRequest) GetOffset ¶
func (x *GetTasksRequest) GetOffset() int64
func (*GetTasksRequest) GetSpec ¶
func (x *GetTasksRequest) GetSpec() string
func (*GetTasksRequest) GetTaskId ¶
func (x *GetTasksRequest) GetTaskId() int64
func (*GetTasksRequest) GetUserId ¶
func (x *GetTasksRequest) GetUserId() int64
func (*GetTasksRequest) ProtoMessage ¶
func (*GetTasksRequest) ProtoMessage()
func (*GetTasksRequest) ProtoReflect ¶
func (x *GetTasksRequest) ProtoReflect() protoreflect.Message
func (*GetTasksRequest) Reset ¶
func (x *GetTasksRequest) Reset()
func (*GetTasksRequest) String ¶
func (x *GetTasksRequest) String() string
type GetTasksResponse ¶
type GetTasksResponse struct { Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` Tasks []*Task `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"` // contains filtered or unexported fields }
func (*GetTasksResponse) Descriptor
deprecated
func (*GetTasksResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTasksResponse.ProtoReflect.Descriptor instead.
func (*GetTasksResponse) GetCount ¶
func (x *GetTasksResponse) GetCount() int64
func (*GetTasksResponse) GetTasks ¶
func (x *GetTasksResponse) GetTasks() []*Task
func (*GetTasksResponse) ProtoMessage ¶
func (*GetTasksResponse) ProtoMessage()
func (*GetTasksResponse) ProtoReflect ¶
func (x *GetTasksResponse) ProtoReflect() protoreflect.Message
func (*GetTasksResponse) Reset ¶
func (x *GetTasksResponse) Reset()
func (*GetTasksResponse) String ¶
func (x *GetTasksResponse) String() string
type GithubRelease ¶
type GithubRelease struct { Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"` Repo string `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"` // contains filtered or unexported fields }
func (*GithubRelease) Descriptor
deprecated
func (*GithubRelease) Descriptor() ([]byte, []int)
Deprecated: Use GithubRelease.ProtoReflect.Descriptor instead.
func (*GithubRelease) GetOwner ¶
func (x *GithubRelease) GetOwner() string
func (*GithubRelease) GetRepo ¶
func (x *GithubRelease) GetRepo() string
func (*GithubRelease) ProtoMessage ¶
func (*GithubRelease) ProtoMessage()
func (*GithubRelease) ProtoReflect ¶
func (x *GithubRelease) ProtoReflect() protoreflect.Message
func (*GithubRelease) Reset ¶
func (x *GithubRelease) Reset()
func (*GithubRelease) String ¶
func (x *GithubRelease) String() string
type HPI ¶
type HPI struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // contains filtered or unexported fields }
func (*HPI) Descriptor
deprecated
func (*HPI) ProtoMessage ¶
func (*HPI) ProtoMessage()
func (*HPI) ProtoReflect ¶
func (x *HPI) ProtoReflect() protoreflect.Message
type JueJin ¶
type JueJin struct { Cookie string `protobuf:"bytes,1,opt,name=cookie,proto3" json:"cookie,omitempty"` // contains filtered or unexported fields }
func (*JueJin) Descriptor
deprecated
func (*JueJin) ProtoMessage ¶
func (*JueJin) ProtoMessage()
func (*JueJin) ProtoReflect ¶
func (x *JueJin) ProtoReflect() protoreflect.Message
type Kind ¶
type Kind int32
Kind 使用时要用字符串形式
const ( Kind_UNKNOWN_KIND Kind = 0 Kind_MOCK Kind = 12 // B站 Kind_BILIBILI_SIGN_IN Kind = 1 Kind_BILIBILI_B_COUNT Kind = 2 // Go语言中文网 Kind_STG_SIGN_IN Kind = 3 // V2ex Kind_V2EX_SIGN_IN Kind = 4 // Evolution X Kind_EVOLUTION_RELEASE Kind = 5 Kind_GITHUB_RELEASE Kind = 6 // 掘金签到 Kind_JUEJIN_SIGN_IN Kind = 7 // 签到天数统计 Kind_JUEJIN_COUNT Kind = 8 // 矿石数 Kind_JUEJIN_POINT Kind = 9 // 码农日历 Kind_JUEJIN_CALENDAR Kind = 10 // 自定义消息 Kind_CUSTOM_MESSAGE Kind = 11 // Deprecated Kind_HPI_SIGN_IN Kind = 13 // bwh Kind_BWH_NETWORK Kind = 14 Kind_BWH_CPU Kind = 15 )
func (Kind) Descriptor ¶
func (Kind) Descriptor() protoreflect.EnumDescriptor
func (Kind) EnumDescriptor
deprecated
func (Kind) Number ¶
func (x Kind) Number() protoreflect.EnumNumber
func (Kind) Type ¶
func (Kind) Type() protoreflect.EnumType
type ReadyTasks ¶
type ReadyTasks struct { Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"` // contains filtered or unexported fields }
func (*ReadyTasks) Descriptor
deprecated
func (*ReadyTasks) Descriptor() ([]byte, []int)
Deprecated: Use ReadyTasks.ProtoReflect.Descriptor instead.
func (*ReadyTasks) GetTasks ¶
func (x *ReadyTasks) GetTasks() []*Task
func (*ReadyTasks) ProtoMessage ¶
func (*ReadyTasks) ProtoMessage()
func (*ReadyTasks) ProtoReflect ¶
func (x *ReadyTasks) ProtoReflect() protoreflect.Message
func (*ReadyTasks) Reset ¶
func (x *ReadyTasks) Reset()
func (*ReadyTasks) String ¶
func (x *ReadyTasks) String() string
type STG ¶
type STG struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Passwd string `protobuf:"bytes,2,opt,name=passwd,proto3" json:"passwd,omitempty"` // contains filtered or unexported fields }
func (*STG) Descriptor
deprecated
func (*STG) GetUsername ¶
func (*STG) ProtoMessage ¶
func (*STG) ProtoMessage()
func (*STG) ProtoReflect ¶
func (x *STG) ProtoReflect() protoreflect.Message
type Task ¶
type Task struct { TaskId int64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` UserId int64 `protobuf:"varint,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Kind string `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"` Spec string `protobuf:"bytes,5,opt,name=spec,proto3" json:"spec,omitempty"` Param []byte `protobuf:"bytes,6,opt,name=param,proto3" json:"param,omitempty"` CreatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` // contains filtered or unexported fields }
func (*Task) Descriptor
deprecated
func (*Task) GetCreatedAt ¶
func (x *Task) GetCreatedAt() *timestamppb.Timestamp
func (*Task) GetDescription ¶
func (*Task) ProtoMessage ¶
func (*Task) ProtoMessage()
func (*Task) ProtoReflect ¶
func (x *Task) ProtoReflect() protoreflect.Message
type TaskService ¶
type TaskService interface { CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...client.CallOption) (*CreateTaskResponse, error) GetTask(ctx context.Context, in *GetTaskRequest, opts ...client.CallOption) (*GetTaskResponse, error) GetTasks(ctx context.Context, in *GetTasksRequest, opts ...client.CallOption) (*GetTasksResponse, error) UpdateTask(ctx context.Context, in *UpdateTaskRequest, opts ...client.CallOption) (*emptypb.Empty, error) DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...client.CallOption) (*emptypb.Empty, error) DispatchTasks(ctx context.Context, in *DispatchTasksRequest, opts ...client.CallOption) (*emptypb.Empty, error) }
func NewTaskService ¶
func NewTaskService(name string, c client.Client) TaskService
type TaskServiceHandler ¶
type TaskServiceHandler interface { CreateTask(context.Context, *CreateTaskRequest, *CreateTaskResponse) error GetTask(context.Context, *GetTaskRequest, *GetTaskResponse) error GetTasks(context.Context, *GetTasksRequest, *GetTasksResponse) error UpdateTask(context.Context, *UpdateTaskRequest, *emptypb.Empty) error DeleteTask(context.Context, *DeleteTaskRequest, *emptypb.Empty) error DispatchTasks(context.Context, *DispatchTasksRequest, *emptypb.Empty) error }
type UpdateTaskRequest ¶
type UpdateTaskRequest struct { Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` // contains filtered or unexported fields }
func (*UpdateTaskRequest) Descriptor
deprecated
func (*UpdateTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateTaskRequest.ProtoReflect.Descriptor instead.
func (*UpdateTaskRequest) GetTask ¶
func (x *UpdateTaskRequest) GetTask() *Task
func (*UpdateTaskRequest) ProtoMessage ¶
func (*UpdateTaskRequest) ProtoMessage()
func (*UpdateTaskRequest) ProtoReflect ¶
func (x *UpdateTaskRequest) ProtoReflect() protoreflect.Message
func (*UpdateTaskRequest) Reset ¶
func (x *UpdateTaskRequest) Reset()
func (*UpdateTaskRequest) String ¶
func (x *UpdateTaskRequest) String() string
type V2Ex ¶
type V2Ex struct { Cookie string `protobuf:"bytes,1,opt,name=cookie,proto3" json:"cookie,omitempty"` // contains filtered or unexported fields }
func (*V2Ex) Descriptor
deprecated
func (*V2Ex) ProtoMessage ¶
func (*V2Ex) ProtoMessage()
func (*V2Ex) ProtoReflect ¶
func (x *V2Ex) ProtoReflect() protoreflect.Message