gonode

package module

v0.0.0-...-9ae062e Latest Latest Go to latest Published: Oct 9, 2020 License: Apache-2.0 Imports: 14 Imported by: 12

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/itfantasy/gonode

Links

Open Source Insights

README ¶

gonode

a service node based on go

Documentation ¶

Index ¶

Constants
func Bind(behavior gen_server.GenServer)
func BindLogger(logWriter logger.LogWriter, logLevel int)
func BindMonitor(monitor monitor.GenMonitor)
func Close(id string) error
func Connect(nickid string, url string) error
func CustomError(errcode int, errmsg string) error
func Debug(arg0 interface{}, args ...interface{})
func ErrorInfo(err error) (int, string)
func GetNodeInfo(id string) (*gen_server.NodeInfo, error)
func GetNodeStatus(id string, ref interface{}) error
func Info() *gen_server.NodeInfo
func IsPeer(id string) bool
func Label(id string) string
func Launch()
func Listen(url string)
func LogError(arg0 interface{}, args ...interface{})
func LogInfo(arg0 interface{}, args ...interface{})
func LogSource(callstack int) string
func LogWarn(arg0 interface{}, args ...interface{})
func Nodes(label string) []string
func Self() string
func Send(id string, msg []byte) error
func SendAll(ids []string, msg []byte) []error
func Supervise(super supervisor.Supervisor) error
type EventHandler
- func (e *EventHandler) OnCheckNode(origin string) (string, bool)
- func (e *EventHandler) OnClose(id string, reason error)
- func (e *EventHandler) OnConn(id string)
- func (e *EventHandler) OnDCError(err error)
- func (e *EventHandler) OnDigestError(err interface{})
- func (e *EventHandler) OnError(id string, err error)
- func (e *EventHandler) OnMsg(id string, msg []byte)
- func (e *EventHandler) OnNewNode(id string) error
- func (e *EventHandler) OnUnregister(id string)
- func (e *EventHandler) OnUpdateNodeStatus() interface{}
type GoNode
- func (g *GoNode) Bind(behavior gen_server.GenServer)
- func (g *GoNode) BindLogger(logWriter logger.LogWriter, logLevel int)
- func (g *GoNode) BindMonitor(monitor monitor.GenMonitor)
- func (g *GoNode) Close(id string) error
- func (g *GoNode) Connnect(nodeId string, url string) error
- func (g *GoNode) Info() *gen_server.NodeInfo
- func (g *GoNode) Launch()
- func (g *GoNode) Listen(url string)
- func (g *GoNode) Logger() *logger.Logger
- func (g *GoNode) Origin() string
- func (g *GoNode) Self() string
- func (g *GoNode) Send(id string, msg []byte) error
- func (g *GoNode) SendAll(ids []string, msg []byte) []error
- func (g *GoNode) Supervise(super supervisor.Supervisor) error

Constants ¶

View Source

const (
	// version
	VERSION string = "v0.9.0.1"
	// reg channel
	CHAN_REG string = "gonode_reg"
	// log channel
	CHAN_LOG string = "gonode_log"
	// monitor channel
	CHAN_MONI string = "gonode_moni"
	// the supervisor role
	SUPERVISOR string = "supervisor"
	// when you set the backends to allnodes,
	// the node will try to conn to everynode in the cluster
	ALLNODES string = "allnodes"
)

Variables ¶

This section is empty.

Functions ¶

func Bind ¶

func Bind(behavior gen_server.GenServer)

func BindLogger ¶

func BindLogger(logWriter logger.LogWriter, logLevel int)

func BindMonitor ¶

func BindMonitor(monitor monitor.GenMonitor)

func Close ¶

func Close(id string) error

func Connect ¶

func Connect(nickid string, url string) error

func CustomError ¶

func CustomError(errcode int, errmsg string) error

func Debug ¶

func Debug(arg0 interface{}, args ...interface{})

func ErrorInfo ¶

func ErrorInfo(err error) (int, string)

func GetNodeInfo ¶

func GetNodeInfo(id string) (*gen_server.NodeInfo, error)

func GetNodeStatus ¶

func GetNodeStatus(id string, ref interface{}) error

func Info ¶

func Info() *gen_server.NodeInfo

func IsPeer ¶

func IsPeer(id string) bool

func Label ¶

func Label(id string) string

func Launch ¶

func Launch()

func Listen ¶

func Listen(url string)

func LogError ¶

func LogError(arg0 interface{}, args ...interface{})

func LogInfo ¶

func LogInfo(arg0 interface{}, args ...interface{})

func LogSource ¶

func LogSource(callstack int) string

func LogWarn ¶

func LogWarn(arg0 interface{}, args ...interface{})

func Nodes ¶

func Nodes(label string) []string

func Self ¶

func Self() string

func Send ¶

func Send(id string, msg []byte) error

func SendAll ¶

func SendAll(ids []string, msg []byte) []error

func Supervise ¶

func Supervise(super supervisor.Supervisor) error

Types ¶

type EventHandler ¶

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

func (*EventHandler) OnCheckNode ¶

func (e *EventHandler) OnCheckNode(origin string) (string, bool)

func (*EventHandler) OnClose ¶

func (e *EventHandler) OnClose(id string, reason error)

func (*EventHandler) OnConn ¶

func (e *EventHandler) OnConn(id string)

func (*EventHandler) OnDCError ¶

func (e *EventHandler) OnDCError(err error)

func (*EventHandler) OnDigestError ¶

func (e *EventHandler) OnDigestError(err interface{})

func (*EventHandler) OnError ¶

func (e *EventHandler) OnError(id string, err error)

func (*EventHandler) OnMsg ¶

func (e *EventHandler) OnMsg(id string, msg []byte)

func (*EventHandler) OnNewNode ¶

func (e *EventHandler) OnNewNode(id string) error

func (*EventHandler) OnUnregister ¶

func (e *EventHandler) OnUnregister(id string)

func (*EventHandler) OnUpdateNodeStatus ¶

func (e *EventHandler) OnUpdateNodeStatus() interface{}

type GoNode ¶

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

func (*GoNode) Bind ¶

func (g *GoNode) Bind(behavior gen_server.GenServer)

func (*GoNode) BindLogger ¶

func (g *GoNode) BindLogger(logWriter logger.LogWriter, logLevel int)

func (*GoNode) BindMonitor ¶

func (g *GoNode) BindMonitor(monitor monitor.GenMonitor)

func (*GoNode) Close ¶

func (g *GoNode) Close(id string) error

func (*GoNode) Connnect ¶

func (g *GoNode) Connnect(nodeId string, url string) error

func (*GoNode) Info ¶

func (g *GoNode) Info() *gen_server.NodeInfo

func (*GoNode) Launch ¶

func (g *GoNode) Launch()

func (*GoNode) Listen ¶

func (g *GoNode) Listen(url string)

func (*GoNode) Logger ¶

func (g *GoNode) Logger() *logger.Logger

func (*GoNode) Origin ¶

func (g *GoNode) Origin() string

func (*GoNode) Self ¶

func (g *GoNode) Self() string

func (*GoNode) Send ¶

func (g *GoNode) Send(id string, msg []byte) error

func (*GoNode) SendAll ¶

func (g *GoNode) SendAll(ids []string, msg []byte) []error

func (*GoNode) Supervise ¶

func (g *GoNode) Supervise(super supervisor.Supervisor) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
behaviors
gen_server
logger
monitor
supervisor
components
mongodb
core
actors
binbuf
datacenter
errs
nets
utils
args
crypt
gz
ini
io
json
os
rand
rsa
snowflake
stl
strs
timer
ts
yaml

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL