This section is empty.
var ( // ConnClosed is returned when the underlying connection was closed. ConnClosed = vterrors.New(vtrpcpb.Code_UNAVAILABLE, "vttablet: Connection Closed") )
func ErrorFromGRPC ¶
ErrorFromGRPC converts a GRPC error to vtError for tabletserver calls.
func ErrorFromVTRPC ¶
ErrorFromVTRPC converts a *vtrpcpb.RPCError to vtError for tabletserver calls.
type TabletDialer ¶
type TabletDialer func(tablet *topodatapb.Tablet, timeout time.Duration) (queryservice.QueryService, error)
TabletDialer represents a function that will return a QueryService object that can communicate with a tablet. Only the tablet's HostName and PortMap should be used (and maybe the alias for debug messages).
When using this TabletDialer to talk to a l2vtgate, only the Hostname will be set to the full address to dial. Implementations should detect this use case as the portmap will then be empty.
timeout represents the connection timeout. If set to 0, this connection should be established in the background and the TabletDialer should return right away.