client

type CallFn func(conn pool.Connection) error

type CallOption interface{}

type Client interface {
	component.Component
	// Call client method
	Call(ctx context.Context, sc ServiceClient, method string, req interface{}, res interface{}, opts ...CallOption) error
	// Stream client
	Stream(ctx context.Context, sc ServiceClient, desc interface{}, method string, req interface{}, opts ...CallOption) (StreamClient, error)
	// Get client connection
	Dial(address string, opts ...DialOption) (pool.Connection, error)
}

type DialOption interface{}

type ServiceClient interface {
	// Get service name of the client
	GetServiceName() string
	// Get dial options for the client
	GetDialOptions() []DialOption
}

type StreamClient interface {
	// Send request
	Send(req interface{}) error
	// Close send and receive response
	CloseAndRecv(res interface{}) error
	// Receive response
	Recv(res interface{}) error
	// Close client connection
	CloseConn() error
}