Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterJobsServiceServer(s grpc.ServiceRegistrar, srv JobsServiceServer)
- type CreateJobRequest
- func (*CreateJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateJobRequest) GetDescription() string
- func (x *CreateJobRequest) GetJobData() string
- func (x *CreateJobRequest) GetJobType() JobType
- func (x *CreateJobRequest) GetName() string
- func (x *CreateJobRequest) GetScheduleTime() *timestamppb.Timestamp
- func (*CreateJobRequest) ProtoMessage()
- func (x *CreateJobRequest) ProtoReflect() protoreflect.Message
- func (x *CreateJobRequest) Reset()
- func (x *CreateJobRequest) String() string
- type CreateJobResponse
- type DeleteJobRequest
- type DeleteJobResponse
- type GetJobRequest
- type Job
- func (*Job) Descriptor() ([]byte, []int)deprecated
- func (x *Job) GetCreatedTime() *timestamppb.Timestamp
- func (x *Job) GetDescription() string
- func (x *Job) GetId() string
- func (x *Job) GetJobData() string
- func (x *Job) GetJobType() JobType
- func (x *Job) GetName() string
- func (x *Job) GetScheduleTime() *timestamppb.Timestamp
- func (x *Job) GetStatus() JobStatus
- func (x *Job) GetUpdatedTime() *timestamppb.Timestamp
- func (*Job) ProtoMessage()
- func (x *Job) ProtoReflect() protoreflect.Message
- func (x *Job) Reset()
- func (x *Job) String() string
- type JobStatus
- type JobType
- type JobsServiceClient
- type JobsServiceServer
- type ListJobsRequest
- func (*ListJobsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListJobsRequest) GetPage() int64
- func (x *ListJobsRequest) GetSize() int64
- func (*ListJobsRequest) ProtoMessage()
- func (x *ListJobsRequest) ProtoReflect() protoreflect.Message
- func (x *ListJobsRequest) Reset()
- func (x *ListJobsRequest) String() string
- type ListJobsResponse
- func (*ListJobsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListJobsResponse) GetHasMore() bool
- func (x *ListJobsResponse) GetJobs() []*Job
- func (x *ListJobsResponse) GetPage() int64
- func (x *ListJobsResponse) GetSize() int64
- func (x *ListJobsResponse) GetTotalCount() int64
- func (x *ListJobsResponse) GetTotalPages() int64
- func (*ListJobsResponse) ProtoMessage()
- func (x *ListJobsResponse) ProtoReflect() protoreflect.Message
- func (x *ListJobsResponse) Reset()
- func (x *ListJobsResponse) String() string
- type UnimplementedJobsServiceServer
- func (UnimplementedJobsServiceServer) CreateJob(context.Context, *CreateJobRequest) (*CreateJobResponse, error)
- func (UnimplementedJobsServiceServer) DeleteJob(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error)
- func (UnimplementedJobsServiceServer) GetJob(context.Context, *GetJobRequest) (*Job, error)
- func (UnimplementedJobsServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
- func (UnimplementedJobsServiceServer) UpdateJob(context.Context, *UpdateJobRequest) (*UpdateJobResponse, error)
- type UnsafeJobsServiceServer
- type UpdateJobRequest
- func (*UpdateJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateJobRequest) GetDescription() string
- func (x *UpdateJobRequest) GetId() string
- func (x *UpdateJobRequest) GetJobData() string
- func (x *UpdateJobRequest) GetJobType() JobType
- func (x *UpdateJobRequest) GetName() string
- func (x *UpdateJobRequest) GetScheduleTime() *timestamppb.Timestamp
- func (*UpdateJobRequest) ProtoMessage()
- func (x *UpdateJobRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateJobRequest) Reset()
- func (x *UpdateJobRequest) String() string
- type UpdateJobResponse
Constants ¶
const ( JobsService_CreateJob_FullMethodName = "/proto.JobsService/CreateJob" JobsService_GetJob_FullMethodName = "/proto.JobsService/GetJob" JobsService_ListJobs_FullMethodName = "/proto.JobsService/ListJobs" JobsService_UpdateJob_FullMethodName = "/proto.JobsService/UpdateJob" JobsService_DeleteJob_FullMethodName = "/proto.JobsService/DeleteJob" )
Variables ¶
var ( JobStatus_name = map[int32]string{ 0: "JOB_STATUS_UNKNOWN", 1: "JOB_STATUS_PENDING", 2: "JOB_STATUS_SCHEDULED", 3: "JOB_STATUS_RUNNING", 4: "JOB_STATUS_SUCCEEDED", 5: "JOB_STATUS_FAILED", } JobStatus_value = map[string]int32{ "JOB_STATUS_UNKNOWN": 0, "JOB_STATUS_PENDING": 1, "JOB_STATUS_SCHEDULED": 2, "JOB_STATUS_RUNNING": 3, "JOB_STATUS_SUCCEEDED": 4, "JOB_STATUS_FAILED": 5, } )
Enum value maps for JobStatus.
var ( JobType_name = map[int32]string{ 0: "JOB_TYPE_EMAIL", 1: "JOB_TYPE_SMS", } JobType_value = map[string]int32{ "JOB_TYPE_EMAIL": 0, "JOB_TYPE_SMS": 1, } )
Enum value maps for JobType.
var File_proto_job_proto protoreflect.FileDescriptor
var JobsService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.JobsService", HandlerType: (*JobsServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateJob", Handler: _JobsService_CreateJob_Handler, }, { MethodName: "GetJob", Handler: _JobsService_GetJob_Handler, }, { MethodName: "ListJobs", Handler: _JobsService_ListJobs_Handler, }, { MethodName: "UpdateJob", Handler: _JobsService_UpdateJob_Handler, }, { MethodName: "DeleteJob", Handler: _JobsService_DeleteJob_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/job.proto", }
JobsService_ServiceDesc is the grpc.ServiceDesc for JobsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterJobsServiceServer ¶
func RegisterJobsServiceServer(s grpc.ServiceRegistrar, srv JobsServiceServer)
Types ¶
type CreateJobRequest ¶
type CreateJobRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` ScheduleTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=schedule_time,json=scheduleTime,proto3" json:"schedule_time,omitempty"` JobType JobType `protobuf:"varint,4,opt,name=job_type,json=jobType,proto3,enum=proto.JobType" json:"job_type,omitempty"` JobData string `protobuf:"bytes,5,opt,name=job_data,json=jobData,proto3" json:"job_data,omitempty"` // contains filtered or unexported fields }
func (*CreateJobRequest) Descriptor
deprecated
func (*CreateJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateJobRequest.ProtoReflect.Descriptor instead.
func (*CreateJobRequest) GetDescription ¶
func (x *CreateJobRequest) GetDescription() string
func (*CreateJobRequest) GetJobData ¶
func (x *CreateJobRequest) GetJobData() string
func (*CreateJobRequest) GetJobType ¶
func (x *CreateJobRequest) GetJobType() JobType
func (*CreateJobRequest) GetName ¶
func (x *CreateJobRequest) GetName() string
func (*CreateJobRequest) GetScheduleTime ¶
func (x *CreateJobRequest) GetScheduleTime() *timestamppb.Timestamp
func (*CreateJobRequest) ProtoMessage ¶
func (*CreateJobRequest) ProtoMessage()
func (*CreateJobRequest) ProtoReflect ¶
func (x *CreateJobRequest) ProtoReflect() protoreflect.Message
func (*CreateJobRequest) Reset ¶
func (x *CreateJobRequest) Reset()
func (*CreateJobRequest) String ¶
func (x *CreateJobRequest) String() string
type CreateJobResponse ¶
type CreateJobResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*CreateJobResponse) Descriptor
deprecated
func (*CreateJobResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateJobResponse.ProtoReflect.Descriptor instead.
func (*CreateJobResponse) GetId ¶
func (x *CreateJobResponse) GetId() string
func (*CreateJobResponse) ProtoMessage ¶
func (*CreateJobResponse) ProtoMessage()
func (*CreateJobResponse) ProtoReflect ¶
func (x *CreateJobResponse) ProtoReflect() protoreflect.Message
func (*CreateJobResponse) Reset ¶
func (x *CreateJobResponse) Reset()
func (*CreateJobResponse) String ¶
func (x *CreateJobResponse) String() string
type DeleteJobRequest ¶
type DeleteJobRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*DeleteJobRequest) Descriptor
deprecated
func (*DeleteJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteJobRequest.ProtoReflect.Descriptor instead.
func (*DeleteJobRequest) GetId ¶
func (x *DeleteJobRequest) GetId() string
func (*DeleteJobRequest) ProtoMessage ¶
func (*DeleteJobRequest) ProtoMessage()
func (*DeleteJobRequest) ProtoReflect ¶
func (x *DeleteJobRequest) ProtoReflect() protoreflect.Message
func (*DeleteJobRequest) Reset ¶
func (x *DeleteJobRequest) Reset()
func (*DeleteJobRequest) String ¶
func (x *DeleteJobRequest) String() string
type DeleteJobResponse ¶
type DeleteJobResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*DeleteJobResponse) Descriptor
deprecated
func (*DeleteJobResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteJobResponse.ProtoReflect.Descriptor instead.
func (*DeleteJobResponse) GetMessage ¶
func (x *DeleteJobResponse) GetMessage() string
func (*DeleteJobResponse) ProtoMessage ¶
func (*DeleteJobResponse) ProtoMessage()
func (*DeleteJobResponse) ProtoReflect ¶
func (x *DeleteJobResponse) ProtoReflect() protoreflect.Message
func (*DeleteJobResponse) Reset ¶
func (x *DeleteJobResponse) Reset()
func (*DeleteJobResponse) String ¶
func (x *DeleteJobResponse) String() string
type GetJobRequest ¶
type GetJobRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetJobRequest) Descriptor
deprecated
func (*GetJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.
func (*GetJobRequest) GetId ¶
func (x *GetJobRequest) GetId() string
func (*GetJobRequest) ProtoMessage ¶
func (*GetJobRequest) ProtoMessage()
func (*GetJobRequest) ProtoReflect ¶
func (x *GetJobRequest) ProtoReflect() protoreflect.Message
func (*GetJobRequest) Reset ¶
func (x *GetJobRequest) Reset()
func (*GetJobRequest) String ¶
func (x *GetJobRequest) String() string
type Job ¶
type Job struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` ScheduleTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=schedule_time,json=scheduleTime,proto3" json:"schedule_time,omitempty"` CreatedTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"` UpdatedTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=updated_time,json=updatedTime,proto3" json:"updated_time,omitempty"` Status JobStatus `protobuf:"varint,7,opt,name=status,proto3,enum=proto.JobStatus" json:"status,omitempty"` JobType JobType `protobuf:"varint,8,opt,name=job_type,json=jobType,proto3,enum=proto.JobType" json:"job_type,omitempty"` JobData string `protobuf:"bytes,9,opt,name=job_data,json=jobData,proto3" json:"job_data,omitempty"` // contains filtered or unexported fields }
func (*Job) Descriptor
deprecated
func (*Job) GetCreatedTime ¶
func (x *Job) GetCreatedTime() *timestamppb.Timestamp
func (*Job) GetDescription ¶
func (*Job) GetJobData ¶
func (*Job) GetJobType ¶
func (*Job) GetScheduleTime ¶
func (x *Job) GetScheduleTime() *timestamppb.Timestamp
func (*Job) GetUpdatedTime ¶
func (x *Job) GetUpdatedTime() *timestamppb.Timestamp
func (*Job) ProtoMessage ¶
func (*Job) ProtoMessage()
func (*Job) ProtoReflect ¶
func (x *Job) ProtoReflect() protoreflect.Message
type JobStatus ¶
type JobStatus int32
func (JobStatus) Descriptor ¶
func (JobStatus) Descriptor() protoreflect.EnumDescriptor
func (JobStatus) EnumDescriptor
deprecated
func (JobStatus) Number ¶
func (x JobStatus) Number() protoreflect.EnumNumber
func (JobStatus) Type ¶
func (JobStatus) Type() protoreflect.EnumType
type JobType ¶
type JobType int32
func (JobType) Descriptor ¶
func (JobType) Descriptor() protoreflect.EnumDescriptor
func (JobType) EnumDescriptor
deprecated
func (JobType) Number ¶
func (x JobType) Number() protoreflect.EnumNumber
func (JobType) Type ¶
func (JobType) Type() protoreflect.EnumType
type JobsServiceClient ¶
type JobsServiceClient interface { CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*CreateJobResponse, error) GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error) ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) UpdateJob(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*UpdateJobResponse, error) DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*DeleteJobResponse, error) }
JobsServiceClient is the client API for JobsService 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 NewJobsServiceClient ¶
func NewJobsServiceClient(cc grpc.ClientConnInterface) JobsServiceClient
type JobsServiceServer ¶
type JobsServiceServer interface { CreateJob(context.Context, *CreateJobRequest) (*CreateJobResponse, error) GetJob(context.Context, *GetJobRequest) (*Job, error) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) UpdateJob(context.Context, *UpdateJobRequest) (*UpdateJobResponse, error) DeleteJob(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error) // contains filtered or unexported methods }
JobsServiceServer is the server API for JobsService service. All implementations must embed UnimplementedJobsServiceServer for forward compatibility
type ListJobsRequest ¶
type ListJobsRequest struct { Page int64 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"` Size int64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"` // contains filtered or unexported fields }
func (*ListJobsRequest) Descriptor
deprecated
func (*ListJobsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.
func (*ListJobsRequest) GetPage ¶
func (x *ListJobsRequest) GetPage() int64
func (*ListJobsRequest) GetSize ¶
func (x *ListJobsRequest) GetSize() int64
func (*ListJobsRequest) ProtoMessage ¶
func (*ListJobsRequest) ProtoMessage()
func (*ListJobsRequest) ProtoReflect ¶
func (x *ListJobsRequest) ProtoReflect() protoreflect.Message
func (*ListJobsRequest) Reset ¶
func (x *ListJobsRequest) Reset()
func (*ListJobsRequest) String ¶
func (x *ListJobsRequest) String() string
type ListJobsResponse ¶
type ListJobsResponse struct { TotalCount int64 `protobuf:"varint,1,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"` TotalPages int64 `protobuf:"varint,2,opt,name=total_pages,json=totalPages,proto3" json:"total_pages,omitempty"` Page int64 `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"` Size int64 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"` HasMore bool `protobuf:"varint,5,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"` Jobs []*Job `protobuf:"bytes,6,rep,name=jobs,proto3" json:"jobs,omitempty"` // contains filtered or unexported fields }
func (*ListJobsResponse) Descriptor
deprecated
func (*ListJobsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.
func (*ListJobsResponse) GetHasMore ¶
func (x *ListJobsResponse) GetHasMore() bool
func (*ListJobsResponse) GetJobs ¶
func (x *ListJobsResponse) GetJobs() []*Job
func (*ListJobsResponse) GetPage ¶
func (x *ListJobsResponse) GetPage() int64
func (*ListJobsResponse) GetSize ¶
func (x *ListJobsResponse) GetSize() int64
func (*ListJobsResponse) GetTotalCount ¶
func (x *ListJobsResponse) GetTotalCount() int64
func (*ListJobsResponse) GetTotalPages ¶
func (x *ListJobsResponse) GetTotalPages() int64
func (*ListJobsResponse) ProtoMessage ¶
func (*ListJobsResponse) ProtoMessage()
func (*ListJobsResponse) ProtoReflect ¶
func (x *ListJobsResponse) ProtoReflect() protoreflect.Message
func (*ListJobsResponse) Reset ¶
func (x *ListJobsResponse) Reset()
func (*ListJobsResponse) String ¶
func (x *ListJobsResponse) String() string
type UnimplementedJobsServiceServer ¶
type UnimplementedJobsServiceServer struct { }
UnimplementedJobsServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedJobsServiceServer) CreateJob ¶
func (UnimplementedJobsServiceServer) CreateJob(context.Context, *CreateJobRequest) (*CreateJobResponse, error)
func (UnimplementedJobsServiceServer) DeleteJob ¶
func (UnimplementedJobsServiceServer) DeleteJob(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error)
func (UnimplementedJobsServiceServer) GetJob ¶
func (UnimplementedJobsServiceServer) GetJob(context.Context, *GetJobRequest) (*Job, error)
func (UnimplementedJobsServiceServer) ListJobs ¶
func (UnimplementedJobsServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
func (UnimplementedJobsServiceServer) UpdateJob ¶
func (UnimplementedJobsServiceServer) UpdateJob(context.Context, *UpdateJobRequest) (*UpdateJobResponse, error)
type UnsafeJobsServiceServer ¶
type UnsafeJobsServiceServer interface {
// contains filtered or unexported methods
}
UnsafeJobsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JobsServiceServer will result in compilation errors.
type UpdateJobRequest ¶
type UpdateJobRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` ScheduleTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=schedule_time,json=scheduleTime,proto3" json:"schedule_time,omitempty"` JobType JobType `protobuf:"varint,5,opt,name=job_type,json=jobType,proto3,enum=proto.JobType" json:"job_type,omitempty"` JobData string `protobuf:"bytes,6,opt,name=job_data,json=jobData,proto3" json:"job_data,omitempty"` // contains filtered or unexported fields }
func (*UpdateJobRequest) Descriptor
deprecated
func (*UpdateJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateJobRequest.ProtoReflect.Descriptor instead.
func (*UpdateJobRequest) GetDescription ¶
func (x *UpdateJobRequest) GetDescription() string
func (*UpdateJobRequest) GetId ¶
func (x *UpdateJobRequest) GetId() string
func (*UpdateJobRequest) GetJobData ¶
func (x *UpdateJobRequest) GetJobData() string
func (*UpdateJobRequest) GetJobType ¶
func (x *UpdateJobRequest) GetJobType() JobType
func (*UpdateJobRequest) GetName ¶
func (x *UpdateJobRequest) GetName() string
func (*UpdateJobRequest) GetScheduleTime ¶
func (x *UpdateJobRequest) GetScheduleTime() *timestamppb.Timestamp
func (*UpdateJobRequest) ProtoMessage ¶
func (*UpdateJobRequest) ProtoMessage()
func (*UpdateJobRequest) ProtoReflect ¶
func (x *UpdateJobRequest) ProtoReflect() protoreflect.Message
func (*UpdateJobRequest) Reset ¶
func (x *UpdateJobRequest) Reset()
func (*UpdateJobRequest) String ¶
func (x *UpdateJobRequest) String() string
type UpdateJobResponse ¶
type UpdateJobResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*UpdateJobResponse) Descriptor
deprecated
func (*UpdateJobResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateJobResponse.ProtoReflect.Descriptor instead.
func (*UpdateJobResponse) GetMessage ¶
func (x *UpdateJobResponse) GetMessage() string
func (*UpdateJobResponse) ProtoMessage ¶
func (*UpdateJobResponse) ProtoMessage()
func (*UpdateJobResponse) ProtoReflect ¶
func (x *UpdateJobResponse) ProtoReflect() protoreflect.Message
func (*UpdateJobResponse) Reset ¶
func (x *UpdateJobResponse) Reset()
func (*UpdateJobResponse) String ¶
func (x *UpdateJobResponse) String() string