internal

package
v0.0.0-...-41dc4b6 Latest Latest
Warning

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

Go to latest
Published: Dec 17, 2018 License: BSD-3-Clause Imports: 9 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

func Creds

Creds returns credential information obtained from DialSettings, or if none, then it returns default credential information.

Types

type DialSettings

type DialSettings struct {
	Endpoint        string
	Scopes          []string
	TokenSource     oauth2.TokenSource
	Credentials     *google.DefaultCredentials
	CredentialsFile string // if set, Token Source is ignored.
	CredentialsJSON []byte
	UserAgent       string
	APIKey          string
	HTTPClient      *http.Client
	GRPCDialOpts    []grpc.DialOption
	GRPCConn        *grpc.ClientConn
	NoAuth          bool
}

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

func (*DialSettings) Validate

func (ds *DialSettings) Validate() error

Validate reports an error if ds is invalid.

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()

Close releases resources associated with the pool and causes Next to unblock.

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