xdsclient

type BackoffParams struct {
	Min, Max, Reset time.Duration
}

type Client interface {
	// Observe adds resources of given type url and names to the attention set
	// of the client.
	Observe(ctx context.Context, typeUrl string, resourceNames []string) error

	// AddResourceWatcher registers a callback cb that will be invoked every
	// time a resource with given type url changes. Function returns a callback
	// to deregister the watcher.
	AddResourceWatcher(typeUrl string, cb WatcherCallback) func()

	// Run initialize the node and start an AggregatedDiscoverService stream.
	// Requests and responses are processed until provided Context ctx is
	// done or non-retriable error occurs.
	Run(ctx context.Context, node *corepb.Node, conn grpc.ClientConnInterface) error
}

type Config struct {
	ServerAddr string `mapstructure:"xds-server-address"`
	UseSOTW    bool   `mapstructure:"xds-use-sotw-protocol"`
	NodeID     string `mapstructure:"xds-node-id"`
}

type ConnectionOptions struct {
	RetryBackoff    BackoffParams
	RetryConnection bool
	IsRetriable     func(code codes.Code) (retry bool)
}

type DialOptionsProvider interface {
	GRPCOptions(context.Context) ([]grpc.DialOption, error)
}

type NodeProvider interface {
	Node(nodeID, zone string) *corepb.Node
}

type WatcherCallback func(res *xds.VersionedResources)

type XDSClient[ReqT requestConstraint, RespT responseConstraint] struct {
	// contains filtered or unexported fields
}