interfaces

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

type BaseComponent struct {
	AppContext
}

type FrontendId = string

type IAppContext interface {
	Set(ctx IApplication)
	App() IApplication
}

type IApplication interface {
	//NodeId current nodeId
	NodeId() string

	//NodeType current nodeType
	NodeType() string

	//ThisNode current node info
	ThisNode() INode

	//Register load component
	Register(components ...IComponent)

	//Find get component
	Find(name string) IComponent

	//Remove remove a component
	Remove(name string) IComponent

	//All all components
	All() []IComponent

	//PostEvent
	PostEvent(e IEvent)

	//OnShutdown  execute this func before the application shutdown
	OnShutdown(shutdownFunc ...func())

	//Startup
	Startup(startupFunc ...func())
}

type IComponent interface {
	IAppContext

	//Name unique components name
	Name() string

	Init()

	AfterInit()

	BeforeStop()

	Stop()
}

type IConnectListener func(conn net.Conn)

type IConnector interface {
	Start()

	OnConnect(listener IConnectListener)

	Stop()
}

type IEvent interface {
	// event name
	EventName() string
}

type IHandler interface {
	IAppContext

	Name() string

	SetName(name string)

	PreInit()

	Init()
}

type INetworkEntity interface {
	Push(route string, data interface{}) error
	RPC(route string, data interface{}) error
	LastMid() uint64
	Response(data interface{}) error
	ResponseMid(mid uint64, data interface{}) error
	Close() error
	RemoteAddr() net.Addr
}

type INode interface {
	NodeId() string
	Address() string
	RpcAddress() string
	Settings() json.Any
	IsDisabled() bool
}

type IRoute interface {
	NodeType() string
	HandlerName() string
	Method() string
}

type ISession interface {
	SID() SID
	UID() UID
	FrontendId() FrontendId
	SetStatus(status int)
	Status() int

	Data() map[string]interface{}
	Remove(key string)
	Set(key string, value interface{})
	Contains(key string) bool

	Conn() net.Conn
	OnClose(listener SessionListener)
	OnError(listener SessionListener)
	OnMessage(listener MessageListener)
	Send(msg []byte) error
	SendBatch(batchMsg ...[]byte)

	Closed()
}

type MessageListener func(bytes []byte) error

type NodeMap map[string]map[string]INode

type Packet struct {
	Type   byte
	Length int
	Data   []byte
}

type PacketDecoder interface {
	Decode(data []byte) ([]*Packet, error)
}

type PacketEncoder interface {
	Encode(typ byte, buf []byte) ([]byte, error)
}

type RouteFunc func(session ISession, msg RpcMessage, nodeInfo []RpcNodeInfo)

type RouteFunction func(session ISession, packet interface{}, ctx IApplication) error

type RpcFilter struct {
	Name   string
	Before RpcFilterFunc
	After  RpcFilterFunc
}

type RpcFilterFunc func(nodeId string, msg interface{})

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

type RpcNodeInfo interface {
	Id() string
	Address() string
	NodeType() string
	Weight() int
}

type SID = int64

type Serializer interface {
	Marshal(interface{}) ([]byte, error)

	Unmarshal([]byte, interface{}) error

	Name() string
}

type SessionListener func(session ISession)

type UID = int64