Skip to content
Snippets Groups Projects
Commit e770fd47 authored by ale's avatar ale
Browse files

Small fix to grpc dep

parent ed6b32b6
Branches
No related tags found
No related merge requests found
......@@ -20,23 +20,47 @@
// symbols to avoid circular dependencies.
package internal
import "context"
import (
"context"
"time"
"google.golang.org/grpc/connectivity"
)
var (
// WithContextDialer is exported by dialoptions.go
WithContextDialer interface{} // func(context.Context, string) (net.Conn, error) grpc.DialOption
// WithResolverBuilder is exported by dialoptions.go
// WithResolverBuilder is set by dialoptions.go
WithResolverBuilder interface{} // func (resolver.Builder) grpc.DialOption
// WithHealthCheckFunc is not exported by dialoptions.go
// WithHealthCheckFunc is set by dialoptions.go
WithHealthCheckFunc interface{} // func (HealthChecker) DialOption
// HealthCheckFunc is used to provide client-side LB channel health checking
HealthCheckFunc HealthChecker
// BalancerUnregister is exported by package balancer to unregister a balancer.
BalancerUnregister func(name string)
// KeepaliveMinPingTime is the minimum ping interval. This must be 10s by
// default, but tests may wish to set it lower for convenience.
KeepaliveMinPingTime = 10 * time.Second
// StatusRawProto is exported by status/status.go. This func returns a
// pointer to the wrapped Status proto for a given status.Status without a
// call to proto.Clone(). The returned Status proto should not be mutated by
// the caller.
StatusRawProto interface{} // func (*status.Status) *spb.Status
// NewRequestInfoContext creates a new context based on the argument context attaching
// the passed in RequestInfo to the new context.
NewRequestInfoContext interface{} // func(context.Context, credentials.RequestInfo) context.Context
// ParseServiceConfigForTesting is for creating a fake
// ClientConn for resolver testing only
ParseServiceConfigForTesting interface{} // func(string) *serviceconfig.ParseResult
)
// HealthChecker defines the signature of the client-side LB channel health checking function.
type HealthChecker func(ctx context.Context, newStream func() (interface{}, error), reportHealth func(bool), serviceName string) error
//
// The implementation is expected to create a health checking RPC stream by
// calling newStream(), watch for the health status of serviceName, and report
// it's health back by calling setConnectivityState().
//
// The health checking protocol is defined at:
// https://github.com/grpc/grpc/blob/master/doc/health-checking.md
type HealthChecker func(ctx context.Context, newStream func(string) (interface{}, error), setConnectivityState func(connectivity.State, error), serviceName string) error
const (
// CredsBundleModeFallback switches GoogleDefaultCreds to fallback mode.
......
......@@ -372,10 +372,10 @@
"revisionTime": "2019-11-27T22:20:17Z"
},
{
"checksumSHA1": "xUOlil5rXPg8m1Suz3lvtXwuGh4=",
"checksumSHA1": "2ecKsnQiTXRTR6wcKzt0HbBolq4=",
"path": "google.golang.org/grpc/internal",
"revision": "36f3126920fe326b7874e730e3cc26546186d8f0",
"revisionTime": "2018-12-27T22:30:17Z"
"revision": "4b2104f1fb2b5f1a267fab0a7e704a1066d53775",
"revisionTime": "2019-11-27T23:11:47Z"
},
{
"checksumSHA1": "pF8iy9/Pmnt2a8sEAtYtOLQtdHE=",
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment