storage

package

Go to main page

Versions in this module

v0

v0.0.3

Aug 21, 2020

Changes in this version

+ var ContentTypes = map[string]serializer.ContentType

+ var ErrAlreadyExists = errors.New("resource already exists")

+ var ErrAmbiguousFind = errors.New("two or more results were aquired when one was expected")

+ var ErrNotFound = errors.New("resource not found")

+ var ErrNotTracked = fmt.Errorf("untracked object: %w", ErrNotFound)

+ func DecodePartialObjects(rc io.ReadCloser, scheme *kruntime.Scheme, allowMultiple bool, ...) ([]runtime.PartialObject, error)

type GenericMappedRawStorage

+ func (r *GenericMappedRawStorage) ContentType(key ObjectKey) (ct serializer.ContentType)

+ func (r *GenericMappedRawStorage) SetMappings(m map[ObjectKey]string)

type GenericRawStorage

+ func (r *GenericRawStorage) ContentType(_ ObjectKey) serializer.ContentType

type GenericStorage

+ func (s *GenericStorage) Create(obj runtime.Object) error

+ func (s *GenericStorage) Find(kind KindKey, opts ...filter.ListOption) (runtime.Object, error)

+ func (s *GenericStorage) ObjectKeyFor(obj runtime.Object) (ObjectKey, error)

+ func (s *GenericStorage) Update(obj runtime.Object) error

type KindKey

+ EqualsGVK func(kind KindKey, respectVersion bool) bool

+ GetGVK func() schema.GroupVersionKind

+ GetGroup func() string

+ GetKind func() string

+ GetVersion func() string

type MappedRawStorage

+ SetMappings func(m map[ObjectKey]string)

+ type ObjectKey interface

+ func NewObjectKey(kind KindKey, id runtime.Identifyable) ObjectKey

type RawStorage

+ ContentType func(key ObjectKey) serializer.ContentType

+ type ReadStorage interface

+ Checksum func(key ObjectKey) (string, error)

+ Close func() error

+ Count func(kind KindKey) (uint64, error)

+ Find func(kind KindKey, opts ...filter.ListOption) (runtime.Object, error)

+ Get func(key ObjectKey) (runtime.Object, error)

+ GetMeta func(key ObjectKey) (runtime.PartialObject, error)

+ List func(kind KindKey, opts ...filter.ListOption) ([]runtime.Object, error)

+ ListMeta func(kind KindKey) ([]runtime.PartialObject, error)

+ ObjectKeyFor func(obj runtime.Object) (ObjectKey, error)

+ RawStorage func() RawStorage

+ Serializer func() serializer.Serializer

+ type WriteStorage interface

+ Create func(obj runtime.Object) error

+ Delete func(key ObjectKey) error

+ Patch func(key ObjectKey, patch []byte) error

+ Update func(obj runtime.Object) error

v0.0.2

Jul 27, 2020

v0.0.1

Jul 16, 2020

Changes in this version

+ var Formats = map[string]Format

+ type AnyKey fmt.Stringer

+ type Format uint8

+ const FormatJSON

+ const FormatYAML

+ type GenericMappedRawStorage struct

+ func (r *GenericMappedRawStorage) AddMapping(key Key, path string)

+ func (r *GenericMappedRawStorage) Checksum(key Key) (s string, err error)

+ func (r *GenericMappedRawStorage) Delete(key Key) (err error)

+ func (r *GenericMappedRawStorage) Exists(key Key) bool

+ func (r *GenericMappedRawStorage) Format(key Key) (f Format)

+ func (r *GenericMappedRawStorage) GetKey(path string) (Key, error)

+ func (r *GenericMappedRawStorage) List(kind KindKey) ([]Key, error)

+ func (r *GenericMappedRawStorage) Read(key Key) ([]byte, error)

+ func (r *GenericMappedRawStorage) RemoveMapping(key Key)

+ func (r *GenericMappedRawStorage) WatchDir() string

+ func (r *GenericMappedRawStorage) Write(key Key, content []byte) error

+ type GenericRawStorage struct

+ func (r *GenericRawStorage) Checksum(key Key) (s string, err error)

+ func (r *GenericRawStorage) Delete(key Key) error

+ func (r *GenericRawStorage) Exists(key Key) bool

+ func (r *GenericRawStorage) Format(key Key) Format

+ func (r *GenericRawStorage) GetKey(p string) (key Key, err error)

+ func (r *GenericRawStorage) List(key KindKey) ([]Key, error)

+ func (r *GenericRawStorage) Read(key Key) ([]byte, error)

+ func (r *GenericRawStorage) WatchDir() string

+ func (r *GenericRawStorage) Write(key Key, content []byte) error

+ type GenericStorage struct

+ func (s *GenericStorage) Checksum(gvk schema.GroupVersionKind, uid runtime.UID) (string, error)

+ func (s *GenericStorage) Close() error

+ func (s *GenericStorage) Count(gvk schema.GroupVersionKind) (uint64, error)

+ func (s *GenericStorage) Delete(gvk schema.GroupVersionKind, uid runtime.UID) error

+ func (s *GenericStorage) Get(gvk schema.GroupVersionKind, uid runtime.UID) (runtime.Object, error)

+ func (s *GenericStorage) GetMeta(gvk schema.GroupVersionKind, uid runtime.UID) (runtime.Object, error)

+ func (s *GenericStorage) List(gvk schema.GroupVersionKind) (result []runtime.Object, walkerr error)

+ func (s *GenericStorage) ListMeta(gvk schema.GroupVersionKind) (result []runtime.Object, walkerr error)

+ func (s *GenericStorage) New(gvk schema.GroupVersionKind) (runtime.Object, error)

+ func (s *GenericStorage) Patch(gvk schema.GroupVersionKind, uid runtime.UID, patch []byte) error

+ func (s *GenericStorage) RawStorage() RawStorage

+ func (s *GenericStorage) Serializer() serializer.Serializer

+ func (s *GenericStorage) Set(gvk schema.GroupVersionKind, obj runtime.Object) error

+ type Key struct

+ func KeyForUID(gvk schema.GroupVersionKind, uid runtime.UID) Key

+ func NewKey(kind runtime.Kind, uid runtime.UID) Key

+ func ParseKey(input string) (k Key, err error)

+ func (k Key) String() string

+ func (k Key) ToKindKey() KindKey

+ type KindKey struct

+ func KeyForKind(gvk schema.GroupVersionKind) KindKey

+ func NewKindKey(kind runtime.Kind) KindKey

+ func (k KindKey) String() string

+ type MappedRawStorage interface

+ AddMapping func(key Key, path string)

+ RemoveMapping func(key Key)

+ func NewGenericMappedRawStorage(dir string) MappedRawStorage

+ type RawStorage interface

+ Checksum func(key Key) (string, error)

+ Delete func(key Key) error

+ Exists func(key Key) bool

+ Format func(key Key) Format

+ GetKey func(path string) (Key, error)

+ List func(key KindKey) ([]Key, error)

+ Read func(key Key) ([]byte, error)

+ WatchDir func() string

+ Write func(key Key, content []byte) error

+ func NewGenericRawStorage(dir string) RawStorage

+ type Storage interface

+ Checksum func(gvk schema.GroupVersionKind, uid runtime.UID) (string, error)

+ Close func() error

+ Count func(gvk schema.GroupVersionKind) (uint64, error)

+ Delete func(gvk schema.GroupVersionKind, uid runtime.UID) error

+ Get func(gvk schema.GroupVersionKind, uid runtime.UID) (runtime.Object, error)

+ GetMeta func(gvk schema.GroupVersionKind, uid runtime.UID) (runtime.Object, error)

+ List func(gvk schema.GroupVersionKind) ([]runtime.Object, error)

+ ListMeta func(gvk schema.GroupVersionKind) ([]runtime.Object, error)

+ New func(gvk schema.GroupVersionKind) (runtime.Object, error)

+ Patch func(gvk schema.GroupVersionKind, uid runtime.UID, patch []byte) error

+ RawStorage func() RawStorage

+ Serializer func() serializer.Serializer

+ Set func(gvk schema.GroupVersionKind, obj runtime.Object) error

+ func NewGenericStorage(rawStorage RawStorage, serializer serializer.Serializer) Storage

v0.0.1-beta.1

Jul 6, 2020

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