models

Documentation

Index

• func Get(ctx context.Context, s rest.StandardStorage, name string, ...) (runtime.Object, error)
• func GetV2(ctx context.Context, s rest.StandardStorage, name string, ...) (runtime.Object, error)
• func List(ctx context.Context, s rest.StandardStorage, q *query.Query) (runtime.Object, error)
• func ObjectMetaFilter(obj metav1.ObjectMeta, key, value string) bool
• func Watch(ctx context.Context, s rest.StandardStorage, q *query.Query) (watch.Interface, error)
• type CompareFunc
• type FilterFunc
• type ListToObjectSliceFunction
• type MutatingFunc
• type PageableResponse
  • func DefaultList(object runtime.Object, q *query.Query, ...) (*PageableResponse, error)
  • func DefaultListMerge(objects []runtime.Object, litToSliceFunc ListToObjectSliceFunction, ...) (*PageableResponse, error)
  • func ListExV2(ctx context.Context, s rest.StandardStorage, q *query.Query, ...) (*PageableResponse, error)

Functions

func Get

func Get(ctx context.Context, s rest.StandardStorage, name string, resourceVersion string) (runtime.Object, error)

Deprecated

func GetV2

func GetV2(ctx context.Context, s rest.StandardStorage, name string, resourceVersion string, mutatingFunc MutatingFunc) (runtime.Object, error)

func List

func List(ctx context.Context, s rest.StandardStorage, q *query.Query) (runtime.Object, error)

func ObjectMetaFilter

func ObjectMetaFilter(obj metav1.ObjectMeta, key, value string) bool

func Watch

func Watch(ctx context.Context, s rest.StandardStorage, q *query.Query) (watch.Interface, error)

Types

type CompareFunc

type CompareFunc func(left runtime.Object, right runtime.Object, orderBy string) bool

var DefaultCompareFunc CompareFunc = func(left runtime.Object, right runtime.Object, _ string) bool {
	leftMeta, _ := meta.Accessor(left)
	rightMeta, _ := meta.Accessor(right)
	if leftMeta.GetCreationTimestamp().Time.Equal(rightMeta.GetCreationTimestamp().Time) {
		return leftMeta.GetName() > rightMeta.GetName()
	}
	return leftMeta.GetCreationTimestamp().Time.After(rightMeta.GetCreationTimestamp().Time)
}

type FilterFunc

type FilterFunc func(obj runtime.Object) bool

type ListToObjectSliceFunction

type ListToObjectSliceFunction func(runtime.Object, *query.Query) []runtime.Object

type MutatingFunc

type MutatingFunc func(obj runtime.Object) runtime.Object

var DefaultMutatingFunc MutatingFunc = func(obj runtime.Object) runtime.Object {
	return obj
}

type PageableResponse

type PageableResponse struct {
	Items      []interface{} `json:"items" description:"paging data"`
	TotalCount int           `json:"totalCount" description:"total count"`
}

func DefaultList

func DefaultList(object runtime.Object, q *query.Query, litToSliceFunc ListToObjectSliceFunction, compareFunc CompareFunc, mutatingFunc MutatingFunc) (*PageableResponse, error)

DefaultList a func to build a PageableResponse

func DefaultListMerge

func DefaultListMerge(objects []runtime.Object, litToSliceFunc ListToObjectSliceFunction, compareFunc CompareFunc, mutatingFunc MutatingFunc) (*PageableResponse, error)

DefaultListMerge a func to build a PageableResponse from many obj

func ListExV2

func ListExV2(ctx context.Context, s rest.StandardStorage, q *query.Query, litToSliceFunc ListToObjectSliceFunction, compareFunc CompareFunc, mutatingFunc MutatingFunc) (*PageableResponse, error)