client

Documentation

Index

• Variables
• func AddWatch(ctx context.Context, registry registry.Discovery, endpoint string, ...) bool
• func IsSecure(u *url.URL) bool
• type Applier
• type Client
• type Factory
  • func NewFactory(r registry.Discovery, opts ...Option) Factory
• type Option
  • func WithPickerBuilder(in selector.Builder) Option
• type Target

Variables

var ErrCancelWatch = errors.New("cancel watch")

var LOG = log.NewHelper(log.With(log.GetLogger(), "source", "servicewatch"))

Functions

func AddWatch

func AddWatch(ctx context.Context, registry registry.Discovery, endpoint string, applier Applier) bool

func IsSecure

func IsSecure(u *url.URL) bool

IsSecure parses isSecure for Endpoint URL.

Types

type Applier

type Applier interface {
	Callback([]*registry.ServiceInstance) error
	Canceled() bool
}

type Client

type Client interface {
	http.RoundTripper
	io.Closer
}

type Factory

type Factory func(*config.Endpoint) (Client, error)

Factory is returns service client.

func NewFactory

func NewFactory(r registry.Discovery, opts ...Option) Factory

NewFactory new a client factory.

type Option

type Option func(*options)

func WithPickerBuilder

func WithPickerBuilder(in selector.Builder) Option

type Target

type Target struct {
	Scheme    string
	Authority string
	Endpoint  string
}

Target is resolver target