pb

Documentation

Index

• Variables
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (m *Message) GetData() []byte
  • func (m *Message) GetHops() uint64
  • func (m *Message) GetKey() []byte
  • func (m *Message) GetSender() []byte
  • func (m *Message) GetType() Message_Type
  • func (*Message) ProtoMessage()
  • func (m *Message) Reset()
  • func (m *Message) String() string
  • func (m *Message) XXX_DiscardUnknown()
  • func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Message) XXX_Merge(src proto.Message)
  • func (m *Message) XXX_Size() int
  • func (m *Message) XXX_Unmarshal(b []byte) error
• type Message_Type
  • func (Message_Type) EnumDescriptor() ([]byte, []int)
  • func (x Message_Type) String() string
• type State
  • func (*State) Descriptor() ([]byte, []int)
  • func (m *State) GetLeafset() [][]byte
  • func (m *State) GetNeighborhood() [][]byte
  • func (m *State) GetRoutingTable() [][]byte
  • func (*State) ProtoMessage()
  • func (m *State) Reset()
  • func (m *State) String() string
  • func (m *State) XXX_DiscardUnknown()
  • func (m *State) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *State) XXX_Merge(src proto.Message)
  • func (m *State) XXX_Size() int
  • func (m *State) XXX_Unmarshal(b []byte) error

Variables

var Message_Type_name = map[int32]string{
	0: "MESSAGE",
	1: "NODE_JOIN",
	2: "NODE_ANNOUNCE",
	3: "NODE_EXIT",
	4: "HEARTBEAT",
	5: "STATE_REQUEST",
	6: "STATE_DATA",
}

var Message_Type_value = map[string]int32{
	"MESSAGE":       0,
	"NODE_JOIN":     1,
	"NODE_ANNOUNCE": 2,
	"NODE_EXIT":     3,
	"HEARTBEAT":     4,
	"STATE_REQUEST": 5,
	"STATE_DATA":    6,
}

Types

type Message

type Message struct {
	Type                 Message_Type `protobuf:"varint,1,opt,name=type,proto3,enum=pb.Message_Type" json:"type,omitempty"`
	Sender               []byte       `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	Key                  []byte       `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Data                 []byte       `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Hops                 uint64       `protobuf:"varint,5,opt,name=hops,proto3" json:"hops,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Message) Descriptor

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

func (*Message) GetData

func (m *Message) GetData() []byte

func (*Message) GetHops

func (m *Message) GetHops() uint64

func (*Message) GetKey

func (m *Message) GetKey() []byte

func (*Message) GetSender

func (m *Message) GetSender() []byte

func (*Message) GetType

func (m *Message) GetType() Message_Type

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) Reset

func (m *Message) Reset()

func (*Message) String

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal

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

func (*Message) XXX_Merge

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

func (*Message) XXX_Size

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal

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

type Message_Type

type Message_Type int32

const (
	Message_MESSAGE       Message_Type = 0
	Message_NODE_JOIN     Message_Type = 1
	Message_NODE_ANNOUNCE Message_Type = 2
	Message_NODE_EXIT     Message_Type = 3
	Message_HEARTBEAT     Message_Type = 4
	Message_STATE_REQUEST Message_Type = 5
	Message_STATE_DATA    Message_Type = 6
)

func (Message_Type) EnumDescriptor

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

func (Message_Type) String

func (x Message_Type) String() string

type State

type State struct {
	Neighborhood         [][]byte `protobuf:"bytes,1,rep,name=Neighborhood,proto3" json:"Neighborhood,omitempty"`
	Leafset              [][]byte `protobuf:"bytes,2,rep,name=Leafset,proto3" json:"Leafset,omitempty"`
	RoutingTable         [][]byte `protobuf:"bytes,3,rep,name=RoutingTable,proto3" json:"RoutingTable,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*State) Descriptor

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

func (*State) GetLeafset

func (m *State) GetLeafset() [][]byte

func (*State) GetNeighborhood

func (m *State) GetNeighborhood() [][]byte

func (*State) GetRoutingTable

func (m *State) GetRoutingTable() [][]byte

func (*State) ProtoMessage

func (*State) ProtoMessage()

func (*State) Reset

func (m *State) Reset()

func (*State) String

func (m *State) String() string

func (*State) XXX_DiscardUnknown

func (m *State) XXX_DiscardUnknown()

func (*State) XXX_Marshal

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

func (*State) XXX_Merge

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

func (*State) XXX_Size

func (m *State) XXX_Size() int

func (*State) XXX_Unmarshal

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