spb

Apr 16, 2019

Changes in this version

type AddSubscription

+ ID uint64

type ChannelSnapshot

+ NextSubID uint64

Jun 19, 2018

Changes in this version

type ClientInfo

+ ConnID []byte

+ PingInterval int32

+ PingMaxOut int32

+ Protocol int32

Mar 16, 2018

Changes in this version

+ var RaftOperation_Type_name = map[int32]string

+ var RaftOperation_Type_value = map[string]int32

+ type AddClient struct

+ Refresh bool

+ Request *pb.ConnectRequest

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

+ func (*AddClient) ProtoMessage()

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

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

+ func (m *AddClient) Reset()

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

+ func (m *AddClient) String() string

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

+ type AddSubscription struct

+ AckInbox string

+ Request *pb.SubscriptionRequest

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

+ func (*AddSubscription) ProtoMessage()

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

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

+ func (m *AddSubscription) Reset()

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

+ func (m *AddSubscription) String() string

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

+ type Batch struct

+ Messages []*pb.MsgProto

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

+ func (*Batch) ProtoMessage()

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

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

+ func (m *Batch) Reset()

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

+ func (m *Batch) String() string

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

+ type ChannelSnapshot struct

+ Channel string

+ First uint64

+ Last uint64

+ Subscriptions []*SubscriptionSnapshot

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

+ func (*ChannelSnapshot) ProtoMessage()

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

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

+ func (m *ChannelSnapshot) Reset()

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

+ func (m *ChannelSnapshot) String() string

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

type ClientDelete

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

type ClientInfo

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

type CtrlMsg

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

type CtrlMsg_Type

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

+ type RaftJoinRequest struct

+ NodeAddr string

+ NodeID string

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

+ func (*RaftJoinRequest) ProtoMessage()

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

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

+ func (m *RaftJoinRequest) Reset()

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

+ func (m *RaftJoinRequest) String() string

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

+ type RaftJoinResponse struct

+ Error string

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

+ func (*RaftJoinResponse) ProtoMessage()

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

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

+ func (m *RaftJoinResponse) Reset()

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

+ func (m *RaftJoinResponse) String() string

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

+ type RaftOperation struct

+ Channel string

+ ClientConnect *AddClient

+ ClientDisconnect *pb.CloseRequest

+ OpType RaftOperation_Type

+ PublishBatch *Batch

+ Sub *AddSubscription

+ SubSentAck *SubSentAndAck

+ Unsub *pb.UnsubscribeRequest

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

+ func (*RaftOperation) ProtoMessage()

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

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

+ func (m *RaftOperation) Reset()

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

+ func (m *RaftOperation) String() string

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

+ type RaftOperation_Type int32

+ const RaftOperation_CloseSubscription

+ const RaftOperation_Connect

+ const RaftOperation_DeleteChannel

+ const RaftOperation_Disconnect

+ const RaftOperation_Publish

+ const RaftOperation_RemoveSubscription

+ const RaftOperation_SendAndAck

+ const RaftOperation_Subscribe

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

+ func (x RaftOperation_Type) String() string

+ type RaftSnapshot struct

+ Channels []*ChannelSnapshot

+ Clients []*ClientInfo

+ Padding []byte

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

+ func (*RaftSnapshot) ProtoMessage()

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

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

+ func (m *RaftSnapshot) Reset()

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

+ func (m *RaftSnapshot) String() string

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

type ServerInfo

+ NodeID string

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

+ type SubSentAndAck struct

+ Ack []uint64

+ AckInbox string

+ Channel string

+ Sent []uint64

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

+ func (*SubSentAndAck) ProtoMessage()

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

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

+ func (m *SubSentAndAck) Reset()

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

+ func (m *SubSentAndAck) String() string

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

type SubState

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

type SubStateDelete

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

type SubStateUpdate

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

+ type SubscriptionSnapshot struct

+ AcksPending []uint64

+ State *SubState

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

+ func (*SubscriptionSnapshot) ProtoMessage()

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

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

+ func (m *SubscriptionSnapshot) Reset()

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

+ func (m *SubscriptionSnapshot) String() string

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

Oct 25, 2017

Changes in this version

type CtrlMsg

+ RefID string

type SubState

+ IsClosed bool

Jun 27, 2017

Changes in this version

type CtrlMsg_Type

+ const CtrlMsg_Partitioning

Apr 10, 2017

Changes in this version

type CtrlMsg_Type

+ const CtrlMsg_FTHeartbeat

type ServerInfo

+ AcksSubs string

Dec 12, 2016

Changes in this version

+ var CtrlMsg_Type_name = map[int32]string

+ var CtrlMsg_Type_value = map[string]int32

+ type CtrlMsg struct

+ Data []byte

+ MsgType CtrlMsg_Type

+ ServerID string

+ func (*CtrlMsg) ProtoMessage()

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

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

+ func (m *CtrlMsg) Reset()

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

+ func (m *CtrlMsg) String() string

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

+ type CtrlMsg_Type int32

+ const CtrlMsg_ConnClose

+ const CtrlMsg_SubClose

+ const CtrlMsg_SubUnsubscribe

+ func (x CtrlMsg_Type) String() string

type ServerInfo

+ SubClose string

Oct 19, 2016

Changes in this version

type SubState

+ IsDurable bool

Jul 8, 2016

Changes in this version

+ type ClientDelete struct

+ ID string

+ func (*ClientDelete) ProtoMessage()

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

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

+ func (m *ClientDelete) Reset()

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

+ func (m *ClientDelete) String() string

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

+ type ClientInfo struct

+ HbInbox string

+ ID string

+ func (*ClientInfo) ProtoMessage()

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

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

+ func (m *ClientInfo) Reset()

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

+ func (m *ClientInfo) String() string

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

Jun 24, 2016

Changes in this version

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

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

+ type ServerInfo struct

+ Close string

+ ClusterID string

+ Discovery string

+ Publish string

+ Subscribe string

+ Unsubscribe string

+ func (*ServerInfo) ProtoMessage()

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

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

+ func (m *ServerInfo) Reset()

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

+ func (m *ServerInfo) String() string

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

+ type SubState struct

+ AckInbox string

+ AckWaitInSecs int32

+ ClientID string

+ DurableName string

+ ID uint64

+ Inbox string

+ LastSent uint64

+ MaxInFlight int32

+ QGroup string

+ func (*SubState) ProtoMessage()

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

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

+ func (m *SubState) Reset()

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

+ func (m *SubState) String() string

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

+ type SubStateDelete struct

+ ID uint64

+ func (*SubStateDelete) ProtoMessage()

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

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

+ func (m *SubStateDelete) Reset()

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

+ func (m *SubStateDelete) String() string

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

+ type SubStateUpdate struct

+ ID uint64

+ Seqno uint64

+ func (*SubStateUpdate) ProtoMessage()

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

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

+ func (m *SubStateUpdate) Reset()

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

+ func (m *SubStateUpdate) String() string

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