pb

Documentation

Index

• Variables
• func RegisterJobResultServer(s grpc.ServiceRegistrar, srv JobResultServer)
• type DeleteJobResultRequest
  • func (*DeleteJobResultRequest) Descriptor() ([]byte, []int)
  • func (x *DeleteJobResultRequest) GetJobId() string
  • func (*DeleteJobResultRequest) ProtoMessage()
  • func (x *DeleteJobResultRequest) ProtoReflect() protoreflect.Message
  • func (x *DeleteJobResultRequest) Reset()
  • func (x *DeleteJobResultRequest) String() string
• type DeleteJobResultResponse
  • func (*DeleteJobResultResponse) Descriptor() ([]byte, []int)
  • func (*DeleteJobResultResponse) ProtoMessage()
  • func (x *DeleteJobResultResponse) ProtoReflect() protoreflect.Message
  • func (x *DeleteJobResultResponse) Reset()
  • func (x *DeleteJobResultResponse) String() string
• type GetJobResultRequest
  • func (*GetJobResultRequest) Descriptor() ([]byte, []int)
  • func (x *GetJobResultRequest) GetJobId() string
  • func (*GetJobResultRequest) ProtoMessage()
  • func (x *GetJobResultRequest) ProtoReflect() protoreflect.Message
  • func (x *GetJobResultRequest) Reset()
  • func (x *GetJobResultRequest) String() string
• type GetJobResultResponse
  • func (*GetJobResultResponse) Descriptor() ([]byte, []int)
  • func (x *GetJobResultResponse) GetError() string
  • func (x *GetJobResultResponse) GetJobId() string
  • func (x *GetJobResultResponse) GetMetadata() *structpb.Value
  • func (*GetJobResultResponse) ProtoMessage()
  • func (x *GetJobResultResponse) ProtoReflect() protoreflect.Message
  • func (x *GetJobResultResponse) Reset()
  • func (x *GetJobResultResponse) String() string
• type JobResultClient
  • func NewJobResultClient(cc grpc.ClientConnInterface) JobResultClient
• type JobResultServer
• type UnimplementedJobResultServer
  • func (UnimplementedJobResultServer) Delete(context.Context, *DeleteJobResultRequest) (*DeleteJobResultResponse, error)
  • func (UnimplementedJobResultServer) Get(context.Context, *GetJobResultRequest) (*GetJobResultResponse, error)
• type UnsafeJobResultServer

Variables

var File_internal_handler_resulthdl_protos_jobresult_request_proto protoreflect.FileDescriptor

var File_internal_handler_resulthdl_protos_jobresult_response_proto protoreflect.FileDescriptor

var File_internal_handler_resulthdl_protos_jobresult_service_proto protoreflect.FileDescriptor

var JobResult_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jobresult.JobResult",
	HandlerType: (*JobResultServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _JobResult_Get_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _JobResult_Delete_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/handler/resulthdl/protos/jobresult_service.proto",
}

JobResult_ServiceDesc is the grpc.ServiceDesc for JobResult service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterJobResultServer

func RegisterJobResultServer(s grpc.ServiceRegistrar, srv JobResultServer)

Types

type DeleteJobResultRequest

type DeleteJobResultRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteJobResultRequest) Descriptor

func (*DeleteJobResultRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteJobResultRequest.ProtoReflect.Descriptor instead.

func (*DeleteJobResultRequest) GetJobId

func (x *DeleteJobResultRequest) GetJobId() string

func (*DeleteJobResultRequest) ProtoMessage

func (*DeleteJobResultRequest) ProtoMessage()

func (*DeleteJobResultRequest) ProtoReflect

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

func (*DeleteJobResultRequest) Reset

func (x *DeleteJobResultRequest) Reset()

func (*DeleteJobResultRequest) String

func (x *DeleteJobResultRequest) String() string

type DeleteJobResultResponse

type DeleteJobResultResponse struct {
	// contains filtered or unexported fields
}

Empty response

func (*DeleteJobResultResponse) Descriptor

func (*DeleteJobResultResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteJobResultResponse.ProtoReflect.Descriptor instead.

func (*DeleteJobResultResponse) ProtoMessage

func (*DeleteJobResultResponse) ProtoMessage()

func (*DeleteJobResultResponse) ProtoReflect

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

func (*DeleteJobResultResponse) Reset

func (x *DeleteJobResultResponse) Reset()

func (*DeleteJobResultResponse) String

func (x *DeleteJobResultResponse) String() string

type GetJobResultRequest

type GetJobResultRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobResultRequest) Descriptor

func (*GetJobResultRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetJobResultRequest.ProtoReflect.Descriptor instead.

func (*GetJobResultRequest) GetJobId

func (x *GetJobResultRequest) GetJobId() string

func (*GetJobResultRequest) ProtoMessage

func (*GetJobResultRequest) ProtoMessage()

func (*GetJobResultRequest) ProtoReflect

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

func (*GetJobResultRequest) Reset

func (x *GetJobResultRequest) Reset()

func (*GetJobResultRequest) String

func (x *GetJobResultRequest) String() string

type GetJobResultResponse

type GetJobResultResponse struct {
	JobId    string          `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Metadata *structpb.Value `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Error    string          `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobResultResponse) Descriptor

func (*GetJobResultResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetJobResultResponse.ProtoReflect.Descriptor instead.

func (*GetJobResultResponse) GetError

func (x *GetJobResultResponse) GetError() string

func (*GetJobResultResponse) GetJobId

func (x *GetJobResultResponse) GetJobId() string

func (*GetJobResultResponse) GetMetadata

func (x *GetJobResultResponse) GetMetadata() *structpb.Value

func (*GetJobResultResponse) ProtoMessage

func (*GetJobResultResponse) ProtoMessage()

func (*GetJobResultResponse) ProtoReflect

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

func (*GetJobResultResponse) Reset

func (x *GetJobResultResponse) Reset()

func (*GetJobResultResponse) String

func (x *GetJobResultResponse) String() string

type JobResultClient

type JobResultClient interface {
	Get(ctx context.Context, in *GetJobResultRequest, opts ...grpc.CallOption) (*GetJobResultResponse, error)
	Delete(ctx context.Context, in *DeleteJobResultRequest, opts ...grpc.CallOption) (*DeleteJobResultResponse, error)
}

JobResultClient is the client API for JobResult 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 NewJobResultClient

func NewJobResultClient(cc grpc.ClientConnInterface) JobResultClient

type JobResultServer

type JobResultServer interface {
	Get(context.Context, *GetJobResultRequest) (*GetJobResultResponse, error)
	Delete(context.Context, *DeleteJobResultRequest) (*DeleteJobResultResponse, error)
	// contains filtered or unexported methods
}

JobResultServer is the server API for JobResult service. All implementations must embed UnimplementedJobResultServer for forward compatibility

type UnimplementedJobResultServer

type UnimplementedJobResultServer struct {
}

UnimplementedJobResultServer must be embedded to have forward compatible implementations.

func (UnimplementedJobResultServer) Delete

func (UnimplementedJobResultServer) Delete(context.Context, *DeleteJobResultRequest) (*DeleteJobResultResponse, error)

func (UnimplementedJobResultServer) Get

func (UnimplementedJobResultServer) Get(context.Context, *GetJobResultRequest) (*GetJobResultResponse, error)

type UnsafeJobResultServer

type UnsafeJobResultServer interface {
	// contains filtered or unexported methods
}

UnsafeJobResultServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JobResultServer will result in compilation errors.