protobuf

package

Go to main page

Versions in this module

v0

v0.0.6

Jul 15, 2025

v0.0.5

Jul 11, 2025

Changes in this version

type ExecuteTaskRequest

+ JobId int64

+ JobRequest []byte

+ func (x *ExecuteTaskRequest) GetJobId() int64

+ func (x *ExecuteTaskRequest) GetJobRequest() []byte

v0.0.4

Jul 11, 2025

Changes in this version

type ExecuteTaskResponse

+ ErrMsg string

+ Url string

+ func (x *ExecuteTaskResponse) GetErrMsg() string

+ func (x *ExecuteTaskResponse) GetUrl() string

v0.0.3

Jul 11, 2025

Changes in this version

+ const Job_CreateAttachment_FullMethodName

+ const Task_GetDescription_FullMethodName

+ type ExecuteTaskRequest struct

+ Request []byte

+ func (*ExecuteTaskRequest) Descriptor() ([]byte, []int)

+ func (*ExecuteTaskRequest) ProtoMessage()

+ func (x *ExecuteTaskRequest) GetRequest() []byte

+ func (x *ExecuteTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *ExecuteTaskRequest) Reset()

+ func (x *ExecuteTaskRequest) String() string

+ type ExecuteTaskResponse struct

+ Response []byte

+ func (*ExecuteTaskResponse) Descriptor() ([]byte, []int)

+ func (*ExecuteTaskResponse) ProtoMessage()

+ func (x *ExecuteTaskResponse) GetResponse() []byte

+ func (x *ExecuteTaskResponse) ProtoReflect() protoreflect.Message

+ func (x *ExecuteTaskResponse) Reset()

+ func (x *ExecuteTaskResponse) String() string

+ type GetTaskDescriptionRequest struct

+ func (*GetTaskDescriptionRequest) Descriptor() ([]byte, []int)

+ func (*GetTaskDescriptionRequest) ProtoMessage()

+ func (x *GetTaskDescriptionRequest) ProtoReflect() protoreflect.Message

+ func (x *GetTaskDescriptionRequest) Reset()

+ func (x *GetTaskDescriptionRequest) String() string

+ type GetTaskDescriptionResponse struct

+ Description string

+ func (*GetTaskDescriptionResponse) Descriptor() ([]byte, []int)

+ func (*GetTaskDescriptionResponse) ProtoMessage()

+ func (x *GetTaskDescriptionResponse) GetDescription() string

+ func (x *GetTaskDescriptionResponse) ProtoReflect() protoreflect.Message

+ func (x *GetTaskDescriptionResponse) Reset()

+ func (x *GetTaskDescriptionResponse) String() string

type JobClient

+ CreateAttachment func(ctx context.Context, in *JobCreateAttachmentRequest, opts ...grpc.CallOption) (*JobCreateAttachmentResponse, error)

+ type JobCreateAttachmentRequest struct

+ Data []byte

+ Filename string

+ JobName string

+ func (*JobCreateAttachmentRequest) Descriptor() ([]byte, []int)

+ func (*JobCreateAttachmentRequest) ProtoMessage()

+ func (x *JobCreateAttachmentRequest) GetData() []byte

+ func (x *JobCreateAttachmentRequest) GetFilename() string

+ func (x *JobCreateAttachmentRequest) GetJobName() string

+ func (x *JobCreateAttachmentRequest) ProtoReflect() protoreflect.Message

+ func (x *JobCreateAttachmentRequest) Reset()

+ func (x *JobCreateAttachmentRequest) String() string

+ type JobCreateAttachmentResponse struct

+ Url string

+ func (*JobCreateAttachmentResponse) Descriptor() ([]byte, []int)

+ func (*JobCreateAttachmentResponse) ProtoMessage()

+ func (x *JobCreateAttachmentResponse) GetUrl() string

+ func (x *JobCreateAttachmentResponse) ProtoReflect() protoreflect.Message

+ func (x *JobCreateAttachmentResponse) Reset()

+ func (x *JobCreateAttachmentResponse) String() string

type JobServer

+ CreateAttachment func(context.Context, *JobCreateAttachmentRequest) (*JobCreateAttachmentResponse, error)

type JobUpdateProgressRequest

+ Id int64

+ func (x *JobUpdateProgressRequest) GetId() int64

type TaskClient

+ GetDescription func(ctx context.Context, in *GetTaskDescriptionRequest, opts ...grpc.CallOption) (*GetTaskDescriptionResponse, error)

type TaskServer

+ GetDescription func(context.Context, *GetTaskDescriptionRequest) (*GetTaskDescriptionResponse, error)

type UnimplementedJobServer

+ func (UnimplementedJobServer) CreateAttachment(context.Context, *JobCreateAttachmentRequest) (*JobCreateAttachmentResponse, error)

type UnimplementedTaskServer

+ func (UnimplementedTaskServer) GetDescription(context.Context, *GetTaskDescriptionRequest) (*GetTaskDescriptionResponse, error)

v0.0.2

Jul 8, 2025

v0.0.1

Jul 7, 2025

Changes in this version

+ const Job_InvokeService_FullMethodName

+ const Job_UpdateProgress_FullMethodName

+ const Task_Execute_FullMethodName

+ var File_proto_job_proto protoreflect.FileDescriptor

+ var File_proto_task_proto protoreflect.FileDescriptor

+ var Job_ServiceDesc = grpc.ServiceDesc

+ var Task_ServiceDesc = grpc.ServiceDesc

+ func RegisterJobServer(s grpc.ServiceRegistrar, srv JobServer)

+ func RegisterTaskServer(s grpc.ServiceRegistrar, srv TaskServer)

+ type JobClient interface

+ InvokeService func(ctx context.Context, in *JobInvokeServiceRequest, opts ...grpc.CallOption) (*JobInvokeServiceResponse, error)

+ UpdateProgress func(ctx context.Context, in *JobUpdateProgressRequest, opts ...grpc.CallOption) (*JobUpdateProgressResponse, error)

+ func NewJobClient(cc grpc.ClientConnInterface) JobClient

+ type JobInvokeServiceRequest struct

+ App string

+ Method string

+ Module string

+ Request []byte

+ Version int32

+ func (*JobInvokeServiceRequest) Descriptor() ([]byte, []int)

+ func (*JobInvokeServiceRequest) ProtoMessage()

+ func (x *JobInvokeServiceRequest) GetApp() string

+ func (x *JobInvokeServiceRequest) GetMethod() string

+ func (x *JobInvokeServiceRequest) GetModule() string

+ func (x *JobInvokeServiceRequest) GetRequest() []byte

+ func (x *JobInvokeServiceRequest) GetVersion() int32

+ func (x *JobInvokeServiceRequest) ProtoReflect() protoreflect.Message

+ func (x *JobInvokeServiceRequest) Reset()

+ func (x *JobInvokeServiceRequest) String() string

+ type JobInvokeServiceResponse struct

+ Response []byte

+ func (*JobInvokeServiceResponse) Descriptor() ([]byte, []int)

+ func (*JobInvokeServiceResponse) ProtoMessage()

+ func (x *JobInvokeServiceResponse) GetResponse() []byte

+ func (x *JobInvokeServiceResponse) ProtoReflect() protoreflect.Message

+ func (x *JobInvokeServiceResponse) Reset()

+ func (x *JobInvokeServiceResponse) String() string

+ type JobServer interface

+ InvokeService func(context.Context, *JobInvokeServiceRequest) (*JobInvokeServiceResponse, error)

+ UpdateProgress func(context.Context, *JobUpdateProgressRequest) (*JobUpdateProgressResponse, error)

+ type JobUpdateProgressRequest struct

+ Progress int32

+ TaskId int64

+ func (*JobUpdateProgressRequest) Descriptor() ([]byte, []int)

+ func (*JobUpdateProgressRequest) ProtoMessage()

+ func (x *JobUpdateProgressRequest) GetProgress() int32

+ func (x *JobUpdateProgressRequest) GetTaskId() int64

+ func (x *JobUpdateProgressRequest) ProtoReflect() protoreflect.Message

+ func (x *JobUpdateProgressRequest) Reset()

+ func (x *JobUpdateProgressRequest) String() string

+ type JobUpdateProgressResponse struct

+ func (*JobUpdateProgressResponse) Descriptor() ([]byte, []int)

+ func (*JobUpdateProgressResponse) ProtoMessage()

+ func (x *JobUpdateProgressResponse) ProtoReflect() protoreflect.Message

+ func (x *JobUpdateProgressResponse) Reset()

+ func (x *JobUpdateProgressResponse) String() string

+ type TaskClient interface

+ Execute func(ctx context.Context, in *TaskExecuteRequest, opts ...grpc.CallOption) (*TaskExecuteResponse, error)

+ func NewTaskClient(cc grpc.ClientConnInterface) TaskClient

+ type TaskExecuteRequest struct

+ Params map[string]string

+ func (*TaskExecuteRequest) Descriptor() ([]byte, []int)

+ func (*TaskExecuteRequest) ProtoMessage()

+ func (x *TaskExecuteRequest) GetParams() map[string]string

+ func (x *TaskExecuteRequest) ProtoReflect() protoreflect.Message

+ func (x *TaskExecuteRequest) Reset()

+ func (x *TaskExecuteRequest) String() string

+ type TaskExecuteResponse struct

+ Error string

+ Result string

+ func (*TaskExecuteResponse) Descriptor() ([]byte, []int)

+ func (*TaskExecuteResponse) ProtoMessage()

+ func (x *TaskExecuteResponse) GetError() string

+ func (x *TaskExecuteResponse) GetResult() string

+ func (x *TaskExecuteResponse) ProtoReflect() protoreflect.Message

+ func (x *TaskExecuteResponse) Reset()

+ func (x *TaskExecuteResponse) String() string

+ type TaskServer interface

+ Execute func(context.Context, *TaskExecuteRequest) (*TaskExecuteResponse, error)

+ type UnimplementedJobServer struct

+ func (UnimplementedJobServer) InvokeService(context.Context, *JobInvokeServiceRequest) (*JobInvokeServiceResponse, error)

+ func (UnimplementedJobServer) UpdateProgress(context.Context, *JobUpdateProgressRequest) (*JobUpdateProgressResponse, error)

+ type UnimplementedTaskServer struct

+ func (UnimplementedTaskServer) Execute(context.Context, *TaskExecuteRequest) (*TaskExecuteResponse, error)

+ type UnsafeJobServer interface

+ type UnsafeTaskServer interface

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