cnclient

type PipelineClient interface {
	NewStream(ctx context.Context, backend string) (morpc.Stream, error)
	Raw() morpc.RPCClient
	Close() error
}

type PipelineConfig struct {
	// MaxSenderNumber is the max number of backends per host for compute node service.
	MaxSenderNumber int
	// TimeOutForEachConnect is the out time for each tcp connect.
	TimeOutForEachConnect time.Duration
	// related buffer size.
	ReadBufferSize  int
	WriteBufferSize int
	// RPC rpc config
	RPC rpc.Config
}