v1

package
v0.0.0-...-0ac81a3 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EboolkiqSvc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "daangn.eboolkiq.v1.EboolkiqSvc",
	HandlerType: (*EboolkiqSvcServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateQueue",
			Handler:    _EboolkiqSvc_CreateQueue_Handler,
		},
		{
			MethodName: "GetQueue",
			Handler:    _EboolkiqSvc_GetQueue_Handler,
		},
		{
			MethodName: "DeleteQueue",
			Handler:    _EboolkiqSvc_DeleteQueue_Handler,
		},
		{
			MethodName: "FlushQueue",
			Handler:    _EboolkiqSvc_FlushQueue_Handler,
		},
		{
			MethodName: "CreateTask",
			Handler:    _EboolkiqSvc_CreateTask_Handler,
		},
		{
			MethodName: "GetTask",
			Handler:    _EboolkiqSvc_GetTask_Handler,
		},
		{
			MethodName: "FinishTask",
			Handler:    _EboolkiqSvc_FinishTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "daangn/eboolkiq/v1/eboolkiq_svc.proto",
}

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

View Source 
var File_daangn_eboolkiq_v1_eboolkiq_svc_proto protoreflect.FileDescriptor

Functions

func RegisterEboolkiqSvcServer 

func RegisterEboolkiqSvcServer(s grpc.ServiceRegistrar, srv EboolkiqSvcServer)

Types

type CreateQueueReq 

type CreateQueueReq struct {
	Queue *pb.Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateQueueReq) CheckValid 

func (x *CreateQueueReq) CheckValid() error

func (*CreateQueueReq) Descriptor deprecated 

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

Deprecated: Use CreateQueueReq.ProtoReflect.Descriptor instead.

func (*CreateQueueReq) GetQueue 

func (x *CreateQueueReq) GetQueue() *pb.Queue

func (*CreateQueueReq) IsValid 

func (x *CreateQueueReq) IsValid() bool

func (*CreateQueueReq) ProtoMessage 

func (*CreateQueueReq) ProtoMessage()

func (*CreateQueueReq) ProtoReflect 

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

func (*CreateQueueReq) Reset 

func (x *CreateQueueReq) Reset()

func (*CreateQueueReq) String 

func (x *CreateQueueReq) String() string

type CreateTaskReq 

type CreateTaskReq struct {
	Queue *pb.Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	Task  *pb.Task  `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTaskReq) CheckValid 

func (x *CreateTaskReq) CheckValid() error

func (*CreateTaskReq) Descriptor deprecated 

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

Deprecated: Use CreateTaskReq.ProtoReflect.Descriptor instead.

func (*CreateTaskReq) GetQueue 

func (x *CreateTaskReq) GetQueue() *pb.Queue

func (*CreateTaskReq) GetTask 

func (x *CreateTaskReq) GetTask() *pb.Task

func (*CreateTaskReq) IsValid 

func (x *CreateTaskReq) IsValid() bool

func (*CreateTaskReq) ProtoMessage 

func (*CreateTaskReq) ProtoMessage()

func (*CreateTaskReq) ProtoReflect 

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

func (*CreateTaskReq) Reset 

func (x *CreateTaskReq) Reset()

func (*CreateTaskReq) String 

func (x *CreateTaskReq) String() string

type DeleteQueueReq 

type DeleteQueueReq struct {
	Queue *pb.Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteQueueReq) CheckValid 

func (x *DeleteQueueReq) CheckValid() error

func (*DeleteQueueReq) Descriptor deprecated 

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

Deprecated: Use DeleteQueueReq.ProtoReflect.Descriptor instead.

func (*DeleteQueueReq) GetQueue 

func (x *DeleteQueueReq) GetQueue() *pb.Queue

func (*DeleteQueueReq) IsValid 

func (x *DeleteQueueReq) IsValid() bool

func (*DeleteQueueReq) ProtoMessage 

func (*DeleteQueueReq) ProtoMessage()

func (*DeleteQueueReq) ProtoReflect 

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

func (*DeleteQueueReq) Reset 

func (x *DeleteQueueReq) Reset()

func (*DeleteQueueReq) String 

func (x *DeleteQueueReq) String() string

type EboolkiqSvcClient 

type EboolkiqSvcClient interface {
	// CreateQueue creates a queue on the eboolkiq server.
	CreateQueue(ctx context.Context, in *CreateQueueReq, opts ...grpc.CallOption) (*pb.Queue, error)
	// GetQueue gets queue from the eboolkiq server.
	GetQueue(ctx context.Context, in *GetQueueReq, opts ...grpc.CallOption) (*pb.Queue, error)
	// DeleteQueue deletes the queue on the eboolkiq server.
	DeleteQueue(ctx context.Context, in *DeleteQueueReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// FlushQueue deletes all tasks from the queue.
	FlushQueue(ctx context.Context, in *FlushQueueReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// CreateTask creates a task in the queue.
	CreateTask(ctx context.Context, in *CreateTaskReq, opts ...grpc.CallOption) (*pb.Task, error)
	// GetTask gets a task from the queue.
	GetTask(ctx context.Context, in *GetTaskReq, opts ...grpc.CallOption) (*pb.Task, error)
	// FinishTask set task as finished.
	FinishTask(ctx context.Context, in *FinishTaskReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

EboolkiqSvcClient is the client API for EboolkiqSvc 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 NewEboolkiqSvcClient 

func NewEboolkiqSvcClient(cc grpc.ClientConnInterface) EboolkiqSvcClient

type EboolkiqSvcServer 

type EboolkiqSvcServer interface {
	// CreateQueue creates a queue on the eboolkiq server.
	CreateQueue(context.Context, *CreateQueueReq) (*pb.Queue, error)
	// GetQueue gets queue from the eboolkiq server.
	GetQueue(context.Context, *GetQueueReq) (*pb.Queue, error)
	// DeleteQueue deletes the queue on the eboolkiq server.
	DeleteQueue(context.Context, *DeleteQueueReq) (*emptypb.Empty, error)
	// FlushQueue deletes all tasks from the queue.
	FlushQueue(context.Context, *FlushQueueReq) (*emptypb.Empty, error)
	// CreateTask creates a task in the queue.
	CreateTask(context.Context, *CreateTaskReq) (*pb.Task, error)
	// GetTask gets a task from the queue.
	GetTask(context.Context, *GetTaskReq) (*pb.Task, error)
	// FinishTask set task as finished.
	FinishTask(context.Context, *FinishTaskReq) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

EboolkiqSvcServer is the server API for EboolkiqSvc service. All implementations must embed UnimplementedEboolkiqSvcServer for forward compatibility

type FinishTaskReq 

type FinishTaskReq struct {
	Queue   *pb.Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	Task    *pb.Task  `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	Failed  bool      `protobuf:"varint,3,opt,name=failed,proto3" json:"failed,omitempty"`
	Message string    `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*FinishTaskReq) CheckValid 

func (x *FinishTaskReq) CheckValid() error

func (*FinishTaskReq) Descriptor deprecated 

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

Deprecated: Use FinishTaskReq.ProtoReflect.Descriptor instead.

func (*FinishTaskReq) GetFailed 

func (x *FinishTaskReq) GetFailed() bool

func (*FinishTaskReq) GetMessage 

func (x *FinishTaskReq) GetMessage() string

func (*FinishTaskReq) GetQueue 

func (x *FinishTaskReq) GetQueue() *pb.Queue

func (*FinishTaskReq) GetTask 

func (x *FinishTaskReq) GetTask() *pb.Task

func (*FinishTaskReq) IsValid 

func (x *FinishTaskReq) IsValid() bool

func (*FinishTaskReq) ProtoMessage 

func (*FinishTaskReq) ProtoMessage()

func (*FinishTaskReq) ProtoReflect 

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

func (*FinishTaskReq) Reset 

func (x *FinishTaskReq) Reset()

func (*FinishTaskReq) String 

func (x *FinishTaskReq) String() string

type FlushQueueReq 

type FlushQueueReq struct {
	Queue *pb.Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

func (*FlushQueueReq) CheckValid 

func (x *FlushQueueReq) CheckValid() error

func (*FlushQueueReq) Descriptor deprecated 

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

Deprecated: Use FlushQueueReq.ProtoReflect.Descriptor instead.

func (*FlushQueueReq) GetQueue 

func (x *FlushQueueReq) GetQueue() *pb.Queue

func (*FlushQueueReq) IsValid 

func (x *FlushQueueReq) IsValid() bool

func (*FlushQueueReq) ProtoMessage 

func (*FlushQueueReq) ProtoMessage()

func (*FlushQueueReq) ProtoReflect 

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

func (*FlushQueueReq) Reset 

func (x *FlushQueueReq) Reset()

func (*FlushQueueReq) String 

func (x *FlushQueueReq) String() string

type GetQueueReq 

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

func (*GetQueueReq) CheckValid 

func (x *GetQueueReq) CheckValid() error

func (*GetQueueReq) Descriptor deprecated 

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

Deprecated: Use GetQueueReq.ProtoReflect.Descriptor instead.

func (*GetQueueReq) GetName 

func (x *GetQueueReq) GetName() string

func (*GetQueueReq) IsValid 

func (x *GetQueueReq) IsValid() bool

func (*GetQueueReq) ProtoMessage 

func (*GetQueueReq) ProtoMessage()

func (*GetQueueReq) ProtoReflect 

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

func (*GetQueueReq) Reset 

func (x *GetQueueReq) Reset()

func (*GetQueueReq) String 

func (x *GetQueueReq) String() string

type GetTaskReq 

type GetTaskReq struct {
	Queue      *pb.Queue            `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	WaitTime   *durationpb.Duration `protobuf:"bytes,2,opt,name=wait_time,json=waitTime,proto3" json:"wait_time,omitempty"`
	AutoFinish bool                 `protobuf:"varint,3,opt,name=auto_finish,json=autoFinish,proto3" json:"auto_finish,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskReq) CheckValid 

func (x *GetTaskReq) CheckValid() error

func (*GetTaskReq) Descriptor deprecated 

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

Deprecated: Use GetTaskReq.ProtoReflect.Descriptor instead.

func (*GetTaskReq) GetAutoFinish 

func (x *GetTaskReq) GetAutoFinish() bool

func (*GetTaskReq) GetQueue 

func (x *GetTaskReq) GetQueue() *pb.Queue

func (*GetTaskReq) GetWaitTime 

func (x *GetTaskReq) GetWaitTime() *durationpb.Duration

func (*GetTaskReq) IsValid 

func (x *GetTaskReq) IsValid() bool

func (*GetTaskReq) ProtoMessage 

func (*GetTaskReq) ProtoMessage()

func (*GetTaskReq) ProtoReflect 

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

func (*GetTaskReq) Reset 

func (x *GetTaskReq) Reset()

func (*GetTaskReq) String 

func (x *GetTaskReq) String() string

type UnimplementedEboolkiqSvcServer 

type UnimplementedEboolkiqSvcServer struct {
}

UnimplementedEboolkiqSvcServer must be embedded to have forward compatible implementations.

func (UnimplementedEboolkiqSvcServer) CreateQueue 

func (UnimplementedEboolkiqSvcServer) CreateQueue(context.Context, *CreateQueueReq) (*pb.Queue, error)

func (UnimplementedEboolkiqSvcServer) CreateTask 

func (UnimplementedEboolkiqSvcServer) CreateTask(context.Context, *CreateTaskReq) (*pb.Task, error)

func (UnimplementedEboolkiqSvcServer) DeleteQueue 

func (UnimplementedEboolkiqSvcServer) DeleteQueue(context.Context, *DeleteQueueReq) (*emptypb.Empty, error)

func (UnimplementedEboolkiqSvcServer) FinishTask 

func (UnimplementedEboolkiqSvcServer) FinishTask(context.Context, *FinishTaskReq) (*emptypb.Empty, error)

func (UnimplementedEboolkiqSvcServer) FlushQueue 

func (UnimplementedEboolkiqSvcServer) FlushQueue(context.Context, *FlushQueueReq) (*emptypb.Empty, error)

func (UnimplementedEboolkiqSvcServer) GetQueue 

func (UnimplementedEboolkiqSvcServer) GetQueue(context.Context, *GetQueueReq) (*pb.Queue, error)

func (UnimplementedEboolkiqSvcServer) GetTask 

func (UnimplementedEboolkiqSvcServer) GetTask(context.Context, *GetTaskReq) (*pb.Task, error)

type UnsafeEboolkiqSvcServer 

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

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

type UpdateQueueReq 

type UpdateQueueReq struct {
	Queue *pb.Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateQueueReq) Descriptor deprecated 

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

Deprecated: Use UpdateQueueReq.ProtoReflect.Descriptor instead.

func (*UpdateQueueReq) GetQueue 

func (x *UpdateQueueReq) GetQueue() *pb.Queue

func (*UpdateQueueReq) ProtoMessage 

func (*UpdateQueueReq) ProtoMessage()

func (*UpdateQueueReq) ProtoReflect 

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

func (*UpdateQueueReq) Reset 

func (x *UpdateQueueReq) Reset()

func (*UpdateQueueReq) String 

func (x *UpdateQueueReq) 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.