Versions in this module Expand all Collapse all v1 v1.1.0 Dec 4, 2018 v1.0.0 Dec 3, 2018 Changes in this version + var Queue_Unit_name = map[int32]string + var Queue_Unit_value = map[string]int32 + func RegisterQueuesServiceServer(s *grpc.Server, srv QueuesServiceServer) + type Ack struct + Code string + Success bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Ack) Descriptor() ([]byte, []int) + func (*Ack) ProtoMessage() + func (m *Ack) GetCode() string + func (m *Ack) GetSuccess() bool + func (m *Ack) Reset() + func (m *Ack) String() string + func (m *Ack) XXX_DiscardUnknown() + func (m *Ack) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Ack) XXX_Merge(src proto.Message) + func (m *Ack) XXX_Size() int + func (m *Ack) XXX_Unmarshal(b []byte) error + type ListReply struct + Queues []*Queue + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListReply) Descriptor() ([]byte, []int) + func (*ListReply) ProtoMessage() + func (m *ListReply) GetQueues() []*Queue + func (m *ListReply) Reset() + func (m *ListReply) String() string + func (m *ListReply) XXX_DiscardUnknown() + func (m *ListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListReply) XXX_Merge(src proto.Message) + func (m *ListReply) XXX_Size() int + func (m *ListReply) XXX_Unmarshal(b []byte) error + type ListRequest struct + Project string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListRequest) Descriptor() ([]byte, []int) + func (*ListRequest) ProtoMessage() + func (m *ListRequest) GetProject() string + func (m *ListRequest) Reset() + func (m *ListRequest) String() string + func (m *ListRequest) XXX_DiscardUnknown() + func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListRequest) XXX_Merge(src proto.Message) + func (m *ListRequest) XXX_Size() int + func (m *ListRequest) XXX_Unmarshal(b []byte) error + type ListTasksReply struct + Tasks []*Task + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListTasksReply) Descriptor() ([]byte, []int) + func (*ListTasksReply) ProtoMessage() + func (m *ListTasksReply) GetTasks() []*Task + func (m *ListTasksReply) Reset() + func (m *ListTasksReply) String() string + func (m *ListTasksReply) XXX_DiscardUnknown() + func (m *ListTasksReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListTasksReply) XXX_Merge(src proto.Message) + func (m *ListTasksReply) XXX_Size() int + func (m *ListTasksReply) XXX_Unmarshal(b []byte) error + type ListTasksRequest struct + Project string + QueueName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListTasksRequest) Descriptor() ([]byte, []int) + func (*ListTasksRequest) ProtoMessage() + func (m *ListTasksRequest) GetProject() string + func (m *ListTasksRequest) GetQueueName() string + func (m *ListTasksRequest) Reset() + func (m *ListTasksRequest) String() string + func (m *ListTasksRequest) XXX_DiscardUnknown() + func (m *ListTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListTasksRequest) XXX_Merge(src proto.Message) + func (m *ListTasksRequest) XXX_Size() int + func (m *ListTasksRequest) XXX_Unmarshal(b []byte) error + type ListenInitial struct + Project string + QueueName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListenInitial) Descriptor() ([]byte, []int) + func (*ListenInitial) ProtoMessage() + func (m *ListenInitial) GetProject() string + func (m *ListenInitial) GetQueueName() string + func (m *ListenInitial) Reset() + func (m *ListenInitial) String() string + func (m *ListenInitial) XXX_DiscardUnknown() + func (m *ListenInitial) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListenInitial) XXX_Merge(src proto.Message) + func (m *ListenInitial) XXX_Size() int + func (m *ListenInitial) XXX_Unmarshal(b []byte) error + type ListenReply struct + Task *Task + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListenReply) Descriptor() ([]byte, []int) + func (*ListenReply) ProtoMessage() + func (m *ListenReply) GetTask() *Task + func (m *ListenReply) Reset() + func (m *ListenReply) String() string + func (m *ListenReply) XXX_DiscardUnknown() + func (m *ListenReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListenReply) XXX_Merge(src proto.Message) + func (m *ListenReply) XXX_Size() int + func (m *ListenReply) XXX_Unmarshal(b []byte) error + type ListenRequest struct + Request isListenRequest_Request + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListenRequest) Descriptor() ([]byte, []int) + func (*ListenRequest) ProtoMessage() + func (*ListenRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *ListenRequest) GetAck() *Ack + func (m *ListenRequest) GetInitial() *ListenInitial + func (m *ListenRequest) GetRequest() isListenRequest_Request + func (m *ListenRequest) Reset() + func (m *ListenRequest) String() string + func (m *ListenRequest) XXX_DiscardUnknown() + func (m *ListenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListenRequest) XXX_Merge(src proto.Message) + func (m *ListenRequest) XXX_Size() int + func (m *ListenRequest) XXX_Unmarshal(b []byte) error + type ListenRequest_Ack struct + Ack *Ack + type ListenRequest_Initial struct + Initial *ListenInitial + type PauseRequest struct + Project string + QueueName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PauseRequest) Descriptor() ([]byte, []int) + func (*PauseRequest) ProtoMessage() + func (m *PauseRequest) GetProject() string + func (m *PauseRequest) GetQueueName() string + func (m *PauseRequest) Reset() + func (m *PauseRequest) String() string + func (m *PauseRequest) XXX_DiscardUnknown() + func (m *PauseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PauseRequest) XXX_Merge(src proto.Message) + func (m *PauseRequest) XXX_Size() int + func (m *PauseRequest) XXX_Unmarshal(b []byte) error + type Queue struct + MaxConcurrent int32 + MaxRetries int32 + Name string + Paused bool + Project string + TasksPerUnit int64 + Unit Queue_Unit + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Queue) Descriptor() ([]byte, []int) + func (*Queue) ProtoMessage() + func (m *Queue) GetMaxConcurrent() int32 + func (m *Queue) GetMaxRetries() int32 + func (m *Queue) GetName() string + func (m *Queue) GetPaused() bool + func (m *Queue) GetProject() string + func (m *Queue) GetTasksPerUnit() int64 + func (m *Queue) GetUnit() Queue_Unit + func (m *Queue) Reset() + func (m *Queue) String() string + func (m *Queue) XXX_DiscardUnknown() + func (m *Queue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Queue) XXX_Merge(src proto.Message) + func (m *Queue) XXX_Size() int + func (m *Queue) XXX_Unmarshal(b []byte) error + type Queue_Unit int32 + const Queue_UNIT_MINUTES + const Queue_UNIT_SECONDS + const Queue_UNIT_UNKNOWN + func (Queue_Unit) EnumDescriptor() ([]byte, []int) + func (x Queue_Unit) String() string + type QueuesServiceClient interface + List func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListReply, error) + ListTasks func(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksReply, error) + Listen func(ctx context.Context, opts ...grpc.CallOption) (QueuesService_ListenClient, error) + Pause func(ctx context.Context, in *PauseRequest, opts ...grpc.CallOption) (*Queue, error) + Resume func(ctx context.Context, in *ResumeRequest, opts ...grpc.CallOption) (*Queue, error) + SendTasks func(ctx context.Context, in *SendTasksRequest, opts ...grpc.CallOption) (*SendTasksReply, error) + func NewQueuesServiceClient(cc *grpc.ClientConn) QueuesServiceClient + type QueuesServiceServer interface + List func(context.Context, *ListRequest) (*ListReply, error) + ListTasks func(context.Context, *ListTasksRequest) (*ListTasksReply, error) + Listen func(QueuesService_ListenServer) error + Pause func(context.Context, *PauseRequest) (*Queue, error) + Resume func(context.Context, *ResumeRequest) (*Queue, error) + SendTasks func(context.Context, *SendTasksRequest) (*SendTasksReply, error) + type QueuesService_ListenClient interface + Recv func() (*ListenReply, error) + Send func(*ListenRequest) error + type QueuesService_ListenServer interface + Recv func() (*ListenRequest, error) + Send func(*ListenReply) error + type ResumeRequest struct + Project string + QueueName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResumeRequest) Descriptor() ([]byte, []int) + func (*ResumeRequest) ProtoMessage() + func (m *ResumeRequest) GetProject() string + func (m *ResumeRequest) GetQueueName() string + func (m *ResumeRequest) Reset() + func (m *ResumeRequest) String() string + func (m *ResumeRequest) XXX_DiscardUnknown() + func (m *ResumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResumeRequest) XXX_Merge(src proto.Message) + func (m *ResumeRequest) XXX_Size() int + func (m *ResumeRequest) XXX_Unmarshal(b []byte) error + type SendTask struct + MinEta *timestamp.Timestamp + Payload []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SendTask) Descriptor() ([]byte, []int) + func (*SendTask) ProtoMessage() + func (m *SendTask) GetMinEta() *timestamp.Timestamp + func (m *SendTask) GetPayload() []byte + func (m *SendTask) Reset() + func (m *SendTask) String() string + func (m *SendTask) XXX_DiscardUnknown() + func (m *SendTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SendTask) XXX_Merge(src proto.Message) + func (m *SendTask) XXX_Size() int + func (m *SendTask) XXX_Unmarshal(b []byte) error + type SendTasksReply struct + Codes []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SendTasksReply) Descriptor() ([]byte, []int) + func (*SendTasksReply) ProtoMessage() + func (m *SendTasksReply) GetCodes() []string + func (m *SendTasksReply) Reset() + func (m *SendTasksReply) String() string + func (m *SendTasksReply) XXX_DiscardUnknown() + func (m *SendTasksReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SendTasksReply) XXX_Merge(src proto.Message) + func (m *SendTasksReply) XXX_Size() int + func (m *SendTasksReply) XXX_Unmarshal(b []byte) error + type SendTasksRequest struct + Project string + QueueName string + Tasks []*SendTask + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SendTasksRequest) Descriptor() ([]byte, []int) + func (*SendTasksRequest) ProtoMessage() + func (m *SendTasksRequest) GetProject() string + func (m *SendTasksRequest) GetQueueName() string + func (m *SendTasksRequest) GetTasks() []*SendTask + func (m *SendTasksRequest) Reset() + func (m *SendTasksRequest) String() string + func (m *SendTasksRequest) XXX_DiscardUnknown() + func (m *SendTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SendTasksRequest) XXX_Merge(src proto.Message) + func (m *SendTasksRequest) XXX_Size() int + func (m *SendTasksRequest) XXX_Unmarshal(b []byte) error + type Task struct + Code string + Created *timestamp.Timestamp + MinEta *timestamp.Timestamp + Payload []byte + Project string + QueueName string + Retry int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Task) Descriptor() ([]byte, []int) + func (*Task) ProtoMessage() + func (m *Task) GetCode() string + func (m *Task) GetCreated() *timestamp.Timestamp + func (m *Task) GetMinEta() *timestamp.Timestamp + func (m *Task) GetPayload() []byte + func (m *Task) GetProject() string + func (m *Task) GetQueueName() string + func (m *Task) GetRetry() int32 + func (m *Task) Reset() + func (m *Task) String() string + func (m *Task) XXX_DiscardUnknown() + func (m *Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Task) XXX_Merge(src proto.Message) + func (m *Task) XXX_Size() int + func (m *Task) XXX_Unmarshal(b []byte) error
Go to main page