mock

package

v0.0.1 Latest Latest Go to latest Published: Mar 12, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

func ClientGetM[T any](c *Client, key string) (T, bool)

func GraphMsgGetM[T any](msg graph.IMsg, key string) (T, bool)

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

func MsgGetClient(msg graph.IMsg) *Client

func NewClient(opt Option) (*Client, *util.Err)

func (c *Client) BindNetMsg(node string, msg util.IMsg, receiver MsgToStrAny)

func (c *Client) BindPointMsg(node, inPoint string, fn graph.MsgToErr)

func (c *Client) Dialer() kiwi.IDialer

func (c *Client) GetM(key string) (any, bool)

func (c *Client) Graph() graph.IGraph

func (c *Client) Id() string

func (c *Client) Push(fn util.FnAnySlc, params ...any)

func (c *Client) Receive(agent kiwi.IAgent, bytes []byte)

func (c *Client) SetM(key string, data any)

type Decoder func(kiwi.IAgent, []byte) (svc kiwi.TSvc, mtd kiwi.TCode, msg util.IMsg, err *util.Err)

type MsgToStrAny func(client *Client, msg util.IMsg) (point string, data any)

type Option struct {
	Id      string
	Name    string
	Ip      string
	Port    int
	Mermaid []byte
	Decoder Decoder
	Head    util.M
	HeadLen uint32
}

type Receiver struct {
	Node string
	Fn   MsgToStrAny
}