Versions in this module Expand all Collapse all v0 v0.7.0 Sep 16, 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
Go to main page