node

Documentation

Index

• type Node
  • func (n *Node) AddTaskRequest(message string) (string, error)
  • func (n *Node) DelistRequest() (string, error)
  • func (n *Node) KeepAliveRequest() (string, error)
  • func (n *Node) LoadConfig(cfg *config.Config) error
  • func (n *Node) Marshal() ([]byte, error)
  • func (n *Node) RegisterRequest() (string, error)
  • func (n *Node) RegisterResponse() (string, error)
  • func (n *Node) RunHTTPServer()
  • func (n *Node) RunTCPServer(masterCh chan Requset) error
  • func (n *Node) SendRequest(requestType string, requestMessage string) error
  • func (n *Node) String() string
  • func (n *Node) UpdateRequest() (string, error)
  • func (n *Node) UpdateTaskRequest(message string) (string, error)
• type Requset
  • func (r *Requset) Marshal() ([]byte, error)
  • func (r *Requset) String() string

Types

type Node

type Node struct {
	ID    string `json:"id"`
	Name  string `json:"name"`
	Role  string `json:"role"`
	Debug bool   `json:"debug"`

	Master serverConfig `json:"master"`
	Server serverConfig `json:"server"`

	Token tokenConfig `json:"token"`
}

Node represents a genernal node info

func (*Node) AddTaskRequest

func (n *Node) AddTaskRequest(message string) (string, error)

func (*Node) DelistRequest

func (n *Node) DelistRequest() (string, error)

func (*Node) KeepAliveRequest

func (n *Node) KeepAliveRequest() (string, error)

func (*Node) LoadConfig

func (n *Node) LoadConfig(cfg *config.Config) error

LoadConfig load node config to an existed node.

func (*Node) Marshal

func (n *Node) Marshal() ([]byte, error)

Marshal returns the JSON encoding of a node info.

func (*Node) RegisterRequest

func (n *Node) RegisterRequest() (string, error)

func (*Node) RegisterResponse

func (n *Node) RegisterResponse() (string, error)

func (*Node) RunHTTPServer

func (n *Node) RunHTTPServer()

func (*Node) RunTCPServer

func (n *Node) RunTCPServer(masterCh chan Requset) error

RunTCPServer runs a server to listen tcp request

func (*Node) SendRequest

func (n *Node) SendRequest(requestType string, requestMessage string) error

func (*Node) String

func (n *Node) String() string

func (*Node) UpdateRequest

func (n *Node) UpdateRequest() (string, error)

func (*Node) UpdateTaskRequest

func (n *Node) UpdateTaskRequest(message string) (string, error)

type Requset

type Requset struct {
	ID   string `json:"id"`
	Name string `json:"name"`
	Type string `json:"type"`
	Node Node   `json:"node"`

	Massage interface{} `json:"massage"`
}

func (*Requset) Marshal

func (r *Requset) Marshal() ([]byte, error)

Marshal returns the JSON encoding of a node info.

func (*Requset) String

func (r *Requset) String() string