clusterapi

Documentation

Index

• Constants
• type DesktopHealthMonitor
  • func NewDesktopHealthMonitor(cm k8shelpers.ConnectionManager) *DesktopHealthMonitor
  • func (hm *DesktopHealthMonitor) GetHealthStatus(ctx context.Context, kubeContextPtr *string, namespacePtr *string, ...) (HealthStatus, error)
  • func (hm *DesktopHealthMonitor) ReadyWait(ctx context.Context, kubeContextPtr *string, namespacePtr *string, ...) error
  • func (hm *DesktopHealthMonitor) Shutdown()
  • func (hm *DesktopHealthMonitor) WatchHealthStatus(ctx context.Context, kubeContextPtr *string, namespacePtr *string, ...) (<-chan HealthStatus, error)
• type DesktopProxy
  • func NewDesktopProxy(cm k8shelpers.ConnectionManager, pathPrefix string) (*DesktopProxy, error)
  • func (p *DesktopProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (p *DesktopProxy) Shutdown()
• type HealthMonitor
  • func NewHealthMonitor(cfg *config.Config, cm k8shelpers.ConnectionManager) HealthMonitor
• type HealthStatus
• type InClusterHealthMonitor
  • func NewInClusterHealthMonitor(cm k8shelpers.ConnectionManager, clusterAPIEndpoint string) *InClusterHealthMonitor
  • func (hm *InClusterHealthMonitor) GetHealthStatus(ctx context.Context, kubeContextPtr *string, namespacePtr *string, ...) (HealthStatus, error)
  • func (hm *InClusterHealthMonitor) ReadyWait(ctx context.Context, kubeContextPtr *string, namespacePtr *string, ...) error
  • func (hm *InClusterHealthMonitor) Shutdown()
  • func (hm *InClusterHealthMonitor) WatchHealthStatus(ctx context.Context, kubeContextPtr *string, namespacePtr *string, ...) (<-chan HealthStatus, error)
• type InClusterProxy
  • func NewInClusterProxy(clusterAPIEndpoint string, pathPrefix string) (*InClusterProxy, error)
  • func (p *InClusterProxy) Shutdown()
• type Proxy

Constants

const (
	HealthStatusSuccess  = "SUCCESS"
	HealthStatusFailure  = "FAILURE"
	HealthStatusPending  = "PENDING"
	HealthStatusNotFound = "NOTFOUND"
	HealthStatusUknown   = "UNKNOWN"
)

const DefaultNamespace = "kubetail-system"

const DefaultServiceName = "kubetail-cluster-api"

Types

type DesktopHealthMonitor

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

Represents DesktopHealthMonitor

func NewDesktopHealthMonitor

func NewDesktopHealthMonitor(cm k8shelpers.ConnectionManager) *DesktopHealthMonitor

Create new DesktopHealthMonitor instance

func (*DesktopHealthMonitor) GetHealthStatus

func (hm *DesktopHealthMonitor) GetHealthStatus(ctx context.Context, kubeContextPtr *string, namespacePtr *string, serviceNamePtr *string) (HealthStatus, error)

GetHealthStatus

func (*DesktopHealthMonitor) ReadyWait

func (hm *DesktopHealthMonitor) ReadyWait(ctx context.Context, kubeContextPtr *string, namespacePtr *string, serviceNamePtr *string) error

ReadyWait

func (*DesktopHealthMonitor) Shutdown

func (hm *DesktopHealthMonitor) Shutdown()

Shutdown all managed monitors

func (*DesktopHealthMonitor) WatchHealthStatus

func (hm *DesktopHealthMonitor) WatchHealthStatus(ctx context.Context, kubeContextPtr *string, namespacePtr *string, serviceNamePtr *string) (<-chan HealthStatus, error)

WatchHealthStatus

type DesktopProxy

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

Represents DesktopProxy

func NewDesktopProxy

func NewDesktopProxy(cm k8shelpers.ConnectionManager, pathPrefix string) (*DesktopProxy, error)

Create new DesktopProxy

func (*DesktopProxy) ServeHTTP

func (p *DesktopProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP

func (*DesktopProxy) Shutdown

func (p *DesktopProxy) Shutdown()

Shutdown

type HealthMonitor

type HealthMonitor interface {
	Shutdown()
	GetHealthStatus(ctx context.Context, kubeContextPtr *string, namespacePtr *string, serviceNamePtr *string) (HealthStatus, error)
	WatchHealthStatus(ctx context.Context, kubeContextPtr *string, namespacePtr *string, serviceNamePtr *string) (<-chan HealthStatus, error)
	ReadyWait(ctx context.Context, kubeContextPtr *string, namespacePtr *string, serviceNamePtr *string) error
}

Represents HealthMonitor

func NewHealthMonitor

func NewHealthMonitor(cfg *config.Config, cm k8shelpers.ConnectionManager) HealthMonitor

Create new HealthMonitor instance

type HealthStatus

type HealthStatus string

Represents HealthStatus enum

type InClusterHealthMonitor

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

Respresents InClusterHealthMonitor

func NewInClusterHealthMonitor

func NewInClusterHealthMonitor(cm k8shelpers.ConnectionManager, clusterAPIEndpoint string) *InClusterHealthMonitor

Create new InClusterHealthMonitor instance

func (*InClusterHealthMonitor) GetHealthStatus

func (hm *InClusterHealthMonitor) GetHealthStatus(ctx context.Context, kubeContextPtr *string, namespacePtr *string, serviceNamePtr *string) (HealthStatus, error)

GetHealthStatus

func (*InClusterHealthMonitor) ReadyWait

func (hm *InClusterHealthMonitor) ReadyWait(ctx context.Context, kubeContextPtr *string, namespacePtr *string, serviceNamePtr *string) error

ReadyWait

func (*InClusterHealthMonitor) Shutdown

func (hm *InClusterHealthMonitor) Shutdown()

Shutdown all managed monitors

func (*InClusterHealthMonitor) WatchHealthStatus

func (hm *InClusterHealthMonitor) WatchHealthStatus(ctx context.Context, kubeContextPtr *string, namespacePtr *string, serviceNamePtr *string) (<-chan HealthStatus, error)

WatchHealthStatus

type InClusterProxy

type InClusterProxy struct {
	*httputil.ReverseProxy
}

Represents InClusterProxy

func NewInClusterProxy

func NewInClusterProxy(clusterAPIEndpoint string, pathPrefix string) (*InClusterProxy, error)

Create new InClusterProxy

func (*InClusterProxy) Shutdown

func (p *InClusterProxy) Shutdown()

Shutdown

type Proxy

type Proxy interface {
	ServeHTTP(w http.ResponseWriter, r *http.Request)
	Shutdown()
}

Proxy interface