pb

package
v0.0.12 Latest Latest
Warning

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

 Go to latest Published: Jul 3, 2022 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pb_main_proto protoreflect.FileDescriptor
View Source 
var UltraQueueInternal_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "UltraQueueInternal",
	HandlerType: (*UltraQueueInternalServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Dequeue",
			Handler:    _UltraQueueInternal_Dequeue_Handler,
		},
		{
			MethodName: "Ack",
			Handler:    _UltraQueueInternal_Ack_Handler,
		},
		{
			MethodName: "Nack",
			Handler:    _UltraQueueInternal_Nack_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "DrainReceive",
			Handler:       _UltraQueueInternal_DrainReceive_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "pb/main.proto",
}

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

Functions

func RegisterUltraQueueInternalServer 

func RegisterUltraQueueInternalServer(s grpc.ServiceRegistrar, srv UltraQueueInternalServer)

Types

type AckRequest 

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

func (*AckRequest) Descriptor deprecated 

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

Deprecated: Use AckRequest.ProtoReflect.Descriptor instead.

func (*AckRequest) GetTaskID 

func (x *AckRequest) GetTaskID() string

func (*AckRequest) ProtoMessage 

func (*AckRequest) ProtoMessage()

func (*AckRequest) ProtoReflect 

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

func (*AckRequest) Reset 

func (x *AckRequest) Reset()

func (*AckRequest) String 

func (x *AckRequest) String() string

type Applied 

type Applied struct {
	Applied bool `protobuf:"varint,1,opt,name=applied,proto3" json:"applied,omitempty"`
	// contains filtered or unexported fields
}

func (*Applied) Descriptor deprecated 

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

Deprecated: Use Applied.ProtoReflect.Descriptor instead.

func (*Applied) GetApplied 

func (x *Applied) GetApplied() bool

func (*Applied) ProtoMessage 

func (*Applied) ProtoMessage()

func (*Applied) ProtoReflect 

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

func (*Applied) Reset 

func (x *Applied) Reset()

func (*Applied) String 

func (x *Applied) String() string

type DequeueRequest 

type DequeueRequest struct {
	Topic              string `protobuf:"bytes,1,opt,name=Topic,proto3" json:"Topic,omitempty"`
	InFlightTTLSeconds int32  `protobuf:"zigzag32,2,opt,name=InFlightTTLSeconds,proto3" json:"InFlightTTLSeconds,omitempty"`
	Tasks              int32  `protobuf:"zigzag32,3,opt,name=Tasks,proto3" json:"Tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueRequest) Descriptor deprecated 

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

Deprecated: Use DequeueRequest.ProtoReflect.Descriptor instead.

func (*DequeueRequest) GetInFlightTTLSeconds 

func (x *DequeueRequest) GetInFlightTTLSeconds() int32

func (*DequeueRequest) GetTasks 

func (x *DequeueRequest) GetTasks() int32

func (*DequeueRequest) GetTopic 

func (x *DequeueRequest) GetTopic() 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 DrainTask added in v0.0.5 

type DrainTask struct {
	Priority int32  `protobuf:"zigzag32,1,opt,name=Priority,proto3" json:"Priority,omitempty"`
	Topic    string `protobuf:"bytes,2,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Payload  string `protobuf:"bytes,3,opt,name=Payload,proto3" json:"Payload,omitempty"`
	// contains filtered or unexported fields
}

func (*DrainTask) Descriptor deprecated added in v0.0.5 

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

Deprecated: Use DrainTask.ProtoReflect.Descriptor instead.

func (*DrainTask) GetPayload added in v0.0.5 

func (x *DrainTask) GetPayload() string

func (*DrainTask) GetPriority added in v0.0.5 

func (x *DrainTask) GetPriority() int32

func (*DrainTask) GetTopic added in v0.0.5 

func (x *DrainTask) GetTopic() string

func (*DrainTask) ProtoMessage added in v0.0.5 

func (*DrainTask) ProtoMessage()

func (*DrainTask) ProtoReflect added in v0.0.5 

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

func (*DrainTask) Reset added in v0.0.5 

func (x *DrainTask) Reset()

func (*DrainTask) String added in v0.0.5 

func (x *DrainTask) String() string

type DrainTaskList added in v0.0.5 

type DrainTaskList struct {
	Tasks []*DrainTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*DrainTaskList) Descriptor deprecated added in v0.0.5 

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

Deprecated: Use DrainTaskList.ProtoReflect.Descriptor instead.

func (*DrainTaskList) GetTasks added in v0.0.5 

func (x *DrainTaskList) GetTasks() []*DrainTask

func (*DrainTaskList) ProtoMessage added in v0.0.5 

func (*DrainTaskList) ProtoMessage()

func (*DrainTaskList) ProtoReflect added in v0.0.5 

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

func (*DrainTaskList) Reset added in v0.0.5 

func (x *DrainTaskList) Reset()

func (*DrainTaskList) String added in v0.0.5 

func (x *DrainTaskList) String() string

type NackRequest 

type NackRequest struct {
	TaskID       string `protobuf:"bytes,1,opt,name=TaskID,proto3" json:"TaskID,omitempty"`
	DelaySeconds int32  `protobuf:"zigzag32,2,opt,name=DelaySeconds,proto3" json:"DelaySeconds,omitempty"`
	// contains filtered or unexported fields
}

func (*NackRequest) Descriptor deprecated 

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

Deprecated: Use NackRequest.ProtoReflect.Descriptor instead.

func (*NackRequest) GetDelaySeconds 

func (x *NackRequest) GetDelaySeconds() int32

func (*NackRequest) GetTaskID 

func (x *NackRequest) GetTaskID() string

func (*NackRequest) ProtoMessage 

func (*NackRequest) ProtoMessage()

func (*NackRequest) ProtoReflect 

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

func (*NackRequest) Reset 

func (x *NackRequest) Reset()

func (*NackRequest) String 

func (x *NackRequest) String() string

type Task 

type Task struct {
	ID               string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Topic            string `protobuf:"bytes,2,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Payload          string `protobuf:"bytes,3,opt,name=Payload,proto3" json:"Payload,omitempty"`
	CreatedAt        string `protobuf:"bytes,4,opt,name=CreatedAt,proto3" json:"CreatedAt,omitempty"`
	Version          int32  `protobuf:"zigzag32,5,opt,name=Version,proto3" json:"Version,omitempty"`
	DeliveryAttempts int32  `protobuf:"zigzag32,6,opt,name=DeliveryAttempts,proto3" json:"DeliveryAttempts,omitempty"`
	Priority         int32  `protobuf:"zigzag32,7,opt,name=Priority,proto3" json:"Priority,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCreatedAt 

func (x *Task) GetCreatedAt() string

func (*Task) GetDeliveryAttempts 

func (x *Task) GetDeliveryAttempts() int32

func (*Task) GetID 

func (x *Task) GetID() string

func (*Task) GetPayload 

func (x *Task) GetPayload() string

func (*Task) GetPriority 

func (x *Task) GetPriority() int32

func (*Task) GetTopic 

func (x *Task) GetTopic() string

func (*Task) GetVersion 

func (x *Task) GetVersion() int32

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskResponse 

type TaskResponse struct {
	Tasks []*TreeTask `protobuf:"bytes,1,rep,name=Tasks,proto3" json:"Tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskResponse) Descriptor deprecated 

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

Deprecated: Use TaskResponse.ProtoReflect.Descriptor instead.

func (*TaskResponse) GetTasks 

func (x *TaskResponse) GetTasks() []*TreeTask

func (*TaskResponse) ProtoMessage 

func (*TaskResponse) ProtoMessage()

func (*TaskResponse) ProtoReflect 

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

func (*TaskResponse) Reset 

func (x *TaskResponse) Reset()

func (*TaskResponse) String 

func (x *TaskResponse) String() string

type TreeTask 

type TreeTask struct {
	ID   string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Task *Task  `protobuf:"bytes,2,opt,name=Task,proto3" json:"Task,omitempty"`
	// contains filtered or unexported fields
}

func (*TreeTask) Descriptor deprecated 

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

Deprecated: Use TreeTask.ProtoReflect.Descriptor instead.

func (*TreeTask) GetID 

func (x *TreeTask) GetID() string

func (*TreeTask) GetTask 

func (x *TreeTask) GetTask() *Task

func (*TreeTask) ProtoMessage 

func (*TreeTask) ProtoMessage()

func (*TreeTask) ProtoReflect 

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

func (*TreeTask) Reset 

func (x *TreeTask) Reset()

func (*TreeTask) String 

func (x *TreeTask) String() string

type UltraQueueInternalClient 

type UltraQueueInternalClient interface {
	Dequeue(ctx context.Context, in *DequeueRequest, opts ...grpc.CallOption) (*TaskResponse, error)
	Ack(ctx context.Context, in *AckRequest, opts ...grpc.CallOption) (*Applied, error)
	Nack(ctx context.Context, in *NackRequest, opts ...grpc.CallOption) (*Applied, error)
	DrainReceive(ctx context.Context, opts ...grpc.CallOption) (UltraQueueInternal_DrainReceiveClient, error)
}

UltraQueueInternalClient is the client API for UltraQueueInternal 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 NewUltraQueueInternalClient 

func NewUltraQueueInternalClient(cc grpc.ClientConnInterface) UltraQueueInternalClient

type UltraQueueInternalServer 

type UltraQueueInternalServer interface {
	Dequeue(context.Context, *DequeueRequest) (*TaskResponse, error)
	Ack(context.Context, *AckRequest) (*Applied, error)
	Nack(context.Context, *NackRequest) (*Applied, error)
	DrainReceive(UltraQueueInternal_DrainReceiveServer) error
	// contains filtered or unexported methods
}

UltraQueueInternalServer is the server API for UltraQueueInternal service. All implementations must embed UnimplementedUltraQueueInternalServer for forward compatibility

type UltraQueueInternal_DrainReceiveClient added in v0.0.5 

type UltraQueueInternal_DrainReceiveClient interface {
	Send(*DrainTaskList) error
	CloseAndRecv() (*Applied, error)
	grpc.ClientStream
}

type UltraQueueInternal_DrainReceiveServer added in v0.0.5 

type UltraQueueInternal_DrainReceiveServer interface {
	SendAndClose(*Applied) error
	Recv() (*DrainTaskList, error)
	grpc.ServerStream
}

type UnimplementedUltraQueueInternalServer 

type UnimplementedUltraQueueInternalServer struct {
}

UnimplementedUltraQueueInternalServer must be embedded to have forward compatible implementations.

func (UnimplementedUltraQueueInternalServer) Ack 

func (UnimplementedUltraQueueInternalServer) Ack(context.Context, *AckRequest) (*Applied, error)

func (UnimplementedUltraQueueInternalServer) Dequeue 

func (UnimplementedUltraQueueInternalServer) Dequeue(context.Context, *DequeueRequest) (*TaskResponse, error)

func (UnimplementedUltraQueueInternalServer) DrainReceive added in v0.0.5 

func (UnimplementedUltraQueueInternalServer) DrainReceive(UltraQueueInternal_DrainReceiveServer) error

func (UnimplementedUltraQueueInternalServer) Nack 

func (UnimplementedUltraQueueInternalServer) Nack(context.Context, *NackRequest) (*Applied, error)

type UnsafeUltraQueueInternalServer 

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

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

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.