kubepartitioner

Documentation

Index

• func NewKubeResourceClient(dynamicClient dynamic.Interface, gvks []schema.GroupVersionKind, ...) models.ResourcesClient
• type KubeResource
  • func NewKubeResource(resource *unstructured.Unstructured, config *rest.Config, ...) *KubeResource
  • func (k *KubeResource) GetOwnerNodeForPartitionerId(partitionerId string) string
  • func (k *KubeResource) GetResourcePartitionKeyForPartitionerId(partitionerId string) (error, string)
  • func (k *KubeResource) GetUnstructured() *unstructured.Unstructured
  • func (k *KubeResource) SetOwnerNodeForPartitionerId(partitionerId string, owner string) error

Functions

func NewKubeResourceClient

func NewKubeResourceClient(dynamicClient dynamic.Interface, gvks []schema.GroupVersionKind, config *rest.Config) models.ResourcesClient

Types

type KubeResource

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

func NewKubeResource

func NewKubeResource(resource *unstructured.Unstructured, config *rest.Config, dynamicClient dynamic.Interface) *KubeResource

func (*KubeResource) GetOwnerNodeForPartitionerId

func (k *KubeResource) GetOwnerNodeForPartitionerId(partitionerId string) string

func (*KubeResource) GetResourcePartitionKeyForPartitionerId

func (k *KubeResource) GetResourcePartitionKeyForPartitionerId(partitionerId string) (error, string)

func (*KubeResource) GetUnstructured

func (k *KubeResource) GetUnstructured() *unstructured.Unstructured

func (*KubeResource) SetOwnerNodeForPartitionerId

func (k *KubeResource) SetOwnerNodeForPartitionerId(partitionerId string, owner string) error