rpc

package
v0.0.19 Latest Latest
Warning

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

Go to latest
Published: Feb 27, 2021 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

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

Jump to

Keyboard shortcuts

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