proto

package

Go to main page

Versions in this module

v0

v0.2.0

Jun 2, 2022

Changes in this version

+ var File_model_proto protoreflect.FileDescriptor

type Ack

+ Reference *TaskReference

+ func (x *Ack) GetReference() *TaskReference

type AdminClient

+ GetQueue func(ctx context.Context, in *GetQueueRequest, opts ...grpc.CallOption) (*QueueConfig, error)

+ UpdateQueue func(ctx context.Context, in *UpdateQueueRequest, opts ...grpc.CallOption) (*QueueConfig, error)

type AdminServer

+ GetQueue func(context.Context, *GetQueueRequest) (*QueueConfig, error)

+ UpdateQueue func(context.Context, *UpdateQueueRequest) (*QueueConfig, error)

type ClusterInfo

+ LeaderId string

+ func (x *ClusterInfo) GetLeaderId() string

type Command

+ func (x *Command) GetQueue() *QueueConfig

+ type Command_Queue struct

+ Queue *QueueConfig

type DeleteTaskRequest

+ Reference *TaskReference

+ func (x *DeleteTaskRequest) GetReference() *TaskReference

+ type GetQueueRequest struct

+ Queue string

+ RequestId string

+ func (*GetQueueRequest) Descriptor() ([]byte, []int)

+ func (*GetQueueRequest) ProtoMessage()

+ func (x *GetQueueRequest) GetQueue() string

+ func (x *GetQueueRequest) GetRequestId() string

+ func (x *GetQueueRequest) ProtoReflect() protoreflect.Message

+ func (x *GetQueueRequest) Reset()

+ func (x *GetQueueRequest) String() string

type GetTaskRequest

+ Reference *TaskReference

+ func (x *GetTaskRequest) GetReference() *TaskReference

type PushTaskRequest

+ Queue string

+ Schedule isPushTaskRequest_Schedule

+ func (m *PushTaskRequest) GetSchedule() isPushTaskRequest_Schedule

+ func (x *PushTaskRequest) GetQueue() string

+ func (x *PushTaskRequest) GetScheduleTime() *timestamppb.Timestamp

+ type PushTaskRequest_ScheduleTime struct

+ ScheduleTime *timestamppb.Timestamp

+ type PushTaskRequest_TtsSeconds struct

+ TtsSeconds int64

+ type QueueConfig struct

+ AckDeadlineSeconds int32

+ Id string

+ LastDeliveredQueuedTask string

+ LastDeliveredScheduledTask string

+ func (*QueueConfig) Descriptor() ([]byte, []int)

+ func (*QueueConfig) ProtoMessage()

+ func (x *QueueConfig) GetAckDeadlineSeconds() int32

+ func (x *QueueConfig) GetId() string

+ func (x *QueueConfig) GetLastDeliveredQueuedTask() string

+ func (x *QueueConfig) GetLastDeliveredScheduledTask() string

+ func (x *QueueConfig) ProtoReflect() protoreflect.Message

+ func (x *QueueConfig) Reset()

+ func (x *QueueConfig) String() string

type Server

+ Host string

+ QueuePort int32

+ RaftPort int32

+ SqlPort int32

+ func (x *Server) GetHost() string

+ func (x *Server) GetQueuePort() int32

+ func (x *Server) GetRaftPort() int32

+ func (x *Server) GetSqlPort() int32

type Task

+ CreatedAt *timestamppb.Timestamp

+ Queue string

+ ScheduleTime *timestamppb.Timestamp

+ func (x *Task) GetCreatedAt() *timestamppb.Timestamp

+ func (x *Task) GetQueue() string

+ func (x *Task) GetScheduleTime() *timestamppb.Timestamp

+ type TaskReference struct

+ Queue string

+ TaskId string

+ func (*TaskReference) Descriptor() ([]byte, []int)

+ func (*TaskReference) ProtoMessage()

+ func (x *TaskReference) GetQueue() string

+ func (x *TaskReference) GetTaskId() string

+ func (x *TaskReference) ProtoReflect() protoreflect.Message

+ func (x *TaskReference) Reset()

+ func (x *TaskReference) String() string

type UnimplementedAdminServer

+ func (UnimplementedAdminServer) GetQueue(context.Context, *GetQueueRequest) (*QueueConfig, error)

+ func (UnimplementedAdminServer) UpdateQueue(context.Context, *UpdateQueueRequest) (*QueueConfig, error)

+ type UpdateQueueRequest struct

+ Queue *QueueConfig

+ RequestId string

+ func (*UpdateQueueRequest) Descriptor() ([]byte, []int)

+ func (*UpdateQueueRequest) ProtoMessage()

+ func (x *UpdateQueueRequest) GetQueue() *QueueConfig

+ func (x *UpdateQueueRequest) GetRequestId() string

+ func (x *UpdateQueueRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateQueueRequest) Reset()

+ func (x *UpdateQueueRequest) String() string

v0.1.0

May 8, 2022

Changes in this version

+ var Admin_ServiceDesc = grpc.ServiceDesc

+ var File_admin_service_proto protoreflect.FileDescriptor

+ var File_misc_proto protoreflect.FileDescriptor

+ var File_queue_service_proto protoreflect.FileDescriptor

+ var Queue_ServiceDesc = grpc.ServiceDesc

+ func RegisterAdminServer(s grpc.ServiceRegistrar, srv AdminServer)

+ func RegisterQueueServer(s grpc.ServiceRegistrar, srv QueueServer)

+ type Ack struct

+ Namespace string

+ TaskId string

+ func (*Ack) Descriptor() ([]byte, []int)

+ func (*Ack) ProtoMessage()

+ func (x *Ack) GetNamespace() string

+ func (x *Ack) GetTaskId() string

+ func (x *Ack) ProtoReflect() protoreflect.Message

+ func (x *Ack) Reset()

+ func (x *Ack) String() string

+ type AddClusterMemberRequest struct

+ MemberAddress string

+ MemberId string

+ func (*AddClusterMemberRequest) Descriptor() ([]byte, []int)

+ func (*AddClusterMemberRequest) ProtoMessage()

+ func (x *AddClusterMemberRequest) GetMemberAddress() string

+ func (x *AddClusterMemberRequest) GetMemberId() string

+ func (x *AddClusterMemberRequest) ProtoReflect() protoreflect.Message

+ func (x *AddClusterMemberRequest) Reset()

+ func (x *AddClusterMemberRequest) String() string

+ type AdminClient interface

+ AddClusterMember func(ctx context.Context, in *AddClusterMemberRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ BootstrapCluster func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ CheckHealth func(ctx context.Context, in *CheckHealthRequest, opts ...grpc.CallOption) (*Status, error)

+ GetClusterInfo func(ctx context.Context, in *GetClusterInfoRequest, opts ...grpc.CallOption) (*ClusterInfo, error)

+ GetNamespace func(ctx context.Context, in *GetNamespaceRequest, opts ...grpc.CallOption) (*Namespace, error)

+ RemoveClusterMember func(ctx context.Context, in *RemoveClusterMemberRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ UpdateNamespace func(ctx context.Context, in *UpdateNamespaceRequest, opts ...grpc.CallOption) (*Namespace, error)

+ func NewAdminClient(cc grpc.ClientConnInterface) AdminClient

+ type AdminServer interface

+ AddClusterMember func(context.Context, *AddClusterMemberRequest) (*emptypb.Empty, error)

+ BootstrapCluster func(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

+ CheckHealth func(context.Context, *CheckHealthRequest) (*Status, error)

+ GetClusterInfo func(context.Context, *GetClusterInfoRequest) (*ClusterInfo, error)

+ GetNamespace func(context.Context, *GetNamespaceRequest) (*Namespace, error)

+ RemoveClusterMember func(context.Context, *RemoveClusterMemberRequest) (*emptypb.Empty, error)

+ UpdateNamespace func(context.Context, *UpdateNamespaceRequest) (*Namespace, error)

+ type CheckHealthRequest struct

+ RequestId string

+ func (*CheckHealthRequest) Descriptor() ([]byte, []int)

+ func (*CheckHealthRequest) ProtoMessage()

+ func (x *CheckHealthRequest) GetRequestId() string

+ func (x *CheckHealthRequest) ProtoReflect() protoreflect.Message

+ func (x *CheckHealthRequest) Reset()

+ func (x *CheckHealthRequest) String() string

+ type ClusterInfo struct

+ LeaderAddress string

+ Members []*Server

+ ServerId string

+ func (*ClusterInfo) Descriptor() ([]byte, []int)

+ func (*ClusterInfo) ProtoMessage()

+ func (x *ClusterInfo) GetLeaderAddress() string

+ func (x *ClusterInfo) GetMembers() []*Server

+ func (x *ClusterInfo) GetServerId() string

+ func (x *ClusterInfo) ProtoReflect() protoreflect.Message

+ func (x *ClusterInfo) Reset()

+ func (x *ClusterInfo) String() string

+ type Command struct

+ Cmd isCommand_Cmd

+ func (*Command) Descriptor() ([]byte, []int)

+ func (*Command) ProtoMessage()

+ func (m *Command) GetCmd() isCommand_Cmd

+ func (x *Command) GetAck() *Ack

+ func (x *Command) GetNamespace() *Namespace

+ func (x *Command) GetTask() *Task

+ func (x *Command) ProtoReflect() protoreflect.Message

+ func (x *Command) Reset()

+ func (x *Command) String() string

+ type Command_Ack struct

+ Ack *Ack

+ type Command_Namespace struct

+ Namespace *Namespace

+ type Command_Task struct

+ Task *Task

+ type DeleteTaskRequest struct

+ Async bool

+ Namespace string

+ RequestId string

+ TaskId string

+ func (*DeleteTaskRequest) Descriptor() ([]byte, []int)

+ func (*DeleteTaskRequest) ProtoMessage()

+ func (x *DeleteTaskRequest) GetAsync() bool

+ func (x *DeleteTaskRequest) GetNamespace() string

+ func (x *DeleteTaskRequest) GetRequestId() string

+ func (x *DeleteTaskRequest) GetTaskId() string

+ func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteTaskRequest) Reset()

+ func (x *DeleteTaskRequest) String() string

+ type DeleteTaskResponse struct

+ ForwardedTo string

+ func (*DeleteTaskResponse) Descriptor() ([]byte, []int)

+ func (*DeleteTaskResponse) ProtoMessage()

+ func (x *DeleteTaskResponse) GetForwardedTo() string

+ func (x *DeleteTaskResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteTaskResponse) Reset()

+ func (x *DeleteTaskResponse) String() string

+ type GetClusterInfoRequest struct

+ RequestId string

+ func (*GetClusterInfoRequest) Descriptor() ([]byte, []int)

+ func (*GetClusterInfoRequest) ProtoMessage()

+ func (x *GetClusterInfoRequest) GetRequestId() string

+ func (x *GetClusterInfoRequest) ProtoReflect() protoreflect.Message

+ func (x *GetClusterInfoRequest) Reset()

+ func (x *GetClusterInfoRequest) String() string

+ type GetNamespaceRequest struct

+ NamespaceId string

+ RequestId string

+ func (*GetNamespaceRequest) Descriptor() ([]byte, []int)

+ func (*GetNamespaceRequest) ProtoMessage()

+ func (x *GetNamespaceRequest) GetNamespaceId() string

+ func (x *GetNamespaceRequest) GetRequestId() string

+ func (x *GetNamespaceRequest) ProtoReflect() protoreflect.Message

+ func (x *GetNamespaceRequest) Reset()

+ func (x *GetNamespaceRequest) String() string

+ type GetTaskRequest struct

+ Namespace string

+ RequestId string

+ TaskId string

+ func (*GetTaskRequest) Descriptor() ([]byte, []int)

+ func (*GetTaskRequest) ProtoMessage()

+ func (x *GetTaskRequest) GetNamespace() string

+ func (x *GetTaskRequest) GetRequestId() string

+ func (x *GetTaskRequest) GetTaskId() string

+ func (x *GetTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *GetTaskRequest) Reset()

+ func (x *GetTaskRequest) String() string

+ type Namespace struct

+ Id string

+ LastDeliveredTask string

+ func (*Namespace) Descriptor() ([]byte, []int)

+ func (*Namespace) ProtoMessage()

+ func (x *Namespace) GetId() string

+ func (x *Namespace) GetLastDeliveredTask() string

+ func (x *Namespace) ProtoReflect() protoreflect.Message

+ func (x *Namespace) Reset()

+ func (x *Namespace) String() string

+ type PullRequest struct

+ Request isPullRequest_Request

+ func (*PullRequest) Descriptor() ([]byte, []int)

+ func (*PullRequest) ProtoMessage()

+ func (m *PullRequest) GetRequest() isPullRequest_Request

+ func (x *PullRequest) GetAck() *Ack

+ func (x *PullRequest) GetStartReq() *StartStreamRequest

+ func (x *PullRequest) ProtoReflect() protoreflect.Message

+ func (x *PullRequest) Reset()

+ func (x *PullRequest) String() string

+ type PullRequest_Ack struct

+ Ack *Ack

+ type PullRequest_StartReq struct

+ StartReq *StartStreamRequest

+ type PushStreamResponse struct

+ ForwardedTo string

+ Message string

+ Status uint32

+ Task *Task

+ func (*PushStreamResponse) Descriptor() ([]byte, []int)

+ func (*PushStreamResponse) ProtoMessage()

+ func (x *PushStreamResponse) GetForwardedTo() string

+ func (x *PushStreamResponse) GetMessage() string

+ func (x *PushStreamResponse) GetStatus() uint32

+ func (x *PushStreamResponse) GetTask() *Task

+ func (x *PushStreamResponse) ProtoReflect() protoreflect.Message

+ func (x *PushStreamResponse) Reset()

+ func (x *PushStreamResponse) String() string

+ type PushTaskRequest struct

+ Async bool

+ DeliverAt *timestamppb.Timestamp

+ Metadata map[string]string

+ Namespace string

+ Payload []byte

+ RequestId string

+ TtsSeconds int64

+ func (*PushTaskRequest) Descriptor() ([]byte, []int)

+ func (*PushTaskRequest) ProtoMessage()

+ func (x *PushTaskRequest) GetAsync() bool

+ func (x *PushTaskRequest) GetDeliverAt() *timestamppb.Timestamp

+ func (x *PushTaskRequest) GetMetadata() map[string]string

+ func (x *PushTaskRequest) GetNamespace() string

+ func (x *PushTaskRequest) GetPayload() []byte

+ func (x *PushTaskRequest) GetRequestId() string

+ func (x *PushTaskRequest) GetTtsSeconds() int64

+ func (x *PushTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *PushTaskRequest) Reset()

+ func (x *PushTaskRequest) String() string

+ type PushTaskResponse struct

+ ForwardedTo string

+ Task *Task

+ func (*PushTaskResponse) Descriptor() ([]byte, []int)

+ func (*PushTaskResponse) ProtoMessage()

+ func (x *PushTaskResponse) GetForwardedTo() string

+ func (x *PushTaskResponse) GetTask() *Task

+ func (x *PushTaskResponse) ProtoReflect() protoreflect.Message

+ func (x *PushTaskResponse) Reset()

+ func (x *PushTaskResponse) String() string

+ type QueueClient interface

+ Delete func(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*DeleteTaskResponse, error)

+ Get func(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error)

+ Pull func(ctx context.Context, opts ...grpc.CallOption) (Queue_PullClient, error)

+ Push func(ctx context.Context, in *PushTaskRequest, opts ...grpc.CallOption) (*PushTaskResponse, error)

+ PushStream func(ctx context.Context, opts ...grpc.CallOption) (Queue_PushStreamClient, error)

+ func NewQueueClient(cc grpc.ClientConnInterface) QueueClient

+ type QueueServer interface

+ Delete func(context.Context, *DeleteTaskRequest) (*DeleteTaskResponse, error)

+ Get func(context.Context, *GetTaskRequest) (*Task, error)

+ Pull func(Queue_PullServer) error

+ Push func(context.Context, *PushTaskRequest) (*PushTaskResponse, error)

+ PushStream func(Queue_PushStreamServer) error

+ type Queue_PullClient interface

+ Recv func() (*Task, error)

+ Send func(*PullRequest) error

+ type Queue_PullServer interface

+ Recv func() (*PullRequest, error)

+ Send func(*Task) error

+ type Queue_PushStreamClient interface

+ Recv func() (*PushStreamResponse, error)

+ Send func(*PushTaskRequest) error

+ type Queue_PushStreamServer interface

+ Recv func() (*PushTaskRequest, error)

+ Send func(*PushStreamResponse) error

+ type RemoveClusterMemberRequest struct

+ MemberId string

+ func (*RemoveClusterMemberRequest) Descriptor() ([]byte, []int)

+ func (*RemoveClusterMemberRequest) ProtoMessage()

+ func (x *RemoveClusterMemberRequest) GetMemberId() string

+ func (x *RemoveClusterMemberRequest) ProtoReflect() protoreflect.Message

+ func (x *RemoveClusterMemberRequest) Reset()

+ func (x *RemoveClusterMemberRequest) String() string

+ type Server struct

+ Address string

+ Id string

+ func (*Server) Descriptor() ([]byte, []int)

+ func (*Server) ProtoMessage()

+ func (x *Server) GetAddress() string

+ func (x *Server) GetId() string

+ func (x *Server) ProtoReflect() protoreflect.Message

+ func (x *Server) Reset()

+ func (x *Server) String() string

+ type StartStreamRequest struct

+ Namespace string

+ RequestId string

+ func (*StartStreamRequest) Descriptor() ([]byte, []int)

+ func (*StartStreamRequest) ProtoMessage()

+ func (x *StartStreamRequest) GetNamespace() string

+ func (x *StartStreamRequest) GetRequestId() string

+ func (x *StartStreamRequest) ProtoReflect() protoreflect.Message

+ func (x *StartStreamRequest) Reset()

+ func (x *StartStreamRequest) String() string

+ type Status struct

+ func (*Status) Descriptor() ([]byte, []int)

+ func (*Status) ProtoMessage()

+ func (x *Status) ProtoReflect() protoreflect.Message

+ func (x *Status) Reset()

+ func (x *Status) String() string

+ type Task struct

+ DeliverAt *timestamppb.Timestamp

+ Id string

+ LastRetry *timestamppb.Timestamp

+ Metadata map[string]string

+ Namespace string

+ Payload []byte

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

+ func (*Task) ProtoMessage()

+ func (x *Task) GetDeliverAt() *timestamppb.Timestamp

+ func (x *Task) GetId() string

+ func (x *Task) GetLastRetry() *timestamppb.Timestamp

+ func (x *Task) GetMetadata() map[string]string

+ func (x *Task) GetNamespace() string

+ func (x *Task) GetPayload() []byte

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

+ func (x *Task) Reset()

+ func (x *Task) String() string

+ type UnimplementedAdminServer struct

+ func (UnimplementedAdminServer) AddClusterMember(context.Context, *AddClusterMemberRequest) (*emptypb.Empty, error)

+ func (UnimplementedAdminServer) BootstrapCluster(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

+ func (UnimplementedAdminServer) CheckHealth(context.Context, *CheckHealthRequest) (*Status, error)

+ func (UnimplementedAdminServer) GetClusterInfo(context.Context, *GetClusterInfoRequest) (*ClusterInfo, error)

+ func (UnimplementedAdminServer) GetNamespace(context.Context, *GetNamespaceRequest) (*Namespace, error)

+ func (UnimplementedAdminServer) RemoveClusterMember(context.Context, *RemoveClusterMemberRequest) (*emptypb.Empty, error)

+ func (UnimplementedAdminServer) UpdateNamespace(context.Context, *UpdateNamespaceRequest) (*Namespace, error)

+ type UnimplementedQueueServer struct

+ func (UnimplementedQueueServer) Delete(context.Context, *DeleteTaskRequest) (*DeleteTaskResponse, error)

+ func (UnimplementedQueueServer) Get(context.Context, *GetTaskRequest) (*Task, error)

+ func (UnimplementedQueueServer) Pull(Queue_PullServer) error

+ func (UnimplementedQueueServer) Push(context.Context, *PushTaskRequest) (*PushTaskResponse, error)

+ func (UnimplementedQueueServer) PushStream(Queue_PushStreamServer) error

+ type UnsafeAdminServer interface

+ type UnsafeQueueServer interface

+ type UpdateNamespaceRequest struct

+ Namespace *Namespace

+ RequestId string

+ func (*UpdateNamespaceRequest) Descriptor() ([]byte, []int)

+ func (*UpdateNamespaceRequest) ProtoMessage()

+ func (x *UpdateNamespaceRequest) GetNamespace() *Namespace

+ func (x *UpdateNamespaceRequest) GetRequestId() string

+ func (x *UpdateNamespaceRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateNamespaceRequest) Reset()

+ func (x *UpdateNamespaceRequest) String() string

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