utils

package

v1.24.2 Latest Latest Go to latest Published: Dec 18, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kubegems/kubegems

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func ApplyResource(ctx context.Context, cli client.Client, obj client.Object, ...) error
func ConvertToTypedList(uns []*unstructured.Unstructured, schema *runtime.Scheme) []client.Object
func ConvertToTypedObject(uns *unstructured.Unstructured, schema *runtime.Scheme) client.Object
func CorrectNamespaces[T client.Object](cli client.Client, defaultNamespace string, list []T)
func CorrectNamespacesForRefrences(cli client.Client, defaultns string, list []ManagedResource)
func EqualMapValues(a, b map[string]interface{}) bool
func IsCRD(obj client.Object) bool
func IsSkipedOn(obj client.Object, key string) bool
func NamespacedScopeOf(cli client.Client, obj runtime.Object) (apimeta.RESTScopeName, error)
func NamespacedScopeOfGVK(cli client.Client, gvk schema.GroupVersionKind) (apimeta.RESTScopeName, error)
func ReadObjectsFromFile[T runtime.Object](path string) ([]T, error)
func SplitYAML(data []byte) ([]*unstructured.Unstructured, error)
func SplitYAMLFilterd[T runtime.Object](raw io.Reader) ([]T, error)
type Apply
- func (a *Apply) Sync(ctx context.Context, defaultnamespace string, managed []ManagedResource, ...) ([]ManagedResource, error)
- func (a Apply) SyncDiff(ctx context.Context, diff DiffResult, options *SyncOptions) ([]ManagedResource, error)
type ApplyOptions
type DiffResult
- func Diff(managed []ManagedResource, resources []*unstructured.Unstructured) DiffResult
- func DiffWithDefaultNamespace(cli client.Client, defaultnamespace string, managed []ManagedResource, ...) DiffResult
type ManagedResource
- func GetReference(obj client.Object) ManagedResource
- func (obj *ManagedResource) GetObjectKind() schema.ObjectKind
- func (obj *ManagedResource) GroupVersionKind() schema.GroupVersionKind
- func (obj *ManagedResource) SetGroupVersionKind(gvk schema.GroupVersionKind)
type SyncOptions
- func NewDefaultSyncOptions() *SyncOptions

Constants ¶

View Source

const ReadCache = 4096

Variables ¶

This section is empty.

Functions ¶

func ApplyResource ¶

func ApplyResource(ctx context.Context, cli client.Client, obj client.Object, options ApplyOptions) error

func ConvertToTypedList ¶ added in v1.23.8

func ConvertToTypedList(uns []*unstructured.Unstructured, schema *runtime.Scheme) []client.Object

func ConvertToTypedObject ¶ added in v1.23.8

func ConvertToTypedObject(uns *unstructured.Unstructured, schema *runtime.Scheme) client.Object

func CorrectNamespaces ¶

func CorrectNamespaces[T client.Object](cli client.Client, defaultNamespace string, list []T)

func CorrectNamespacesForRefrences ¶

func CorrectNamespacesForRefrences(cli client.Client, defaultns string, list []ManagedResource)

func EqualMapValues ¶

func EqualMapValues(a, b map[string]interface{}) bool

func IsCRD ¶

func IsCRD(obj client.Object) bool

func IsSkipedOn ¶

func IsSkipedOn(obj client.Object, key string) bool

func NamespacedScopeOf ¶

func NamespacedScopeOf(cli client.Client, obj runtime.Object) (apimeta.RESTScopeName, error)

func NamespacedScopeOfGVK ¶

func NamespacedScopeOfGVK(cli client.Client, gvk schema.GroupVersionKind) (apimeta.RESTScopeName, error)

func ReadObjectsFromFile ¶

func ReadObjectsFromFile[T runtime.Object](path string) ([]T, error)

func SplitYAML ¶

func SplitYAML(data []byte) ([]*unstructured.Unstructured, error)

func SplitYAMLFilterd ¶

func SplitYAMLFilterd[T runtime.Object](raw io.Reader) ([]T, error)

SplitYAMLFilterd reurns objects has type of `t`

Types ¶

type Apply ¶

type Apply struct {
	Client client.Client
}

func (*Apply) Sync ¶

func (a *Apply) Sync(
	ctx context.Context, defaultnamespace string,
	managed []ManagedResource, resources []*unstructured.Unstructured,
	options *SyncOptions,
) ([]ManagedResource, error)

func (Apply) SyncDiff ¶

func (a Apply) SyncDiff(ctx context.Context, diff DiffResult, options *SyncOptions) ([]ManagedResource, error)

nolint: funlen

type ApplyOptions ¶

type ApplyOptions struct {
	ServerSideApply bool
	FieldOwner      string
}

type DiffResult ¶

type DiffResult struct {
	Creats  []*unstructured.Unstructured
	Applys  []*unstructured.Unstructured
	Removes []*unstructured.Unstructured
}

func Diff ¶

func Diff(managed []ManagedResource, resources []*unstructured.Unstructured) DiffResult

func DiffWithDefaultNamespace ¶

func DiffWithDefaultNamespace(
	cli client.Client,
	defaultnamespace string,
	managed []ManagedResource,
	resources []*unstructured.Unstructured,
) DiffResult

type ManagedResource ¶ added in v1.23.8

type ManagedResource struct {
	APIVersion string `json:"apiVersion,omitempty"`
	Kind       string `json:"kind,omitempty"`
	Namespace  string `json:"namespace,omitempty"`
	Name       string `json:"name,omitempty"`
}

func GetReference ¶ added in v1.23.8

func GetReference(obj client.Object) ManagedResource

func (*ManagedResource) GetObjectKind ¶ added in v1.23.8

func (obj *ManagedResource) GetObjectKind() schema.ObjectKind

func (*ManagedResource) GroupVersionKind ¶ added in v1.23.8

func (obj *ManagedResource) GroupVersionKind() schema.GroupVersionKind

func (*ManagedResource) SetGroupVersionKind ¶ added in v1.23.8

func (obj *ManagedResource) SetGroupVersionKind(gvk schema.GroupVersionKind)

IsAnAPIObject allows clients to preemptively get a reference to an API object and pass it to places that intend only to get a reference to that object. This simplifies the event recording interface.

type SyncOptions ¶

type SyncOptions struct {
	ServerSideApply bool
	CreateNamespace bool
	CleanCRD        bool
}

func NewDefaultSyncOptions ¶

func NewDefaultSyncOptions() *SyncOptions

Source Files ¶

View all Source files

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