Documentation

Index

Constants

const (
	// RegistryIP - Local IP for discover
	RegistryIP = "192.168.86.24"

	//LocalIP - Local IP for discover
	LocalIP = "127.0.0.1"

	// RegistryPort - port for discover
	RegistryPort = 50055

	// Discover the overall thing for discover
	Discover = "argon:50055"

	// LocalDiscover the overall thing for discover
	LocalDiscover = "127.0.0.1:50055"
)

const PickFirstBalancerName = "my_pick_first"

PickFirstBalancerName is the name of the pick_first balancer.


const PickonlyfirstBalancerName = "pick_only_first"

PickFirstBalancerName is the name of the pick_first balancer.


Variables

This section is empty.

Functions

func BaseResolveAll

func BaseResolveAll(name string) ([]*pbdi.RegistryEntry, error)

ResolveAll gets all servers

func BuildContext

func BuildContext(label, origin string) (context.Context, context.CancelFunc)

BuildContext builds a context object for use

func FuzzyMatch

func FuzzyMatch(matcher, matchee proto.Message) error

FuzzyMatch experimental fuzzy match

func GetMaster

func GetMaster(name, caller string) (*pbdi.RegistryEntry, error)

GetMaster resolves out a server

func LFDial

func LFDial(host string) (*grpc.ClientConn, error)

LFDial fundamental dial

func LFDialServer

func LFDialServer(ctx context.Context, servername string) (*grpc.ClientConn, error)

LFDialServer dial a specific job

func LFFind

func LFFind(ctx context.Context, servername string) ([]string, error)

LFFind finds all servers

func ManualContext

func ManualContext(label, origin string, t time.Duration, force bool) (context.Context, context.CancelFunc)

ManualContext builds a context object for use

func Resolve

func Resolve(name, origin string) (string, int32, error)

Resolve resolves out a server

func ResolveAll

func ResolveAll(name string) ([]*pbdi.RegistryEntry, error)

ResolveAll gets all servers

func ResolveV2

func ResolveV2(name string) (*pbdi.RegistryEntry, error)

Resolve resolves out a server

func ResolveV3

func ResolveV3(name string) ([]*pbdi.RegistryEntry, error)

ResolveV3 resolves out a server

func ResolveV3Client

func ResolveV3Client(name string) ([]*pbdi.RegistryEntry, error)

ResolveV3 resolves out a server

Types

type DiscoveryClientResolverBuilder

type DiscoveryClientResolverBuilder struct{}

func (*DiscoveryClientResolverBuilder) Build

func (*DiscoveryClientResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

func (*DiscoveryClientResolverBuilder) Scheme

func (*DiscoveryClientResolverBuilder) Scheme() string

type DiscoveryServerResolverBuilder

type DiscoveryServerResolverBuilder struct{}

func (*DiscoveryServerResolverBuilder) Build

func (*DiscoveryServerResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

func (*DiscoveryServerResolverBuilder) Scheme

func (*DiscoveryServerResolverBuilder) Scheme() string