mrpc

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

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

type ClientPoolConfig struct {
	Host        string
	Port        int
	InitialCap  int
	MaxIdle     int
	MaxCap      int
	IdleTimeout time.Duration
}

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

type FrameType uint8

type Header struct {
	CRC32         uint32
	RequestID     uint64
	PayloadLength uint32
	FrameType     FrameType
}

type MethodHandler struct {
	UnaryHandler  UnaryFunc
	StreamHandler StreamFunc
}

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

type Request struct {
	Service string          `json:"service"`
	Method  string          `json:"method"`
	Request json.RawMessage `json:"request"`
}

type Response struct {
	Code     int32           `json:"code"`
	Message  string          `json:"message"`
	Response json.RawMessage `json:"response"`
}

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

type StreamFunc func(ctx context.Context, req json.RawMessage, stream *StreamServer) error

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

type UnaryFunc func(ctx context.Context, req json.RawMessage) (any, error)