internal

package
v0.0.0-...-adeea6a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 10, 2022 License: BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Overview

Package internal supports the options and transport packages.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DialSettings

type DialSettings struct {
	Endpoint     string
	Scopes       []string
	TokenSource  oauth2.TokenSource
	UserAgent    string
	HTTPClient   *http.Client
	GRPCDialOpts []grpc.DialOption
	GRPCConn     *grpc.ClientConn
}

DialSettings holds information needed to establish a connection with a Google API service.

type PoolResolver

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

PoolResolver provides a fixed list of addresses to load balance between and does not provide further updates.

func NewPoolResolver

func NewPoolResolver(size int, o *DialSettings) *PoolResolver

NewPoolResolver returns a PoolResolver This is an EXPERIMENTAL API and may be changed or removed in the future.

func (*PoolResolver) Close

func (r *PoolResolver) Close()

func (*PoolResolver) Next

func (r *PoolResolver) Next() ([]*naming.Update, error)

Next returns a static list of updates on the first call, and blocks indefinitely until Close is called on subsequent calls.

func (*PoolResolver) Resolve

func (r *PoolResolver) Resolve(target string) (naming.Watcher, error)

Resolve returns a Watcher for the endpoint defined by the DialSettings provided to NewPoolResolver.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL