rpc_clients

type BenchmarkConfig struct {
	UDSPath     string        // Unix Domain Socket path
	Timeout     time.Duration // Request timeout
	MaxRetries  int           // Maximum retry attempts
	WarmupCalls int           // Number of warmup calls before measurement
}

type BenchmarkResult struct {
	Protocol    string        // Protocol name
	PayloadSize string        // Payload size category
	Latency     time.Duration // Average latency
	Throughput  float64       // Requests per second
	ErrorRate   float64       // Percentage of failed requests
	CPUUsage    float64       // Average CPU usage percentage
	MemoryUsage int64         // Memory usage in bytes
}

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

type JSONRPCError struct {
	Code    int         `json:"code"`
	Message string      `json:"message"`
	Data    interface{} `json:"data,omitempty"`
}

type JSONRPCRequest struct {
	JSONRPC string      `json:"jsonrpc"`
	Method  string      `json:"method"`
	Params  interface{} `json:"params"`
	ID      uint64      `json:"id"`
}

type JSONRPCResponse struct {
	JSONRPC string          `json:"jsonrpc"`
	Result  json.RawMessage `json:"result,omitempty"`
	Error   *JSONRPCError   `json:"error,omitempty"`
	ID      uint64          `json:"id"`
}

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

type MsgpackRequest struct {
	Type   uint8       // 0 for request
	MsgID  uint32      // Message ID
	Method string      // Method name
	Params interface{} // Parameters
}

type MsgpackResponse struct {
	Type   uint8       // 1 for response
	MsgID  uint32      // Message ID
	Error  interface{} // Error if any
	Result interface{} // Result value
}

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

type RPCClient interface {
	// Connect establishes a connection to the RPC server via Unix Domain Socket
	Connect(udsPath string) error

	// Call invokes a remote method with given arguments and stores the reply
	Call(ctx context.Context, method string, args interface{}, reply interface{}) error

	// Close terminates the connection and cleans up resources
	Close() error

	// Name returns the protocol name for identification in benchmarks
	Name() string
}

type TestPayload struct {
	Size   string      // "small", "medium", "large"
	Method string      // RPC method to call
	Data   interface{} // Actual payload data
}

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