pb

package

Go to main page

Versions in this module

v0

v0.4.5

May 16, 2019

v0.4.4

May 9, 2019

v0.4.2

Mar 14, 2019

v0.4.0

Jun 2, 2018

Changes in this version

type Ack

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

type CloseRequest

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

type CloseResponse

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

type ConnectRequest

+ ConnID []byte

+ PingInterval int32

+ PingMaxOut int32

+ Protocol int32

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

type ConnectResponse

+ PingInterval int32

+ PingMaxOut int32

+ PingRequests string

+ Protocol int32

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

type MsgProto

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

+ type Ping struct

+ ConnID []byte

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

+ func (*Ping) ProtoMessage()

+ func (m *Ping) Marshal() (dAtA []byte, err error)

+ func (m *Ping) MarshalTo(dAtA []byte) (int, error)

+ func (m *Ping) Reset()

+ func (m *Ping) Size() (n int)

+ func (m *Ping) String() string

+ func (m *Ping) Unmarshal(dAtA []byte) error

+ type PingResponse struct

+ Error string

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

+ func (*PingResponse) ProtoMessage()

+ func (m *PingResponse) Marshal() (dAtA []byte, err error)

+ func (m *PingResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *PingResponse) Reset()

+ func (m *PingResponse) Size() (n int)

+ func (m *PingResponse) String() string

+ func (m *PingResponse) Unmarshal(dAtA []byte) error

type PubAck

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

type PubMsg

+ ConnID []byte

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

type StartPosition

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

type SubscriptionRequest

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

type SubscriptionResponse

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

type UnsubscribeRequest

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

v0.3.4

Dec 12, 2016

Changes in this version

type ConnectResponse

+ SubCloseRequests string

v0.3.0

Oct 19, 2016

v0.2.0

Jul 19, 2016

v0.1.0

Jun 24, 2016

Changes in this version

+ var ErrIntOverflowProtocol = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthProtocol = fmt.Errorf("proto: negative length found during unmarshaling")

+ var StartPosition_name = map[int32]string

+ var StartPosition_value = map[string]int32

+ type Ack struct

+ Sequence uint64

+ Subject string

+ func (*Ack) ProtoMessage()

+ func (m *Ack) Marshal() (data []byte, err error)

+ func (m *Ack) MarshalTo(data []byte) (int, error)

+ func (m *Ack) Reset()

+ func (m *Ack) Size() (n int)

+ func (m *Ack) String() string

+ func (m *Ack) Unmarshal(data []byte) error

+ type CloseRequest struct

+ ClientID string

+ func (*CloseRequest) ProtoMessage()

+ func (m *CloseRequest) Marshal() (data []byte, err error)

+ func (m *CloseRequest) MarshalTo(data []byte) (int, error)

+ func (m *CloseRequest) Reset()

+ func (m *CloseRequest) Size() (n int)

+ func (m *CloseRequest) String() string

+ func (m *CloseRequest) Unmarshal(data []byte) error

+ type CloseResponse struct

+ Error string

+ func (*CloseResponse) ProtoMessage()

+ func (m *CloseResponse) Marshal() (data []byte, err error)

+ func (m *CloseResponse) MarshalTo(data []byte) (int, error)

+ func (m *CloseResponse) Reset()

+ func (m *CloseResponse) Size() (n int)

+ func (m *CloseResponse) String() string

+ func (m *CloseResponse) Unmarshal(data []byte) error

+ type ConnectRequest struct

+ ClientID string

+ HeartbeatInbox string

+ func (*ConnectRequest) ProtoMessage()

+ func (m *ConnectRequest) Marshal() (data []byte, err error)

+ func (m *ConnectRequest) MarshalTo(data []byte) (int, error)

+ func (m *ConnectRequest) Reset()

+ func (m *ConnectRequest) Size() (n int)

+ func (m *ConnectRequest) String() string

+ func (m *ConnectRequest) Unmarshal(data []byte) error

+ type ConnectResponse struct

+ CloseRequests string

+ Error string

+ PubPrefix string

+ PublicKey string

+ SubRequests string

+ UnsubRequests string

+ func (*ConnectResponse) ProtoMessage()

+ func (m *ConnectResponse) Marshal() (data []byte, err error)

+ func (m *ConnectResponse) MarshalTo(data []byte) (int, error)

+ func (m *ConnectResponse) Reset()

+ func (m *ConnectResponse) Size() (n int)

+ func (m *ConnectResponse) String() string

+ func (m *ConnectResponse) Unmarshal(data []byte) error

+ type MsgProto struct

+ CRC32 uint32

+ Data []byte

+ Redelivered bool

+ Reply string

+ Sequence uint64

+ Subject string

+ Timestamp int64

+ func (*MsgProto) ProtoMessage()

+ func (m *MsgProto) Marshal() (data []byte, err error)

+ func (m *MsgProto) MarshalTo(data []byte) (int, error)

+ func (m *MsgProto) Reset()

+ func (m *MsgProto) Size() (n int)

+ func (m *MsgProto) String() string

+ func (m *MsgProto) Unmarshal(data []byte) error

+ type PubAck struct

+ Error string

+ Guid string

+ func (*PubAck) ProtoMessage()

+ func (m *PubAck) Marshal() (data []byte, err error)

+ func (m *PubAck) MarshalTo(data []byte) (int, error)

+ func (m *PubAck) Reset()

+ func (m *PubAck) Size() (n int)

+ func (m *PubAck) String() string

+ func (m *PubAck) Unmarshal(data []byte) error

+ type PubMsg struct

+ ClientID string

+ Data []byte

+ Guid string

+ Reply string

+ Sha256 []byte

+ Subject string

+ func (*PubMsg) ProtoMessage()

+ func (m *PubMsg) Marshal() (data []byte, err error)

+ func (m *PubMsg) MarshalTo(data []byte) (int, error)

+ func (m *PubMsg) Reset()

+ func (m *PubMsg) Size() (n int)

+ func (m *PubMsg) String() string

+ func (m *PubMsg) Unmarshal(data []byte) error

+ type StartPosition int32

+ const StartPosition_First

+ const StartPosition_LastReceived

+ const StartPosition_NewOnly

+ const StartPosition_SequenceStart

+ const StartPosition_TimeDeltaStart

+ func (x StartPosition) String() string

+ type SubscriptionRequest struct

+ AckWaitInSecs int32

+ ClientID string

+ DurableName string

+ Inbox string

+ MaxInFlight int32

+ QGroup string

+ StartPosition StartPosition

+ StartSequence uint64

+ StartTimeDelta int64

+ Subject string

+ func (*SubscriptionRequest) ProtoMessage()

+ func (m *SubscriptionRequest) Marshal() (data []byte, err error)

+ func (m *SubscriptionRequest) MarshalTo(data []byte) (int, error)

+ func (m *SubscriptionRequest) Reset()

+ func (m *SubscriptionRequest) Size() (n int)

+ func (m *SubscriptionRequest) String() string

+ func (m *SubscriptionRequest) Unmarshal(data []byte) error

+ type SubscriptionResponse struct

+ AckInbox string

+ Error string

+ func (*SubscriptionResponse) ProtoMessage()

+ func (m *SubscriptionResponse) Marshal() (data []byte, err error)

+ func (m *SubscriptionResponse) MarshalTo(data []byte) (int, error)

+ func (m *SubscriptionResponse) Reset()

+ func (m *SubscriptionResponse) Size() (n int)

+ func (m *SubscriptionResponse) String() string

+ func (m *SubscriptionResponse) Unmarshal(data []byte) error

+ type UnsubscribeRequest struct

+ ClientID string

+ DurableName string

+ Inbox string

+ Subject string

+ func (*UnsubscribeRequest) ProtoMessage()

+ func (m *UnsubscribeRequest) Marshal() (data []byte, err error)

+ func (m *UnsubscribeRequest) MarshalTo(data []byte) (int, error)

+ func (m *UnsubscribeRequest) Reset()

+ func (m *UnsubscribeRequest) Size() (n int)

+ func (m *UnsubscribeRequest) String() string

+ func (m *UnsubscribeRequest) Unmarshal(data []byte) error

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