scommons

Documentation

Index

• Variables
• func NewMessageIterator(s storage.Storage, opts *storage.IterOptions) storage.MessageIterator
• func PrependPrefix(prefix, key []byte) []byte
• type StorageCommons
  • func (s *StorageCommons) ForEach(fn func(msg *sgproto.Message) error) error
  • func (s *StorageCommons) ForEachWALEntry(min []byte, fn func(msg *sgproto.Message) error) error
  • func (s *StorageCommons) ForRange(min, max sandflake.ID, fn func(msg *sgproto.Message) error) error
  • func (s *StorageCommons) LastKVForPrefix(prefix, suffix []byte) []byte
  • func (s *StorageCommons) LastKeyForPrefix(prefix []byte) []byte

Variables

var (
	ViewPrefix = []byte("v")
	WalPrefix  = []byte("w")
)

Functions

func NewMessageIterator

func NewMessageIterator(s storage.Storage, opts *storage.IterOptions) storage.MessageIterator

func PrependPrefix

func PrependPrefix(prefix, key []byte) []byte

Types

type StorageCommons

type StorageCommons struct {
	storage.Storage
}

func (*StorageCommons) ForEach

func (s *StorageCommons) ForEach(fn func(msg *sgproto.Message) error) error

func (*StorageCommons) ForEachWALEntry

func (s *StorageCommons) ForEachWALEntry(min []byte, fn func(msg *sgproto.Message) error) error

func (*StorageCommons) ForRange

func (s *StorageCommons) ForRange(min, max sandflake.ID, fn func(msg *sgproto.Message) error) error

func (*StorageCommons) LastKVForPrefix

func (s *StorageCommons) LastKVForPrefix(prefix, suffix []byte) []byte

func (*StorageCommons) LastKeyForPrefix

func (s *StorageCommons) LastKeyForPrefix(prefix []byte) []byte