package testing

import "k8s.io/kubernetes/pkg/kubelet/checkpointmanager/testing"

Index ¶

• type MemStore
• func NewMemStore() *MemStore
• func (mstore *MemStore) Delete(key string) error
• func (mstore *MemStore) List() ([]string, error)
• func (mstore *MemStore) Read(key string) ([]byte, error)
• func (mstore *MemStore) Write(key string, data []byte) error

Types ¶

type MemStore ¶

type MemStore struct {
	sync.Mutex
	// contains filtered or unexported fields
}

MemStore is an implementation of CheckpointStore interface which stores checkpoint in memory.

func NewMemStore ¶

func NewMemStore() *MemStore

NewMemStore returns an instance of MemStore

func (*MemStore) Delete ¶

func (mstore *MemStore) Delete(key string) error

Delete deletes data from the store

func (*MemStore) List ¶

func (mstore *MemStore) List() ([]string, error)

List returns all the keys from the store

func (*MemStore) Read ¶

func (mstore *MemStore) Read(key string) ([]byte, error)

Read returns data read from store

func (*MemStore) Write ¶

func (mstore *MemStore) Write(key string, data []byte) error

Write writes the data to the store

Source Files ¶

util.go

Directories ¶