mockfragment

Documentation

Index

• type MockFragment
  • func New() *MockFragment
  • func (f *MockFragment) Close() error
  • func (f *MockFragment) Compaction() (bool, error)
  • func (f *MockFragment) Delete(key string)
  • func (f *MockFragment) Destroy() error
  • func (f *MockFragment) Fill()
  • func (f *MockFragment) Get(key string) interface{}
  • func (f *MockFragment) Length() int
  • func (f *MockFragment) Move(part *partitions.Partition, name string, owners []discovery.Member) error
  • func (f *MockFragment) Name() string
  • func (f *MockFragment) Put(key string, value interface{})
  • func (f *MockFragment) Result() map[partitions.Kind]map[uint64]Result
  • func (f *MockFragment) Stats() storage.Stats
• type Result

Types

type MockFragment

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

func New

func New() *MockFragment

func (*MockFragment) Close

func (f *MockFragment) Close() error

func (*MockFragment) Compaction

func (f *MockFragment) Compaction() (bool, error)

func (*MockFragment) Delete

func (f *MockFragment) Delete(key string)

func (*MockFragment) Destroy

func (f *MockFragment) Destroy() error

func (*MockFragment) Fill

func (f *MockFragment) Fill()

func (*MockFragment) Get

func (f *MockFragment) Get(key string) interface{}

func (*MockFragment) Length

func (f *MockFragment) Length() int

func (*MockFragment) Move

func (f *MockFragment) Move(part *partitions.Partition, name string, owners []discovery.Member) error

func (*MockFragment) Name

func (f *MockFragment) Name() string

func (*MockFragment) Put

func (f *MockFragment) Put(key string, value interface{})

func (*MockFragment) Result

func (f *MockFragment) Result() map[partitions.Kind]map[uint64]Result

func (*MockFragment) Stats

func (f *MockFragment) Stats() storage.Stats

type Result

type Result struct {
	Name   string
	Owners []discovery.Member
}