rpc

type ClientHelper interface {
	Ready() error
	Close()
}

type Config struct {
	// RPC instance host
	Host string
	// The max number of simultaneous requests.
	// Should be slightly less than the RPC server concurrency to avoid
	// ResourceExhausted errors
	Concurrency int
	// Enable client-side TLS on RPC connections?
	EnableTLS bool
	// Max receive msg size (bytes)
	MaxRecvSize int
	// Max send msg size (bytes)
	MaxSendSize int
	// Alternative dialer implementation
	DialFun Dialer
}

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

type Dialer = func(c *Config) (pb.RPCClient, ClientHelper, error)