slotkeyrepo

Documentation

Index

• Constants
• type SlotKeyEntry
• type SlotKeyRepo
  • func NewSlotKeyRepo(db objmetadb.ObjStoreMetaDBAPI) *SlotKeyRepo
  • func (s *SlotKeyRepo) AllKeysChan(ctx context.Context, slot uint16, seekSlotKey string) (<-chan *SlotKeyEntry, error)
  • func (s *SlotKeyRepo) Get(slot uint16, key string) (value string, err error)
  • func (s *SlotKeyRepo) Has(slot uint16, key string) (bool, error)
  • func (s *SlotKeyRepo) Remove(slot uint16, key string) error
  • func (s *SlotKeyRepo) Set(slot uint16, key string, value string) error

Constants

const SlotPrefix = "slot/"

Types

type SlotKeyEntry

type SlotKeyEntry struct {
	Slot  uint16
	Key   string
	Value string
}

type SlotKeyRepo

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

SlotKeyRepo saves information about the slot and cid key mapping.

func NewSlotKeyRepo

func NewSlotKeyRepo(db objmetadb.ObjStoreMetaDBAPI) *SlotKeyRepo

func (*SlotKeyRepo) AllKeysChan

func (s *SlotKeyRepo) AllKeysChan(ctx context.Context, slot uint16, seekSlotKey string) (<-chan *SlotKeyEntry, error)

func (*SlotKeyRepo) Get

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

func (*SlotKeyRepo) Has

func (s *SlotKeyRepo) Has(slot uint16, key string) (bool, error)

func (*SlotKeyRepo) Remove

func (s *SlotKeyRepo) Remove(slot uint16, key string) error

func (*SlotKeyRepo) Set

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