Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

rpc

package

Go to main page

Versions in this module

v0

v0.0.25

Sep 2, 2021

v0.0.21

Apr 7, 2021

v0.0.20

Mar 12, 2021

Changes in this version

+ var QueueId_QueueType_name = map[int32]string

+ var QueueId_QueueType_value = map[string]int32

type QueueId

+ Type QueueId_QueueType

+ func (m *QueueId) GetType() QueueId_QueueType

+ type QueueId_QueueType int32

+ const QueueId_Fifo

+ const QueueId_Standard

+ func (QueueId_QueueType) EnumDescriptor() ([]byte, []int)

+ func (x QueueId_QueueType) String() string

v0.0.19

Feb 27, 2021

v0.0.18

Feb 11, 2021

v0.0.17

Sep 25, 2020

v0.0.16

Jul 10, 2020

v0.0.15

Jun 30, 2020

v0.0.14

Feb 4, 2020

Changes in this version

+ 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 struct

+ QueueId *QueueId

+ RPCTimeout int64

+ Receipts []*MessageReceipt

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AckMessagesRequest) ProtoMessage()

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

+ func (j *AckMessagesRequest) MarshalJSON() ([]byte, error)

+ func (j *AckMessagesRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetQueueId() *QueueId

+ func (m *AckMessagesRequest) GetRPCTimeout() int64

+ func (m *AckMessagesRequest) GetReceipts() []*MessageReceipt

+ func (m *AckMessagesRequest) Reset()

+ func (m *AckMessagesRequest) String() string

+ func (m *AckMessagesRequest) XXX_DiscardUnknown()

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

+ func (m *AckMessagesRequest) XXX_Size() int

+ func (m *AckMessagesRequest) XXX_Unmarshal(b []byte) error

+ type AckMessagesResponse struct

+ Failed []*MessageReceipt

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AckMessagesResponse) ProtoMessage()

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

+ func (j *AckMessagesResponse) MarshalJSON() ([]byte, error)

+ func (j *AckMessagesResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetFailed() []*MessageReceipt

+ func (m *AckMessagesResponse) Reset()

+ func (m *AckMessagesResponse) String() string

+ func (m *AckMessagesResponse) XXX_DiscardUnknown()

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

+ func (m *AckMessagesResponse) XXX_Size() int

+ func (m *AckMessagesResponse) XXX_Unmarshal(b []byte) error

+ type CreateQueueRequest struct

+ Attributes map[string]string

+ Id *QueueId

+ RPCTimeout int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateQueueRequest) ProtoMessage()

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

+ func (j *CreateQueueRequest) MarshalJSON() ([]byte, error)

+ func (j *CreateQueueRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetAttributes() map[string]string

+ func (m *CreateQueueRequest) GetId() *QueueId

+ func (m *CreateQueueRequest) GetRPCTimeout() int64

+ func (m *CreateQueueRequest) Reset()

+ func (m *CreateQueueRequest) String() string

+ func (m *CreateQueueRequest) XXX_DiscardUnknown()

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

+ func (m *CreateQueueRequest) XXX_Size() int

+ func (m *CreateQueueRequest) XXX_Unmarshal(b []byte) error

+ type CreateQueueResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateQueueResponse) ProtoMessage()

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

+ func (j *CreateQueueResponse) MarshalJSON() ([]byte, error)

+ func (j *CreateQueueResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

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

+ func (m *CreateQueueResponse) String() string

+ func (m *CreateQueueResponse) XXX_DiscardUnknown()

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

+ func (m *CreateQueueResponse) XXX_Size() int

+ func (m *CreateQueueResponse) XXX_Unmarshal(b []byte) error

+ type DeleteQueueRequest struct

+ Id *QueueId

+ RPCTimeout int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteQueueRequest) ProtoMessage()

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

+ func (j *DeleteQueueRequest) MarshalJSON() ([]byte, error)

+ func (j *DeleteQueueRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetId() *QueueId

+ func (m *DeleteQueueRequest) GetRPCTimeout() int64

+ func (m *DeleteQueueRequest) Reset()

+ func (m *DeleteQueueRequest) String() string

+ func (m *DeleteQueueRequest) XXX_DiscardUnknown()

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

+ func (m *DeleteQueueRequest) XXX_Size() int

+ func (m *DeleteQueueRequest) XXX_Unmarshal(b []byte) error

+ type DeleteQueueResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteQueueResponse) ProtoMessage()

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

+ func (j *DeleteQueueResponse) MarshalJSON() ([]byte, error)

+ func (j *DeleteQueueResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (j *DeleteQueueResponse) UnmarshalJSON(input []byte) error

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

+ func (m *DeleteQueueResponse) Reset()

+ func (m *DeleteQueueResponse) String() string

+ func (m *DeleteQueueResponse) XXX_DiscardUnknown()

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

+ func (m *DeleteQueueResponse) XXX_Size() int

+ func (m *DeleteQueueResponse) XXX_Unmarshal(b []byte) error

+ type FailedPublish struct

+ ErrorMessage string

+ Index int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*FailedPublish) ProtoMessage()

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

+ func (j *FailedPublish) MarshalJSON() ([]byte, error)

+ func (j *FailedPublish) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetErrorMessage() string

+ func (m *FailedPublish) GetIndex() int64

+ func (m *FailedPublish) Reset()

+ func (m *FailedPublish) String() string

+ func (m *FailedPublish) XXX_DiscardUnknown()

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

+ func (m *FailedPublish) XXX_Size() int

+ func (m *FailedPublish) XXX_Unmarshal(b []byte) error

+ type GetMessagesRequest struct

+ AckDeadlineSeconds int64

+ LongPollSeconds int64

+ MaxMessages int64

+ QueueId *QueueId

+ RPCTimeout int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetMessagesRequest) ProtoMessage()

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

+ func (j *GetMessagesRequest) MarshalJSON() ([]byte, error)

+ func (j *GetMessagesRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetAckDeadlineSeconds() int64

+ func (m *GetMessagesRequest) GetLongPollSeconds() int64

+ func (m *GetMessagesRequest) GetMaxMessages() int64

+ func (m *GetMessagesRequest) GetQueueId() *QueueId

+ func (m *GetMessagesRequest) GetRPCTimeout() int64

+ func (m *GetMessagesRequest) Reset()

+ func (m *GetMessagesRequest) String() string

+ func (m *GetMessagesRequest) XXX_DiscardUnknown()

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

+ func (m *GetMessagesRequest) XXX_Size() int

+ func (m *GetMessagesRequest) XXX_Unmarshal(b []byte) error

+ type GetMessagesResponse struct

+ Messages []*Message

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetMessagesResponse) ProtoMessage()

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

+ func (j *GetMessagesResponse) MarshalJSON() ([]byte, error)

+ func (j *GetMessagesResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetMessages() []*Message

+ func (m *GetMessagesResponse) Reset()

+ func (m *GetMessagesResponse) String() string

+ func (m *GetMessagesResponse) XXX_DiscardUnknown()

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

+ func (m *GetMessagesResponse) XXX_Size() int

+ func (m *GetMessagesResponse) XXX_Unmarshal(b []byte) error

+ type GetQueueRequest struct

+ Id *QueueId

+ RPCTimeout int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetQueueRequest) ProtoMessage()

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

+ func (j *GetQueueRequest) MarshalJSON() ([]byte, error)

+ func (j *GetQueueRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetId() *QueueId

+ func (m *GetQueueRequest) GetRPCTimeout() int64

+ func (m *GetQueueRequest) Reset()

+ func (m *GetQueueRequest) String() string

+ func (m *GetQueueRequest) XXX_DiscardUnknown()

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

+ func (m *GetQueueRequest) XXX_Size() int

+ func (m *GetQueueRequest) XXX_Unmarshal(b []byte) error

+ type GetQueueResponse struct

+ Attributes map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetQueueResponse) ProtoMessage()

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

+ func (j *GetQueueResponse) MarshalJSON() ([]byte, error)

+ func (j *GetQueueResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetAttributes() map[string]string

+ func (m *GetQueueResponse) Reset()

+ func (m *GetQueueResponse) String() string

+ func (m *GetQueueResponse) XXX_DiscardUnknown()

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

+ func (m *GetQueueResponse) XXX_Size() int

+ func (m *GetQueueResponse) XXX_Unmarshal(b []byte) error

+ type HealthcheckRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*HealthcheckRequest) ProtoMessage()

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

+ func (j *HealthcheckRequest) MarshalJSON() ([]byte, error)

+ func (j *HealthcheckRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

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

+ func (m *HealthcheckRequest) String() string

+ func (m *HealthcheckRequest) XXX_DiscardUnknown()

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

+ func (m *HealthcheckRequest) XXX_Size() int

+ func (m *HealthcheckRequest) XXX_Unmarshal(b []byte) error

+ type HealthcheckResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*HealthcheckResponse) ProtoMessage()

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

+ func (j *HealthcheckResponse) MarshalJSON() ([]byte, error)

+ func (j *HealthcheckResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

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

+ func (m *HealthcheckResponse) String() string

+ func (m *HealthcheckResponse) XXX_DiscardUnknown()

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

+ func (m *HealthcheckResponse) XXX_Size() int

+ func (m *HealthcheckResponse) XXX_Unmarshal(b []byte) error

+ type ListQueuesRequest struct

+ Filter string

+ Namespace string

+ RPCTimeout int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListQueuesRequest) ProtoMessage()

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

+ func (j *ListQueuesRequest) MarshalJSON() ([]byte, error)

+ func (j *ListQueuesRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetFilter() string

+ func (m *ListQueuesRequest) GetNamespace() string

+ func (m *ListQueuesRequest) GetRPCTimeout() int64

+ func (m *ListQueuesRequest) Reset()

+ func (m *ListQueuesRequest) String() string

+ func (m *ListQueuesRequest) XXX_DiscardUnknown()

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

+ func (m *ListQueuesRequest) XXX_Size() int

+ func (m *ListQueuesRequest) XXX_Unmarshal(b []byte) error

+ type ListQueuesResponse struct

+ Queues []*QueueId

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListQueuesResponse) ProtoMessage()

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

+ func (j *ListQueuesResponse) MarshalJSON() ([]byte, error)

+ func (j *ListQueuesResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetQueues() []*QueueId

+ func (m *ListQueuesResponse) Reset()

+ func (m *ListQueuesResponse) String() string

+ func (m *ListQueuesResponse) XXX_DiscardUnknown()

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

+ func (m *ListQueuesResponse) XXX_Size() int

+ func (m *ListQueuesResponse) XXX_Unmarshal(b []byte) error

+ type Message struct

+ Attributes map[string]string

+ Data string

+ Receipt *MessageReceipt

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Message) ProtoMessage()

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

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

+ func (j *Message) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetAttributes() map[string]string

+ func (m *Message) GetData() string

+ func (m *Message) GetReceipt() *MessageReceipt

+ func (m *Message) Reset()

+ func (m *Message) String() string

+ func (m *Message) XXX_DiscardUnknown()

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

+ func (m *Message) XXX_Size() int

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

+ type MessageReceipt struct

+ ErrorMessage string

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MessageReceipt) ProtoMessage()

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

+ func (j *MessageReceipt) MarshalJSON() ([]byte, error)

+ func (j *MessageReceipt) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetErrorMessage() string

+ func (m *MessageReceipt) GetId() string

+ func (m *MessageReceipt) Reset()

+ func (m *MessageReceipt) String() string

+ func (m *MessageReceipt) XXX_DiscardUnknown()

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

+ func (m *MessageReceipt) XXX_Size() int

+ func (m *MessageReceipt) XXX_Unmarshal(b []byte) error

+ type ModifyAckDeadlineRequest struct

+ AckDeadlineSeconds int64

+ QueueId *QueueId

+ RPCTimeout int64

+ Receipt *MessageReceipt

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ModifyAckDeadlineRequest) ProtoMessage()

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

+ func (j *ModifyAckDeadlineRequest) MarshalJSON() ([]byte, error)

+ func (j *ModifyAckDeadlineRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetAckDeadlineSeconds() int64

+ func (m *ModifyAckDeadlineRequest) GetQueueId() *QueueId

+ func (m *ModifyAckDeadlineRequest) GetRPCTimeout() int64

+ func (m *ModifyAckDeadlineRequest) GetReceipt() *MessageReceipt

+ func (m *ModifyAckDeadlineRequest) Reset()

+ func (m *ModifyAckDeadlineRequest) String() string

+ func (m *ModifyAckDeadlineRequest) XXX_DiscardUnknown()

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

+ func (m *ModifyAckDeadlineRequest) XXX_Size() int

+ func (m *ModifyAckDeadlineRequest) XXX_Unmarshal(b []byte) error

+ type ModifyAckDeadlineResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ModifyAckDeadlineResponse) ProtoMessage()

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

+ func (j *ModifyAckDeadlineResponse) MarshalJSON() ([]byte, error)

+ func (j *ModifyAckDeadlineResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

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

+ func (m *ModifyAckDeadlineResponse) String() string

+ func (m *ModifyAckDeadlineResponse) XXX_DiscardUnknown()

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

+ func (m *ModifyAckDeadlineResponse) XXX_Size() int

+ func (m *ModifyAckDeadlineResponse) XXX_Unmarshal(b []byte) error

+ type ModifyQueueRequest struct

+ Attributes map[string]string

+ Id *QueueId

+ RPCTimeout int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ModifyQueueRequest) ProtoMessage()

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

+ func (j *ModifyQueueRequest) MarshalJSON() ([]byte, error)

+ func (j *ModifyQueueRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetAttributes() map[string]string

+ func (m *ModifyQueueRequest) GetId() *QueueId

+ func (m *ModifyQueueRequest) GetRPCTimeout() int64

+ func (m *ModifyQueueRequest) Reset()

+ func (m *ModifyQueueRequest) String() string

+ func (m *ModifyQueueRequest) XXX_DiscardUnknown()

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

+ func (m *ModifyQueueRequest) XXX_Size() int

+ func (m *ModifyQueueRequest) XXX_Unmarshal(b []byte) error

+ type ModifyQueueResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ModifyQueueResponse) ProtoMessage()

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

+ func (j *ModifyQueueResponse) MarshalJSON() ([]byte, error)

+ func (j *ModifyQueueResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (j *ModifyQueueResponse) UnmarshalJSON(input []byte) error

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

+ func (m *ModifyQueueResponse) Reset()

+ func (m *ModifyQueueResponse) String() string

+ func (m *ModifyQueueResponse) XXX_DiscardUnknown()

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

+ func (m *ModifyQueueResponse) XXX_Size() int

+ func (m *ModifyQueueResponse) XXX_Unmarshal(b []byte) error

+ type PublishMessagesRequest struct

+ Messages []*Message

+ QueueId *QueueId

+ RPCTimeout int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PublishMessagesRequest) ProtoMessage()

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

+ func (j *PublishMessagesRequest) MarshalJSON() ([]byte, error)

+ func (j *PublishMessagesRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetMessages() []*Message

+ func (m *PublishMessagesRequest) GetQueueId() *QueueId

+ func (m *PublishMessagesRequest) GetRPCTimeout() int64

+ func (m *PublishMessagesRequest) Reset()

+ func (m *PublishMessagesRequest) String() string

+ func (m *PublishMessagesRequest) XXX_DiscardUnknown()

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

+ func (m *PublishMessagesRequest) XXX_Size() int

+ func (m *PublishMessagesRequest) XXX_Unmarshal(b []byte) error

+ type PublishMessagesResponse struct

+ Failed []*FailedPublish

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PublishMessagesResponse) ProtoMessage()

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

+ func (j *PublishMessagesResponse) MarshalJSON() ([]byte, error)

+ func (j *PublishMessagesResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetFailed() []*FailedPublish

+ func (m *PublishMessagesResponse) Reset()

+ func (m *PublishMessagesResponse) String() string

+ func (m *PublishMessagesResponse) XXX_DiscardUnknown()

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

+ func (m *PublishMessagesResponse) XXX_Size() int

+ func (m *PublishMessagesResponse) XXX_Unmarshal(b []byte) error

+ type PurgeQueueRequest struct

+ Id *QueueId

+ RPCTimeout int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PurgeQueueRequest) ProtoMessage()

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

+ func (j *PurgeQueueRequest) MarshalJSON() ([]byte, error)

+ func (j *PurgeQueueRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetId() *QueueId

+ func (m *PurgeQueueRequest) GetRPCTimeout() int64

+ func (m *PurgeQueueRequest) Reset()

+ func (m *PurgeQueueRequest) String() string

+ func (m *PurgeQueueRequest) XXX_DiscardUnknown()

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

+ func (m *PurgeQueueRequest) XXX_Size() int

+ func (m *PurgeQueueRequest) XXX_Unmarshal(b []byte) error

+ type PurgeQueueResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PurgeQueueResponse) ProtoMessage()

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

+ func (j *PurgeQueueResponse) MarshalJSON() ([]byte, error)

+ func (j *PurgeQueueResponse) MarshalJSONBuf(buf fflib.EncodingBuffer) error

+ func (j *PurgeQueueResponse) UnmarshalJSON(input []byte) error

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

+ func (m *PurgeQueueResponse) Reset()

+ func (m *PurgeQueueResponse) String() string

+ func (m *PurgeQueueResponse) XXX_DiscardUnknown()

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

+ func (m *PurgeQueueResponse) XXX_Size() int

+ func (m *PurgeQueueResponse) XXX_Unmarshal(b []byte) error

+ type QProxyClient interface

+ AckMessages func(ctx context.Context, in *AckMessagesRequest, opts ...grpc.CallOption) (*AckMessagesResponse, error)

+ CreateQueue func(ctx context.Context, in *CreateQueueRequest, opts ...grpc.CallOption) (*CreateQueueResponse, error)

+ DeleteQueue func(ctx context.Context, in *DeleteQueueRequest, opts ...grpc.CallOption) (*DeleteQueueResponse, error)

+ GetMessages func(ctx context.Context, in *GetMessagesRequest, opts ...grpc.CallOption) (*GetMessagesResponse, error)

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

+ Healthcheck func(ctx context.Context, in *HealthcheckRequest, opts ...grpc.CallOption) (*HealthcheckResponse, error)

+ ListQueues func(ctx context.Context, in *ListQueuesRequest, opts ...grpc.CallOption) (QProxy_ListQueuesClient, error)

+ ModifyAckDeadline func(ctx context.Context, in *ModifyAckDeadlineRequest, opts ...grpc.CallOption) (*ModifyAckDeadlineResponse, error)

+ ModifyQueue func(ctx context.Context, in *ModifyQueueRequest, opts ...grpc.CallOption) (*ModifyQueueResponse, error)

+ PublishMessages func(ctx context.Context, in *PublishMessagesRequest, opts ...grpc.CallOption) (*PublishMessagesResponse, error)

+ PurgeQueue func(ctx context.Context, in *PurgeQueueRequest, opts ...grpc.CallOption) (*PurgeQueueResponse, error)

+ func NewQProxyClient(cc *grpc.ClientConn) QProxyClient

+ type QProxyServer interface

+ AckMessages func(context.Context, *AckMessagesRequest) (*AckMessagesResponse, error)

+ CreateQueue func(context.Context, *CreateQueueRequest) (*CreateQueueResponse, error)

+ DeleteQueue func(context.Context, *DeleteQueueRequest) (*DeleteQueueResponse, error)

+ GetMessages func(context.Context, *GetMessagesRequest) (*GetMessagesResponse, error)

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

+ Healthcheck func(context.Context, *HealthcheckRequest) (*HealthcheckResponse, error)

+ ListQueues func(*ListQueuesRequest, QProxy_ListQueuesServer) error

+ ModifyAckDeadline func(context.Context, *ModifyAckDeadlineRequest) (*ModifyAckDeadlineResponse, error)

+ ModifyQueue func(context.Context, *ModifyQueueRequest) (*ModifyQueueResponse, error)

+ PublishMessages func(context.Context, *PublishMessagesRequest) (*PublishMessagesResponse, error)

+ PurgeQueue func(context.Context, *PurgeQueueRequest) (*PurgeQueueResponse, error)

+ type QProxy_ListQueuesClient interface

+ Recv func() (*ListQueuesResponse, error)

+ type QProxy_ListQueuesServer interface

+ Send func(*ListQueuesResponse) error

+ type QueueId struct

+ Name string

+ Namespace string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*QueueId) ProtoMessage()

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

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

+ func (j *QueueId) MarshalJSONBuf(buf fflib.EncodingBuffer) error

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

+ 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) GetName() string

+ func (m *QueueId) GetNamespace() string

+ func (m *QueueId) Reset()

+ func (m *QueueId) String() string

+ func (m *QueueId) XXX_DiscardUnknown()

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

+ func (m *QueueId) XXX_Size() int

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