Documentation ¶
Overview ¶
Package rpc is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- func RegisterQProxyHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQProxyHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QProxyClient) error
- func RegisterQProxyHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQProxyServer(s *grpc.Server, srv QProxyServer)
- type AckMessagesRequest
- func (*AckMessagesRequest) Descriptor() ([]byte, []int)
- func (m *AckMessagesRequest) GetQueueId() *QueueId
- func (m *AckMessagesRequest) GetRPCTimeout() int64
- func (m *AckMessagesRequest) GetReceipts() []*MessageReceipt
- func (j *AckMessagesRequest) MarshalJSON() ([]byte, error)
- func (j *AckMessagesRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *AckMessagesRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*AckMessagesRequest) ProtoMessage()
- func (m *AckMessagesRequest) Reset()
- func (m *AckMessagesRequest) String() string
- func (j *AckMessagesRequest) UnmarshalJSON(input []byte) error
- func (j *AckMessagesRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *AckMessagesRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *AckMessagesRequest) XXX_DiscardUnknown()
- func (m *AckMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *AckMessagesRequest) XXX_Merge(src proto.Message)
- func (m *AckMessagesRequest) XXX_Size() int
- func (m *AckMessagesRequest) XXX_Unmarshal(b []byte) error
- type AckMessagesResponse
- func (*AckMessagesResponse) Descriptor() ([]byte, []int)
- func (m *AckMessagesResponse) GetFailed() []*MessageReceipt
- func (j *AckMessagesResponse) MarshalJSON() ([]byte, error)
- func (j *AckMessagesResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *AckMessagesResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*AckMessagesResponse) ProtoMessage()
- func (m *AckMessagesResponse) Reset()
- func (m *AckMessagesResponse) String() string
- func (j *AckMessagesResponse) UnmarshalJSON(input []byte) error
- func (j *AckMessagesResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *AckMessagesResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *AckMessagesResponse) XXX_DiscardUnknown()
- func (m *AckMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *AckMessagesResponse) XXX_Merge(src proto.Message)
- func (m *AckMessagesResponse) XXX_Size() int
- func (m *AckMessagesResponse) XXX_Unmarshal(b []byte) error
- type CreateQueueRequest
- func (*CreateQueueRequest) Descriptor() ([]byte, []int)
- func (m *CreateQueueRequest) GetAttributes() map[string]string
- func (m *CreateQueueRequest) GetId() *QueueId
- func (m *CreateQueueRequest) GetRPCTimeout() int64
- func (j *CreateQueueRequest) MarshalJSON() ([]byte, error)
- func (j *CreateQueueRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *CreateQueueRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*CreateQueueRequest) ProtoMessage()
- func (m *CreateQueueRequest) Reset()
- func (m *CreateQueueRequest) String() string
- func (j *CreateQueueRequest) UnmarshalJSON(input []byte) error
- func (j *CreateQueueRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *CreateQueueRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *CreateQueueRequest) XXX_DiscardUnknown()
- func (m *CreateQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CreateQueueRequest) XXX_Merge(src proto.Message)
- func (m *CreateQueueRequest) XXX_Size() int
- func (m *CreateQueueRequest) XXX_Unmarshal(b []byte) error
- type CreateQueueResponse
- func (*CreateQueueResponse) Descriptor() ([]byte, []int)
- func (j *CreateQueueResponse) MarshalJSON() ([]byte, error)
- func (j *CreateQueueResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *CreateQueueResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*CreateQueueResponse) ProtoMessage()
- func (m *CreateQueueResponse) Reset()
- func (m *CreateQueueResponse) String() string
- func (j *CreateQueueResponse) UnmarshalJSON(input []byte) error
- func (j *CreateQueueResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *CreateQueueResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *CreateQueueResponse) XXX_DiscardUnknown()
- func (m *CreateQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CreateQueueResponse) XXX_Merge(src proto.Message)
- func (m *CreateQueueResponse) XXX_Size() int
- func (m *CreateQueueResponse) XXX_Unmarshal(b []byte) error
- type DeleteQueueRequest
- func (*DeleteQueueRequest) Descriptor() ([]byte, []int)
- func (m *DeleteQueueRequest) GetId() *QueueId
- func (m *DeleteQueueRequest) GetRPCTimeout() int64
- func (j *DeleteQueueRequest) MarshalJSON() ([]byte, error)
- func (j *DeleteQueueRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *DeleteQueueRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*DeleteQueueRequest) ProtoMessage()
- func (m *DeleteQueueRequest) Reset()
- func (m *DeleteQueueRequest) String() string
- func (j *DeleteQueueRequest) UnmarshalJSON(input []byte) error
- func (j *DeleteQueueRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *DeleteQueueRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *DeleteQueueRequest) XXX_DiscardUnknown()
- func (m *DeleteQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DeleteQueueRequest) XXX_Merge(src proto.Message)
- func (m *DeleteQueueRequest) XXX_Size() int
- func (m *DeleteQueueRequest) XXX_Unmarshal(b []byte) error
- type DeleteQueueResponse
- func (*DeleteQueueResponse) Descriptor() ([]byte, []int)
- func (j *DeleteQueueResponse) MarshalJSON() ([]byte, error)
- func (j *DeleteQueueResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (*DeleteQueueResponse) ProtoMessage()
- func (m *DeleteQueueResponse) Reset()
- func (m *DeleteQueueResponse) String() string
- func (j *DeleteQueueResponse) UnmarshalJSON(input []byte) error
- func (j *DeleteQueueResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (m *DeleteQueueResponse) XXX_DiscardUnknown()
- func (m *DeleteQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DeleteQueueResponse) XXX_Merge(src proto.Message)
- func (m *DeleteQueueResponse) XXX_Size() int
- func (m *DeleteQueueResponse) XXX_Unmarshal(b []byte) error
- type FailedPublish
- func (*FailedPublish) Descriptor() ([]byte, []int)
- func (m *FailedPublish) GetErrorMessage() string
- func (m *FailedPublish) GetIndex() int64
- func (j *FailedPublish) MarshalJSON() ([]byte, error)
- func (j *FailedPublish) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *FailedPublish) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*FailedPublish) ProtoMessage()
- func (m *FailedPublish) Reset()
- func (m *FailedPublish) String() string
- func (j *FailedPublish) UnmarshalJSON(input []byte) error
- func (j *FailedPublish) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *FailedPublish) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *FailedPublish) XXX_DiscardUnknown()
- func (m *FailedPublish) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *FailedPublish) XXX_Merge(src proto.Message)
- func (m *FailedPublish) XXX_Size() int
- func (m *FailedPublish) XXX_Unmarshal(b []byte) error
- type GetMessagesRequest
- func (*GetMessagesRequest) Descriptor() ([]byte, []int)
- func (m *GetMessagesRequest) GetAckDeadlineSeconds() int64
- func (m *GetMessagesRequest) GetLongPollSeconds() int64
- func (m *GetMessagesRequest) GetMaxMessages() int64
- func (m *GetMessagesRequest) GetQueueId() *QueueId
- func (m *GetMessagesRequest) GetRPCTimeout() int64
- func (j *GetMessagesRequest) MarshalJSON() ([]byte, error)
- func (j *GetMessagesRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *GetMessagesRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*GetMessagesRequest) ProtoMessage()
- func (m *GetMessagesRequest) Reset()
- func (m *GetMessagesRequest) String() string
- func (j *GetMessagesRequest) UnmarshalJSON(input []byte) error
- func (j *GetMessagesRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *GetMessagesRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *GetMessagesRequest) XXX_DiscardUnknown()
- func (m *GetMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetMessagesRequest) XXX_Merge(src proto.Message)
- func (m *GetMessagesRequest) XXX_Size() int
- func (m *GetMessagesRequest) XXX_Unmarshal(b []byte) error
- type GetMessagesResponse
- func (*GetMessagesResponse) Descriptor() ([]byte, []int)
- func (m *GetMessagesResponse) GetMessages() []*Message
- func (j *GetMessagesResponse) MarshalJSON() ([]byte, error)
- func (j *GetMessagesResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *GetMessagesResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*GetMessagesResponse) ProtoMessage()
- func (m *GetMessagesResponse) Reset()
- func (m *GetMessagesResponse) String() string
- func (j *GetMessagesResponse) UnmarshalJSON(input []byte) error
- func (j *GetMessagesResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *GetMessagesResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *GetMessagesResponse) XXX_DiscardUnknown()
- func (m *GetMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetMessagesResponse) XXX_Merge(src proto.Message)
- func (m *GetMessagesResponse) XXX_Size() int
- func (m *GetMessagesResponse) XXX_Unmarshal(b []byte) error
- type GetQueueRequest
- func (*GetQueueRequest) Descriptor() ([]byte, []int)
- func (m *GetQueueRequest) GetId() *QueueId
- func (m *GetQueueRequest) GetRPCTimeout() int64
- func (j *GetQueueRequest) MarshalJSON() ([]byte, error)
- func (j *GetQueueRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *GetQueueRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*GetQueueRequest) ProtoMessage()
- func (m *GetQueueRequest) Reset()
- func (m *GetQueueRequest) String() string
- func (j *GetQueueRequest) UnmarshalJSON(input []byte) error
- func (j *GetQueueRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *GetQueueRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *GetQueueRequest) XXX_DiscardUnknown()
- func (m *GetQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetQueueRequest) XXX_Merge(src proto.Message)
- func (m *GetQueueRequest) XXX_Size() int
- func (m *GetQueueRequest) XXX_Unmarshal(b []byte) error
- type GetQueueResponse
- func (*GetQueueResponse) Descriptor() ([]byte, []int)
- func (m *GetQueueResponse) GetAttributes() map[string]string
- func (j *GetQueueResponse) MarshalJSON() ([]byte, error)
- func (j *GetQueueResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *GetQueueResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*GetQueueResponse) ProtoMessage()
- func (m *GetQueueResponse) Reset()
- func (m *GetQueueResponse) String() string
- func (j *GetQueueResponse) UnmarshalJSON(input []byte) error
- func (j *GetQueueResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *GetQueueResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *GetQueueResponse) XXX_DiscardUnknown()
- func (m *GetQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetQueueResponse) XXX_Merge(src proto.Message)
- func (m *GetQueueResponse) XXX_Size() int
- func (m *GetQueueResponse) XXX_Unmarshal(b []byte) error
- type HealthcheckRequest
- func (*HealthcheckRequest) Descriptor() ([]byte, []int)
- func (j *HealthcheckRequest) MarshalJSON() ([]byte, error)
- func (j *HealthcheckRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *HealthcheckRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*HealthcheckRequest) ProtoMessage()
- func (m *HealthcheckRequest) Reset()
- func (m *HealthcheckRequest) String() string
- func (j *HealthcheckRequest) UnmarshalJSON(input []byte) error
- func (j *HealthcheckRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *HealthcheckRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *HealthcheckRequest) XXX_DiscardUnknown()
- func (m *HealthcheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *HealthcheckRequest) XXX_Merge(src proto.Message)
- func (m *HealthcheckRequest) XXX_Size() int
- func (m *HealthcheckRequest) XXX_Unmarshal(b []byte) error
- type HealthcheckResponse
- func (*HealthcheckResponse) Descriptor() ([]byte, []int)
- func (j *HealthcheckResponse) MarshalJSON() ([]byte, error)
- func (j *HealthcheckResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *HealthcheckResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*HealthcheckResponse) ProtoMessage()
- func (m *HealthcheckResponse) Reset()
- func (m *HealthcheckResponse) String() string
- func (j *HealthcheckResponse) UnmarshalJSON(input []byte) error
- func (j *HealthcheckResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *HealthcheckResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *HealthcheckResponse) XXX_DiscardUnknown()
- func (m *HealthcheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *HealthcheckResponse) XXX_Merge(src proto.Message)
- func (m *HealthcheckResponse) XXX_Size() int
- func (m *HealthcheckResponse) XXX_Unmarshal(b []byte) error
- type ListQueuesRequest
- func (*ListQueuesRequest) Descriptor() ([]byte, []int)
- func (m *ListQueuesRequest) GetFilter() string
- func (m *ListQueuesRequest) GetNamespace() string
- func (m *ListQueuesRequest) GetRPCTimeout() int64
- func (j *ListQueuesRequest) MarshalJSON() ([]byte, error)
- func (j *ListQueuesRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *ListQueuesRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*ListQueuesRequest) ProtoMessage()
- func (m *ListQueuesRequest) Reset()
- func (m *ListQueuesRequest) String() string
- func (j *ListQueuesRequest) UnmarshalJSON(input []byte) error
- func (j *ListQueuesRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *ListQueuesRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *ListQueuesRequest) XXX_DiscardUnknown()
- func (m *ListQueuesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ListQueuesRequest) XXX_Merge(src proto.Message)
- func (m *ListQueuesRequest) XXX_Size() int
- func (m *ListQueuesRequest) XXX_Unmarshal(b []byte) error
- type ListQueuesResponse
- func (*ListQueuesResponse) Descriptor() ([]byte, []int)
- func (m *ListQueuesResponse) GetQueues() []*QueueId
- func (j *ListQueuesResponse) MarshalJSON() ([]byte, error)
- func (j *ListQueuesResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *ListQueuesResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*ListQueuesResponse) ProtoMessage()
- func (m *ListQueuesResponse) Reset()
- func (m *ListQueuesResponse) String() string
- func (j *ListQueuesResponse) UnmarshalJSON(input []byte) error
- func (j *ListQueuesResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *ListQueuesResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *ListQueuesResponse) XXX_DiscardUnknown()
- func (m *ListQueuesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ListQueuesResponse) XXX_Merge(src proto.Message)
- func (m *ListQueuesResponse) XXX_Size() int
- func (m *ListQueuesResponse) XXX_Unmarshal(b []byte) error
- type Message
- func (*Message) Descriptor() ([]byte, []int)
- func (m *Message) GetAttributes() map[string]string
- func (m *Message) GetData() string
- func (m *Message) GetReceipt() *MessageReceipt
- func (j *Message) MarshalJSON() ([]byte, error)
- func (j *Message) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *Message) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*Message) ProtoMessage()
- func (m *Message) Reset()
- func (m *Message) String() string
- func (j *Message) UnmarshalJSON(input []byte) error
- func (j *Message) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *Message) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *Message) XXX_DiscardUnknown()
- func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Message) XXX_Merge(src proto.Message)
- func (m *Message) XXX_Size() int
- func (m *Message) XXX_Unmarshal(b []byte) error
- type MessageReceipt
- func (*MessageReceipt) Descriptor() ([]byte, []int)
- func (m *MessageReceipt) GetErrorMessage() string
- func (m *MessageReceipt) GetId() string
- func (j *MessageReceipt) MarshalJSON() ([]byte, error)
- func (j *MessageReceipt) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *MessageReceipt) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*MessageReceipt) ProtoMessage()
- func (m *MessageReceipt) Reset()
- func (m *MessageReceipt) String() string
- func (j *MessageReceipt) UnmarshalJSON(input []byte) error
- func (j *MessageReceipt) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *MessageReceipt) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *MessageReceipt) XXX_DiscardUnknown()
- func (m *MessageReceipt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *MessageReceipt) XXX_Merge(src proto.Message)
- func (m *MessageReceipt) XXX_Size() int
- func (m *MessageReceipt) XXX_Unmarshal(b []byte) error
- type ModifyAckDeadlineRequest
- func (*ModifyAckDeadlineRequest) Descriptor() ([]byte, []int)
- func (m *ModifyAckDeadlineRequest) GetAckDeadlineSeconds() int64
- func (m *ModifyAckDeadlineRequest) GetQueueId() *QueueId
- func (m *ModifyAckDeadlineRequest) GetRPCTimeout() int64
- func (m *ModifyAckDeadlineRequest) GetReceipt() *MessageReceipt
- func (j *ModifyAckDeadlineRequest) MarshalJSON() ([]byte, error)
- func (j *ModifyAckDeadlineRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *ModifyAckDeadlineRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*ModifyAckDeadlineRequest) ProtoMessage()
- func (m *ModifyAckDeadlineRequest) Reset()
- func (m *ModifyAckDeadlineRequest) String() string
- func (j *ModifyAckDeadlineRequest) UnmarshalJSON(input []byte) error
- func (j *ModifyAckDeadlineRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *ModifyAckDeadlineRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *ModifyAckDeadlineRequest) XXX_DiscardUnknown()
- func (m *ModifyAckDeadlineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ModifyAckDeadlineRequest) XXX_Merge(src proto.Message)
- func (m *ModifyAckDeadlineRequest) XXX_Size() int
- func (m *ModifyAckDeadlineRequest) XXX_Unmarshal(b []byte) error
- type ModifyAckDeadlineResponse
- func (*ModifyAckDeadlineResponse) Descriptor() ([]byte, []int)
- func (j *ModifyAckDeadlineResponse) MarshalJSON() ([]byte, error)
- func (j *ModifyAckDeadlineResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *ModifyAckDeadlineResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*ModifyAckDeadlineResponse) ProtoMessage()
- func (m *ModifyAckDeadlineResponse) Reset()
- func (m *ModifyAckDeadlineResponse) String() string
- func (j *ModifyAckDeadlineResponse) UnmarshalJSON(input []byte) error
- func (j *ModifyAckDeadlineResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *ModifyAckDeadlineResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *ModifyAckDeadlineResponse) XXX_DiscardUnknown()
- func (m *ModifyAckDeadlineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ModifyAckDeadlineResponse) XXX_Merge(src proto.Message)
- func (m *ModifyAckDeadlineResponse) XXX_Size() int
- func (m *ModifyAckDeadlineResponse) XXX_Unmarshal(b []byte) error
- type ModifyQueueRequest
- func (*ModifyQueueRequest) Descriptor() ([]byte, []int)
- func (m *ModifyQueueRequest) GetAttributes() map[string]string
- func (m *ModifyQueueRequest) GetId() *QueueId
- func (m *ModifyQueueRequest) GetRPCTimeout() int64
- func (j *ModifyQueueRequest) MarshalJSON() ([]byte, error)
- func (j *ModifyQueueRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *ModifyQueueRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*ModifyQueueRequest) ProtoMessage()
- func (m *ModifyQueueRequest) Reset()
- func (m *ModifyQueueRequest) String() string
- func (j *ModifyQueueRequest) UnmarshalJSON(input []byte) error
- func (j *ModifyQueueRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *ModifyQueueRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *ModifyQueueRequest) XXX_DiscardUnknown()
- func (m *ModifyQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ModifyQueueRequest) XXX_Merge(src proto.Message)
- func (m *ModifyQueueRequest) XXX_Size() int
- func (m *ModifyQueueRequest) XXX_Unmarshal(b []byte) error
- type ModifyQueueResponse
- func (*ModifyQueueResponse) Descriptor() ([]byte, []int)
- func (j *ModifyQueueResponse) MarshalJSON() ([]byte, error)
- func (j *ModifyQueueResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (*ModifyQueueResponse) ProtoMessage()
- func (m *ModifyQueueResponse) Reset()
- func (m *ModifyQueueResponse) String() string
- func (j *ModifyQueueResponse) UnmarshalJSON(input []byte) error
- func (j *ModifyQueueResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (m *ModifyQueueResponse) XXX_DiscardUnknown()
- func (m *ModifyQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ModifyQueueResponse) XXX_Merge(src proto.Message)
- func (m *ModifyQueueResponse) XXX_Size() int
- func (m *ModifyQueueResponse) XXX_Unmarshal(b []byte) error
- type PublishMessagesRequest
- func (*PublishMessagesRequest) Descriptor() ([]byte, []int)
- func (m *PublishMessagesRequest) GetMessages() []*Message
- func (m *PublishMessagesRequest) GetQueueId() *QueueId
- func (m *PublishMessagesRequest) GetRPCTimeout() int64
- func (j *PublishMessagesRequest) MarshalJSON() ([]byte, error)
- func (j *PublishMessagesRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *PublishMessagesRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*PublishMessagesRequest) ProtoMessage()
- func (m *PublishMessagesRequest) Reset()
- func (m *PublishMessagesRequest) String() string
- func (j *PublishMessagesRequest) UnmarshalJSON(input []byte) error
- func (j *PublishMessagesRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *PublishMessagesRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *PublishMessagesRequest) XXX_DiscardUnknown()
- func (m *PublishMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *PublishMessagesRequest) XXX_Merge(src proto.Message)
- func (m *PublishMessagesRequest) XXX_Size() int
- func (m *PublishMessagesRequest) XXX_Unmarshal(b []byte) error
- type PublishMessagesResponse
- func (*PublishMessagesResponse) Descriptor() ([]byte, []int)
- func (m *PublishMessagesResponse) GetFailed() []*FailedPublish
- func (j *PublishMessagesResponse) MarshalJSON() ([]byte, error)
- func (j *PublishMessagesResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *PublishMessagesResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*PublishMessagesResponse) ProtoMessage()
- func (m *PublishMessagesResponse) Reset()
- func (m *PublishMessagesResponse) String() string
- func (j *PublishMessagesResponse) UnmarshalJSON(input []byte) error
- func (j *PublishMessagesResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *PublishMessagesResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *PublishMessagesResponse) XXX_DiscardUnknown()
- func (m *PublishMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *PublishMessagesResponse) XXX_Merge(src proto.Message)
- func (m *PublishMessagesResponse) XXX_Size() int
- func (m *PublishMessagesResponse) XXX_Unmarshal(b []byte) error
- type PurgeQueueRequest
- func (*PurgeQueueRequest) Descriptor() ([]byte, []int)
- func (m *PurgeQueueRequest) GetId() *QueueId
- func (m *PurgeQueueRequest) GetRPCTimeout() int64
- func (j *PurgeQueueRequest) MarshalJSON() ([]byte, error)
- func (j *PurgeQueueRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *PurgeQueueRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*PurgeQueueRequest) ProtoMessage()
- func (m *PurgeQueueRequest) Reset()
- func (m *PurgeQueueRequest) String() string
- func (j *PurgeQueueRequest) UnmarshalJSON(input []byte) error
- func (j *PurgeQueueRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *PurgeQueueRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *PurgeQueueRequest) XXX_DiscardUnknown()
- func (m *PurgeQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *PurgeQueueRequest) XXX_Merge(src proto.Message)
- func (m *PurgeQueueRequest) XXX_Size() int
- func (m *PurgeQueueRequest) XXX_Unmarshal(b []byte) error
- type PurgeQueueResponse
- func (*PurgeQueueResponse) Descriptor() ([]byte, []int)
- func (j *PurgeQueueResponse) MarshalJSON() ([]byte, error)
- func (j *PurgeQueueResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (*PurgeQueueResponse) ProtoMessage()
- func (m *PurgeQueueResponse) Reset()
- func (m *PurgeQueueResponse) String() string
- func (j *PurgeQueueResponse) UnmarshalJSON(input []byte) error
- func (j *PurgeQueueResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (m *PurgeQueueResponse) XXX_DiscardUnknown()
- func (m *PurgeQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *PurgeQueueResponse) XXX_Merge(src proto.Message)
- func (m *PurgeQueueResponse) XXX_Size() int
- func (m *PurgeQueueResponse) XXX_Unmarshal(b []byte) error
- type QProxyClient
- type QProxyServer
- type QProxy_ListQueuesClient
- type QProxy_ListQueuesServer
- type QueueId
- func (*QueueId) Descriptor() ([]byte, []int)
- func (m *QueueId) GetName() string
- func (m *QueueId) GetNamespace() string
- func (j *QueueId) MarshalJSON() ([]byte, error)
- func (j *QueueId) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (j *QueueId) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
- func (*QueueId) ProtoMessage()
- func (m *QueueId) Reset()
- func (m *QueueId) String() string
- func (j *QueueId) UnmarshalJSON(input []byte) error
- func (j *QueueId) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (j *QueueId) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
- func (m *QueueId) XXX_DiscardUnknown()
- func (m *QueueId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *QueueId) XXX_Merge(src proto.Message)
- func (m *QueueId) XXX_Size() int
- func (m *QueueId) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterQProxyHandler ¶
RegisterQProxyHandler registers the http handlers for service QProxy to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterQProxyHandlerClient ¶
func RegisterQProxyHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QProxyClient) error
RegisterQProxyHandlerClient registers the http handlers for service QProxy to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QProxyClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QProxyClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QProxyClient" to call the correct interceptors.
func RegisterQProxyHandlerFromEndpoint ¶
func RegisterQProxyHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterQProxyHandlerFromEndpoint is same as RegisterQProxyHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterQProxyServer ¶
func RegisterQProxyServer(s *grpc.Server, srv QProxyServer)
Types ¶
type AckMessagesRequest ¶
type AckMessagesRequest struct { QueueId *QueueId `protobuf:"bytes,1,opt,name=QueueId,proto3" json:"QueueId"` Receipts []*MessageReceipt `protobuf:"bytes,2,rep,name=Receipts,proto3" json:"Receipts"` RPCTimeout int64 `protobuf:"varint,100,opt,name=RPCTimeout,proto3" json:"RPCTimeout"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AckMessagesRequest) Descriptor ¶
func (*AckMessagesRequest) Descriptor() ([]byte, []int)
func (*AckMessagesRequest) GetQueueId ¶
func (m *AckMessagesRequest) GetQueueId() *QueueId
func (*AckMessagesRequest) GetRPCTimeout ¶
func (m *AckMessagesRequest) GetRPCTimeout() int64
func (*AckMessagesRequest) GetReceipts ¶
func (m *AckMessagesRequest) GetReceipts() []*MessageReceipt
func (*AckMessagesRequest) MarshalJSON ¶
func (j *AckMessagesRequest) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*AckMessagesRequest) MarshalJSONBuf ¶
func (j *AckMessagesRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*AckMessagesRequest) MarshalJSONPB ¶
func (j *AckMessagesRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*AckMessagesRequest) ProtoMessage ¶
func (*AckMessagesRequest) ProtoMessage()
func (*AckMessagesRequest) Reset ¶
func (m *AckMessagesRequest) Reset()
func (*AckMessagesRequest) String ¶
func (m *AckMessagesRequest) String() string
func (*AckMessagesRequest) UnmarshalJSON ¶
func (j *AckMessagesRequest) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*AckMessagesRequest) UnmarshalJSONFFLexer ¶
func (j *AckMessagesRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*AckMessagesRequest) UnmarshalJSONPB ¶
func (j *AckMessagesRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*AckMessagesRequest) XXX_DiscardUnknown ¶
func (m *AckMessagesRequest) XXX_DiscardUnknown()
func (*AckMessagesRequest) XXX_Marshal ¶
func (m *AckMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AckMessagesRequest) XXX_Merge ¶
func (dst *AckMessagesRequest) XXX_Merge(src proto.Message)
func (*AckMessagesRequest) XXX_Size ¶
func (m *AckMessagesRequest) XXX_Size() int
func (*AckMessagesRequest) XXX_Unmarshal ¶
func (m *AckMessagesRequest) XXX_Unmarshal(b []byte) error
type AckMessagesResponse ¶
type AckMessagesResponse struct { // Return the receipts that failed to ack Failed []*MessageReceipt `protobuf:"bytes,1,rep,name=Failed,proto3" json:"Failed"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AckMessagesResponse) Descriptor ¶
func (*AckMessagesResponse) Descriptor() ([]byte, []int)
func (*AckMessagesResponse) GetFailed ¶
func (m *AckMessagesResponse) GetFailed() []*MessageReceipt
func (*AckMessagesResponse) MarshalJSON ¶
func (j *AckMessagesResponse) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*AckMessagesResponse) MarshalJSONBuf ¶
func (j *AckMessagesResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*AckMessagesResponse) MarshalJSONPB ¶
func (j *AckMessagesResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*AckMessagesResponse) ProtoMessage ¶
func (*AckMessagesResponse) ProtoMessage()
func (*AckMessagesResponse) Reset ¶
func (m *AckMessagesResponse) Reset()
func (*AckMessagesResponse) String ¶
func (m *AckMessagesResponse) String() string
func (*AckMessagesResponse) UnmarshalJSON ¶
func (j *AckMessagesResponse) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*AckMessagesResponse) UnmarshalJSONFFLexer ¶
func (j *AckMessagesResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*AckMessagesResponse) UnmarshalJSONPB ¶
func (j *AckMessagesResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*AckMessagesResponse) XXX_DiscardUnknown ¶
func (m *AckMessagesResponse) XXX_DiscardUnknown()
func (*AckMessagesResponse) XXX_Marshal ¶
func (m *AckMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AckMessagesResponse) XXX_Merge ¶
func (dst *AckMessagesResponse) XXX_Merge(src proto.Message)
func (*AckMessagesResponse) XXX_Size ¶
func (m *AckMessagesResponse) XXX_Size() int
func (*AckMessagesResponse) XXX_Unmarshal ¶
func (m *AckMessagesResponse) XXX_Unmarshal(b []byte) error
type CreateQueueRequest ¶
type CreateQueueRequest struct { Id *QueueId `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id"` Attributes map[string]string `` /* 151-byte string literal not displayed */ RPCTimeout int64 `protobuf:"varint,100,opt,name=RPCTimeout,proto3" json:"RPCTimeout"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateQueueRequest) Descriptor ¶
func (*CreateQueueRequest) Descriptor() ([]byte, []int)
func (*CreateQueueRequest) GetAttributes ¶
func (m *CreateQueueRequest) GetAttributes() map[string]string
func (*CreateQueueRequest) GetId ¶
func (m *CreateQueueRequest) GetId() *QueueId
func (*CreateQueueRequest) GetRPCTimeout ¶
func (m *CreateQueueRequest) GetRPCTimeout() int64
func (*CreateQueueRequest) MarshalJSON ¶
func (j *CreateQueueRequest) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*CreateQueueRequest) MarshalJSONBuf ¶
func (j *CreateQueueRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*CreateQueueRequest) MarshalJSONPB ¶
func (j *CreateQueueRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*CreateQueueRequest) ProtoMessage ¶
func (*CreateQueueRequest) ProtoMessage()
func (*CreateQueueRequest) Reset ¶
func (m *CreateQueueRequest) Reset()
func (*CreateQueueRequest) String ¶
func (m *CreateQueueRequest) String() string
func (*CreateQueueRequest) UnmarshalJSON ¶
func (j *CreateQueueRequest) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*CreateQueueRequest) UnmarshalJSONFFLexer ¶
func (j *CreateQueueRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*CreateQueueRequest) UnmarshalJSONPB ¶
func (j *CreateQueueRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*CreateQueueRequest) XXX_DiscardUnknown ¶
func (m *CreateQueueRequest) XXX_DiscardUnknown()
func (*CreateQueueRequest) XXX_Marshal ¶
func (m *CreateQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateQueueRequest) XXX_Merge ¶
func (dst *CreateQueueRequest) XXX_Merge(src proto.Message)
func (*CreateQueueRequest) XXX_Size ¶
func (m *CreateQueueRequest) XXX_Size() int
func (*CreateQueueRequest) XXX_Unmarshal ¶
func (m *CreateQueueRequest) XXX_Unmarshal(b []byte) error
type CreateQueueResponse ¶
type CreateQueueResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateQueueResponse) Descriptor ¶
func (*CreateQueueResponse) Descriptor() ([]byte, []int)
func (*CreateQueueResponse) MarshalJSON ¶
func (j *CreateQueueResponse) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*CreateQueueResponse) MarshalJSONBuf ¶
func (j *CreateQueueResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*CreateQueueResponse) MarshalJSONPB ¶
func (j *CreateQueueResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*CreateQueueResponse) ProtoMessage ¶
func (*CreateQueueResponse) ProtoMessage()
func (*CreateQueueResponse) Reset ¶
func (m *CreateQueueResponse) Reset()
func (*CreateQueueResponse) String ¶
func (m *CreateQueueResponse) String() string
func (*CreateQueueResponse) UnmarshalJSON ¶
func (j *CreateQueueResponse) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*CreateQueueResponse) UnmarshalJSONFFLexer ¶
func (j *CreateQueueResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*CreateQueueResponse) UnmarshalJSONPB ¶
func (j *CreateQueueResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*CreateQueueResponse) XXX_DiscardUnknown ¶
func (m *CreateQueueResponse) XXX_DiscardUnknown()
func (*CreateQueueResponse) XXX_Marshal ¶
func (m *CreateQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateQueueResponse) XXX_Merge ¶
func (dst *CreateQueueResponse) XXX_Merge(src proto.Message)
func (*CreateQueueResponse) XXX_Size ¶
func (m *CreateQueueResponse) XXX_Size() int
func (*CreateQueueResponse) XXX_Unmarshal ¶
func (m *CreateQueueResponse) XXX_Unmarshal(b []byte) error
type DeleteQueueRequest ¶
type DeleteQueueRequest struct { Id *QueueId `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id"` RPCTimeout int64 `protobuf:"varint,100,opt,name=RPCTimeout,proto3" json:"RPCTimeout"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteQueueRequest) Descriptor ¶
func (*DeleteQueueRequest) Descriptor() ([]byte, []int)
func (*DeleteQueueRequest) GetId ¶
func (m *DeleteQueueRequest) GetId() *QueueId
func (*DeleteQueueRequest) GetRPCTimeout ¶
func (m *DeleteQueueRequest) GetRPCTimeout() int64
func (*DeleteQueueRequest) MarshalJSON ¶
func (j *DeleteQueueRequest) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*DeleteQueueRequest) MarshalJSONBuf ¶
func (j *DeleteQueueRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*DeleteQueueRequest) MarshalJSONPB ¶
func (j *DeleteQueueRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*DeleteQueueRequest) ProtoMessage ¶
func (*DeleteQueueRequest) ProtoMessage()
func (*DeleteQueueRequest) Reset ¶
func (m *DeleteQueueRequest) Reset()
func (*DeleteQueueRequest) String ¶
func (m *DeleteQueueRequest) String() string
func (*DeleteQueueRequest) UnmarshalJSON ¶
func (j *DeleteQueueRequest) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*DeleteQueueRequest) UnmarshalJSONFFLexer ¶
func (j *DeleteQueueRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*DeleteQueueRequest) UnmarshalJSONPB ¶
func (j *DeleteQueueRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*DeleteQueueRequest) XXX_DiscardUnknown ¶
func (m *DeleteQueueRequest) XXX_DiscardUnknown()
func (*DeleteQueueRequest) XXX_Marshal ¶
func (m *DeleteQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteQueueRequest) XXX_Merge ¶
func (dst *DeleteQueueRequest) XXX_Merge(src proto.Message)
func (*DeleteQueueRequest) XXX_Size ¶
func (m *DeleteQueueRequest) XXX_Size() int
func (*DeleteQueueRequest) XXX_Unmarshal ¶
func (m *DeleteQueueRequest) XXX_Unmarshal(b []byte) error
type DeleteQueueResponse ¶
type DeleteQueueResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteQueueResponse) Descriptor ¶
func (*DeleteQueueResponse) Descriptor() ([]byte, []int)
func (*DeleteQueueResponse) MarshalJSON ¶
func (j *DeleteQueueResponse) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*DeleteQueueResponse) MarshalJSONBuf ¶
func (j *DeleteQueueResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*DeleteQueueResponse) ProtoMessage ¶
func (*DeleteQueueResponse) ProtoMessage()
func (*DeleteQueueResponse) Reset ¶
func (m *DeleteQueueResponse) Reset()
func (*DeleteQueueResponse) String ¶
func (m *DeleteQueueResponse) String() string
func (*DeleteQueueResponse) UnmarshalJSON ¶
func (j *DeleteQueueResponse) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*DeleteQueueResponse) UnmarshalJSONFFLexer ¶
func (j *DeleteQueueResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*DeleteQueueResponse) XXX_DiscardUnknown ¶
func (m *DeleteQueueResponse) XXX_DiscardUnknown()
func (*DeleteQueueResponse) XXX_Marshal ¶
func (m *DeleteQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteQueueResponse) XXX_Merge ¶
func (dst *DeleteQueueResponse) XXX_Merge(src proto.Message)
func (*DeleteQueueResponse) XXX_Size ¶
func (m *DeleteQueueResponse) XXX_Size() int
func (*DeleteQueueResponse) XXX_Unmarshal ¶
func (m *DeleteQueueResponse) XXX_Unmarshal(b []byte) error
type FailedPublish ¶
type FailedPublish struct { Index int64 `protobuf:"varint,1,opt,name=Index,proto3" json:"Index"` ErrorMessage string `protobuf:"bytes,2,opt,name=ErrorMessage,proto3" json:"ErrorMessage"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FailedPublish) Descriptor ¶
func (*FailedPublish) Descriptor() ([]byte, []int)
func (*FailedPublish) GetErrorMessage ¶
func (m *FailedPublish) GetErrorMessage() string
func (*FailedPublish) GetIndex ¶
func (m *FailedPublish) GetIndex() int64
func (*FailedPublish) MarshalJSON ¶
func (j *FailedPublish) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*FailedPublish) MarshalJSONBuf ¶
func (j *FailedPublish) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*FailedPublish) MarshalJSONPB ¶
func (j *FailedPublish) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*FailedPublish) ProtoMessage ¶
func (*FailedPublish) ProtoMessage()
func (*FailedPublish) Reset ¶
func (m *FailedPublish) Reset()
func (*FailedPublish) String ¶
func (m *FailedPublish) String() string
func (*FailedPublish) UnmarshalJSON ¶
func (j *FailedPublish) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*FailedPublish) UnmarshalJSONFFLexer ¶
func (j *FailedPublish) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*FailedPublish) UnmarshalJSONPB ¶
func (j *FailedPublish) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*FailedPublish) XXX_DiscardUnknown ¶
func (m *FailedPublish) XXX_DiscardUnknown()
func (*FailedPublish) XXX_Marshal ¶
func (m *FailedPublish) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FailedPublish) XXX_Merge ¶
func (dst *FailedPublish) XXX_Merge(src proto.Message)
func (*FailedPublish) XXX_Size ¶
func (m *FailedPublish) XXX_Size() int
func (*FailedPublish) XXX_Unmarshal ¶
func (m *FailedPublish) XXX_Unmarshal(b []byte) error
type GetMessagesRequest ¶
type GetMessagesRequest struct { QueueId *QueueId `protobuf:"bytes,1,opt,name=QueueId,proto3" json:"QueueId"` // How long to poll for up to MaxMessages messages. 0 implies return immediately LongPollSeconds int64 `protobuf:"varint,2,opt,name=LongPollSeconds,proto3" json:"LongPollSeconds"` MaxMessages int64 `protobuf:"varint,3,opt,name=MaxMessages,proto3" json:"MaxMessages"` AckDeadlineSeconds int64 `protobuf:"varint,4,opt,name=AckDeadlineSeconds,proto3" json:"AckDeadlineSeconds"` RPCTimeout int64 `protobuf:"varint,100,opt,name=RPCTimeout,proto3" json:"RPCTimeout"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetMessagesRequest) Descriptor ¶
func (*GetMessagesRequest) Descriptor() ([]byte, []int)
func (*GetMessagesRequest) GetAckDeadlineSeconds ¶
func (m *GetMessagesRequest) GetAckDeadlineSeconds() int64
func (*GetMessagesRequest) GetLongPollSeconds ¶
func (m *GetMessagesRequest) GetLongPollSeconds() int64
func (*GetMessagesRequest) GetMaxMessages ¶
func (m *GetMessagesRequest) GetMaxMessages() int64
func (*GetMessagesRequest) GetQueueId ¶
func (m *GetMessagesRequest) GetQueueId() *QueueId
func (*GetMessagesRequest) GetRPCTimeout ¶
func (m *GetMessagesRequest) GetRPCTimeout() int64
func (*GetMessagesRequest) MarshalJSON ¶
func (j *GetMessagesRequest) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*GetMessagesRequest) MarshalJSONBuf ¶
func (j *GetMessagesRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*GetMessagesRequest) MarshalJSONPB ¶
func (j *GetMessagesRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*GetMessagesRequest) ProtoMessage ¶
func (*GetMessagesRequest) ProtoMessage()
func (*GetMessagesRequest) Reset ¶
func (m *GetMessagesRequest) Reset()
func (*GetMessagesRequest) String ¶
func (m *GetMessagesRequest) String() string
func (*GetMessagesRequest) UnmarshalJSON ¶
func (j *GetMessagesRequest) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*GetMessagesRequest) UnmarshalJSONFFLexer ¶
func (j *GetMessagesRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*GetMessagesRequest) UnmarshalJSONPB ¶
func (j *GetMessagesRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*GetMessagesRequest) XXX_DiscardUnknown ¶
func (m *GetMessagesRequest) XXX_DiscardUnknown()
func (*GetMessagesRequest) XXX_Marshal ¶
func (m *GetMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetMessagesRequest) XXX_Merge ¶
func (dst *GetMessagesRequest) XXX_Merge(src proto.Message)
func (*GetMessagesRequest) XXX_Size ¶
func (m *GetMessagesRequest) XXX_Size() int
func (*GetMessagesRequest) XXX_Unmarshal ¶
func (m *GetMessagesRequest) XXX_Unmarshal(b []byte) error
type GetMessagesResponse ¶
type GetMessagesResponse struct { Messages []*Message `protobuf:"bytes,1,rep,name=Messages,proto3" json:"Messages"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetMessagesResponse) Descriptor ¶
func (*GetMessagesResponse) Descriptor() ([]byte, []int)
func (*GetMessagesResponse) GetMessages ¶
func (m *GetMessagesResponse) GetMessages() []*Message
func (*GetMessagesResponse) MarshalJSON ¶
func (j *GetMessagesResponse) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*GetMessagesResponse) MarshalJSONBuf ¶
func (j *GetMessagesResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*GetMessagesResponse) MarshalJSONPB ¶
func (j *GetMessagesResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*GetMessagesResponse) ProtoMessage ¶
func (*GetMessagesResponse) ProtoMessage()
func (*GetMessagesResponse) Reset ¶
func (m *GetMessagesResponse) Reset()
func (*GetMessagesResponse) String ¶
func (m *GetMessagesResponse) String() string
func (*GetMessagesResponse) UnmarshalJSON ¶
func (j *GetMessagesResponse) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*GetMessagesResponse) UnmarshalJSONFFLexer ¶
func (j *GetMessagesResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*GetMessagesResponse) UnmarshalJSONPB ¶
func (j *GetMessagesResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*GetMessagesResponse) XXX_DiscardUnknown ¶
func (m *GetMessagesResponse) XXX_DiscardUnknown()
func (*GetMessagesResponse) XXX_Marshal ¶
func (m *GetMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetMessagesResponse) XXX_Merge ¶
func (dst *GetMessagesResponse) XXX_Merge(src proto.Message)
func (*GetMessagesResponse) XXX_Size ¶
func (m *GetMessagesResponse) XXX_Size() int
func (*GetMessagesResponse) XXX_Unmarshal ¶
func (m *GetMessagesResponse) XXX_Unmarshal(b []byte) error
type GetQueueRequest ¶
type GetQueueRequest struct { Id *QueueId `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id"` RPCTimeout int64 `protobuf:"varint,100,opt,name=RPCTimeout,proto3" json:"RPCTimeout"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetQueueRequest) Descriptor ¶
func (*GetQueueRequest) Descriptor() ([]byte, []int)
func (*GetQueueRequest) GetId ¶
func (m *GetQueueRequest) GetId() *QueueId
func (*GetQueueRequest) GetRPCTimeout ¶
func (m *GetQueueRequest) GetRPCTimeout() int64
func (*GetQueueRequest) MarshalJSON ¶
func (j *GetQueueRequest) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*GetQueueRequest) MarshalJSONBuf ¶
func (j *GetQueueRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*GetQueueRequest) MarshalJSONPB ¶
func (j *GetQueueRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*GetQueueRequest) ProtoMessage ¶
func (*GetQueueRequest) ProtoMessage()
func (*GetQueueRequest) Reset ¶
func (m *GetQueueRequest) Reset()
func (*GetQueueRequest) String ¶
func (m *GetQueueRequest) String() string
func (*GetQueueRequest) UnmarshalJSON ¶
func (j *GetQueueRequest) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*GetQueueRequest) UnmarshalJSONFFLexer ¶
func (j *GetQueueRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*GetQueueRequest) UnmarshalJSONPB ¶
func (j *GetQueueRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*GetQueueRequest) XXX_DiscardUnknown ¶
func (m *GetQueueRequest) XXX_DiscardUnknown()
func (*GetQueueRequest) XXX_Marshal ¶
func (m *GetQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetQueueRequest) XXX_Merge ¶
func (dst *GetQueueRequest) XXX_Merge(src proto.Message)
func (*GetQueueRequest) XXX_Size ¶
func (m *GetQueueRequest) XXX_Size() int
func (*GetQueueRequest) XXX_Unmarshal ¶
func (m *GetQueueRequest) XXX_Unmarshal(b []byte) error
type GetQueueResponse ¶
type GetQueueResponse struct { Attributes map[string]string `` /* 151-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetQueueResponse) Descriptor ¶
func (*GetQueueResponse) Descriptor() ([]byte, []int)
func (*GetQueueResponse) GetAttributes ¶
func (m *GetQueueResponse) GetAttributes() map[string]string
func (*GetQueueResponse) MarshalJSON ¶
func (j *GetQueueResponse) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*GetQueueResponse) MarshalJSONBuf ¶
func (j *GetQueueResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*GetQueueResponse) MarshalJSONPB ¶
func (j *GetQueueResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*GetQueueResponse) ProtoMessage ¶
func (*GetQueueResponse) ProtoMessage()
func (*GetQueueResponse) Reset ¶
func (m *GetQueueResponse) Reset()
func (*GetQueueResponse) String ¶
func (m *GetQueueResponse) String() string
func (*GetQueueResponse) UnmarshalJSON ¶
func (j *GetQueueResponse) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*GetQueueResponse) UnmarshalJSONFFLexer ¶
func (j *GetQueueResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*GetQueueResponse) UnmarshalJSONPB ¶
func (j *GetQueueResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*GetQueueResponse) XXX_DiscardUnknown ¶
func (m *GetQueueResponse) XXX_DiscardUnknown()
func (*GetQueueResponse) XXX_Marshal ¶
func (m *GetQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetQueueResponse) XXX_Merge ¶
func (dst *GetQueueResponse) XXX_Merge(src proto.Message)
func (*GetQueueResponse) XXX_Size ¶
func (m *GetQueueResponse) XXX_Size() int
func (*GetQueueResponse) XXX_Unmarshal ¶
func (m *GetQueueResponse) XXX_Unmarshal(b []byte) error
type HealthcheckRequest ¶
type HealthcheckRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HealthcheckRequest) Descriptor ¶
func (*HealthcheckRequest) Descriptor() ([]byte, []int)
func (*HealthcheckRequest) MarshalJSON ¶
func (j *HealthcheckRequest) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*HealthcheckRequest) MarshalJSONBuf ¶
func (j *HealthcheckRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*HealthcheckRequest) MarshalJSONPB ¶
func (j *HealthcheckRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*HealthcheckRequest) ProtoMessage ¶
func (*HealthcheckRequest) ProtoMessage()
func (*HealthcheckRequest) Reset ¶
func (m *HealthcheckRequest) Reset()
func (*HealthcheckRequest) String ¶
func (m *HealthcheckRequest) String() string
func (*HealthcheckRequest) UnmarshalJSON ¶
func (j *HealthcheckRequest) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*HealthcheckRequest) UnmarshalJSONFFLexer ¶
func (j *HealthcheckRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*HealthcheckRequest) UnmarshalJSONPB ¶
func (j *HealthcheckRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*HealthcheckRequest) XXX_DiscardUnknown ¶
func (m *HealthcheckRequest) XXX_DiscardUnknown()
func (*HealthcheckRequest) XXX_Marshal ¶
func (m *HealthcheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthcheckRequest) XXX_Merge ¶
func (dst *HealthcheckRequest) XXX_Merge(src proto.Message)
func (*HealthcheckRequest) XXX_Size ¶
func (m *HealthcheckRequest) XXX_Size() int
func (*HealthcheckRequest) XXX_Unmarshal ¶
func (m *HealthcheckRequest) XXX_Unmarshal(b []byte) error
type HealthcheckResponse ¶
type HealthcheckResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HealthcheckResponse) Descriptor ¶
func (*HealthcheckResponse) Descriptor() ([]byte, []int)
func (*HealthcheckResponse) MarshalJSON ¶
func (j *HealthcheckResponse) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*HealthcheckResponse) MarshalJSONBuf ¶
func (j *HealthcheckResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*HealthcheckResponse) MarshalJSONPB ¶
func (j *HealthcheckResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*HealthcheckResponse) ProtoMessage ¶
func (*HealthcheckResponse) ProtoMessage()
func (*HealthcheckResponse) Reset ¶
func (m *HealthcheckResponse) Reset()
func (*HealthcheckResponse) String ¶
func (m *HealthcheckResponse) String() string
func (*HealthcheckResponse) UnmarshalJSON ¶
func (j *HealthcheckResponse) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*HealthcheckResponse) UnmarshalJSONFFLexer ¶
func (j *HealthcheckResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*HealthcheckResponse) UnmarshalJSONPB ¶
func (j *HealthcheckResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*HealthcheckResponse) XXX_DiscardUnknown ¶
func (m *HealthcheckResponse) XXX_DiscardUnknown()
func (*HealthcheckResponse) XXX_Marshal ¶
func (m *HealthcheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthcheckResponse) XXX_Merge ¶
func (dst *HealthcheckResponse) XXX_Merge(src proto.Message)
func (*HealthcheckResponse) XXX_Size ¶
func (m *HealthcheckResponse) XXX_Size() int
func (*HealthcheckResponse) XXX_Unmarshal ¶
func (m *HealthcheckResponse) XXX_Unmarshal(b []byte) error
type ListQueuesRequest ¶
type ListQueuesRequest struct { Namespace string `protobuf:"bytes,1,opt,name=Namespace,proto3" json:"Namespace"` Filter string `protobuf:"bytes,2,opt,name=Filter,proto3" json:"Filter"` RPCTimeout int64 `protobuf:"varint,100,opt,name=RPCTimeout,proto3" json:"RPCTimeout"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListQueuesRequest) Descriptor ¶
func (*ListQueuesRequest) Descriptor() ([]byte, []int)
func (*ListQueuesRequest) GetFilter ¶
func (m *ListQueuesRequest) GetFilter() string
func (*ListQueuesRequest) GetNamespace ¶
func (m *ListQueuesRequest) GetNamespace() string
func (*ListQueuesRequest) GetRPCTimeout ¶
func (m *ListQueuesRequest) GetRPCTimeout() int64
func (*ListQueuesRequest) MarshalJSON ¶
func (j *ListQueuesRequest) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*ListQueuesRequest) MarshalJSONBuf ¶
func (j *ListQueuesRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*ListQueuesRequest) MarshalJSONPB ¶
func (j *ListQueuesRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*ListQueuesRequest) ProtoMessage ¶
func (*ListQueuesRequest) ProtoMessage()
func (*ListQueuesRequest) Reset ¶
func (m *ListQueuesRequest) Reset()
func (*ListQueuesRequest) String ¶
func (m *ListQueuesRequest) String() string
func (*ListQueuesRequest) UnmarshalJSON ¶
func (j *ListQueuesRequest) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*ListQueuesRequest) UnmarshalJSONFFLexer ¶
func (j *ListQueuesRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*ListQueuesRequest) UnmarshalJSONPB ¶
func (j *ListQueuesRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*ListQueuesRequest) XXX_DiscardUnknown ¶
func (m *ListQueuesRequest) XXX_DiscardUnknown()
func (*ListQueuesRequest) XXX_Marshal ¶
func (m *ListQueuesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListQueuesRequest) XXX_Merge ¶
func (dst *ListQueuesRequest) XXX_Merge(src proto.Message)
func (*ListQueuesRequest) XXX_Size ¶
func (m *ListQueuesRequest) XXX_Size() int
func (*ListQueuesRequest) XXX_Unmarshal ¶
func (m *ListQueuesRequest) XXX_Unmarshal(b []byte) error
type ListQueuesResponse ¶
type ListQueuesResponse struct { Queues []*QueueId `protobuf:"bytes,1,rep,name=Queues,proto3" json:"Queues"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListQueuesResponse) Descriptor ¶
func (*ListQueuesResponse) Descriptor() ([]byte, []int)
func (*ListQueuesResponse) GetQueues ¶
func (m *ListQueuesResponse) GetQueues() []*QueueId
func (*ListQueuesResponse) MarshalJSON ¶
func (j *ListQueuesResponse) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*ListQueuesResponse) MarshalJSONBuf ¶
func (j *ListQueuesResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*ListQueuesResponse) MarshalJSONPB ¶
func (j *ListQueuesResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*ListQueuesResponse) ProtoMessage ¶
func (*ListQueuesResponse) ProtoMessage()
func (*ListQueuesResponse) Reset ¶
func (m *ListQueuesResponse) Reset()
func (*ListQueuesResponse) String ¶
func (m *ListQueuesResponse) String() string
func (*ListQueuesResponse) UnmarshalJSON ¶
func (j *ListQueuesResponse) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*ListQueuesResponse) UnmarshalJSONFFLexer ¶
func (j *ListQueuesResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*ListQueuesResponse) UnmarshalJSONPB ¶
func (j *ListQueuesResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*ListQueuesResponse) XXX_DiscardUnknown ¶
func (m *ListQueuesResponse) XXX_DiscardUnknown()
func (*ListQueuesResponse) XXX_Marshal ¶
func (m *ListQueuesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListQueuesResponse) XXX_Merge ¶
func (dst *ListQueuesResponse) XXX_Merge(src proto.Message)
func (*ListQueuesResponse) XXX_Size ¶
func (m *ListQueuesResponse) XXX_Size() int
func (*ListQueuesResponse) XXX_Unmarshal ¶
func (m *ListQueuesResponse) XXX_Unmarshal(b []byte) error
type Message ¶
type Message struct { Data string `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data"` Attributes map[string]string `` /* 151-byte string literal not displayed */ Receipt *MessageReceipt `protobuf:"bytes,100,opt,name=Receipt,proto3" json:"Receipt"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Message) Descriptor ¶
func (*Message) GetAttributes ¶
func (*Message) GetReceipt ¶
func (m *Message) GetReceipt() *MessageReceipt
func (*Message) MarshalJSON ¶
MarshalJSON marshal bytes to json - template
func (*Message) MarshalJSONBuf ¶
func (j *Message) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) UnmarshalJSON ¶
UnmarshalJSON umarshall json - template of ffjson
func (*Message) UnmarshalJSONFFLexer ¶
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*Message) UnmarshalJSONPB ¶
func (j *Message) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*Message) XXX_DiscardUnknown ¶
func (m *Message) XXX_DiscardUnknown()
func (*Message) XXX_Marshal ¶
func (*Message) XXX_Unmarshal ¶
type MessageReceipt ¶
type MessageReceipt struct { Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id"` ErrorMessage string `protobuf:"bytes,2,opt,name=ErrorMessage,proto3" json:"ErrorMessage"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MessageReceipt) Descriptor ¶
func (*MessageReceipt) Descriptor() ([]byte, []int)
func (*MessageReceipt) GetErrorMessage ¶
func (m *MessageReceipt) GetErrorMessage() string
func (*MessageReceipt) GetId ¶
func (m *MessageReceipt) GetId() string
func (*MessageReceipt) MarshalJSON ¶
func (j *MessageReceipt) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*MessageReceipt) MarshalJSONBuf ¶
func (j *MessageReceipt) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*MessageReceipt) MarshalJSONPB ¶
func (j *MessageReceipt) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*MessageReceipt) ProtoMessage ¶
func (*MessageReceipt) ProtoMessage()
func (*MessageReceipt) Reset ¶
func (m *MessageReceipt) Reset()
func (*MessageReceipt) String ¶
func (m *MessageReceipt) String() string
func (*MessageReceipt) UnmarshalJSON ¶
func (j *MessageReceipt) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*MessageReceipt) UnmarshalJSONFFLexer ¶
func (j *MessageReceipt) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*MessageReceipt) UnmarshalJSONPB ¶
func (j *MessageReceipt) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*MessageReceipt) XXX_DiscardUnknown ¶
func (m *MessageReceipt) XXX_DiscardUnknown()
func (*MessageReceipt) XXX_Marshal ¶
func (m *MessageReceipt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessageReceipt) XXX_Merge ¶
func (dst *MessageReceipt) XXX_Merge(src proto.Message)
func (*MessageReceipt) XXX_Size ¶
func (m *MessageReceipt) XXX_Size() int
func (*MessageReceipt) XXX_Unmarshal ¶
func (m *MessageReceipt) XXX_Unmarshal(b []byte) error
type ModifyAckDeadlineRequest ¶
type ModifyAckDeadlineRequest struct { QueueId *QueueId `protobuf:"bytes,1,opt,name=QueueId,proto3" json:"QueueId"` Receipt *MessageReceipt `protobuf:"bytes,2,opt,name=Receipt,proto3" json:"Receipt"` AckDeadlineSeconds int64 `protobuf:"varint,3,opt,name=AckDeadlineSeconds,proto3" json:"AckDeadlineSeconds"` RPCTimeout int64 `protobuf:"varint,100,opt,name=RPCTimeout,proto3" json:"RPCTimeout"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ModifyAckDeadlineRequest) Descriptor ¶
func (*ModifyAckDeadlineRequest) Descriptor() ([]byte, []int)
func (*ModifyAckDeadlineRequest) GetAckDeadlineSeconds ¶
func (m *ModifyAckDeadlineRequest) GetAckDeadlineSeconds() int64
func (*ModifyAckDeadlineRequest) GetQueueId ¶
func (m *ModifyAckDeadlineRequest) GetQueueId() *QueueId
func (*ModifyAckDeadlineRequest) GetRPCTimeout ¶
func (m *ModifyAckDeadlineRequest) GetRPCTimeout() int64
func (*ModifyAckDeadlineRequest) GetReceipt ¶
func (m *ModifyAckDeadlineRequest) GetReceipt() *MessageReceipt
func (*ModifyAckDeadlineRequest) MarshalJSON ¶
func (j *ModifyAckDeadlineRequest) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*ModifyAckDeadlineRequest) MarshalJSONBuf ¶
func (j *ModifyAckDeadlineRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*ModifyAckDeadlineRequest) MarshalJSONPB ¶
func (j *ModifyAckDeadlineRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*ModifyAckDeadlineRequest) ProtoMessage ¶
func (*ModifyAckDeadlineRequest) ProtoMessage()
func (*ModifyAckDeadlineRequest) Reset ¶
func (m *ModifyAckDeadlineRequest) Reset()
func (*ModifyAckDeadlineRequest) String ¶
func (m *ModifyAckDeadlineRequest) String() string
func (*ModifyAckDeadlineRequest) UnmarshalJSON ¶
func (j *ModifyAckDeadlineRequest) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*ModifyAckDeadlineRequest) UnmarshalJSONFFLexer ¶
func (j *ModifyAckDeadlineRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*ModifyAckDeadlineRequest) UnmarshalJSONPB ¶
func (j *ModifyAckDeadlineRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*ModifyAckDeadlineRequest) XXX_DiscardUnknown ¶
func (m *ModifyAckDeadlineRequest) XXX_DiscardUnknown()
func (*ModifyAckDeadlineRequest) XXX_Marshal ¶
func (m *ModifyAckDeadlineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModifyAckDeadlineRequest) XXX_Merge ¶
func (dst *ModifyAckDeadlineRequest) XXX_Merge(src proto.Message)
func (*ModifyAckDeadlineRequest) XXX_Size ¶
func (m *ModifyAckDeadlineRequest) XXX_Size() int
func (*ModifyAckDeadlineRequest) XXX_Unmarshal ¶
func (m *ModifyAckDeadlineRequest) XXX_Unmarshal(b []byte) error
type ModifyAckDeadlineResponse ¶
type ModifyAckDeadlineResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ModifyAckDeadlineResponse) Descriptor ¶
func (*ModifyAckDeadlineResponse) Descriptor() ([]byte, []int)
func (*ModifyAckDeadlineResponse) MarshalJSON ¶
func (j *ModifyAckDeadlineResponse) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*ModifyAckDeadlineResponse) MarshalJSONBuf ¶
func (j *ModifyAckDeadlineResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*ModifyAckDeadlineResponse) MarshalJSONPB ¶
func (j *ModifyAckDeadlineResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*ModifyAckDeadlineResponse) ProtoMessage ¶
func (*ModifyAckDeadlineResponse) ProtoMessage()
func (*ModifyAckDeadlineResponse) Reset ¶
func (m *ModifyAckDeadlineResponse) Reset()
func (*ModifyAckDeadlineResponse) String ¶
func (m *ModifyAckDeadlineResponse) String() string
func (*ModifyAckDeadlineResponse) UnmarshalJSON ¶
func (j *ModifyAckDeadlineResponse) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*ModifyAckDeadlineResponse) UnmarshalJSONFFLexer ¶
func (j *ModifyAckDeadlineResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*ModifyAckDeadlineResponse) UnmarshalJSONPB ¶
func (j *ModifyAckDeadlineResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*ModifyAckDeadlineResponse) XXX_DiscardUnknown ¶
func (m *ModifyAckDeadlineResponse) XXX_DiscardUnknown()
func (*ModifyAckDeadlineResponse) XXX_Marshal ¶
func (m *ModifyAckDeadlineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModifyAckDeadlineResponse) XXX_Merge ¶
func (dst *ModifyAckDeadlineResponse) XXX_Merge(src proto.Message)
func (*ModifyAckDeadlineResponse) XXX_Size ¶
func (m *ModifyAckDeadlineResponse) XXX_Size() int
func (*ModifyAckDeadlineResponse) XXX_Unmarshal ¶
func (m *ModifyAckDeadlineResponse) XXX_Unmarshal(b []byte) error
type ModifyQueueRequest ¶
type ModifyQueueRequest struct { Id *QueueId `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id"` Attributes map[string]string `` /* 151-byte string literal not displayed */ RPCTimeout int64 `protobuf:"varint,100,opt,name=RPCTimeout,proto3" json:"RPCTimeout"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ModifyQueueRequest) Descriptor ¶
func (*ModifyQueueRequest) Descriptor() ([]byte, []int)
func (*ModifyQueueRequest) GetAttributes ¶
func (m *ModifyQueueRequest) GetAttributes() map[string]string
func (*ModifyQueueRequest) GetId ¶
func (m *ModifyQueueRequest) GetId() *QueueId
func (*ModifyQueueRequest) GetRPCTimeout ¶
func (m *ModifyQueueRequest) GetRPCTimeout() int64
func (*ModifyQueueRequest) MarshalJSON ¶
func (j *ModifyQueueRequest) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*ModifyQueueRequest) MarshalJSONBuf ¶
func (j *ModifyQueueRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*ModifyQueueRequest) MarshalJSONPB ¶
func (j *ModifyQueueRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*ModifyQueueRequest) ProtoMessage ¶
func (*ModifyQueueRequest) ProtoMessage()
func (*ModifyQueueRequest) Reset ¶
func (m *ModifyQueueRequest) Reset()
func (*ModifyQueueRequest) String ¶
func (m *ModifyQueueRequest) String() string
func (*ModifyQueueRequest) UnmarshalJSON ¶
func (j *ModifyQueueRequest) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*ModifyQueueRequest) UnmarshalJSONFFLexer ¶
func (j *ModifyQueueRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*ModifyQueueRequest) UnmarshalJSONPB ¶
func (j *ModifyQueueRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*ModifyQueueRequest) XXX_DiscardUnknown ¶
func (m *ModifyQueueRequest) XXX_DiscardUnknown()
func (*ModifyQueueRequest) XXX_Marshal ¶
func (m *ModifyQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModifyQueueRequest) XXX_Merge ¶
func (dst *ModifyQueueRequest) XXX_Merge(src proto.Message)
func (*ModifyQueueRequest) XXX_Size ¶
func (m *ModifyQueueRequest) XXX_Size() int
func (*ModifyQueueRequest) XXX_Unmarshal ¶
func (m *ModifyQueueRequest) XXX_Unmarshal(b []byte) error
type ModifyQueueResponse ¶
type ModifyQueueResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ModifyQueueResponse) Descriptor ¶
func (*ModifyQueueResponse) Descriptor() ([]byte, []int)
func (*ModifyQueueResponse) MarshalJSON ¶
func (j *ModifyQueueResponse) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*ModifyQueueResponse) MarshalJSONBuf ¶
func (j *ModifyQueueResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*ModifyQueueResponse) ProtoMessage ¶
func (*ModifyQueueResponse) ProtoMessage()
func (*ModifyQueueResponse) Reset ¶
func (m *ModifyQueueResponse) Reset()
func (*ModifyQueueResponse) String ¶
func (m *ModifyQueueResponse) String() string
func (*ModifyQueueResponse) UnmarshalJSON ¶
func (j *ModifyQueueResponse) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*ModifyQueueResponse) UnmarshalJSONFFLexer ¶
func (j *ModifyQueueResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*ModifyQueueResponse) XXX_DiscardUnknown ¶
func (m *ModifyQueueResponse) XXX_DiscardUnknown()
func (*ModifyQueueResponse) XXX_Marshal ¶
func (m *ModifyQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModifyQueueResponse) XXX_Merge ¶
func (dst *ModifyQueueResponse) XXX_Merge(src proto.Message)
func (*ModifyQueueResponse) XXX_Size ¶
func (m *ModifyQueueResponse) XXX_Size() int
func (*ModifyQueueResponse) XXX_Unmarshal ¶
func (m *ModifyQueueResponse) XXX_Unmarshal(b []byte) error
type PublishMessagesRequest ¶
type PublishMessagesRequest struct { QueueId *QueueId `protobuf:"bytes,1,opt,name=QueueId,proto3" json:"QueueId"` Messages []*Message `protobuf:"bytes,2,rep,name=Messages,proto3" json:"Messages"` RPCTimeout int64 `protobuf:"varint,100,opt,name=RPCTimeout,proto3" json:"RPCTimeout"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PublishMessagesRequest) Descriptor ¶
func (*PublishMessagesRequest) Descriptor() ([]byte, []int)
func (*PublishMessagesRequest) GetMessages ¶
func (m *PublishMessagesRequest) GetMessages() []*Message
func (*PublishMessagesRequest) GetQueueId ¶
func (m *PublishMessagesRequest) GetQueueId() *QueueId
func (*PublishMessagesRequest) GetRPCTimeout ¶
func (m *PublishMessagesRequest) GetRPCTimeout() int64
func (*PublishMessagesRequest) MarshalJSON ¶
func (j *PublishMessagesRequest) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*PublishMessagesRequest) MarshalJSONBuf ¶
func (j *PublishMessagesRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*PublishMessagesRequest) MarshalJSONPB ¶
func (j *PublishMessagesRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*PublishMessagesRequest) ProtoMessage ¶
func (*PublishMessagesRequest) ProtoMessage()
func (*PublishMessagesRequest) Reset ¶
func (m *PublishMessagesRequest) Reset()
func (*PublishMessagesRequest) String ¶
func (m *PublishMessagesRequest) String() string
func (*PublishMessagesRequest) UnmarshalJSON ¶
func (j *PublishMessagesRequest) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*PublishMessagesRequest) UnmarshalJSONFFLexer ¶
func (j *PublishMessagesRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*PublishMessagesRequest) UnmarshalJSONPB ¶
func (j *PublishMessagesRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*PublishMessagesRequest) XXX_DiscardUnknown ¶
func (m *PublishMessagesRequest) XXX_DiscardUnknown()
func (*PublishMessagesRequest) XXX_Marshal ¶
func (m *PublishMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PublishMessagesRequest) XXX_Merge ¶
func (dst *PublishMessagesRequest) XXX_Merge(src proto.Message)
func (*PublishMessagesRequest) XXX_Size ¶
func (m *PublishMessagesRequest) XXX_Size() int
func (*PublishMessagesRequest) XXX_Unmarshal ¶
func (m *PublishMessagesRequest) XXX_Unmarshal(b []byte) error
type PublishMessagesResponse ¶
type PublishMessagesResponse struct { // Return the indexes of the messages that failed to send Failed []*FailedPublish `protobuf:"bytes,1,rep,name=Failed,proto3" json:"Failed"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PublishMessagesResponse) Descriptor ¶
func (*PublishMessagesResponse) Descriptor() ([]byte, []int)
func (*PublishMessagesResponse) GetFailed ¶
func (m *PublishMessagesResponse) GetFailed() []*FailedPublish
func (*PublishMessagesResponse) MarshalJSON ¶
func (j *PublishMessagesResponse) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*PublishMessagesResponse) MarshalJSONBuf ¶
func (j *PublishMessagesResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*PublishMessagesResponse) MarshalJSONPB ¶
func (j *PublishMessagesResponse) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*PublishMessagesResponse) ProtoMessage ¶
func (*PublishMessagesResponse) ProtoMessage()
func (*PublishMessagesResponse) Reset ¶
func (m *PublishMessagesResponse) Reset()
func (*PublishMessagesResponse) String ¶
func (m *PublishMessagesResponse) String() string
func (*PublishMessagesResponse) UnmarshalJSON ¶
func (j *PublishMessagesResponse) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*PublishMessagesResponse) UnmarshalJSONFFLexer ¶
func (j *PublishMessagesResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*PublishMessagesResponse) UnmarshalJSONPB ¶
func (j *PublishMessagesResponse) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*PublishMessagesResponse) XXX_DiscardUnknown ¶
func (m *PublishMessagesResponse) XXX_DiscardUnknown()
func (*PublishMessagesResponse) XXX_Marshal ¶
func (m *PublishMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PublishMessagesResponse) XXX_Merge ¶
func (dst *PublishMessagesResponse) XXX_Merge(src proto.Message)
func (*PublishMessagesResponse) XXX_Size ¶
func (m *PublishMessagesResponse) XXX_Size() int
func (*PublishMessagesResponse) XXX_Unmarshal ¶
func (m *PublishMessagesResponse) XXX_Unmarshal(b []byte) error
type PurgeQueueRequest ¶
type PurgeQueueRequest struct { Id *QueueId `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id"` RPCTimeout int64 `protobuf:"varint,100,opt,name=RPCTimeout,proto3" json:"RPCTimeout"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PurgeQueueRequest) Descriptor ¶
func (*PurgeQueueRequest) Descriptor() ([]byte, []int)
func (*PurgeQueueRequest) GetId ¶
func (m *PurgeQueueRequest) GetId() *QueueId
func (*PurgeQueueRequest) GetRPCTimeout ¶
func (m *PurgeQueueRequest) GetRPCTimeout() int64
func (*PurgeQueueRequest) MarshalJSON ¶
func (j *PurgeQueueRequest) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*PurgeQueueRequest) MarshalJSONBuf ¶
func (j *PurgeQueueRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*PurgeQueueRequest) MarshalJSONPB ¶
func (j *PurgeQueueRequest) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)
func (*PurgeQueueRequest) ProtoMessage ¶
func (*PurgeQueueRequest) ProtoMessage()
func (*PurgeQueueRequest) Reset ¶
func (m *PurgeQueueRequest) Reset()
func (*PurgeQueueRequest) String ¶
func (m *PurgeQueueRequest) String() string
func (*PurgeQueueRequest) UnmarshalJSON ¶
func (j *PurgeQueueRequest) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*PurgeQueueRequest) UnmarshalJSONFFLexer ¶
func (j *PurgeQueueRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*PurgeQueueRequest) UnmarshalJSONPB ¶
func (j *PurgeQueueRequest) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*PurgeQueueRequest) XXX_DiscardUnknown ¶
func (m *PurgeQueueRequest) XXX_DiscardUnknown()
func (*PurgeQueueRequest) XXX_Marshal ¶
func (m *PurgeQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PurgeQueueRequest) XXX_Merge ¶
func (dst *PurgeQueueRequest) XXX_Merge(src proto.Message)
func (*PurgeQueueRequest) XXX_Size ¶
func (m *PurgeQueueRequest) XXX_Size() int
func (*PurgeQueueRequest) XXX_Unmarshal ¶
func (m *PurgeQueueRequest) XXX_Unmarshal(b []byte) error
type PurgeQueueResponse ¶
type PurgeQueueResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PurgeQueueResponse) Descriptor ¶
func (*PurgeQueueResponse) Descriptor() ([]byte, []int)
func (*PurgeQueueResponse) MarshalJSON ¶
func (j *PurgeQueueResponse) MarshalJSON() ([]byte, error)
MarshalJSON marshal bytes to json - template
func (*PurgeQueueResponse) MarshalJSONBuf ¶
func (j *PurgeQueueResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*PurgeQueueResponse) ProtoMessage ¶
func (*PurgeQueueResponse) ProtoMessage()
func (*PurgeQueueResponse) Reset ¶
func (m *PurgeQueueResponse) Reset()
func (*PurgeQueueResponse) String ¶
func (m *PurgeQueueResponse) String() string
func (*PurgeQueueResponse) UnmarshalJSON ¶
func (j *PurgeQueueResponse) UnmarshalJSON(input []byte) error
UnmarshalJSON umarshall json - template of ffjson
func (*PurgeQueueResponse) UnmarshalJSONFFLexer ¶
func (j *PurgeQueueResponse) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*PurgeQueueResponse) XXX_DiscardUnknown ¶
func (m *PurgeQueueResponse) XXX_DiscardUnknown()
func (*PurgeQueueResponse) XXX_Marshal ¶
func (m *PurgeQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PurgeQueueResponse) XXX_Merge ¶
func (dst *PurgeQueueResponse) XXX_Merge(src proto.Message)
func (*PurgeQueueResponse) XXX_Size ¶
func (m *PurgeQueueResponse) XXX_Size() int
func (*PurgeQueueResponse) XXX_Unmarshal ¶
func (m *PurgeQueueResponse) XXX_Unmarshal(b []byte) error
type QProxyClient ¶
type QProxyClient interface { ListQueues(ctx context.Context, in *ListQueuesRequest, opts ...grpc.CallOption) (QProxy_ListQueuesClient, error) GetQueue(ctx context.Context, in *GetQueueRequest, opts ...grpc.CallOption) (*GetQueueResponse, error) CreateQueue(ctx context.Context, in *CreateQueueRequest, opts ...grpc.CallOption) (*CreateQueueResponse, error) DeleteQueue(ctx context.Context, in *DeleteQueueRequest, opts ...grpc.CallOption) (*DeleteQueueResponse, error) ModifyQueue(ctx context.Context, in *ModifyQueueRequest, opts ...grpc.CallOption) (*ModifyQueueResponse, error) PurgeQueue(ctx context.Context, in *PurgeQueueRequest, opts ...grpc.CallOption) (*PurgeQueueResponse, error) AckMessages(ctx context.Context, in *AckMessagesRequest, opts ...grpc.CallOption) (*AckMessagesResponse, error) GetMessages(ctx context.Context, in *GetMessagesRequest, opts ...grpc.CallOption) (*GetMessagesResponse, error) PublishMessages(ctx context.Context, in *PublishMessagesRequest, opts ...grpc.CallOption) (*PublishMessagesResponse, error) ModifyAckDeadline(ctx context.Context, in *ModifyAckDeadlineRequest, opts ...grpc.CallOption) (*ModifyAckDeadlineResponse, error) Healthcheck(ctx context.Context, in *HealthcheckRequest, opts ...grpc.CallOption) (*HealthcheckResponse, error) }
QProxyClient is the client API for QProxy service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewQProxyClient ¶
func NewQProxyClient(cc *grpc.ClientConn) QProxyClient
type QProxyServer ¶
type QProxyServer interface { ListQueues(*ListQueuesRequest, QProxy_ListQueuesServer) error GetQueue(context.Context, *GetQueueRequest) (*GetQueueResponse, error) CreateQueue(context.Context, *CreateQueueRequest) (*CreateQueueResponse, error) DeleteQueue(context.Context, *DeleteQueueRequest) (*DeleteQueueResponse, error) ModifyQueue(context.Context, *ModifyQueueRequest) (*ModifyQueueResponse, error) PurgeQueue(context.Context, *PurgeQueueRequest) (*PurgeQueueResponse, error) AckMessages(context.Context, *AckMessagesRequest) (*AckMessagesResponse, error) GetMessages(context.Context, *GetMessagesRequest) (*GetMessagesResponse, error) PublishMessages(context.Context, *PublishMessagesRequest) (*PublishMessagesResponse, error) ModifyAckDeadline(context.Context, *ModifyAckDeadlineRequest) (*ModifyAckDeadlineResponse, error) Healthcheck(context.Context, *HealthcheckRequest) (*HealthcheckResponse, error) }
QProxyServer is the server API for QProxy service.
type QProxy_ListQueuesClient ¶
type QProxy_ListQueuesClient interface { Recv() (*ListQueuesResponse, error) grpc.ClientStream }
type QProxy_ListQueuesServer ¶
type QProxy_ListQueuesServer interface { Send(*ListQueuesResponse) error grpc.ServerStream }
type QueueId ¶
type QueueId struct { Namespace string `protobuf:"bytes,1,opt,name=Namespace,proto3" json:"Namespace"` Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*QueueId) Descriptor ¶
func (*QueueId) GetNamespace ¶
func (*QueueId) MarshalJSON ¶
MarshalJSON marshal bytes to json - template
func (*QueueId) MarshalJSONBuf ¶
func (j *QueueId) MarshalJSONBuf(buf fflib.EncodingBuffer) error
MarshalJSONBuf marshal buff to json - template
func (*QueueId) ProtoMessage ¶
func (*QueueId) ProtoMessage()
func (*QueueId) UnmarshalJSON ¶
UnmarshalJSON umarshall json - template of ffjson
func (*QueueId) UnmarshalJSONFFLexer ¶
UnmarshalJSONFFLexer fast json unmarshall - template ffjson
func (*QueueId) UnmarshalJSONPB ¶
func (j *QueueId) UnmarshalJSONPB(_ *jsonpb.Unmarshaler, b []byte) error
func (*QueueId) XXX_DiscardUnknown ¶
func (m *QueueId) XXX_DiscardUnknown()