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