optimistic_locking_store

Documentation

Index

• Variables
• func IsErrRecordVersionChanged(err error) bool
• type InMemoryStore
  • func NewInMemoryStore() *InMemoryStore
  • func (store *InMemoryStore) GetValue(key string) (*Value, error)
  • func (store *InMemoryStore) PutValue(key string, value *Value) error
• type KubernetesResourceAnnotationsStore
  • func NewKubernetesResourceAnnotationsStore(kubernetesInterface dynamic.Interface, gvr schema.GroupVersionResource, ...) *KubernetesResourceAnnotationsStore
  • func (store *KubernetesResourceAnnotationsStore) GetValue(key string) (*Value, error)
  • func (store *KubernetesResourceAnnotationsStore) PutValue(key string, value *Value) error
• type OptimisticLockingStore
• type Value

Variables

var ErrRecordVersionChanged = errors.New("record version changed")

Functions

func IsErrRecordVersionChanged

func IsErrRecordVersionChanged(err error) bool

Types

type InMemoryStore

type InMemoryStore struct {
	Mux    sync.Mutex
	Values map[string]*Value
}

func NewInMemoryStore

func NewInMemoryStore() *InMemoryStore

func (*InMemoryStore) GetValue

func (store *InMemoryStore) GetValue(key string) (*Value, error)

func (*InMemoryStore) PutValue

func (store *InMemoryStore) PutValue(key string, value *Value) error

type KubernetesResourceAnnotationsStore

type KubernetesResourceAnnotationsStore struct {
	KubernetesInterface dynamic.Interface
	GVR                 schema.GroupVersionResource
	ResourceName        string
	Namespace           string
}

func NewKubernetesResourceAnnotationsStore

func NewKubernetesResourceAnnotationsStore(kubernetesInterface dynamic.Interface, gvr schema.GroupVersionResource, resourceName, namespace string) *KubernetesResourceAnnotationsStore

func (*KubernetesResourceAnnotationsStore) GetValue

func (store *KubernetesResourceAnnotationsStore) GetValue(key string) (*Value, error)

func (*KubernetesResourceAnnotationsStore) PutValue

func (store *KubernetesResourceAnnotationsStore) PutValue(key string, value *Value) error

type OptimisticLockingStore

type OptimisticLockingStore interface {
	GetValue(key string) (*Value, error)
	PutValue(key string, value *Value) error
}

type Value

type Value struct {
	Data string
	// contains filtered or unexported fields
}