rpc

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

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

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

type Codec struct {
}

type Conn struct {
	Codec
	// contains filtered or unexported fields
}

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

type DialOption struct {
	DisconnectHandler func(nodeId string)
}

type IAsyncInvoker interface {
	Invoke(in []byte, err error) error
}

type ICall interface {
	Id() uint32
	Return()
	Reply(in []byte, err error)
	IsAsyncInvoker() bool
	Invoke(in []byte, err error) error
	Done() <-chan IReply
}

type IClient interface {
	//Shoot is a one-way communication, the sender does not pay attention to the receiver's reply
	Shoot(out []byte) error

	// Call performs a unary RPC and returns after the response is received
	// into replyMsg.
	// Support users to use context to cancel blocking status or perform timeout operations
	Call(ctx context.Context, out []byte) ([]byte, error)

	// AsyncCall the safe way to handle asynchronous callbacks is to package the context, replyMsg, and err
	// into a message task and send it to the working goroutine to process the message linearly
	AsyncCall(out []byte, ctx any) error

	// AsyncCallC the functionality and precautions of AsyncCallC are similar to AsyncCall.
	// The difference is that AsyncCallC no need to set a global asynchronous callback.
	AsyncCallC(out []byte, ctx any, cb func(ctx any, in []byte, err error) error) error

	// Close will close all transport links, causes all subsequent requests to fail,
	// All Call or asynchronous Call requests in the waiting queue will return and receive the error ErrDisconnect 'rpc err: disconnect'
	// Close can be called repeatedly
	Close()
}

type IReply interface {
	In() ([]byte, error)
	Return()
}

type IRequest interface {
	NewReader() packet.IPacket
	Data() []byte
	Category() int8
	Response(out []byte) error
	IgnoreRsp()

	// Return To prevent request resource memory leaks,
	// you need to explicitly call the Return method to release it.
	// cannot call Response again later
	Return()
}

type ISession interface {
	Send(seq uint32, category int8, out []byte) error
}

type Item[K comparable, V any] struct {
	// contains filtered or unexported fields
}

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

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

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

type RequestHandle func(req IRequest) error

type RingBuffer[v any] struct {
}

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