Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterDOQServer(s grpc.ServiceRegistrar, srv DOQServer)
- type AckRequest
- type AckResponse
- type CreateQueueRequest
- func (*CreateQueueRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateQueueRequest) GetName() string
- func (x *CreateQueueRequest) GetType() string
- func (*CreateQueueRequest) ProtoMessage()
- func (x *CreateQueueRequest) ProtoReflect() protoreflect.Message
- func (x *CreateQueueRequest) Reset()
- func (x *CreateQueueRequest) String() string
- type CreateQueueResponse
- func (*CreateQueueResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateQueueResponse) GetSuccess() bool
- func (*CreateQueueResponse) ProtoMessage()
- func (x *CreateQueueResponse) ProtoReflect() protoreflect.Message
- func (x *CreateQueueResponse) Reset()
- func (x *CreateQueueResponse) String() string
- type DOQClient
- type DOQServer
- type DOQ_DequeueStreamClient
- type DOQ_DequeueStreamServer
- type DOQ_EnqueueStreamClient
- type DOQ_EnqueueStreamServer
- type DeleteQueueRequest
- func (*DeleteQueueRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteQueueRequest) GetName() string
- func (*DeleteQueueRequest) ProtoMessage()
- func (x *DeleteQueueRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteQueueRequest) Reset()
- func (x *DeleteQueueRequest) String() string
- type DeleteQueueResponse
- func (*DeleteQueueResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteQueueResponse) GetSuccess() bool
- func (*DeleteQueueResponse) ProtoMessage()
- func (x *DeleteQueueResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteQueueResponse) Reset()
- func (x *DeleteQueueResponse) String() string
- type DequeueRequest
- func (*DequeueRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DequeueRequest) GetAck() bool
- func (x *DequeueRequest) GetQueueName() string
- func (*DequeueRequest) ProtoMessage()
- func (x *DequeueRequest) ProtoReflect() protoreflect.Message
- func (x *DequeueRequest) Reset()
- func (x *DequeueRequest) String() string
- type DequeueResponse
- func (*DequeueResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DequeueResponse) GetContent() string
- func (x *DequeueResponse) GetGroup() string
- func (x *DequeueResponse) GetId() uint64
- func (x *DequeueResponse) GetPriority() int64
- func (x *DequeueResponse) GetQueueName() string
- func (x *DequeueResponse) GetSuccess() bool
- func (*DequeueResponse) ProtoMessage()
- func (x *DequeueResponse) ProtoReflect() protoreflect.Message
- func (x *DequeueResponse) Reset()
- func (x *DequeueResponse) String() string
- type EnqueueRequest
- func (*EnqueueRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EnqueueRequest) GetContent() string
- func (x *EnqueueRequest) GetGroup() string
- func (x *EnqueueRequest) GetPriority() int64
- func (x *EnqueueRequest) GetQueueName() string
- func (*EnqueueRequest) ProtoMessage()
- func (x *EnqueueRequest) ProtoReflect() protoreflect.Message
- func (x *EnqueueRequest) Reset()
- func (x *EnqueueRequest) String() string
- type EnqueueResponse
- func (*EnqueueResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EnqueueResponse) GetContent() string
- func (x *EnqueueResponse) GetGroup() string
- func (x *EnqueueResponse) GetId() uint64
- func (x *EnqueueResponse) GetPriority() int64
- func (x *EnqueueResponse) GetQueueName() string
- func (x *EnqueueResponse) GetSuccess() bool
- func (*EnqueueResponse) ProtoMessage()
- func (x *EnqueueResponse) ProtoReflect() protoreflect.Message
- func (x *EnqueueResponse) Reset()
- func (x *EnqueueResponse) String() string
- type NackRequest
- func (*NackRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NackRequest) GetId() uint64
- func (x *NackRequest) GetQueueName() string
- func (*NackRequest) ProtoMessage()
- func (x *NackRequest) ProtoReflect() protoreflect.Message
- func (x *NackRequest) Reset()
- func (x *NackRequest) String() string
- type NackResponse
- type UnimplementedDOQServer
- func (UnimplementedDOQServer) Ack(context.Context, *AckRequest) (*AckResponse, error)
- func (UnimplementedDOQServer) CreateQueue(context.Context, *CreateQueueRequest) (*CreateQueueResponse, error)
- func (UnimplementedDOQServer) DeleteQueue(context.Context, *DeleteQueueRequest) (*DeleteQueueResponse, error)
- func (UnimplementedDOQServer) Dequeue(context.Context, *DequeueRequest) (*DequeueResponse, error)
- func (UnimplementedDOQServer) DequeueStream(*DequeueRequest, DOQ_DequeueStreamServer) error
- func (UnimplementedDOQServer) Enqueue(context.Context, *EnqueueRequest) (*EnqueueResponse, error)
- func (UnimplementedDOQServer) EnqueueStream(DOQ_EnqueueStreamServer) error
- func (UnimplementedDOQServer) Nack(context.Context, *NackRequest) (*NackResponse, error)
- func (UnimplementedDOQServer) UpdatePriority(context.Context, *UpdatePriorityRequest) (*UpdatePriorityResponse, error)
- type UnsafeDOQServer
- type UpdatePriorityRequest
- func (*UpdatePriorityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdatePriorityRequest) GetId() uint64
- func (x *UpdatePriorityRequest) GetPriority() int64
- func (x *UpdatePriorityRequest) GetQueueName() string
- func (*UpdatePriorityRequest) ProtoMessage()
- func (x *UpdatePriorityRequest) ProtoReflect() protoreflect.Message
- func (x *UpdatePriorityRequest) Reset()
- func (x *UpdatePriorityRequest) String() string
- type UpdatePriorityResponse
- func (*UpdatePriorityResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdatePriorityResponse) GetSuccess() bool
- func (*UpdatePriorityResponse) ProtoMessage()
- func (x *UpdatePriorityResponse) ProtoReflect() protoreflect.Message
- func (x *UpdatePriorityResponse) Reset()
- func (x *UpdatePriorityResponse) String() string
Constants ¶
const ( DOQ_CreateQueue_FullMethodName = "/queue.DOQ/CreateQueue" DOQ_DeleteQueue_FullMethodName = "/queue.DOQ/DeleteQueue" DOQ_Enqueue_FullMethodName = "/queue.DOQ/Enqueue" DOQ_EnqueueStream_FullMethodName = "/queue.DOQ/EnqueueStream" DOQ_Dequeue_FullMethodName = "/queue.DOQ/Dequeue" DOQ_DequeueStream_FullMethodName = "/queue.DOQ/DequeueStream" DOQ_Ack_FullMethodName = "/queue.DOQ/Ack" DOQ_Nack_FullMethodName = "/queue.DOQ/Nack" DOQ_UpdatePriority_FullMethodName = "/queue.DOQ/UpdatePriority" )
Variables ¶
var DOQ_ServiceDesc = grpc.ServiceDesc{ ServiceName: "queue.DOQ", HandlerType: (*DOQServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateQueue", Handler: _DOQ_CreateQueue_Handler, }, { MethodName: "DeleteQueue", Handler: _DOQ_DeleteQueue_Handler, }, { MethodName: "Enqueue", Handler: _DOQ_Enqueue_Handler, }, { MethodName: "Dequeue", Handler: _DOQ_Dequeue_Handler, }, { MethodName: "Ack", Handler: _DOQ_Ack_Handler, }, { MethodName: "Nack", Handler: _DOQ_Nack_Handler, }, { MethodName: "UpdatePriority", Handler: _DOQ_UpdatePriority_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "EnqueueStream", Handler: _DOQ_EnqueueStream_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "DequeueStream", Handler: _DOQ_DequeueStream_Handler, ServerStreams: true, }, }, Metadata: "pkg/proto/doq.proto", }
DOQ_ServiceDesc is the grpc.ServiceDesc for DOQ service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_pkg_proto_doq_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDOQServer ¶
func RegisterDOQServer(s grpc.ServiceRegistrar, srv DOQServer)
Types ¶
type AckRequest ¶ added in v0.2.4
type AckRequest struct { QueueName string `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*AckRequest) Descriptor
deprecated
added in
v0.2.4
func (*AckRequest) Descriptor() ([]byte, []int)
Deprecated: Use AckRequest.ProtoReflect.Descriptor instead.
func (*AckRequest) GetId ¶ added in v0.2.4
func (x *AckRequest) GetId() uint64
func (*AckRequest) GetQueueName ¶ added in v0.2.4
func (x *AckRequest) GetQueueName() string
func (*AckRequest) ProtoMessage ¶ added in v0.2.4
func (*AckRequest) ProtoMessage()
func (*AckRequest) ProtoReflect ¶ added in v0.2.4
func (x *AckRequest) ProtoReflect() protoreflect.Message
func (*AckRequest) Reset ¶ added in v0.2.4
func (x *AckRequest) Reset()
func (*AckRequest) String ¶ added in v0.2.4
func (x *AckRequest) String() string
type AckResponse ¶ added in v0.2.4
type AckResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
func (*AckResponse) Descriptor
deprecated
added in
v0.2.4
func (*AckResponse) Descriptor() ([]byte, []int)
Deprecated: Use AckResponse.ProtoReflect.Descriptor instead.
func (*AckResponse) GetSuccess ¶ added in v0.2.4
func (x *AckResponse) GetSuccess() bool
func (*AckResponse) ProtoMessage ¶ added in v0.2.4
func (*AckResponse) ProtoMessage()
func (*AckResponse) ProtoReflect ¶ added in v0.2.4
func (x *AckResponse) ProtoReflect() protoreflect.Message
func (*AckResponse) Reset ¶ added in v0.2.4
func (x *AckResponse) Reset()
func (*AckResponse) String ¶ added in v0.2.4
func (x *AckResponse) String() string
type CreateQueueRequest ¶
type CreateQueueRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*CreateQueueRequest) Descriptor
deprecated
func (*CreateQueueRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateQueueRequest.ProtoReflect.Descriptor instead.
func (*CreateQueueRequest) GetName ¶
func (x *CreateQueueRequest) GetName() string
func (*CreateQueueRequest) GetType ¶
func (x *CreateQueueRequest) GetType() string
func (*CreateQueueRequest) ProtoMessage ¶
func (*CreateQueueRequest) ProtoMessage()
func (*CreateQueueRequest) ProtoReflect ¶
func (x *CreateQueueRequest) ProtoReflect() protoreflect.Message
func (*CreateQueueRequest) Reset ¶
func (x *CreateQueueRequest) Reset()
func (*CreateQueueRequest) String ¶
func (x *CreateQueueRequest) String() string
type CreateQueueResponse ¶
type CreateQueueResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
func (*CreateQueueResponse) Descriptor
deprecated
func (*CreateQueueResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateQueueResponse.ProtoReflect.Descriptor instead.
func (*CreateQueueResponse) GetSuccess ¶
func (x *CreateQueueResponse) GetSuccess() bool
func (*CreateQueueResponse) ProtoMessage ¶
func (*CreateQueueResponse) ProtoMessage()
func (*CreateQueueResponse) ProtoReflect ¶
func (x *CreateQueueResponse) ProtoReflect() protoreflect.Message
func (*CreateQueueResponse) Reset ¶
func (x *CreateQueueResponse) Reset()
func (*CreateQueueResponse) String ¶
func (x *CreateQueueResponse) String() string
type DOQClient ¶
type DOQClient interface { CreateQueue(ctx context.Context, in *CreateQueueRequest, opts ...grpc.CallOption) (*CreateQueueResponse, error) DeleteQueue(ctx context.Context, in *DeleteQueueRequest, opts ...grpc.CallOption) (*DeleteQueueResponse, error) Enqueue(ctx context.Context, in *EnqueueRequest, opts ...grpc.CallOption) (*EnqueueResponse, error) EnqueueStream(ctx context.Context, opts ...grpc.CallOption) (DOQ_EnqueueStreamClient, error) Dequeue(ctx context.Context, in *DequeueRequest, opts ...grpc.CallOption) (*DequeueResponse, error) DequeueStream(ctx context.Context, in *DequeueRequest, opts ...grpc.CallOption) (DOQ_DequeueStreamClient, error) Ack(ctx context.Context, in *AckRequest, opts ...grpc.CallOption) (*AckResponse, error) Nack(ctx context.Context, in *NackRequest, opts ...grpc.CallOption) (*NackResponse, error) UpdatePriority(ctx context.Context, in *UpdatePriorityRequest, opts ...grpc.CallOption) (*UpdatePriorityResponse, error) }
DOQClient is the client API for DOQ 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 NewDOQClient ¶
func NewDOQClient(cc grpc.ClientConnInterface) DOQClient
type DOQServer ¶
type DOQServer interface { CreateQueue(context.Context, *CreateQueueRequest) (*CreateQueueResponse, error) DeleteQueue(context.Context, *DeleteQueueRequest) (*DeleteQueueResponse, error) Enqueue(context.Context, *EnqueueRequest) (*EnqueueResponse, error) EnqueueStream(DOQ_EnqueueStreamServer) error Dequeue(context.Context, *DequeueRequest) (*DequeueResponse, error) DequeueStream(*DequeueRequest, DOQ_DequeueStreamServer) error Ack(context.Context, *AckRequest) (*AckResponse, error) Nack(context.Context, *NackRequest) (*NackResponse, error) UpdatePriority(context.Context, *UpdatePriorityRequest) (*UpdatePriorityResponse, error) // contains filtered or unexported methods }
DOQServer is the server API for DOQ service. All implementations must embed UnimplementedDOQServer for forward compatibility
type DOQ_DequeueStreamClient ¶
type DOQ_DequeueStreamClient interface { Recv() (*DequeueResponse, error) grpc.ClientStream }
type DOQ_DequeueStreamServer ¶
type DOQ_DequeueStreamServer interface { Send(*DequeueResponse) error grpc.ServerStream }
type DOQ_EnqueueStreamClient ¶
type DOQ_EnqueueStreamClient interface { Send(*EnqueueRequest) error Recv() (*EnqueueResponse, error) grpc.ClientStream }
type DOQ_EnqueueStreamServer ¶
type DOQ_EnqueueStreamServer interface { Send(*EnqueueResponse) error Recv() (*EnqueueRequest, error) grpc.ServerStream }
type DeleteQueueRequest ¶
type DeleteQueueRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*DeleteQueueRequest) Descriptor
deprecated
func (*DeleteQueueRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteQueueRequest.ProtoReflect.Descriptor instead.
func (*DeleteQueueRequest) GetName ¶
func (x *DeleteQueueRequest) GetName() string
func (*DeleteQueueRequest) ProtoMessage ¶
func (*DeleteQueueRequest) ProtoMessage()
func (*DeleteQueueRequest) ProtoReflect ¶
func (x *DeleteQueueRequest) ProtoReflect() protoreflect.Message
func (*DeleteQueueRequest) Reset ¶
func (x *DeleteQueueRequest) Reset()
func (*DeleteQueueRequest) String ¶
func (x *DeleteQueueRequest) String() string
type DeleteQueueResponse ¶
type DeleteQueueResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
func (*DeleteQueueResponse) Descriptor
deprecated
func (*DeleteQueueResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteQueueResponse.ProtoReflect.Descriptor instead.
func (*DeleteQueueResponse) GetSuccess ¶
func (x *DeleteQueueResponse) GetSuccess() bool
func (*DeleteQueueResponse) ProtoMessage ¶
func (*DeleteQueueResponse) ProtoMessage()
func (*DeleteQueueResponse) ProtoReflect ¶
func (x *DeleteQueueResponse) ProtoReflect() protoreflect.Message
func (*DeleteQueueResponse) Reset ¶
func (x *DeleteQueueResponse) Reset()
func (*DeleteQueueResponse) String ¶
func (x *DeleteQueueResponse) String() string
type DequeueRequest ¶
type DequeueRequest struct { QueueName string `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"` Ack bool `protobuf:"varint,2,opt,name=ack,proto3" json:"ack,omitempty"` // contains filtered or unexported fields }
func (*DequeueRequest) Descriptor
deprecated
func (*DequeueRequest) Descriptor() ([]byte, []int)
Deprecated: Use DequeueRequest.ProtoReflect.Descriptor instead.
func (*DequeueRequest) GetAck ¶
func (x *DequeueRequest) GetAck() bool
func (*DequeueRequest) GetQueueName ¶
func (x *DequeueRequest) GetQueueName() string
func (*DequeueRequest) ProtoMessage ¶
func (*DequeueRequest) ProtoMessage()
func (*DequeueRequest) ProtoReflect ¶
func (x *DequeueRequest) ProtoReflect() protoreflect.Message
func (*DequeueRequest) Reset ¶
func (x *DequeueRequest) Reset()
func (*DequeueRequest) String ¶
func (x *DequeueRequest) String() string
type DequeueResponse ¶
type DequeueResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` QueueName string `protobuf:"bytes,2,opt,name=queueName,proto3" json:"queueName,omitempty"` Id uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"` Group string `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"` Priority int64 `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"` Content string `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*DequeueResponse) Descriptor
deprecated
func (*DequeueResponse) Descriptor() ([]byte, []int)
Deprecated: Use DequeueResponse.ProtoReflect.Descriptor instead.
func (*DequeueResponse) GetContent ¶
func (x *DequeueResponse) GetContent() string
func (*DequeueResponse) GetGroup ¶
func (x *DequeueResponse) GetGroup() string
func (*DequeueResponse) GetId ¶
func (x *DequeueResponse) GetId() uint64
func (*DequeueResponse) GetPriority ¶
func (x *DequeueResponse) GetPriority() int64
func (*DequeueResponse) GetQueueName ¶
func (x *DequeueResponse) GetQueueName() string
func (*DequeueResponse) GetSuccess ¶
func (x *DequeueResponse) GetSuccess() bool
func (*DequeueResponse) ProtoMessage ¶
func (*DequeueResponse) ProtoMessage()
func (*DequeueResponse) ProtoReflect ¶
func (x *DequeueResponse) ProtoReflect() protoreflect.Message
func (*DequeueResponse) Reset ¶
func (x *DequeueResponse) Reset()
func (*DequeueResponse) String ¶
func (x *DequeueResponse) String() string
type EnqueueRequest ¶
type EnqueueRequest struct { QueueName string `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"` Group string `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"` Priority int64 `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"` Content string `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*EnqueueRequest) Descriptor
deprecated
func (*EnqueueRequest) Descriptor() ([]byte, []int)
Deprecated: Use EnqueueRequest.ProtoReflect.Descriptor instead.
func (*EnqueueRequest) GetContent ¶
func (x *EnqueueRequest) GetContent() string
func (*EnqueueRequest) GetGroup ¶
func (x *EnqueueRequest) GetGroup() string
func (*EnqueueRequest) GetPriority ¶
func (x *EnqueueRequest) GetPriority() int64
func (*EnqueueRequest) GetQueueName ¶
func (x *EnqueueRequest) GetQueueName() string
func (*EnqueueRequest) ProtoMessage ¶
func (*EnqueueRequest) ProtoMessage()
func (*EnqueueRequest) ProtoReflect ¶
func (x *EnqueueRequest) ProtoReflect() protoreflect.Message
func (*EnqueueRequest) Reset ¶
func (x *EnqueueRequest) Reset()
func (*EnqueueRequest) String ¶
func (x *EnqueueRequest) String() string
type EnqueueResponse ¶
type EnqueueResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` QueueName string `protobuf:"bytes,2,opt,name=queueName,proto3" json:"queueName,omitempty"` Id uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"` Group string `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"` Priority int64 `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"` Content string `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*EnqueueResponse) Descriptor
deprecated
func (*EnqueueResponse) Descriptor() ([]byte, []int)
Deprecated: Use EnqueueResponse.ProtoReflect.Descriptor instead.
func (*EnqueueResponse) GetContent ¶
func (x *EnqueueResponse) GetContent() string
func (*EnqueueResponse) GetGroup ¶
func (x *EnqueueResponse) GetGroup() string
func (*EnqueueResponse) GetId ¶
func (x *EnqueueResponse) GetId() uint64
func (*EnqueueResponse) GetPriority ¶
func (x *EnqueueResponse) GetPriority() int64
func (*EnqueueResponse) GetQueueName ¶
func (x *EnqueueResponse) GetQueueName() string
func (*EnqueueResponse) GetSuccess ¶
func (x *EnqueueResponse) GetSuccess() bool
func (*EnqueueResponse) ProtoMessage ¶
func (*EnqueueResponse) ProtoMessage()
func (*EnqueueResponse) ProtoReflect ¶
func (x *EnqueueResponse) ProtoReflect() protoreflect.Message
func (*EnqueueResponse) Reset ¶
func (x *EnqueueResponse) Reset()
func (*EnqueueResponse) String ¶
func (x *EnqueueResponse) String() string
type NackRequest ¶ added in v0.2.4
type NackRequest struct { QueueName string `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*NackRequest) Descriptor
deprecated
added in
v0.2.4
func (*NackRequest) Descriptor() ([]byte, []int)
Deprecated: Use NackRequest.ProtoReflect.Descriptor instead.
func (*NackRequest) GetId ¶ added in v0.2.4
func (x *NackRequest) GetId() uint64
func (*NackRequest) GetQueueName ¶ added in v0.2.4
func (x *NackRequest) GetQueueName() string
func (*NackRequest) ProtoMessage ¶ added in v0.2.4
func (*NackRequest) ProtoMessage()
func (*NackRequest) ProtoReflect ¶ added in v0.2.4
func (x *NackRequest) ProtoReflect() protoreflect.Message
func (*NackRequest) Reset ¶ added in v0.2.4
func (x *NackRequest) Reset()
func (*NackRequest) String ¶ added in v0.2.4
func (x *NackRequest) String() string
type NackResponse ¶ added in v0.2.4
type NackResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
func (*NackResponse) Descriptor
deprecated
added in
v0.2.4
func (*NackResponse) Descriptor() ([]byte, []int)
Deprecated: Use NackResponse.ProtoReflect.Descriptor instead.
func (*NackResponse) GetSuccess ¶ added in v0.2.4
func (x *NackResponse) GetSuccess() bool
func (*NackResponse) ProtoMessage ¶ added in v0.2.4
func (*NackResponse) ProtoMessage()
func (*NackResponse) ProtoReflect ¶ added in v0.2.4
func (x *NackResponse) ProtoReflect() protoreflect.Message
func (*NackResponse) Reset ¶ added in v0.2.4
func (x *NackResponse) Reset()
func (*NackResponse) String ¶ added in v0.2.4
func (x *NackResponse) String() string
type UnimplementedDOQServer ¶
type UnimplementedDOQServer struct { }
UnimplementedDOQServer must be embedded to have forward compatible implementations.
func (UnimplementedDOQServer) Ack ¶ added in v0.2.4
func (UnimplementedDOQServer) Ack(context.Context, *AckRequest) (*AckResponse, error)
func (UnimplementedDOQServer) CreateQueue ¶
func (UnimplementedDOQServer) CreateQueue(context.Context, *CreateQueueRequest) (*CreateQueueResponse, error)
func (UnimplementedDOQServer) DeleteQueue ¶
func (UnimplementedDOQServer) DeleteQueue(context.Context, *DeleteQueueRequest) (*DeleteQueueResponse, error)
func (UnimplementedDOQServer) Dequeue ¶
func (UnimplementedDOQServer) Dequeue(context.Context, *DequeueRequest) (*DequeueResponse, error)
func (UnimplementedDOQServer) DequeueStream ¶
func (UnimplementedDOQServer) DequeueStream(*DequeueRequest, DOQ_DequeueStreamServer) error
func (UnimplementedDOQServer) Enqueue ¶
func (UnimplementedDOQServer) Enqueue(context.Context, *EnqueueRequest) (*EnqueueResponse, error)
func (UnimplementedDOQServer) EnqueueStream ¶
func (UnimplementedDOQServer) EnqueueStream(DOQ_EnqueueStreamServer) error
func (UnimplementedDOQServer) Nack ¶ added in v0.2.4
func (UnimplementedDOQServer) Nack(context.Context, *NackRequest) (*NackResponse, error)
func (UnimplementedDOQServer) UpdatePriority ¶
func (UnimplementedDOQServer) UpdatePriority(context.Context, *UpdatePriorityRequest) (*UpdatePriorityResponse, error)
type UnsafeDOQServer ¶
type UnsafeDOQServer interface {
// contains filtered or unexported methods
}
UnsafeDOQServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DOQServer will result in compilation errors.
type UpdatePriorityRequest ¶
type UpdatePriorityRequest struct { QueueName string `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` Priority int64 `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"` // contains filtered or unexported fields }
func (*UpdatePriorityRequest) Descriptor
deprecated
func (*UpdatePriorityRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdatePriorityRequest.ProtoReflect.Descriptor instead.
func (*UpdatePriorityRequest) GetId ¶
func (x *UpdatePriorityRequest) GetId() uint64
func (*UpdatePriorityRequest) GetPriority ¶
func (x *UpdatePriorityRequest) GetPriority() int64
func (*UpdatePriorityRequest) GetQueueName ¶
func (x *UpdatePriorityRequest) GetQueueName() string
func (*UpdatePriorityRequest) ProtoMessage ¶
func (*UpdatePriorityRequest) ProtoMessage()
func (*UpdatePriorityRequest) ProtoReflect ¶
func (x *UpdatePriorityRequest) ProtoReflect() protoreflect.Message
func (*UpdatePriorityRequest) Reset ¶
func (x *UpdatePriorityRequest) Reset()
func (*UpdatePriorityRequest) String ¶
func (x *UpdatePriorityRequest) String() string
type UpdatePriorityResponse ¶
type UpdatePriorityResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
func (*UpdatePriorityResponse) Descriptor
deprecated
func (*UpdatePriorityResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdatePriorityResponse.ProtoReflect.Descriptor instead.
func (*UpdatePriorityResponse) GetSuccess ¶
func (x *UpdatePriorityResponse) GetSuccess() bool
func (*UpdatePriorityResponse) ProtoMessage ¶
func (*UpdatePriorityResponse) ProtoMessage()
func (*UpdatePriorityResponse) ProtoReflect ¶
func (x *UpdatePriorityResponse) ProtoReflect() protoreflect.Message
func (*UpdatePriorityResponse) Reset ¶
func (x *UpdatePriorityResponse) Reset()
func (*UpdatePriorityResponse) String ¶
func (x *UpdatePriorityResponse) String() string