node

Documentation

Index

• Variables
• type Manager
  • func (*Manager) Descriptor() ([]byte, []int)
  • func (x *Manager) GetGroupNodesMap() map[string]*Nodes
  • func (x *Manager) GetGroups() []string
  • func (x *Manager) GetNodes() map[string]*point.Point
  • func (*Manager) ProtoMessage()
  • func (x *Manager) ProtoReflect() protoreflect.Message
  • func (x *Manager) Reset()
  • func (x *Manager) String() string
• type Node
  • func (*Node) Descriptor() ([]byte, []int)
  • func (x *Node) GetLinks() map[string]*subscribe.Link
  • func (x *Node) GetManager() *Manager
  • func (x *Node) GetTcp() *point.Point
  • func (x *Node) GetUdp() *point.Point
  • func (*Node) ProtoMessage()
  • func (x *Node) ProtoReflect() protoreflect.Message
  • func (x *Node) Reset()
  • func (x *Node) String() string
• type Nodes
  • func (*Nodes) Descriptor() ([]byte, []int)
  • func (x *Nodes) GetGroup() string
  • func (x *Nodes) GetNodeHashMap() map[string]string
  • func (x *Nodes) GetNodes() []string
  • func (*Nodes) ProtoMessage()
  • func (x *Nodes) ProtoReflect() protoreflect.Message
  • func (x *Nodes) Reset()
  • func (x *Nodes) String() string

Variables

var File_node_node_proto protoreflect.FileDescriptor

Types

type Manager

type Manager struct {
	Groups        []string                `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	GroupNodesMap map[string]*Nodes       `` /* 171-byte string literal not displayed */
	Nodes         map[string]*point.Point `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Manager) Descriptor

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

Deprecated: Use Manager.ProtoReflect.Descriptor instead.

func (*Manager) GetGroupNodesMap

func (x *Manager) GetGroupNodesMap() map[string]*Nodes

func (*Manager) GetGroups

func (x *Manager) GetGroups() []string

func (*Manager) GetNodes

func (x *Manager) GetNodes() map[string]*point.Point

func (*Manager) ProtoMessage

func (*Manager) ProtoMessage()

func (*Manager) ProtoReflect

func (x *Manager) ProtoReflect() protoreflect.Message

func (*Manager) Reset

func (x *Manager) Reset()

func (*Manager) String

func (x *Manager) String() string

type Node

type Node struct {
	Tcp     *point.Point               `protobuf:"bytes,4,opt,name=tcp,proto3" json:"tcp,omitempty"`
	Udp     *point.Point               `protobuf:"bytes,5,opt,name=udp,proto3" json:"udp,omitempty"`
	Links   map[string]*subscribe.Link `` /* 151-byte string literal not displayed */
	Manager *Manager                   `protobuf:"bytes,3,opt,name=manager,proto3" json:"manager,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetLinks

func (x *Node) GetLinks() map[string]*subscribe.Link

func (*Node) GetManager

func (x *Node) GetManager() *Manager

func (*Node) GetTcp

func (x *Node) GetTcp() *point.Point

func (*Node) GetUdp

func (x *Node) GetUdp() *point.Point

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) ProtoReflect

func (x *Node) ProtoReflect() protoreflect.Message

func (*Node) Reset

func (x *Node) Reset()

func (*Node) String

func (x *Node) String() string

type Nodes

type Nodes struct {
	Group       string            `protobuf:"bytes,1,opt,name=group,json=name,proto3" json:"group,omitempty"`
	Nodes       []string          `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	NodeHashMap map[string]string `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Nodes) Descriptor

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

Deprecated: Use Nodes.ProtoReflect.Descriptor instead.

func (*Nodes) GetGroup

func (x *Nodes) GetGroup() string

func (*Nodes) GetNodeHashMap

func (x *Nodes) GetNodeHashMap() map[string]string

func (*Nodes) GetNodes

func (x *Nodes) GetNodes() []string

func (*Nodes) ProtoMessage

func (*Nodes) ProtoMessage()

func (*Nodes) ProtoReflect

func (x *Nodes) ProtoReflect() protoreflect.Message

func (*Nodes) Reset

func (x *Nodes) Reset()

func (*Nodes) String

func (x *Nodes) String() string