client

package

v1.0.1 Latest Latest Go to latest Published: Dec 8, 2024 License: MIT Imports: 31 Imported by: 0

Details

This section is empty.

View Source

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

View Source

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

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

func IsSecure(u *url.URL) bool

IsSecure parses isSecure for Endpoint URL.

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

type Client interface {
	http.RoundTripper
	io.Closer
}

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

Factory is returns service client.

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

NewFactory new a client factory.

type Option func(*options)

func WithPickerBuilder(in selector.Builder) Option

type Target struct {
	Scheme    string
	Authority string
	Endpoint  string
}

Target is resolver target