network

type Config struct {
	ID string

	ClientOnly bool

	ServiceProtocol string
	ServiceAddress  string

	P2PSeeds []string

	Topology ITopology
	Router   IRouter
}

type ILink interface {
	Start()
	StartReceiving()
	SendData(data []byte) (n int, err error)
	SendMessage(msg Message) (n int, err error)
	RemoteAddr() net.Addr
	Close()
}

type IProcessor interface {
	Handle(message Message, network *Service) (result interface{}, err error)
	ForMessage() string
}

type IRouter interface {
	Self() Node

	TopologyName() string

	Start(cfg Config) (err error)
	Listen(listener net.Listener)
	ConnectTo(node Node) (linkedNode LinkNode, err error)

	LinkClosed(link ILink)

	JoinTopology(seed Node) (err error)
	LeaveTopology()
	GetAllLinkedNode() (nodes []Node)

	RawMessageProcessor(data []byte, link ILink)
	RegisterMessageProcessor(msgFamily string, processor MessageProcessor)

	SendTo(node Node, msg Message) (n int, err error)
	Broadcast(msg message.Message) (err error)
}

type IService interface {
	Self() (node Node)

	Create(cfg Config) (err error)
	ConnectTo(Node) (err error)

	Join(seeds []Node, cfg *Config) (err error)
	Leave()

	GetAllLinkedNode() (nodes []Node)

	SendTo(node Node, msg message.Message) (n int, err error)
	Broadcast(msg message.Message) (err error)

	RegisterMessageProcessor(msgFamily string, processor MessageProcessor)

	StaticInformation() StaticInformation
}

type ITopology interface {
	Name() string

	MountTo(router IRouter)
	BuildNodeID(node Node) string

	InterestedMessage(msg Message) (interested bool)
	MessageProcessor(msg Message, link ILink)

	Join(seed LinkNode) (err error)
	Leave()

	SetLocalNode(node LinkNode)
	GetLink(node Node) (link ILink, err error)
	GetAllNodes() []LinkNode

	AddLink(link ILink)
	RemoveLink(link ILink)
}

type Link struct {
	Connection          net.Conn
	Reader              *bufio.Reader
	Writer              *bufio.Writer
	RawMessageProcessor RawMessageProcessor
	LinkClosed          LinkClosed
	ConnectOut          bool
	// contains filtered or unexported fields
}

type LinkClosed func(link ILink)

type LinkNode struct {
	Node
	Link ILink
}

type Message struct {
	message.Message
	From Node
}

type MessagePrefix struct {
	Size     int32
	DataType byte
}

type MessageProcessor func(msg Message) (reply *Message)

type Node struct {
	ID           string
	Protocol     string
	ServeAddress string
	CustomerData []byte
}

type RawMessageProcessor func(data []byte, link ILink)

type Router struct {
	Topology            ITopology
	MessageProcessorMap map[string]MessageProcessor
	LocalNode           LinkNode
	// contains filtered or unexported fields
}

type Service struct {
	// contains filtered or unexported fields
}

type StaticInformation struct {
	Topology      string
	ConnectedNode []string
}