pb

package
v0.8.7 Latest Latest
Warning

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

 Go to latest Published: May 2, 2022 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_internal_handler_jobhdl_protos_job_request_proto protoreflect.FileDescriptor
View Source 
var File_internal_handler_jobhdl_protos_job_response_proto protoreflect.FileDescriptor
View Source 
var File_internal_handler_jobhdl_protos_job_service_proto protoreflect.FileDescriptor
View Source 
var Job_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "job.Job",
	HandlerType: (*JobServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _Job_Create_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _Job_Get_Handler,
		},
		{
			MethodName: "GetJobs",
			Handler:    _Job_GetJobs_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _Job_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Job_Delete_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/handler/jobhdl/protos/job_service.proto",
}

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

Functions

func RegisterJobServer 

func RegisterJobServer(s grpc.ServiceRegistrar, srv JobServer)

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"`
	TaskName    string           `protobuf:"bytes,3,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	Timeout     int32            `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	TaskParams  *structpb.Struct `protobuf:"bytes,5,opt,name=task_params,json=taskParams,proto3" json:"task_params,omitempty"`
	RunAt       string           `protobuf:"bytes,6,opt,name=run_at,json=runAt,proto3" json:"run_at,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) GetName 

func (x *CreateJobRequest) GetName() string

func (*CreateJobRequest) GetRunAt 

func (x *CreateJobRequest) GetRunAt() string

func (*CreateJobRequest) GetTaskName 

func (x *CreateJobRequest) GetTaskName() string

func (*CreateJobRequest) GetTaskParams 

func (x *CreateJobRequest) GetTaskParams() *structpb.Struct

func (*CreateJobRequest) GetTimeout 

func (x *CreateJobRequest) GetTimeout() int32

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"`
	Name        string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	TaskName    string                 `protobuf:"bytes,3,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	TaskParams  *structpb.Struct       `protobuf:"bytes,4,opt,name=task_params,json=taskParams,proto3" json:"task_params,omitempty"`
	Timeout     int32                  `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Description string                 `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	Status      int32                  `protobuf:"varint,7,opt,name=status,proto3" json:"status,omitempty"`
	RunAt       *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=run_at,json=runAt,proto3" json:"run_at,omitempty"`
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateJobResponse) Descriptor deprecated 

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

Deprecated: Use CreateJobResponse.ProtoReflect.Descriptor instead.

func (*CreateJobResponse) GetCreatedAt 

func (x *CreateJobResponse) GetCreatedAt() *timestamppb.Timestamp

func (*CreateJobResponse) GetDescription 

func (x *CreateJobResponse) GetDescription() string

func (*CreateJobResponse) GetId 

func (x *CreateJobResponse) GetId() string

func (*CreateJobResponse) GetName 

func (x *CreateJobResponse) GetName() string

func (*CreateJobResponse) GetRunAt 

func (x *CreateJobResponse) GetRunAt() *timestamppb.Timestamp

func (*CreateJobResponse) GetStatus 

func (x *CreateJobResponse) GetStatus() int32

func (*CreateJobResponse) GetTaskName 

func (x *CreateJobResponse) GetTaskName() string

func (*CreateJobResponse) GetTaskParams 

func (x *CreateJobResponse) GetTaskParams() *structpb.Struct

func (*CreateJobResponse) GetTimeout 

func (x *CreateJobResponse) GetTimeout() int32

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 {
	// contains filtered or unexported fields
}

Empty response

func (*DeleteJobResponse) Descriptor deprecated 

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

Deprecated: Use DeleteJobResponse.ProtoReflect.Descriptor instead.

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 GetJobResponse 

type GetJobResponse 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"`
	TaskName      string                 `protobuf:"bytes,3,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	TaskParams    *structpb.Struct       `protobuf:"bytes,4,opt,name=task_params,json=taskParams,proto3" json:"task_params,omitempty"`
	Timeout       int32                  `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Description   string                 `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	Status        int32                  `protobuf:"varint,7,opt,name=status,proto3" json:"status,omitempty"`
	FailureReason string                 `protobuf:"bytes,8,opt,name=failure_reason,json=failureReason,proto3" json:"failure_reason,omitempty"`
	RunAt         *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=run_at,json=runAt,proto3" json:"run_at,omitempty"`
	ScheduledAt   *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	StartedAt     *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	CompletedAt   *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=completed_at,json=completedAt,proto3" json:"completed_at,omitempty"`
	Duration      int64                  `protobuf:"varint,14,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobResponse) Descriptor deprecated 

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

Deprecated: Use GetJobResponse.ProtoReflect.Descriptor instead.

func (*GetJobResponse) GetCompletedAt 

func (x *GetJobResponse) GetCompletedAt() *timestamppb.Timestamp

func (*GetJobResponse) GetCreatedAt 

func (x *GetJobResponse) GetCreatedAt() *timestamppb.Timestamp

func (*GetJobResponse) GetDescription 

func (x *GetJobResponse) GetDescription() string

func (*GetJobResponse) GetDuration 

func (x *GetJobResponse) GetDuration() int64

func (*GetJobResponse) GetFailureReason 

func (x *GetJobResponse) GetFailureReason() string

func (*GetJobResponse) GetId 

func (x *GetJobResponse) GetId() string

func (*GetJobResponse) GetName 

func (x *GetJobResponse) GetName() string

func (*GetJobResponse) GetRunAt 

func (x *GetJobResponse) GetRunAt() *timestamppb.Timestamp

func (*GetJobResponse) GetScheduledAt 

func (x *GetJobResponse) GetScheduledAt() *timestamppb.Timestamp

func (*GetJobResponse) GetStartedAt 

func (x *GetJobResponse) GetStartedAt() *timestamppb.Timestamp

func (*GetJobResponse) GetStatus 

func (x *GetJobResponse) GetStatus() int32

func (*GetJobResponse) GetTaskName 

func (x *GetJobResponse) GetTaskName() string

func (*GetJobResponse) GetTaskParams 

func (x *GetJobResponse) GetTaskParams() *structpb.Struct

func (*GetJobResponse) GetTimeout 

func (x *GetJobResponse) GetTimeout() int32

func (*GetJobResponse) ProtoMessage 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) ProtoReflect 

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

func (*GetJobResponse) Reset 

func (x *GetJobResponse) Reset()

func (*GetJobResponse) String 

func (x *GetJobResponse) String() string

type GetJobsRequest 

type GetJobsRequest struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobsRequest) Descriptor deprecated 

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

Deprecated: Use GetJobsRequest.ProtoReflect.Descriptor instead.

func (*GetJobsRequest) GetStatus 

func (x *GetJobsRequest) GetStatus() string

func (*GetJobsRequest) ProtoMessage 

func (*GetJobsRequest) ProtoMessage()

func (*GetJobsRequest) ProtoReflect 

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

func (*GetJobsRequest) Reset 

func (x *GetJobsRequest) Reset()

func (*GetJobsRequest) String 

func (x *GetJobsRequest) String() string

type GetJobsResponse 

type GetJobsResponse struct {
	Jobs []*GetJobResponse `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobsResponse) Descriptor deprecated 

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

Deprecated: Use GetJobsResponse.ProtoReflect.Descriptor instead.

func (*GetJobsResponse) GetJobs 

func (x *GetJobsResponse) GetJobs() []*GetJobResponse

func (*GetJobsResponse) ProtoMessage 

func (*GetJobsResponse) ProtoMessage()

func (*GetJobsResponse) ProtoReflect 

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

func (*GetJobsResponse) Reset 

func (x *GetJobsResponse) Reset()

func (*GetJobsResponse) String 

func (x *GetJobsResponse) String() string

type JobClient 

type JobClient interface {
	Create(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*CreateJobResponse, error)
	Get(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)
	GetJobs(ctx context.Context, in *GetJobsRequest, opts ...grpc.CallOption) (*GetJobsResponse, error)
	Update(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*UpdateJobResponse, error)
	Delete(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*DeleteJobResponse, error)
}

JobClient is the client API for Job 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 NewJobClient 

func NewJobClient(cc grpc.ClientConnInterface) JobClient

type JobServer 

type JobServer interface {
	Create(context.Context, *CreateJobRequest) (*CreateJobResponse, error)
	Get(context.Context, *GetJobRequest) (*GetJobResponse, error)
	GetJobs(context.Context, *GetJobsRequest) (*GetJobsResponse, error)
	Update(context.Context, *UpdateJobRequest) (*UpdateJobResponse, error)
	Delete(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error)
	// contains filtered or unexported methods
}

JobServer is the server API for Job service. All implementations must embed UnimplementedJobServer for forward compatibility

type UnimplementedJobServer 

type UnimplementedJobServer struct {
}

UnimplementedJobServer must be embedded to have forward compatible implementations.

func (UnimplementedJobServer) Create 

func (UnimplementedJobServer) Create(context.Context, *CreateJobRequest) (*CreateJobResponse, error)

func (UnimplementedJobServer) Delete 

func (UnimplementedJobServer) Delete(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error)

func (UnimplementedJobServer) Get 

func (UnimplementedJobServer) Get(context.Context, *GetJobRequest) (*GetJobResponse, error)

func (UnimplementedJobServer) GetJobs 

func (UnimplementedJobServer) GetJobs(context.Context, *GetJobsRequest) (*GetJobsResponse, error)

func (UnimplementedJobServer) Update 

func (UnimplementedJobServer) Update(context.Context, *UpdateJobRequest) (*UpdateJobResponse, error)

type UnsafeJobServer 

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

UnsafeJobServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JobServer 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"`
	// 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) GetName 

func (x *UpdateJobRequest) GetName() string

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 {
	// contains filtered or unexported fields
}

Empty response

func (*UpdateJobResponse) Descriptor deprecated 

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

Deprecated: Use UpdateJobResponse.ProtoReflect.Descriptor instead.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.