rpc

type ARequest struct {
	ServiceMethod string `json:"method"`
	Seq           uint64 `json:"seq"`
}

type AResponse struct {
	ServiceMethod string `json:"method"`
	Seq           uint64 `json:"seq"`
	Error         string `json:"error"`
}

type Call struct {
	ServiceMethod string
	Args          any
	Reply         any
	Error         error
	Done          chan *Call
}

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

type ClientCodec interface {
	WriteRequest(req Request, payload any) error
	ReadResponse() (Response, error)
	ReadPayload(res Response, payload any) error

	Close() error
}

type Request interface {
	Method() string
	SeqId() uint64
}

type Response interface {
	Method() string
	SeqId() uint64
	ErrorString() string
}

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

type ServerCodec interface {
	ReadRequest() (Request, error)
	ReadPayload(req Request, payload any) error
	WriteResponse(res Response, payload any) error

	Close() error
}

type ServerError string