endpoint

package

v0.0.0-...-c46a175 Latest Latest Go to latest Published: Sep 6, 2021 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Tencent/bk-bcs

Documentation ¶

Index ¶

Variables
type ClusterEndpointsIP
- func NewEndpointsClient(opts ...EndpointsClientOption) (ClusterEndpointsIP, error)
type EndpointsClientOption
type EndpointsClientOptions
type EndpointsHealthOptions
type HealthCheck
- func NewHealthConfig(scheme string, path string) (HealthCheck, error)
type HealthConfig
- func (hc *HealthConfig) IsHTTPAPIHealth(addr string, port uint32) bool
type K8sConfig
- func (c *K8sConfig) GetKubernetesClient() (kubernetes.Interface, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// ErrSchemeInValid invalid scheme
	ErrSchemeInValid = errors.New("scheme invalid, should be http/https")
	// ErrHealthConfigNotInited show HealthConfig not inited
	ErrHealthConfigNotInited = errors.New("healthConfig not inited")
)

View Source

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

View Source

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

Functions ¶

This section is empty.

Types ¶

type ClusterEndpointsIP ¶

type ClusterEndpointsIP interface {
	GetClusterEndpoints() ([]utils.EndPoint, error)
	SyncClusterEndpoints(ctx context.Context)
	Stop()
}

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 HealthCheck ¶

type HealthCheck interface {
	IsHTTPAPIHealth(addr string, port uint32) bool
}

HealthCheck is interface for check addr:port health

func NewHealthConfig ¶

func NewHealthConfig(scheme string, path string) (HealthCheck, error)

NewHealthConfig init HealthConfig

type HealthConfig ¶

type HealthConfig struct {
	Shem string
	Path string
}

HealthConfig conf immutable schem/path

func (*HealthConfig) IsHTTPAPIHealth ¶

func (hc *HealthConfig) IsHTTPAPIHealth(addr string, port uint32) bool

IsHTTPAPIHealth for check schem://addr:port/Path health

type K8sConfig ¶

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

K8sConfig ...

func (*K8sConfig) GetKubernetesClient ¶

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

GetKubernetesClient init kubernetes clientSet by k8sConfig

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL