kubernetes

Documentation

Index

• Constants
• func FormatWatcherID(gvr schema.GroupVersionResource, namespace string, watcherType WatcherType) string
• func NewBaseWatcher(config WatcherConfig, watcherType WatcherType) *baseWatcher
• type KubeConnection
  • func NewKubeConnection(kubeConfig *api.Config, kubeContext string) (*KubeConnection, error)
  • func (kc *KubeConnection) Discover(ctx context.Context) ([]*metav1.APIResourceList, error)
  • func (kc *KubeConnection) GetWatcher(gvr schema.GroupVersionResource, namespace string, watcherType WatcherType) (Watcher, error)
  • func (kc *KubeConnection) Stop()
• type KubeService
  • func NewKubeService() *KubeService
  • func (ks *KubeService) Discover(ctx context.Context, kubeContext string) ([]*metav1.APIResourceList, error)
  • func (ks *KubeService) GetContextNames() []string
  • func (ks *KubeService) GetDefaultContext() string
  • func (ks *KubeService) ListResource(ctx context.Context, kubeContext string, gvr schema.GroupVersionResource, ...) ([]*unstructured.Unstructured, error)
  • func (ks *KubeService) ListResourceTabular(ctx context.Context, kubeContext string, gvr schema.GroupVersionResource, ...) (*metav1.Table, error)
  • func (ks *KubeService) Stop()
• type ListWatcher
  • func NewListWatcher(clientConfig *rest.Config, config WatcherConfig) (*ListWatcher, error)
  • func (bw ListWatcher) GetID() string
  • func (bw ListWatcher) GetLastUsed() time.Time
  • func (bw ListWatcher) GetType() WatcherType
  • func (lw *ListWatcher) List(ctx context.Context) ([]*unstructured.Unstructured, error)
  • func (bw ListWatcher) Stop()
  • func (bw ListWatcher) UpdateLastUsed()
• type TableWatcher
  • func NewTableWatcher(clientConfig *rest.Config, config WatcherConfig) (*TableWatcher, error)
  • func (bw TableWatcher) GetID() string
  • func (bw TableWatcher) GetLastUsed() time.Time
  • func (tw *TableWatcher) GetTable(ctx context.Context) (*metav1.Table, error)
  • func (bw TableWatcher) GetType() WatcherType
  • func (bw TableWatcher) Stop()
  • func (bw TableWatcher) UpdateLastUsed()
• type Watcher
• type WatcherConfig
• type WatcherType

Constants

const (
	// DefaultDialTimeout is the default timeout for the connection
	DefaultDialTimeout = 5 * time.Second

	// MaxResourceWatchers is the maximum number of resource watchers that can be active at the same time
	MaxWatchers = 10
)

const (
	DefaultWatchTimeout = 120 * time.Second
)

const (
	// MaxConnections is the maximum number of connections that can be active at the same time
	MaxConnections = 3
)

Functions

func FormatWatcherID

func FormatWatcherID(gvr schema.GroupVersionResource, namespace string, watcherType WatcherType) string

func NewBaseWatcher

func NewBaseWatcher(config WatcherConfig, watcherType WatcherType) *baseWatcher

Types

type KubeConnection

type KubeConnection struct {
	LastUsed time.Time
	// contains filtered or unexported fields
}

func NewKubeConnection

func NewKubeConnection(kubeConfig *api.Config, kubeContext string) (*KubeConnection, error)

func (*KubeConnection) Discover

func (kc *KubeConnection) Discover(ctx context.Context) ([]*metav1.APIResourceList, error)

func (*KubeConnection) GetWatcher

func (kc *KubeConnection) GetWatcher(gvr schema.GroupVersionResource, namespace string, watcherType WatcherType) (Watcher, error)

func (*KubeConnection) Stop

func (kc *KubeConnection) Stop()

type KubeService

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

func NewKubeService

func NewKubeService() *KubeService

func (*KubeService) Discover

func (ks *KubeService) Discover(ctx context.Context, kubeContext string) ([]*metav1.APIResourceList, error)

func (*KubeService) GetContextNames

func (ks *KubeService) GetContextNames() []string

func (*KubeService) GetDefaultContext

func (ks *KubeService) GetDefaultContext() string

func (*KubeService) ListResource

func (ks *KubeService) ListResource(ctx context.Context, kubeContext string, gvr schema.GroupVersionResource, namespace string) ([]*unstructured.Unstructured, error)

func (*KubeService) ListResourceTabular

func (ks *KubeService) ListResourceTabular(ctx context.Context, kubeContext string, gvr schema.GroupVersionResource, namespace string) (*metav1.Table, error)

func (*KubeService) Stop

func (ks *KubeService) Stop()

type ListWatcher

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

func NewListWatcher

func NewListWatcher(clientConfig *rest.Config, config WatcherConfig) (*ListWatcher, error)

func (ListWatcher) GetID

func (bw ListWatcher) GetID() string

func (ListWatcher) GetLastUsed

func (bw ListWatcher) GetLastUsed() time.Time

func (ListWatcher) GetType

func (bw ListWatcher) GetType() WatcherType

func (*ListWatcher) List

func (lw *ListWatcher) List(ctx context.Context) ([]*unstructured.Unstructured, error)

func (ListWatcher) Stop

func (bw ListWatcher) Stop()

func (ListWatcher) UpdateLastUsed

func (bw ListWatcher) UpdateLastUsed()

type TableWatcher

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

func NewTableWatcher

func NewTableWatcher(clientConfig *rest.Config, config WatcherConfig) (*TableWatcher, error)

func (TableWatcher) GetID

func (bw TableWatcher) GetID() string

func (TableWatcher) GetLastUsed

func (bw TableWatcher) GetLastUsed() time.Time

func (*TableWatcher) GetTable

func (tw *TableWatcher) GetTable(ctx context.Context) (*metav1.Table, error)

func (TableWatcher) GetType

func (bw TableWatcher) GetType() WatcherType

func (TableWatcher) Stop

func (bw TableWatcher) Stop()

func (TableWatcher) UpdateLastUsed

func (bw TableWatcher) UpdateLastUsed()

type Watcher

type Watcher interface {
	Stop()
	GetLastUsed() time.Time
	UpdateLastUsed()
	GetType() WatcherType
	GetID() string
}

type WatcherConfig

type WatcherConfig struct {
	KubeContext string
	GVR         schema.GroupVersionResource
	Namespace   string
	// contains filtered or unexported fields
}

type WatcherType

type WatcherType string

const (
	WatcherTypeList     WatcherType = "list"
	WatcherTypeTable    WatcherType = "table"
	WatcherTypeResource WatcherType = "resource"
)