servicediscovery

Documentation

Index

• type EruServiceDiscovery
  • func New(endpoint string, authConfig types.AuthConfig) *EruServiceDiscovery
  • func (w *EruServiceDiscovery) Watch(ctx context.Context) (_ <-chan []string, err error)
• type LBResolverBuilder
  • func (b *LBResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, _ resolver.BuildOptions) (resolver.Resolver, error)
  • func (b *LBResolverBuilder) Scheme() string
• type ServiceDiscovery

Types

type EruServiceDiscovery

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

EruServiceDiscovery watches eru service status

func New

func New(endpoint string, authConfig types.AuthConfig) *EruServiceDiscovery

New EruServiceDiscovery

func (*EruServiceDiscovery) Watch

func (w *EruServiceDiscovery) Watch(ctx context.Context) (_ <-chan []string, err error)

Watch .

type LBResolverBuilder

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

LBResolverBuilder for service discovery lb

func (*LBResolverBuilder) Build

func (b *LBResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, _ resolver.BuildOptions) (resolver.Resolver, error)

Build for interface

func (*LBResolverBuilder) Scheme

func (b *LBResolverBuilder) Scheme() string

Scheme for interface

type ServiceDiscovery

type ServiceDiscovery interface {
	Watch(context.Context) (<-chan []string, error)
}

ServiceDiscovery notifies current core service addresses