spb

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jun 27, 2017 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package spb is a generated protocol buffer package.

It is generated from these files: 

protocol.proto

It has these top-level messages: 

SubState
SubStateDelete
SubStateUpdate
ServerInfo
ClientInfo
ClientDelete
CtrlMsg

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")
)
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,
}

Functions

This section is empty.

Types

type ClientDelete added in v0.2.0 

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

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) 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

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"`
}

ClientInfo contains information related to a Client

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) 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

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"`
}

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) 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

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) String added in v0.3.4 

func (x CtrlMsg_Type) String() string

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"`
}

ServerInfo contains basic information regarding the Server

func (*ServerInfo) Marshal 

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

func (*ServerInfo) MarshalTo 

func (m *ServerInfo) MarshalTo(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

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"`
}

SubState represents the state of a Subscription

func (*SubState) Marshal 

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

func (*SubState) MarshalTo 

func (m *SubState) MarshalTo(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

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) Marshal 

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

func (*SubStateDelete) MarshalTo 

func (m *SubStateDelete) MarshalTo(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

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) Marshal 

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

func (*SubStateUpdate) MarshalTo 

func (m *SubStateUpdate) MarshalTo(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

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.