api

Documentation

Index

• func UpdateClusterPreferences(prefs *ClusterPreferences, path, context string) error
• func Watch[T client.Object](ctx context.Context, cluster *Cluster, resource *metav1.APIResource, ...)
• type Cluster
  • func NewCluster(ctx context.Context, clusterPrefs observer.Property[ClusterPreferences]) (*Cluster, error)
  • func (cluster *Cluster) GetAPIResource(gvk schema.GroupVersionKind) *metav1.APIResource
  • func (cluster *Cluster) GetReference(ctx context.Context, ref corev1.ObjectReference) (client.Object, error)
  • func (cluster *Cluster) SetObjectGVK(object client.Object) error
• type ClusterPreferences
  • func (c *ClusterPreferences) Defaults()
• type Column
• type Encoder
  • func (s *Encoder) Encode(object client.Object) ([]byte, error)
  • func (s *Encoder) EncodeYAML(object client.Object) ([]byte, error)
• type Events
  • func (e *Events) For(object client.Object) []*eventsv1.Event
• type GroupProperty
  • func (p *GroupProperty) GetID() string
  • func (p *GroupProperty) GetPriority() int8
• type Kubeconfig
• type License
• type Metrics
  • func (m *Metrics) Container(pod types.NamespacedName, container string) *metricsv1beta1.ContainerMetrics
  • func (m *Metrics) Node(name string) *metricsv1beta1.NodeMetrics
  • func (m *Metrics) Pod(name types.NamespacedName) *metricsv1beta1.PodMetrics
  • func (m *Metrics) PodSum(name types.NamespacedName) (*resource.Quantity, *resource.Quantity)
• type Preferences
  • func LoadPreferences() (*Preferences, error)
  • func (c Preferences) Defaults()
  • func (c *Preferences) Save() error
• type Property
• type TextProperty
  • func (p *TextProperty) GetID() string
  • func (p *TextProperty) GetPriority() int8
• type WatchOptions

Functions

func UpdateClusterPreferences

func UpdateClusterPreferences(prefs *ClusterPreferences, path, context string) error

func Watch

func Watch[T client.Object](ctx context.Context, cluster *Cluster, resource *metav1.APIResource, opts WatchOptions[T])

Types

type Cluster

type Cluster struct {
	client.Client
	*kubernetes.Clientset
	Config             *rest.Config
	ClusterPreferences observer.Property[ClusterPreferences]
	Metrics            *Metrics
	Events             *Events
	RESTMapper         meta.RESTMapper
	DynamicClient      *dynamic.DynamicClient
	Scheme             *runtime.Scheme
	Encoder            *Encoder
	Resources          []metav1.APIResource
}

func NewCluster

func NewCluster(ctx context.Context, clusterPrefs observer.Property[ClusterPreferences]) (*Cluster, error)

func (*Cluster) GetAPIResource

func (cluster *Cluster) GetAPIResource(gvk schema.GroupVersionKind) *metav1.APIResource

func (*Cluster) GetReference

func (cluster *Cluster) GetReference(ctx context.Context, ref corev1.ObjectReference) (client.Object, error)

func (*Cluster) SetObjectGVK

func (cluster *Cluster) SetObjectGVK(object client.Object) error

type ClusterPreferences

type ClusterPreferences struct {
	Kubeconfig  *Kubeconfig
	Name        string
	Host        string
	BearerToken string
	TLS         rest.TLSClientConfig
	Exec        *api.ExecConfig
	ReadOnly    bool
	Navigation  struct {
		Favourites []schema.GroupVersionResource
		Pins       []corev1.ObjectReference
	}
}

func (*ClusterPreferences) Defaults

func (c *ClusterPreferences) Defaults()

type Column

type Column struct {
	Name     string
	Priority int8
	Bind     func(listitem *gtk.ListItem, object client.Object)
	Compare  func(a, b client.Object) int
}

type Encoder

type Encoder struct {
	*runtime.Scheme
}

func (*Encoder) Encode

func (s *Encoder) Encode(object client.Object) ([]byte, error)

func (*Encoder) EncodeYAML

func (s *Encoder) EncodeYAML(object client.Object) ([]byte, error)

type Events

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

func (*Events) For

func (e *Events) For(object client.Object) []*eventsv1.Event

type GroupProperty

type GroupProperty struct {
	ID       string
	Priority int8
	Name     string
	Children []Property
	Widget   func(gtk.Widgetter, *adw.NavigationView)
}

func (*GroupProperty) GetID

func (p *GroupProperty) GetID() string

func (*GroupProperty) GetPriority

func (p *GroupProperty) GetPriority() int8

type Kubeconfig

type Kubeconfig struct {
	Path    string
	Context string
}

type License

type License struct {
	ID        string
	Key       string
	ExpiresAt *time.Time
}

type Metrics

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

func (*Metrics) Container

func (m *Metrics) Container(pod types.NamespacedName, container string) *metricsv1beta1.ContainerMetrics

func (*Metrics) Node

func (m *Metrics) Node(name string) *metricsv1beta1.NodeMetrics

func (*Metrics) Pod

func (m *Metrics) Pod(name types.NamespacedName) *metricsv1beta1.PodMetrics

func (*Metrics) PodSum

func (m *Metrics) PodSum(name types.NamespacedName) (*resource.Quantity, *resource.Quantity)

type Preferences

type Preferences struct {
	Clusters []observer.Property[ClusterPreferences]
	// contains filtered or unexported fields
}

func LoadPreferences

func LoadPreferences() (*Preferences, error)

func (Preferences) Defaults

func (c Preferences) Defaults()

func (*Preferences) Save

func (c *Preferences) Save() error

type Property

type Property interface {
	GetID() string
	GetPriority() int8
}

type TextProperty

type TextProperty struct {
	ID        string
	Name      string
	Value     string
	Reference *corev1.ObjectReference
	Widget    func(gtk.Widgetter, *adw.NavigationView)
}

func (*TextProperty) GetID

func (p *TextProperty) GetID() string

func (*TextProperty) GetPriority

func (p *TextProperty) GetPriority() int8

type WatchOptions

type WatchOptions[T client.Object] struct {
	ListOptions metav1.ListOptions
	Property    observer.Property[[]T]
	AddFunc     func(T)
	UpdateFunc  func(T)
	DeleteFunc  func(T)
}