slotmigraterepo

Documentation

Index

• Constants
• type Entry
• type SlotMigrateRepo
  • func NewSlotMigrateRepo(db objmetadb.ObjStoreMetaDBAPI) *SlotMigrateRepo
  • func (s *SlotMigrateRepo) AllKeysChan(ctx context.Context) (<-chan *Entry, error)
  • func (s *SlotMigrateRepo) Get(slot uint16) (value string, err error)
  • func (s *SlotMigrateRepo) Has(slot uint16) (bool, error)
  • func (s *SlotMigrateRepo) Remove(slot uint16) error
  • func (s *SlotMigrateRepo) Set(slot uint16, value string) error

Constants

const SlotMigratePrefix = "migrate/"

Types

type Entry

type Entry struct {
	Slot  uint16
	Value string
}

type SlotMigrateRepo

type SlotMigrateRepo struct {
	// contains filtered or unexported fields
}

SlotMigrateRepo saves information about the slot to be transferred.

func NewSlotMigrateRepo

func NewSlotMigrateRepo(db objmetadb.ObjStoreMetaDBAPI) *SlotMigrateRepo

func (*SlotMigrateRepo) AllKeysChan

func (s *SlotMigrateRepo) AllKeysChan(ctx context.Context) (<-chan *Entry, error)

func (*SlotMigrateRepo) Get

func (s *SlotMigrateRepo) Get(slot uint16) (value string, err error)

func (*SlotMigrateRepo) Has

func (s *SlotMigrateRepo) Has(slot uint16) (bool, error)

func (*SlotMigrateRepo) Remove

func (s *SlotMigrateRepo) Remove(slot uint16) error

func (*SlotMigrateRepo) Set

func (s *SlotMigrateRepo) Set(slot uint16, value string) error