store

Documentation

Index

• func ResourceID(namespace, name string) string
• type MemoryStore
  • func NewMemoryStore() *MemoryStore
  • func (s *MemoryStore) Add(resource *Resource)
  • func (s *MemoryStore) Delete(resourceID string)
  • func (s *MemoryStore) Get(resourceID string) (*Resource, error)
  • func (s *MemoryStore) List(namespace string) []*Resource
  • func (s *MemoryStore) UpSert(resource *Resource)
  • func (s *MemoryStore) Update(resource *Resource) error
  • func (s *MemoryStore) UpdateStatus(resource *Resource) error
• type Resource
  • func NewResource(namespace, name string, resourceVersion int64) *Resource
  • func (r *Resource) GetDeletionTimestamp() *metav1.Time
  • func (r *Resource) GetResourceVersion() string
  • func (r *Resource) GetUID() kubetypes.UID
• type ResourceStatus

Functions

func ResourceID

func ResourceID(namespace, name string) string

Types

type MemoryStore

type MemoryStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMemoryStore

func NewMemoryStore() *MemoryStore

func (*MemoryStore) Add

func (s *MemoryStore) Add(resource *Resource)

func (*MemoryStore) Delete

func (s *MemoryStore) Delete(resourceID string)

func (*MemoryStore) Get

func (s *MemoryStore) Get(resourceID string) (*Resource, error)

func (*MemoryStore) List

func (s *MemoryStore) List(namespace string) []*Resource

func (*MemoryStore) UpSert

func (s *MemoryStore) UpSert(resource *Resource)

func (*MemoryStore) Update

func (s *MemoryStore) Update(resource *Resource) error

func (*MemoryStore) UpdateStatus

func (s *MemoryStore) UpdateStatus(resource *Resource) error

type Resource

type Resource struct {
	Source            string
	ResourceID        string
	ResourceVersion   int64
	Namespace         string
	DeletionTimestamp *metav1.Time
	Spec              unstructured.Unstructured
	Status            ResourceStatus
}

func NewResource

func NewResource(namespace, name string, resourceVersion int64) *Resource

func (*Resource) GetDeletionTimestamp

func (r *Resource) GetDeletionTimestamp() *metav1.Time

func (*Resource) GetResourceVersion

func (r *Resource) GetResourceVersion() string

func (*Resource) GetUID

func (r *Resource) GetUID() kubetypes.UID

type ResourceStatus

type ResourceStatus struct {
	Conditions []metav1.Condition
}