discovery

type Client struct {
	*api.Client

	// Target is the discovered gRPC target that the client connects to.
	Target *Target
}

type ClientObserver interface {
	// ClientConnected is called when a connection to a config API server is
	// established.
	ClientConnected(*Client)

	// ClientDisconnected is called when a connection to a config API server is
	// severed.
	ClientDisconnected(*Client)
}

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

type Connector struct {
	// Observer is notified when a config API client connects to or disconnects
	// from a server. It must not be nil.
	Observer ClientObserver

	// Dial is the dialer used to connect to the discovered targets.
	// If it is nil, DefaultDialer is used.
	Dial Dialer

	// BackoffStrategy controls how long to wait between failures to dial a
	// discovered target.
	BackoffStrategy backoff.Strategy

	// Logger is the target for log messages about dialing failures.
	Logger logging.Logger
	// contains filtered or unexported fields
}

type Dialer func(context.Context, *Target) (*grpc.ClientConn, error)

type MetaData map[interface{}]interface{}

type Target struct {
	// Name is the target name used to dial the endpoint. The syntax is defined
	// in https://github.com/grpc/grpc/blob/master/doc/naming.md.
	Name string

	// Options is a set of grpc.DialOptions used when dialing this target.
	// The options must not include grpc.WithBlock().
	Options []grpc.DialOption

	// MetaData contains driver-specific meta-data about the target.
	MetaData MetaData
}

type TargetObserver interface {
	// TargetAvailable is called when a target becomes available.
	TargetAvailable(*Target)

	// TargetUnavailable is called when a target becomes unavailable.
	TargetUnavailable(*Target)
}

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