spb

package
v0.25.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 17, 2023 License: Apache-2.0 Imports: 7 Imported by: 24

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthProtocol        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProtocol          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupProtocol = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CtrlMsg_Type_name = map[int32]string{
	0: "SubUnsubscribe",
	1: "SubClose",
	2: "ConnClose",
	3: "FTHeartbeat",
	4: "Partitioning",
}
View Source 
var CtrlMsg_Type_value = map[string]int32{
	"SubUnsubscribe": 0,
	"SubClose":       1,
	"ConnClose":      2,
	"FTHeartbeat":    3,
	"Partitioning":   4,
}
View Source 
var RaftOperation_Type_name = map[int32]string{
	0: "Publish",
	1: "Subscribe",
	2: "RemoveSubscription",
	3: "CloseSubscription",
	4: "SendAndAck",
	6: "Connect",
	7: "Disconnect",
	8: "DeleteChannel",
}
View Source 
var RaftOperation_Type_value = map[string]int32{
	"Publish":            0,
	"Subscribe":          1,
	"RemoveSubscription": 2,
	"CloseSubscription":  3,
	"SendAndAck":         4,
	"Connect":            6,
	"Disconnect":         7,
	"DeleteChannel":      8,
}

Functions

This section is empty.

Types

type AddClient added in v0.9.0 

type AddClient struct {
	Request *pb.ConnectRequest `protobuf:"bytes,1,opt,name=Request,proto3" json:"Request,omitempty"`
	Refresh bool               `protobuf:"varint,2,opt,name=Refresh,proto3" json:"Refresh,omitempty"`
}

AddClient is used to replicate a new client connection.

func (*AddClient) Descriptor added in v0.9.0 

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

func (*AddClient) Marshal added in v0.9.0 

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

func (*AddClient) MarshalTo added in v0.9.0 

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

func (*AddClient) MarshalToSizedBuffer added in v0.21.0 

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

func (*AddClient) ProtoMessage added in v0.9.0 

func (*AddClient) ProtoMessage()

func (*AddClient) Reset added in v0.9.0 

func (m *AddClient) Reset()

func (*AddClient) Size added in v0.9.0 

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

func (*AddClient) String added in v0.9.0 

func (m *AddClient) String() string

func (*AddClient) Unmarshal added in v0.9.0 

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

func (*AddClient) XXX_DiscardUnknown added in v0.21.0 

func (m *AddClient) XXX_DiscardUnknown()

func (*AddClient) XXX_Marshal added in v0.21.0 

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

func (*AddClient) XXX_Merge added in v0.21.0 

func (m *AddClient) XXX_Merge(src proto.Message)

func (*AddClient) XXX_Size added in v0.21.0 

func (m *AddClient) XXX_Size() int

func (*AddClient) XXX_Unmarshal added in v0.21.0 

func (m *AddClient) XXX_Unmarshal(b []byte) error

type AddSubscription added in v0.9.0 

type AddSubscription struct {
	Request  *pb.SubscriptionRequest `protobuf:"bytes,1,opt,name=Request,proto3" json:"Request,omitempty"`
	AckInbox string                  `protobuf:"bytes,2,opt,name=AckInbox,proto3" json:"AckInbox,omitempty"`
	ID       uint64                  `protobuf:"varint,3,opt,name=ID,proto3" json:"ID,omitempty"`
}

AddSubscription is used to replicate a new client subscription.

func (*AddSubscription) Descriptor added in v0.9.0 

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

func (*AddSubscription) Marshal added in v0.9.0 

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

func (*AddSubscription) MarshalTo added in v0.9.0 

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

func (*AddSubscription) MarshalToSizedBuffer added in v0.21.0 

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

func (*AddSubscription) ProtoMessage added in v0.9.0 

func (*AddSubscription) ProtoMessage()

func (*AddSubscription) Reset added in v0.9.0 

func (m *AddSubscription) Reset()

func (*AddSubscription) Size added in v0.9.0 

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

func (*AddSubscription) String added in v0.9.0 

func (m *AddSubscription) String() string

func (*AddSubscription) Unmarshal added in v0.9.0 

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

func (*AddSubscription) XXX_DiscardUnknown added in v0.21.0 

func (m *AddSubscription) XXX_DiscardUnknown()

func (*AddSubscription) XXX_Marshal added in v0.21.0 

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

func (*AddSubscription) XXX_Merge added in v0.21.0 

func (m *AddSubscription) XXX_Merge(src proto.Message)

func (*AddSubscription) XXX_Size added in v0.21.0 

func (m *AddSubscription) XXX_Size() int

func (*AddSubscription) XXX_Unmarshal added in v0.21.0 

func (m *AddSubscription) XXX_Unmarshal(b []byte) error

type Batch added in v0.9.0 

type Batch struct {
	Messages []*pb.MsgProto `protobuf:"bytes,1,rep,name=Messages,proto3" json:"Messages,omitempty"`
}

Batch is a batch of messages for replication.

func (*Batch) Descriptor added in v0.9.0 

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

func (*Batch) Marshal added in v0.9.0 

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

func (*Batch) MarshalTo added in v0.9.0 

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

func (*Batch) MarshalToSizedBuffer added in v0.21.0 

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

func (*Batch) ProtoMessage added in v0.9.0 

func (*Batch) ProtoMessage()

func (*Batch) Reset added in v0.9.0 

func (m *Batch) Reset()

func (*Batch) Size added in v0.9.0 

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

func (*Batch) String added in v0.9.0 

func (m *Batch) String() string

func (*Batch) Unmarshal added in v0.9.0 

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

func (*Batch) XXX_DiscardUnknown added in v0.21.0 

func (m *Batch) XXX_DiscardUnknown()

func (*Batch) XXX_Marshal added in v0.21.0 

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

func (*Batch) XXX_Merge added in v0.21.0 

func (m *Batch) XXX_Merge(src proto.Message)

func (*Batch) XXX_Size added in v0.21.0 

func (m *Batch) XXX_Size() int

func (*Batch) XXX_Unmarshal added in v0.21.0 

func (m *Batch) XXX_Unmarshal(b []byte) error

type ChannelSnapshot added in v0.9.0 

type ChannelSnapshot struct {
	Channel       string                  `protobuf:"bytes,1,opt,name=Channel,proto3" json:"Channel,omitempty"`
	First         uint64                  `protobuf:"varint,2,opt,name=First,proto3" json:"First,omitempty"`
	Last          uint64                  `protobuf:"varint,3,opt,name=Last,proto3" json:"Last,omitempty"`
	Subscriptions []*SubscriptionSnapshot `protobuf:"bytes,4,rep,name=Subscriptions,proto3" json:"Subscriptions,omitempty"`
	NextSubID     uint64                  `protobuf:"varint,5,opt,name=NextSubID,proto3" json:"NextSubID,omitempty"`
	ChannelID     uint64                  `protobuf:"varint,6,opt,name=ChannelID,proto3" json:"ChannelID,omitempty"`
}

ChannelSnapshot is a snapshot of a channel

func (*ChannelSnapshot) Descriptor added in v0.9.0 

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

func (*ChannelSnapshot) Marshal added in v0.9.0 

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

func (*ChannelSnapshot) MarshalTo added in v0.9.0 

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

func (*ChannelSnapshot) MarshalToSizedBuffer added in v0.21.0 

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

func (*ChannelSnapshot) ProtoMessage added in v0.9.0 

func (*ChannelSnapshot) ProtoMessage()

func (*ChannelSnapshot) Reset added in v0.9.0 

func (m *ChannelSnapshot) Reset()

func (*ChannelSnapshot) Size added in v0.9.0 

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

func (*ChannelSnapshot) String added in v0.9.0 

func (m *ChannelSnapshot) String() string

func (*ChannelSnapshot) Unmarshal added in v0.9.0 

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

func (*ChannelSnapshot) XXX_DiscardUnknown added in v0.21.0 

func (m *ChannelSnapshot) XXX_DiscardUnknown()

func (*ChannelSnapshot) XXX_Marshal added in v0.21.0 

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

func (*ChannelSnapshot) XXX_Merge added in v0.21.0 

func (m *ChannelSnapshot) XXX_Merge(src proto.Message)

func (*ChannelSnapshot) XXX_Size added in v0.21.0 

func (m *ChannelSnapshot) XXX_Size() int

func (*ChannelSnapshot) XXX_Unmarshal added in v0.21.0 

func (m *ChannelSnapshot) XXX_Unmarshal(b []byte) error

type ClientDelete added in v0.2.0 

type ClientDelete struct {
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
}

func (*ClientDelete) Descriptor added in v0.9.0 

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

func (*ClientDelete) Marshal added in v0.2.0 

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

func (*ClientDelete) MarshalTo added in v0.2.0 

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

func (*ClientDelete) MarshalToSizedBuffer added in v0.21.0 

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

func (*ClientDelete) ProtoMessage added in v0.2.0 

func (*ClientDelete) ProtoMessage()

func (*ClientDelete) Reset added in v0.2.0 

func (m *ClientDelete) Reset()

func (*ClientDelete) Size added in v0.2.0 

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

func (*ClientDelete) String added in v0.2.0 

func (m *ClientDelete) String() string

func (*ClientDelete) Unmarshal added in v0.2.0 

func (m *ClientDelete) Unmarshal(dAtA []byte) error

func (*ClientDelete) XXX_DiscardUnknown added in v0.21.0 

func (m *ClientDelete) XXX_DiscardUnknown()

func (*ClientDelete) XXX_Marshal added in v0.21.0 

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

func (*ClientDelete) XXX_Merge added in v0.21.0 

func (m *ClientDelete) XXX_Merge(src proto.Message)

func (*ClientDelete) XXX_Size added in v0.21.0 

func (m *ClientDelete) XXX_Size() int

func (*ClientDelete) XXX_Unmarshal added in v0.21.0 

func (m *ClientDelete) XXX_Unmarshal(b []byte) error

type ClientInfo added in v0.2.0 

type ClientInfo struct {
	ID           string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	HbInbox      string `protobuf:"bytes,2,opt,name=HbInbox,proto3" json:"HbInbox,omitempty"`
	ConnID       []byte `protobuf:"bytes,3,opt,name=ConnID,proto3" json:"ConnID,omitempty"`
	Protocol     int32  `protobuf:"varint,4,opt,name=Protocol,proto3" json:"Protocol,omitempty"`
	PingInterval int32  `protobuf:"varint,5,opt,name=PingInterval,proto3" json:"PingInterval,omitempty"`
	PingMaxOut   int32  `protobuf:"varint,6,opt,name=PingMaxOut,proto3" json:"PingMaxOut,omitempty"`
}

ClientInfo contains information related to a Client

func (*ClientInfo) Descriptor added in v0.9.0 

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

func (*ClientInfo) Marshal added in v0.2.0 

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

func (*ClientInfo) MarshalTo added in v0.2.0 

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

func (*ClientInfo) MarshalToSizedBuffer added in v0.21.0 

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

func (*ClientInfo) ProtoMessage added in v0.2.0 

func (*ClientInfo) ProtoMessage()

func (*ClientInfo) Reset added in v0.2.0 

func (m *ClientInfo) Reset()

func (*ClientInfo) Size added in v0.2.0 

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

func (*ClientInfo) String added in v0.2.0 

func (m *ClientInfo) String() string

func (*ClientInfo) Unmarshal added in v0.2.0 

func (m *ClientInfo) Unmarshal(dAtA []byte) error

func (*ClientInfo) XXX_DiscardUnknown added in v0.21.0 

func (m *ClientInfo) XXX_DiscardUnknown()

func (*ClientInfo) XXX_Marshal added in v0.21.0 

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

func (*ClientInfo) XXX_Merge added in v0.21.0 

func (m *ClientInfo) XXX_Merge(src proto.Message)

func (*ClientInfo) XXX_Size added in v0.21.0 

func (m *ClientInfo) XXX_Size() int

func (*ClientInfo) XXX_Unmarshal added in v0.21.0 

func (m *ClientInfo) XXX_Unmarshal(b []byte) error

type CtrlMsg added in v0.3.4 

type CtrlMsg struct {
	MsgType  CtrlMsg_Type `protobuf:"varint,1,opt,name=MsgType,proto3,enum=spb.CtrlMsg_Type" json:"MsgType,omitempty"`
	ServerID string       `protobuf:"bytes,2,opt,name=ServerID,proto3" json:"ServerID,omitempty"`
	Data     []byte       `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	RefID    string       `protobuf:"bytes,4,opt,name=RefID,proto3" json:"RefID,omitempty"`
}

func (*CtrlMsg) Descriptor added in v0.9.0 

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

func (*CtrlMsg) Marshal added in v0.3.4 

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

func (*CtrlMsg) MarshalTo added in v0.3.4 

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

func (*CtrlMsg) MarshalToSizedBuffer added in v0.21.0 

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

func (*CtrlMsg) ProtoMessage added in v0.3.4 

func (*CtrlMsg) ProtoMessage()

func (*CtrlMsg) Reset added in v0.3.4 

func (m *CtrlMsg) Reset()

func (*CtrlMsg) Size added in v0.3.4 

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

func (*CtrlMsg) String added in v0.3.4 

func (m *CtrlMsg) String() string

func (*CtrlMsg) Unmarshal added in v0.3.4 

func (m *CtrlMsg) Unmarshal(dAtA []byte) error

func (*CtrlMsg) XXX_DiscardUnknown added in v0.21.0 

func (m *CtrlMsg) XXX_DiscardUnknown()

func (*CtrlMsg) XXX_Marshal added in v0.21.0 

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

func (*CtrlMsg) XXX_Merge added in v0.21.0 

func (m *CtrlMsg) XXX_Merge(src proto.Message)

func (*CtrlMsg) XXX_Size added in v0.21.0 

func (m *CtrlMsg) XXX_Size() int

func (*CtrlMsg) XXX_Unmarshal added in v0.21.0 

func (m *CtrlMsg) XXX_Unmarshal(b []byte) error

type CtrlMsg_Type added in v0.3.4 

type CtrlMsg_Type int32
const (
	CtrlMsg_SubUnsubscribe CtrlMsg_Type = 0
	CtrlMsg_SubClose       CtrlMsg_Type = 1
	CtrlMsg_ConnClose      CtrlMsg_Type = 2
	CtrlMsg_FTHeartbeat    CtrlMsg_Type = 3
	CtrlMsg_Partitioning   CtrlMsg_Type = 4
)

func (CtrlMsg_Type) EnumDescriptor added in v0.9.0 

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

func (CtrlMsg_Type) String added in v0.3.4 

func (x CtrlMsg_Type) String() string

type RaftJoinRequest added in v0.9.0 

type RaftJoinRequest struct {
	NodeID   string `protobuf:"bytes,1,opt,name=NodeID,proto3" json:"NodeID,omitempty"`
	NodeAddr string `protobuf:"bytes,2,opt,name=NodeAddr,proto3" json:"NodeAddr,omitempty"`
}

RaftJoinRequest is a request to join a Raft group.

func (*RaftJoinRequest) Descriptor added in v0.9.0 

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

func (*RaftJoinRequest) Marshal added in v0.9.0 

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

func (*RaftJoinRequest) MarshalTo added in v0.9.0 

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

func (*RaftJoinRequest) MarshalToSizedBuffer added in v0.21.0 

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

func (*RaftJoinRequest) ProtoMessage added in v0.9.0 

func (*RaftJoinRequest) ProtoMessage()

func (*RaftJoinRequest) Reset added in v0.9.0 

func (m *RaftJoinRequest) Reset()

func (*RaftJoinRequest) Size added in v0.9.0 

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

func (*RaftJoinRequest) String added in v0.9.0 

func (m *RaftJoinRequest) String() string

func (*RaftJoinRequest) Unmarshal added in v0.9.0 

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

func (*RaftJoinRequest) XXX_DiscardUnknown added in v0.21.0 

func (m *RaftJoinRequest) XXX_DiscardUnknown()

func (*RaftJoinRequest) XXX_Marshal added in v0.21.0 

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

func (*RaftJoinRequest) XXX_Merge added in v0.21.0 

func (m *RaftJoinRequest) XXX_Merge(src proto.Message)

func (*RaftJoinRequest) XXX_Size added in v0.21.0 

func (m *RaftJoinRequest) XXX_Size() int

func (*RaftJoinRequest) XXX_Unmarshal added in v0.21.0 

func (m *RaftJoinRequest) XXX_Unmarshal(b []byte) error

type RaftJoinResponse added in v0.9.0 

type RaftJoinResponse struct {
	Error string `protobuf:"bytes,1,opt,name=Error,proto3" json:"Error,omitempty"`
}

RaftJoinResponse is a response to a RaftJoinRequest.

func (*RaftJoinResponse) Descriptor added in v0.9.0 

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

func (*RaftJoinResponse) Marshal added in v0.9.0 

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

func (*RaftJoinResponse) MarshalTo added in v0.9.0 

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

func (*RaftJoinResponse) MarshalToSizedBuffer added in v0.21.0 

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

func (*RaftJoinResponse) ProtoMessage added in v0.9.0 

func (*RaftJoinResponse) ProtoMessage()

func (*RaftJoinResponse) Reset added in v0.9.0 

func (m *RaftJoinResponse) Reset()

func (*RaftJoinResponse) Size added in v0.9.0 

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

func (*RaftJoinResponse) String added in v0.9.0 

func (m *RaftJoinResponse) String() string

func (*RaftJoinResponse) Unmarshal added in v0.9.0 

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

func (*RaftJoinResponse) XXX_DiscardUnknown added in v0.21.0 

func (m *RaftJoinResponse) XXX_DiscardUnknown()

func (*RaftJoinResponse) XXX_Marshal added in v0.21.0 

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

func (*RaftJoinResponse) XXX_Merge added in v0.21.0 

func (m *RaftJoinResponse) XXX_Merge(src proto.Message)

func (*RaftJoinResponse) XXX_Size added in v0.21.0 

func (m *RaftJoinResponse) XXX_Size() int

func (*RaftJoinResponse) XXX_Unmarshal added in v0.21.0 

func (m *RaftJoinResponse) XXX_Unmarshal(b []byte) error

type RaftOperation added in v0.9.0 

type RaftOperation struct {
	OpType           RaftOperation_Type     `protobuf:"varint,1,opt,name=OpType,proto3,enum=spb.RaftOperation_Type" json:"OpType,omitempty"`
	PublishBatch     *Batch                 `protobuf:"bytes,2,opt,name=PublishBatch,proto3" json:"PublishBatch,omitempty"`
	Sub              *AddSubscription       `protobuf:"bytes,3,opt,name=Sub,proto3" json:"Sub,omitempty"`
	Unsub            *pb.UnsubscribeRequest `protobuf:"bytes,4,opt,name=Unsub,proto3" json:"Unsub,omitempty"`
	SubSentAck       *SubSentAndAck         `protobuf:"bytes,5,opt,name=SubSentAck,proto3" json:"SubSentAck,omitempty"`
	ClientConnect    *AddClient             `protobuf:"bytes,7,opt,name=ClientConnect,proto3" json:"ClientConnect,omitempty"`
	ClientDisconnect *pb.CloseRequest       `protobuf:"bytes,8,opt,name=ClientDisconnect,proto3" json:"ClientDisconnect,omitempty"`
	Channel          string                 `protobuf:"bytes,9,opt,name=Channel,proto3" json:"Channel,omitempty"`
	ChannelID        uint64                 `protobuf:"varint,10,opt,name=ChannelID,proto3" json:"ChannelID,omitempty"`
}

RaftOperation is a Raft log message.

func (*RaftOperation) Descriptor added in v0.9.0 

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

func (*RaftOperation) Marshal added in v0.9.0 

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

func (*RaftOperation) MarshalTo added in v0.9.0 

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

func (*RaftOperation) MarshalToSizedBuffer added in v0.21.0 

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

func (*RaftOperation) ProtoMessage added in v0.9.0 

func (*RaftOperation) ProtoMessage()

func (*RaftOperation) Reset added in v0.9.0 

func (m *RaftOperation) Reset()

func (*RaftOperation) Size added in v0.9.0 

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

func (*RaftOperation) String added in v0.9.0 

func (m *RaftOperation) String() string

func (*RaftOperation) Unmarshal added in v0.9.0 

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

func (*RaftOperation) XXX_DiscardUnknown added in v0.21.0 

func (m *RaftOperation) XXX_DiscardUnknown()

func (*RaftOperation) XXX_Marshal added in v0.21.0 

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

func (*RaftOperation) XXX_Merge added in v0.21.0 

func (m *RaftOperation) XXX_Merge(src proto.Message)

func (*RaftOperation) XXX_Size added in v0.21.0 

func (m *RaftOperation) XXX_Size() int

func (*RaftOperation) XXX_Unmarshal added in v0.21.0 

func (m *RaftOperation) XXX_Unmarshal(b []byte) error

type RaftOperation_Type added in v0.9.0 

type RaftOperation_Type int32
const (
	RaftOperation_Publish            RaftOperation_Type = 0
	RaftOperation_Subscribe          RaftOperation_Type = 1
	RaftOperation_RemoveSubscription RaftOperation_Type = 2
	RaftOperation_CloseSubscription  RaftOperation_Type = 3
	RaftOperation_SendAndAck         RaftOperation_Type = 4
	RaftOperation_Connect            RaftOperation_Type = 6
	RaftOperation_Disconnect         RaftOperation_Type = 7
	RaftOperation_DeleteChannel      RaftOperation_Type = 8
)

func (RaftOperation_Type) EnumDescriptor added in v0.9.0 

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

func (RaftOperation_Type) String added in v0.9.0 

func (x RaftOperation_Type) String() string

type RaftSnapshot added in v0.9.0 

type RaftSnapshot struct {
	Clients  []*ClientInfo      `protobuf:"bytes,1,rep,name=Clients,proto3" json:"Clients,omitempty"`
	Channels []*ChannelSnapshot `protobuf:"bytes,2,rep,name=Channels,proto3" json:"Channels,omitempty"`
	Padding  []byte             `protobuf:"bytes,3,opt,name=Padding,proto3" json:"Padding,omitempty"`
}

RaftSnapshot is a snapshot of the state of the server.

func (*RaftSnapshot) Descriptor added in v0.9.0 

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

func (*RaftSnapshot) Marshal added in v0.9.0 

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

func (*RaftSnapshot) MarshalTo added in v0.9.0 

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

func (*RaftSnapshot) MarshalToSizedBuffer added in v0.21.0 

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

func (*RaftSnapshot) ProtoMessage added in v0.9.0 

func (*RaftSnapshot) ProtoMessage()

func (*RaftSnapshot) Reset added in v0.9.0 

func (m *RaftSnapshot) Reset()

func (*RaftSnapshot) Size added in v0.9.0 

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

func (*RaftSnapshot) String added in v0.9.0 

func (m *RaftSnapshot) String() string

func (*RaftSnapshot) Unmarshal added in v0.9.0 

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

func (*RaftSnapshot) XXX_DiscardUnknown added in v0.21.0 

func (m *RaftSnapshot) XXX_DiscardUnknown()

func (*RaftSnapshot) XXX_Marshal added in v0.21.0 

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

func (*RaftSnapshot) XXX_Merge added in v0.21.0 

func (m *RaftSnapshot) XXX_Merge(src proto.Message)

func (*RaftSnapshot) XXX_Size added in v0.21.0 

func (m *RaftSnapshot) XXX_Size() int

func (*RaftSnapshot) XXX_Unmarshal added in v0.21.0 

func (m *RaftSnapshot) XXX_Unmarshal(b []byte) error

type ServerInfo 

type ServerInfo struct {
	ClusterID   string `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"`
	Discovery   string `protobuf:"bytes,2,opt,name=Discovery,proto3" json:"Discovery,omitempty"`
	Publish     string `protobuf:"bytes,3,opt,name=Publish,proto3" json:"Publish,omitempty"`
	Subscribe   string `protobuf:"bytes,4,opt,name=Subscribe,proto3" json:"Subscribe,omitempty"`
	Unsubscribe string `protobuf:"bytes,5,opt,name=Unsubscribe,proto3" json:"Unsubscribe,omitempty"`
	Close       string `protobuf:"bytes,6,opt,name=Close,proto3" json:"Close,omitempty"`
	SubClose    string `protobuf:"bytes,7,opt,name=SubClose,proto3" json:"SubClose,omitempty"`
	AcksSubs    string `protobuf:"bytes,8,opt,name=AcksSubs,proto3" json:"AcksSubs,omitempty"`
	NodeID      string `protobuf:"bytes,9,opt,name=NodeID,proto3" json:"NodeID,omitempty"`
}

ServerInfo contains basic information regarding the Server

func (*ServerInfo) Descriptor added in v0.9.0 

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

func (*ServerInfo) Marshal 

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

func (*ServerInfo) MarshalTo 

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

func (*ServerInfo) MarshalToSizedBuffer added in v0.21.0 

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

func (*ServerInfo) ProtoMessage 

func (*ServerInfo) ProtoMessage()

func (*ServerInfo) Reset 

func (m *ServerInfo) Reset()

func (*ServerInfo) Size 

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

func (*ServerInfo) String 

func (m *ServerInfo) String() string

func (*ServerInfo) Unmarshal 

func (m *ServerInfo) Unmarshal(dAtA []byte) error

func (*ServerInfo) XXX_DiscardUnknown added in v0.21.0 

func (m *ServerInfo) XXX_DiscardUnknown()

func (*ServerInfo) XXX_Marshal added in v0.21.0 

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

func (*ServerInfo) XXX_Merge added in v0.21.0 

func (m *ServerInfo) XXX_Merge(src proto.Message)

func (*ServerInfo) XXX_Size added in v0.21.0 

func (m *ServerInfo) XXX_Size() int

func (*ServerInfo) XXX_Unmarshal added in v0.21.0 

func (m *ServerInfo) XXX_Unmarshal(b []byte) error

type SubSentAndAck added in v0.9.0 

type SubSentAndAck struct {
	Channel  string   `protobuf:"bytes,1,opt,name=Channel,proto3" json:"Channel,omitempty"`
	AckInbox string   `protobuf:"bytes,2,opt,name=AckInbox,proto3" json:"AckInbox,omitempty"`
	Sent     []uint64 `protobuf:"varint,3,rep,packed,name=Sent,proto3" json:"Sent,omitempty"`
	Ack      []uint64 `protobuf:"varint,4,rep,packed,name=Ack,proto3" json:"Ack,omitempty"`
}

SubSentAndAck is used to replicate a sent and/or ack messages.

func (*SubSentAndAck) Descriptor added in v0.9.0 

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

func (*SubSentAndAck) Marshal added in v0.9.0 

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

func (*SubSentAndAck) MarshalTo added in v0.9.0 

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

func (*SubSentAndAck) MarshalToSizedBuffer added in v0.21.0 

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

func (*SubSentAndAck) ProtoMessage added in v0.9.0 

func (*SubSentAndAck) ProtoMessage()

func (*SubSentAndAck) Reset added in v0.9.0 

func (m *SubSentAndAck) Reset()

func (*SubSentAndAck) Size added in v0.9.0 

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

func (*SubSentAndAck) String added in v0.9.0 

func (m *SubSentAndAck) String() string

func (*SubSentAndAck) Unmarshal added in v0.9.0 

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

func (*SubSentAndAck) XXX_DiscardUnknown added in v0.21.0 

func (m *SubSentAndAck) XXX_DiscardUnknown()

func (*SubSentAndAck) XXX_Marshal added in v0.21.0 

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

func (*SubSentAndAck) XXX_Merge added in v0.21.0 

func (m *SubSentAndAck) XXX_Merge(src proto.Message)

func (*SubSentAndAck) XXX_Size added in v0.21.0 

func (m *SubSentAndAck) XXX_Size() int

func (*SubSentAndAck) XXX_Unmarshal added in v0.21.0 

func (m *SubSentAndAck) XXX_Unmarshal(b []byte) error

type SubState 

type SubState struct {
	ID            uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	ClientID      string `protobuf:"bytes,2,opt,name=clientID,proto3" json:"clientID,omitempty"`
	QGroup        string `protobuf:"bytes,3,opt,name=qGroup,proto3" json:"qGroup,omitempty"`
	Inbox         string `protobuf:"bytes,4,opt,name=inbox,proto3" json:"inbox,omitempty"`
	AckInbox      string `protobuf:"bytes,5,opt,name=ackInbox,proto3" json:"ackInbox,omitempty"`
	MaxInFlight   int32  `protobuf:"varint,6,opt,name=maxInFlight,proto3" json:"maxInFlight,omitempty"`
	AckWaitInSecs int32  `protobuf:"varint,7,opt,name=ackWaitInSecs,proto3" json:"ackWaitInSecs,omitempty"`
	DurableName   string `protobuf:"bytes,8,opt,name=durableName,proto3" json:"durableName,omitempty"`
	LastSent      uint64 `protobuf:"varint,9,opt,name=lastSent,proto3" json:"lastSent,omitempty"`
	IsDurable     bool   `protobuf:"varint,10,opt,name=isDurable,proto3" json:"isDurable,omitempty"`
	IsClosed      bool   `protobuf:"varint,11,opt,name=isClosed,proto3" json:"isClosed,omitempty"`
}

SubState represents the state of a Subscription

func (*SubState) Descriptor added in v0.9.0 

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

func (*SubState) Marshal 

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

func (*SubState) MarshalTo 

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

func (*SubState) MarshalToSizedBuffer added in v0.21.0 

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

func (*SubState) ProtoMessage 

func (*SubState) ProtoMessage()

func (*SubState) Reset 

func (m *SubState) Reset()

func (*SubState) Size 

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

func (*SubState) String 

func (m *SubState) String() string

func (*SubState) Unmarshal 

func (m *SubState) Unmarshal(dAtA []byte) error

func (*SubState) XXX_DiscardUnknown added in v0.21.0 

func (m *SubState) XXX_DiscardUnknown()

func (*SubState) XXX_Marshal added in v0.21.0 

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

func (*SubState) XXX_Merge added in v0.21.0 

func (m *SubState) XXX_Merge(src proto.Message)

func (*SubState) XXX_Size added in v0.21.0 

func (m *SubState) XXX_Size() int

func (*SubState) XXX_Unmarshal added in v0.21.0 

func (m *SubState) XXX_Unmarshal(b []byte) error

type SubStateDelete 

type SubStateDelete struct {
	ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
}

SubStateDelete marks a Subscription as deleted

func (*SubStateDelete) Descriptor added in v0.9.0 

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

func (*SubStateDelete) Marshal 

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

func (*SubStateDelete) MarshalTo 

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

func (*SubStateDelete) MarshalToSizedBuffer added in v0.21.0 

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

func (*SubStateDelete) ProtoMessage 

func (*SubStateDelete) ProtoMessage()

func (*SubStateDelete) Reset 

func (m *SubStateDelete) Reset()

func (*SubStateDelete) Size 

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

func (*SubStateDelete) String 

func (m *SubStateDelete) String() string

func (*SubStateDelete) Unmarshal 

func (m *SubStateDelete) Unmarshal(dAtA []byte) error

func (*SubStateDelete) XXX_DiscardUnknown added in v0.21.0 

func (m *SubStateDelete) XXX_DiscardUnknown()

func (*SubStateDelete) XXX_Marshal added in v0.21.0 

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

func (*SubStateDelete) XXX_Merge added in v0.21.0 

func (m *SubStateDelete) XXX_Merge(src proto.Message)

func (*SubStateDelete) XXX_Size added in v0.21.0 

func (m *SubStateDelete) XXX_Size() int

func (*SubStateDelete) XXX_Unmarshal added in v0.21.0 

func (m *SubStateDelete) XXX_Unmarshal(b []byte) error

type SubStateUpdate 

type SubStateUpdate struct {
	ID    uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Seqno uint64 `protobuf:"varint,2,opt,name=seqno,proto3" json:"seqno,omitempty"`
}

SubStateUpdate represents a subscription update (either Msg or Ack)

func (*SubStateUpdate) Descriptor added in v0.9.0 

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

func (*SubStateUpdate) Marshal 

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

func (*SubStateUpdate) MarshalTo 

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

func (*SubStateUpdate) MarshalToSizedBuffer added in v0.21.0 

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

func (*SubStateUpdate) ProtoMessage 

func (*SubStateUpdate) ProtoMessage()

func (*SubStateUpdate) Reset 

func (m *SubStateUpdate) Reset()

func (*SubStateUpdate) Size 

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

func (*SubStateUpdate) String 

func (m *SubStateUpdate) String() string

func (*SubStateUpdate) Unmarshal 

func (m *SubStateUpdate) Unmarshal(dAtA []byte) error

func (*SubStateUpdate) XXX_DiscardUnknown added in v0.21.0 

func (m *SubStateUpdate) XXX_DiscardUnknown()

func (*SubStateUpdate) XXX_Marshal added in v0.21.0 

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

func (*SubStateUpdate) XXX_Merge added in v0.21.0 

func (m *SubStateUpdate) XXX_Merge(src proto.Message)

func (*SubStateUpdate) XXX_Size added in v0.21.0 

func (m *SubStateUpdate) XXX_Size() int

func (*SubStateUpdate) XXX_Unmarshal added in v0.21.0 

func (m *SubStateUpdate) XXX_Unmarshal(b []byte) error

type SubscriptionSnapshot added in v0.9.0 

type SubscriptionSnapshot struct {
	State       *SubState `protobuf:"bytes,1,opt,name=State,proto3" json:"State,omitempty"`
	AcksPending []uint64  `protobuf:"varint,2,rep,packed,name=AcksPending,proto3" json:"AcksPending,omitempty"`
}

SubscriptionSnaphot is the snapshot of a subscription

func (*SubscriptionSnapshot) Descriptor added in v0.9.0 

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

func (*SubscriptionSnapshot) Marshal added in v0.9.0 

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

func (*SubscriptionSnapshot) MarshalTo added in v0.9.0 

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

func (*SubscriptionSnapshot) MarshalToSizedBuffer added in v0.21.0 

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

func (*SubscriptionSnapshot) ProtoMessage added in v0.9.0 

func (*SubscriptionSnapshot) ProtoMessage()

func (*SubscriptionSnapshot) Reset added in v0.9.0 

func (m *SubscriptionSnapshot) Reset()

func (*SubscriptionSnapshot) Size added in v0.9.0 

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

func (*SubscriptionSnapshot) String added in v0.9.0 

func (m *SubscriptionSnapshot) String() string

func (*SubscriptionSnapshot) Unmarshal added in v0.9.0 

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

func (*SubscriptionSnapshot) XXX_DiscardUnknown added in v0.21.0 

func (m *SubscriptionSnapshot) XXX_DiscardUnknown()

func (*SubscriptionSnapshot) XXX_Marshal added in v0.21.0 

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

func (*SubscriptionSnapshot) XXX_Merge added in v0.21.0 

func (m *SubscriptionSnapshot) XXX_Merge(src proto.Message)

func (*SubscriptionSnapshot) XXX_Size added in v0.21.0 

func (m *SubscriptionSnapshot) XXX_Size() int

func (*SubscriptionSnapshot) XXX_Unmarshal added in v0.21.0 

func (m *SubscriptionSnapshot) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.