legrpc

package
v0.2.2 Latest Latest
Warning

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

Go to latest
Published: Mar 30, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Resolver

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

Resolver implements google.golang.org/grpc/resolver.Resolver

func (*Resolver) Close

func (r *Resolver) Close()

Close closes the resolver.

func (*Resolver) ResolveNow

func (r *Resolver) ResolveNow(_ resolver.ResolveNowOptions)

ResolveNow will be called by gRPC to try to resolve the target name again. It's just a hint, resolver can ignore this if it's not necessary.

It could be called multiple times concurrently.

type ResolverBuilder

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

ResolverBuilder implements google.golang.org/grpc/resolver.Builder

func NewResolverBuilder

func NewResolverBuilder(d leaderelection.RaceDecider, clock clocks.Clock) *ResolverBuilder

NewResolverBuilder creates a new ResolverBuilder wrapping the passed RaceDecider

func (*ResolverBuilder) Build

Build creates a new resolver for the given target.

gRPC dial calls Build synchronously, and fails if the returned error is not nil. This implementation ignores the target and simply wraps the encapsulated `decider` in a Resolver.

func (*ResolverBuilder) Scheme

func (r *ResolverBuilder) Scheme() string

Scheme returns the scheme supported by this resolver. Scheme is defined at https://github.com/grpc/grpc/blob/master/doc/naming.md.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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