endpoint

Documentation

Overview

Package endpoint xxx

Index

• Variables
• type ClusterEndpointsIP
  • func NewEndpointsClient(opts ...EndpointsClientOption) (ClusterEndpointsIP, error)
• type EndpointsClientOption
  • func WithDebug(debug bool) EndpointsClientOption
  • func WithHealthConfig(healthConfig EndpointsHealthOptions) EndpointsClientOption
  • func WithInterval(interval time.Duration) EndpointsClientOption
  • func WithK8sConfig(ks8Config K8sConfig) EndpointsClientOption
• type EndpointsClientOptions
• type EndpointsHealthOptions
• type K8sConfig
  • func (c *K8sConfig) GetKubernetesClient() (kubernetes.Interface, error)

Variables

var (
	// ErrEndpointsClientNotInited show endpointsClient not inited
	ErrEndpointsClientNotInited = errors.New("endpointsClient not inited")
)

var (
	// ErrK8sConfigNotInited show K8sConfig not inited
	ErrK8sConfigNotInited = errors.New("k8sConfig not inited")
)

Types

type ClusterEndpointsIP

type ClusterEndpointsIP interface {
	GetClusterEndpoints() ([]utils.EndPoint, error)
}

ClusterEndpointsIP is a interface for sync kubernetes master endpointIPs

func NewEndpointsClient

func NewEndpointsClient(opts ...EndpointsClientOption) (ClusterEndpointsIP, error)

NewEndpointsClient init endpoints client

type EndpointsClientOption

type EndpointsClientOption func(options *EndpointsClientOptions)

EndpointsClientOption func for set EndpointsClientOptions

func WithDebug

func WithDebug(debug bool) EndpointsClientOption

WithDebug set debug for unit test

func WithHealthConfig

func WithHealthConfig(healthConfig EndpointsHealthOptions) EndpointsClientOption

WithHealthConfig set health check options

func WithInterval

func WithInterval(interval time.Duration) EndpointsClientOption

WithInterval set interval

func WithK8sConfig

func WithK8sConfig(ks8Config K8sConfig) EndpointsClientOption

WithK8sConfig set k8sConfig

type EndpointsClientOptions

type EndpointsClientOptions struct {
	K8sConfig    K8sConfig
	HealthConfig EndpointsHealthOptions
	Interval     time.Duration
	Debug        bool
}

EndpointsClientOptions conf options

type EndpointsHealthOptions

type EndpointsHealthOptions struct {
	Scheme string
	Path   string
}

EndpointsHealthOptions show health check scheme&path

type K8sConfig

type K8sConfig struct {
	Mater      string `json:"master"`
	KubeConfig string `json:"kubeConfig"`
}

K8sConfig xxx

func (*K8sConfig) GetKubernetesClient

func (c *K8sConfig) GetKubernetesClient() (kubernetes.Interface, error)

GetKubernetesClient init kubernetes clientSet by k8sConfig