tcp

Documentation

Index

• func DecodeBody(content string, writeTo interface{}) error
• func EncodeBody(data interface{}) (string, error)
• type Frame
• type MessageFromCluster
• type MessageType
• type TcpClientsManager
  • func InitTcpClientsManager(nodeId string) *TcpClientsManager
  • func (c *TcpClientsManager) SendMessage(toNodeId string, messageType MessageType, action actions.Action, ...) (*Frame, error)
• type TcpServer
  • func InitServer(nodeIp string, nodePort string) *TcpServer
  • func (s *TcpServer) Run() chan MessageFromCluster
  • func (s *TcpServer) Shutdown()

Functions

func DecodeBody

func DecodeBody(content string, writeTo interface{}) error

func EncodeBody

func EncodeBody(data interface{}) (string, error)

Types

type Frame

type Frame struct {
	FromNodeId  string //id = ip:port
	MessageType MessageType
	Action      actions.Action
	Error       bool
	Body        string
}

type MessageFromCluster

type MessageFromCluster struct {
	Frame          Frame
	ReplyToChannel chan Frame
}

type MessageType

type MessageType rune

const (
	Request  MessageType = 'Q'
	Response MessageType = 'A'
)

type TcpClientsManager

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

func InitTcpClientsManager

func InitTcpClientsManager(nodeId string) *TcpClientsManager

func (*TcpClientsManager) SendMessage

func (c *TcpClientsManager) SendMessage(toNodeId string, messageType MessageType, action actions.Action, body interface{}) (*Frame, error)

type TcpServer

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

func InitServer

func InitServer(nodeIp string, nodePort string) *TcpServer

func (*TcpServer) Run

func (s *TcpServer) Run() chan MessageFromCluster

func (*TcpServer) Shutdown

func (s *TcpServer) Shutdown()