protos

Documentation

Index

• type ConnProperty
  • func (*ConnProperty) Descriptor() ([]byte, []int)
  • func (m *ConnProperty) GetLocalID() string
  • func (m *ConnProperty) GetLocalIP() []byte
  • func (m *ConnProperty) GetLocalPort() uint32
  • func (m *ConnProperty) GetRemoteID() string
  • func (m *ConnProperty) GetRemoteIP() []byte
  • func (m *ConnProperty) GetRemotePort() uint32
  • func (*ConnProperty) ProtoMessage()
  • func (m *ConnProperty) Reset()
  • func (m *ConnProperty) String() string
  • func (m *ConnProperty) XXX_DiscardUnknown()
  • func (m *ConnProperty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ConnProperty) XXX_Merge(src proto.Message)
  • func (m *ConnProperty) XXX_Size() int
  • func (m *ConnProperty) XXX_Unmarshal(b []byte) error
• type Handshake
  • func (*Handshake) Descriptor() ([]byte, []int)
  • func (m *Handshake) GetCmdSets() []uint32
  • func (m *Handshake) GetID() []byte
  • func (m *Handshake) GetName() string
  • func (m *Handshake) GetPort() uint32
  • func (m *Handshake) GetRemoteIP() []byte
  • func (m *Handshake) GetRemotePort() uint32
  • func (*Handshake) ProtoMessage()
  • func (m *Handshake) Reset()
  • func (m *Handshake) String() string
  • func (m *Handshake) XXX_DiscardUnknown()
  • func (m *Handshake) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Handshake) XXX_Merge(src proto.Message)
  • func (m *Handshake) XXX_Size() int
  • func (m *Handshake) XXX_Unmarshal(b []byte) error
• type Topo
  • func (*Topo) Descriptor() ([]byte, []int)
  • func (m *Topo) GetPeers() []*ConnProperty
  • func (m *Topo) GetPivot() string
  • func (m *Topo) GetTime() int64
  • func (*Topo) ProtoMessage()
  • func (m *Topo) Reset()
  • func (m *Topo) String() string
  • func (m *Topo) XXX_DiscardUnknown()
  • func (m *Topo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Topo) XXX_Merge(src proto.Message)
  • func (m *Topo) XXX_Size() int
  • func (m *Topo) XXX_Unmarshal(b []byte) error

Types

type ConnProperty

type ConnProperty struct {
	LocalID              string   `protobuf:"bytes,1,opt,name=LocalID,proto3" json:"LocalID,omitempty"`
	LocalIP              []byte   `protobuf:"bytes,2,opt,name=LocalIP,proto3" json:"LocalIP,omitempty"`
	LocalPort            uint32   `protobuf:"varint,3,opt,name=LocalPort,proto3" json:"LocalPort,omitempty"`
	RemoteID             string   `protobuf:"bytes,4,opt,name=RemoteID,proto3" json:"RemoteID,omitempty"`
	RemoteIP             []byte   `protobuf:"bytes,5,opt,name=RemoteIP,proto3" json:"RemoteIP,omitempty"`
	RemotePort           uint32   `protobuf:"varint,6,opt,name=RemotePort,proto3" json:"RemotePort,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConnProperty) Descriptor

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

func (*ConnProperty) GetLocalID

func (m *ConnProperty) GetLocalID() string

func (*ConnProperty) GetLocalIP

func (m *ConnProperty) GetLocalIP() []byte

func (*ConnProperty) GetLocalPort

func (m *ConnProperty) GetLocalPort() uint32

func (*ConnProperty) GetRemoteID

func (m *ConnProperty) GetRemoteID() string

func (*ConnProperty) GetRemoteIP

func (m *ConnProperty) GetRemoteIP() []byte

func (*ConnProperty) GetRemotePort

func (m *ConnProperty) GetRemotePort() uint32

func (*ConnProperty) ProtoMessage

func (*ConnProperty) ProtoMessage()

func (*ConnProperty) Reset

func (m *ConnProperty) Reset()

func (*ConnProperty) String

func (m *ConnProperty) String() string

func (*ConnProperty) XXX_DiscardUnknown

func (m *ConnProperty) XXX_DiscardUnknown()

func (*ConnProperty) XXX_Marshal

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

func (*ConnProperty) XXX_Merge

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

func (*ConnProperty) XXX_Size

func (m *ConnProperty) XXX_Size() int

func (*ConnProperty) XXX_Unmarshal

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

type Handshake

type Handshake struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	ID                   []byte   `protobuf:"bytes,2,opt,name=ID,proto3" json:"ID,omitempty"`
	CmdSets              []uint32 `protobuf:"varint,3,rep,packed,name=CmdSets,proto3" json:"CmdSets,omitempty"`
	RemoteIP             []byte   `protobuf:"bytes,4,opt,name=RemoteIP,proto3" json:"RemoteIP,omitempty"`
	RemotePort           uint32   `protobuf:"varint,5,opt,name=RemotePort,proto3" json:"RemotePort,omitempty"`
	Port                 uint32   `protobuf:"varint,6,opt,name=Port,proto3" json:"Port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Handshake) Descriptor

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

func (*Handshake) GetCmdSets

func (m *Handshake) GetCmdSets() []uint32

func (*Handshake) GetID

func (m *Handshake) GetID() []byte

func (*Handshake) GetName

func (m *Handshake) GetName() string

func (*Handshake) GetPort

func (m *Handshake) GetPort() uint32

func (*Handshake) GetRemoteIP

func (m *Handshake) GetRemoteIP() []byte

func (*Handshake) GetRemotePort

func (m *Handshake) GetRemotePort() uint32

func (*Handshake) ProtoMessage

func (*Handshake) ProtoMessage()

func (*Handshake) Reset

func (m *Handshake) Reset()

func (*Handshake) String

func (m *Handshake) String() string

func (*Handshake) XXX_DiscardUnknown

func (m *Handshake) XXX_DiscardUnknown()

func (*Handshake) XXX_Marshal

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

func (*Handshake) XXX_Merge

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

func (*Handshake) XXX_Size

func (m *Handshake) XXX_Size() int

func (*Handshake) XXX_Unmarshal

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

type Topo

type Topo struct {
	Pivot                string          `protobuf:"bytes,1,opt,name=Pivot,proto3" json:"Pivot,omitempty"`
	Peers                []*ConnProperty `protobuf:"bytes,2,rep,name=Peers,proto3" json:"Peers,omitempty"`
	Time                 int64           `protobuf:"varint,3,opt,name=Time,proto3" json:"Time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Topo) Descriptor

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

func (*Topo) GetPeers

func (m *Topo) GetPeers() []*ConnProperty

func (*Topo) GetPivot

func (m *Topo) GetPivot() string

func (*Topo) GetTime

func (m *Topo) GetTime() int64

func (*Topo) ProtoMessage

func (*Topo) ProtoMessage()

func (*Topo) Reset

func (m *Topo) Reset()

func (*Topo) String

func (m *Topo) String() string

func (*Topo) XXX_DiscardUnknown

func (m *Topo) XXX_DiscardUnknown()

func (*Topo) XXX_Marshal

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

func (*Topo) XXX_Merge

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

func (*Topo) XXX_Size

func (m *Topo) XXX_Size() int

func (*Topo) XXX_Unmarshal

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