pb

package

Go to main page

Versions in this module

v1

v1.8.0

Mar 10, 2024

v1.7.0

Feb 12, 2024

Changes in this version

+ var ErrUnexpectedEndOfGroupProtocol = fmt.Errorf("proto: unexpected end of group")

type Ack

+ func (m *Ack) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Ack) XXX_DiscardUnknown()

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

+ func (m *Ack) XXX_Merge(src proto.Message)

+ func (m *Ack) XXX_Size() int

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

type CloseRequest

+ func (m *CloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CloseRequest) XXX_DiscardUnknown()

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

+ func (m *CloseRequest) XXX_Merge(src proto.Message)

+ func (m *CloseRequest) XXX_Size() int

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

type CloseResponse

+ func (m *CloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CloseResponse) XXX_DiscardUnknown()

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

+ func (m *CloseResponse) XXX_Merge(src proto.Message)

+ func (m *CloseResponse) XXX_Size() int

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

type ConnectRequest

+ func (m *ConnectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConnectRequest) XXX_DiscardUnknown()

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

+ func (m *ConnectRequest) XXX_Merge(src proto.Message)

+ func (m *ConnectRequest) XXX_Size() int

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

type ConnectResponse

+ func (m *ConnectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConnectResponse) XXX_DiscardUnknown()

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

+ func (m *ConnectResponse) XXX_Merge(src proto.Message)

+ func (m *ConnectResponse) XXX_Size() int

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

type MsgProto

+ func (m *MsgProto) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MsgProto) XXX_DiscardUnknown()

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

+ func (m *MsgProto) XXX_Merge(src proto.Message)

+ func (m *MsgProto) XXX_Size() int

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

type Ping

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

+ func (m *Ping) XXX_DiscardUnknown()

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

+ func (m *Ping) XXX_Merge(src proto.Message)

+ func (m *Ping) XXX_Size() int

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

type PingResponse

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

+ func (m *PingResponse) XXX_DiscardUnknown()

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

+ func (m *PingResponse) XXX_Merge(src proto.Message)

+ func (m *PingResponse) XXX_Size() int

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

type PubAck

+ func (m *PubAck) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PubAck) XXX_DiscardUnknown()

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

+ func (m *PubAck) XXX_Merge(src proto.Message)

+ func (m *PubAck) XXX_Size() int

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

type PubMsg

+ func (m *PubMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PubMsg) XXX_DiscardUnknown()

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

+ func (m *PubMsg) XXX_Merge(src proto.Message)

+ func (m *PubMsg) XXX_Size() int

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

type SubscriptionRequest

+ func (m *SubscriptionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SubscriptionRequest) XXX_DiscardUnknown()

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

+ func (m *SubscriptionRequest) XXX_Merge(src proto.Message)

+ func (m *SubscriptionRequest) XXX_Size() int

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

type SubscriptionResponse

+ func (m *SubscriptionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SubscriptionResponse) XXX_DiscardUnknown()

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

+ func (m *SubscriptionResponse) XXX_Merge(src proto.Message)

+ func (m *SubscriptionResponse) XXX_Size() int

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

type UnsubscribeRequest

+ func (m *UnsubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UnsubscribeRequest) XXX_DiscardUnknown()

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

+ func (m *UnsubscribeRequest) XXX_Merge(src proto.Message)

+ func (m *UnsubscribeRequest) XXX_Size() int

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

v1.6.1

Oct 10, 2022

v1.6.0

Oct 10, 2022

v1.5.0

Dec 25, 2020

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

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

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

+ 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

+ ConnID []byte

+ HeartbeatInbox string

+ PingInterval int32

+ PingMaxOut int32

+ Protocol int32

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

+ 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

+ PingInterval int32

+ PingMaxOut int32

+ PingRequests string

+ Protocol int32

+ PubPrefix string

+ PublicKey string

+ SubCloseRequests string

+ SubRequests string

+ UnsubRequests string

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

+ 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

+ RedeliveryCount uint32

+ Reply string

+ Sequence uint64

+ Subject string

+ Timestamp int64

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

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

+ Error string

+ Guid string

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

+ 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

+ ConnID []byte

+ Data []byte

+ Guid string

+ Reply string

+ Sha256 []byte

+ Subject string

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

+ 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 (StartPosition) EnumDescriptor() ([]byte, []int)

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

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

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

+ 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

v1.4.0

Apr 11, 2020

v1.2.0

Apr 2, 2020

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