proto

package
v0.2.10 Latest Latest
Warning

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

Go to latest
Published: Oct 18, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
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

View Source
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)

View Source
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

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) CreateQueue

func (UnimplementedDOQServer) DeleteQueue

func (UnimplementedDOQServer) Dequeue

func (UnimplementedDOQServer) DequeueStream

func (UnimplementedDOQServer) Enqueue

func (UnimplementedDOQServer) EnqueueStream

func (UnimplementedDOQServer) Nack added in v0.2.4

func (UnimplementedDOQServer) UpdatePriority

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL