nodes

Documentation

Index

• func APINodeServicesRegister(node *APINode, server *grpc.Server)
• type APINode
  • func NewAPINode() *APINode
  • func (this *APINode) Daemon()
  • func (this *APINode) InstallSystemService() error
  • func (this *APINode) Start()
• type IPLibraryUpdater
  • func NewIPLibraryUpdater() *IPLibraryUpdater
  • func (this *IPLibraryUpdater) DataDir() string
  • func (this *IPLibraryUpdater) DownloadFile(fileId int64, writer io.Writer) error
  • func (this *IPLibraryUpdater) FindLatestFile() (code string, fileId int64, err error)
  • func (this *IPLibraryUpdater) LogError(err error)
  • func (this *IPLibraryUpdater) LogInfo(message string)
• type NodeStatusExecutor
  • func NewNodeStatusExecutor() *NodeStatusExecutor
  • func (this *NodeStatusExecutor) Listen()
• type RestServer
  • func (this *RestServer) Listen(listener net.Listener) error
  • func (this *RestServer) ListenHTTPS(listener net.Listener, tlsConfig *tls.Config) error
• type StartIssue
  • func NewStartIssue(code string, message string, suggestion string) *StartIssue

Functions

func APINodeServicesRegister

func APINodeServicesRegister(node *APINode, server *grpc.Server)

Types

type APINode

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

func NewAPINode

func NewAPINode() *APINode

func (*APINode) Daemon

func (this *APINode) Daemon()

Daemon 实现守护进程

func (*APINode) InstallSystemService

func (this *APINode) InstallSystemService() error

InstallSystemService 安装系统服务

func (*APINode) Start

func (this *APINode) Start()

type IPLibraryUpdater

type IPLibraryUpdater struct {
}

func NewIPLibraryUpdater

func NewIPLibraryUpdater() *IPLibraryUpdater

func (*IPLibraryUpdater) DataDir

func (this *IPLibraryUpdater) DataDir() string

DataDir 文件目录

func (*IPLibraryUpdater) DownloadFile

func (this *IPLibraryUpdater) DownloadFile(fileId int64, writer io.Writer) error

DownloadFile 下载文件

func (*IPLibraryUpdater) FindLatestFile

func (this *IPLibraryUpdater) FindLatestFile() (code string, fileId int64, err error)

FindLatestFile 检查最新的IP库文件

func (*IPLibraryUpdater) LogError

func (this *IPLibraryUpdater) LogError(err error)

LogError 错误日志

func (*IPLibraryUpdater) LogInfo

func (this *IPLibraryUpdater) LogInfo(message string)

LogInfo 普通日志

type NodeStatusExecutor

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

func NewNodeStatusExecutor

func NewNodeStatusExecutor() *NodeStatusExecutor

func (*NodeStatusExecutor) Listen

func (this *NodeStatusExecutor) Listen()

type RestServer

type RestServer struct{}

func (*RestServer) Listen

func (this *RestServer) Listen(listener net.Listener) error

func (*RestServer) ListenHTTPS

func (this *RestServer) ListenHTTPS(listener net.Listener, tlsConfig *tls.Config) error

type StartIssue

type StartIssue struct {
	Code       string `json:"code"`
	Message    string `json:"message"`
	Suggestion string `json:"suggestion"`
}

func NewStartIssue

func NewStartIssue(code string, message string, suggestion string) *StartIssue