client

Documentation

Index

• Variables
• func AddWatch(ctx context.Context, registry registry.Discovery, endpoint string, ...) bool
• func IsSecure(u *url.URL) bool
• type Applier
• type BuildContext
  • func EmptyBuildContext() *BuildContext
  • func NewBuildContext(cfg *config.Gateway) *BuildContext
• type Client
• type Factory
  • func NewFactory(r registry.Discovery, opts ...Option) Factory
• type HTTPSClientStore
  • func NewHTTPSClientStore(clientConfigs map[string]*tls.Config) *HTTPSClientStore
  • func (s *HTTPSClientStore) GetClient(name string) *http.Client
• type NewNodeOption
  • func WithTLS(in bool) NewNodeOption
  • func WithTLSConfigName(in string) NewNodeOption
• type NodeOptions
• 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 BuildContext

type BuildContext struct {
	TLSConfigs     map[string]*tls.Config
	TLSClientStore *HTTPSClientStore
}

func EmptyBuildContext

func EmptyBuildContext() *BuildContext

func NewBuildContext

func NewBuildContext(cfg *config.Gateway) *BuildContext

type Client

type Client interface {
	http.RoundTripper
	io.Closer
}

type Factory

type Factory func(*BuildContext, *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 HTTPSClientStore

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

func NewHTTPSClientStore

func NewHTTPSClientStore(clientConfigs map[string]*tls.Config) *HTTPSClientStore

func (*HTTPSClientStore) GetClient

func (s *HTTPSClientStore) GetClient(name string) *http.Client

type NewNodeOption

type NewNodeOption func(*NodeOptions)

func WithTLS

func WithTLS(in bool) NewNodeOption

func WithTLSConfigName

func WithTLSConfigName(in string) NewNodeOption

type NodeOptions

type NodeOptions struct {
	TLS           bool
	TLSConfigName string
}

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