Versions in this module Expand all Collapse all v0 v0.0.1 Apr 23, 2019 Changes in this version + func JoinKeyPrefix(prefixes ...string) string + func KeyPrefixForAPIVersion(apiVersion string) string + func KeyPrefixForAPIVersionKind(apiVersion, kind string) string + func KeyPrefixForAPIVersionKindNamespace(apiVersion, kind, namespace string) string + func NewInstrumentedAsyncRevisionInterface(r AsyncWriteRevisionInterface) *instrumentedAsyncRevisionInterface + func NewInstrumentedRevisionInterface(r RevisionInterface) *instrumentedRevisionInterface + func NewInstrumentedRevisionPurger(r RevisionPurger) *instrumentedRevisionPurger + func NewRevisionPurger(s *RevisionStore) *revisionPurger + func ResourceKey(apiVersion, kind, namespace, name string) string + func RevisionKey(resourceKey string, revisionKey string) string + func StripMetadata(u *unstructured.Unstructured) + type AsyncResponse struct + Error error + Revision Revision + type AsyncWriteRevisionInterface interface + AsyncCreate func(context.Context, Revision) (<-chan AsyncResponse, error) + AsyncDelete func(context.Context, Revision) (<-chan AsyncResponse, error) + AsyncUpdate func(context.Context, Revision) (<-chan AsyncResponse, error) + type ConcreteRevision struct + func RevisionFrom(u *unstructured.Unstructured) *ConcreteRevision + func (c *ConcreteRevision) APIVersion() string + func (c *ConcreteRevision) Content() (*unstructured.Unstructured, error) + func (c *ConcreteRevision) Deleted() bool + func (c *ConcreteRevision) Kind() string + func (c *ConcreteRevision) MarshalJSON() ([]byte, error) + func (c *ConcreteRevision) Name() string + func (c *ConcreteRevision) Namespace() string + func (c *ConcreteRevision) ResourceVersion() int + func (c *ConcreteRevision) RevisionTimestamp() time.Time + func (c *ConcreteRevision) SetDeleted(deleted bool) + func (c *ConcreteRevision) String() string + func (c *ConcreteRevision) TypeMeta() metav1.TypeMeta + func (r ConcreteRevision) Key() string + func (r ConcreteRevision) ResourceKey() string + func (r ConcreteRevision) RevisionKey() string + type InMemoryRevisionGetter struct + func NewInMemoryGetter() *InMemoryRevisionGetter + func (s *InMemoryRevisionGetter) Backend() string + func (s *InMemoryRevisionGetter) PurgeRevision(ctx context.Context, rev Revision) error + func (s *InMemoryRevisionGetter) PurgeRevisions(ctx context.Context, revs RevisionList) (RevisionList, error) + func (s *InMemoryRevisionGetter) Revisions(namespace string) RevisionInterface + func (s *InMemoryRevisionGetter) State(ctx context.Context, o StateOptions) (State, error) + type LazyLoadingRevision struct + func ParseLazyLoadingRevision(ctx context.Context, s Storer, path string) (*LazyLoadingRevision, error) + func (l *LazyLoadingRevision) APIVersion() string + func (l *LazyLoadingRevision) Content() (*unstructured.Unstructured, error) + func (l *LazyLoadingRevision) Deleted() bool + func (l *LazyLoadingRevision) Kind() string + func (l *LazyLoadingRevision) MarshalJSON() ([]byte, error) + func (l *LazyLoadingRevision) Name() string + func (l *LazyLoadingRevision) Namespace() string + func (l *LazyLoadingRevision) ResourceVersion() int + func (l *LazyLoadingRevision) RevisionTimestamp() time.Time + func (l *LazyLoadingRevision) SetDeleted(deleted bool) + func (l *LazyLoadingRevision) String() string + func (l *LazyLoadingRevision) TypeMeta() metav1.TypeMeta + func (r LazyLoadingRevision) Key() string + func (r LazyLoadingRevision) ResourceKey() string + func (r LazyLoadingRevision) RevisionKey() string + type OptionFunc func(*RevisionStore) + func WithBackend(backend backend.Backend) OptionFunc + func WithCache(shouldCache bool) OptionFunc + func WithConcurrentWrites(concurrentWrites int) OptionFunc + func WithConfigger(configger config.Configger) OptionFunc + func WithDeleteUntracked(deleteUntracked bool) OptionFunc + func WithEncrypter(e crypt.Encrypter) OptionFunc + type PurgingRevisionGetter interface + type ReadWriteStore struct + func (s *ReadWriteStore) Backend() string + func (s *ReadWriteStore) PurgeRevision(ctx context.Context, rev Revision) error + func (s *ReadWriteStore) PurgeRevisions(ctx context.Context, revs RevisionList) (RevisionList, error) + func (s *ReadWriteStore) Revisions(namespace string) RevisionInterface + func (s *ReadWriteStore) State(ctx context.Context, o StateOptions) (State, error) + func (s *ReadWriteStore) Sync(ctx context.Context, handlers handler.ResourceHandlers) (State, RevisionList, error) + type Revision interface + APIVersion func() string + Content func() (*unstructured.Unstructured, error) + Deleted func() bool + Key func() string + Kind func() string + Name func() string + Namespace func() string + ResourceKey func() string + ResourceVersion func() int + RevisionKey func() string + RevisionTimestamp func() time.Time + SetDeleted func(bool) + TypeMeta func() metav1.TypeMeta + type RevisionClient interface + type RevisionGetter interface + Revisions func(namespace string) RevisionInterface + type RevisionInterface interface + Create func(context.Context, Revision) (Revision, error) + Delete func(context.Context, Revision) error + Get func(context.Context, Revision) (Revision, error) + List func(context.Context, metav1.TypeMeta, string, metav1.ListOptions) (RevisionList, error) + Update func(context.Context, Revision) (Revision, error) + type RevisionList []Revision + func (revs RevisionList) Cut(i, j int) RevisionList + func (revs RevisionList) Len() int + func (revs RevisionList) Less(x, y int) bool + func (revs RevisionList) MarshalJSONWithContent(prefix, indent string) ([]byte, error) + func (revs RevisionList) String() string + func (revs RevisionList) Swap(x, y int) + type RevisionPurger interface + PurgeRevision func(context.Context, Revision) error + PurgeRevisions func(context.Context, RevisionList) (RevisionList, error) + type RevisionStore struct + func (s *RevisionStore) Backend() string + func (s *RevisionStore) Close(ctx context.Context) error + func (s *RevisionStore) Revisions(namespace string) RevisionInterface + func (s *RevisionStore) State(ctx context.Context, o StateOptions) (State, error) + func (s *RevisionStore) Sync(ctx context.Context, handlers handler.ResourceHandlers) (State, RevisionList, error) + type State map[string]RevisionList + func (s State) MarshalJSONOnlyContent(prefix, indent string) ([]byte, error) + func (s State) MarshalJSONWithContent(prefix, indent string) ([]byte, error) + type StateOptions struct + AllNamespaces bool + AllRevisions bool + LabelSelector *metav1.LabelSelector + Name string + Namespace string + OnlyDeleted bool + Time time.Time + type Stater interface + State func(context.Context, StateOptions) (State, error) + type Storer interface + Backend func() string + Close func(context.Context) error + Sync func(context.Context, handler.ResourceHandlers) (State, RevisionList, error) + func New(ctx context.Context, opts ...OptionFunc) (Storer, error) + func NewFromEnv(ctx context.Context) (Storer, error) + func NewReadWriteStorer(writer Storer, reader RevisionClient, ...) (Storer, error)
Go to main page