rpc

package
v0.0.16 Latest Latest
Warning

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

 Go to latest Published: Jul 10, 2020 License: MIT Imports: 17 Imported by: 0

Documentation

Overview

Package rpc is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterQProxyHandler 

func RegisterQProxyHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

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) Descriptor() ([]byte, []int)

func (*Message) GetAttributes 

func (m *Message) GetAttributes() map[string]string

func (*Message) GetData 

func (m *Message) GetData() string

func (*Message) GetReceipt 

func (m *Message) GetReceipt() *MessageReceipt

func (*Message) MarshalJSON 

func (j *Message) MarshalJSON() ([]byte, error)

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

func (j *Message) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

func (*Message) UnmarshalJSON 

func (j *Message) UnmarshalJSON(input []byte) error

UnmarshalJSON umarshall json - template of ffjson

func (*Message) UnmarshalJSONFFLexer 

func (j *Message) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

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 (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Message) XXX_Merge 

func (dst *Message) XXX_Merge(src proto.Message)

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

func (m *Message) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*QueueId) GetName 

func (m *QueueId) GetName() string

func (*QueueId) GetNamespace 

func (m *QueueId) GetNamespace() string

func (*QueueId) MarshalJSON 

func (j *QueueId) MarshalJSON() ([]byte, error)

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

func (j *QueueId) MarshalJSONPB(*jsonpb.Marshaler) ([]byte, error)

func (*QueueId) ProtoMessage 

func (*QueueId) ProtoMessage()

func (*QueueId) Reset 

func (m *QueueId) Reset()

func (*QueueId) String 

func (m *QueueId) String() string

func (*QueueId) UnmarshalJSON 

func (j *QueueId) UnmarshalJSON(input []byte) error

UnmarshalJSON umarshall json - template of ffjson

func (*QueueId) UnmarshalJSONFFLexer 

func (j *QueueId) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

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

func (*QueueId) XXX_Marshal 

func (m *QueueId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueId) XXX_Merge 

func (dst *QueueId) XXX_Merge(src proto.Message)

func (*QueueId) XXX_Size 

func (m *QueueId) XXX_Size() int

func (*QueueId) XXX_Unmarshal 

func (m *QueueId) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.