reffs

Documentation

Index

• func NewReflogReader(r io.ReadSeekCloser) (ref.ReflogReader, error)
• type Store
  • func NewStore(rootDir string) *Store
  • func (s *Store) Copy(srcKey, dstKey string) (err error)
  • func (s *Store) Delete(key string) error
  • func (s *Store) DeleteTransaction(id uuid.UUID) error
  • func (s *Store) Filter(prefixes, notPrefixes []string) (m map[string][]byte, err error)
  • func (s *Store) FilterKey(prefixes, notPrefixes []string) (keys []string, err error)
  • func (s *Store) GCTransactions(txTTL time.Duration) (ids []uuid.UUID, err error)
  • func (s *Store) Get(key string) (val []byte, err error)
  • func (s *Store) GetTransaction(id uuid.UUID) (*ref.Transaction, error)
  • func (s *Store) GetTransactionLogs(txid uuid.UUID) (logs map[string]*ref.Reflog, err error)
  • func (s *Store) ListTransactions(offset, limit int) (txs []*ref.Transaction, err error)
  • func (s *Store) LogReader(key string) (ref.ReflogReader, error)
  • func (s *Store) NewTransaction(tx *ref.Transaction) (*uuid.UUID, error)
  • func (s *Store) Rename(oldKey, newKey string) (err error)
  • func (s *Store) Set(key string, val []byte) error
  • func (s *Store) SetWithLog(key string, val []byte, log *ref.Reflog) error
  • func (s *Store) UpdateTransaction(tx *ref.Transaction) error

Functions

func NewReflogReader

func NewReflogReader(r io.ReadSeekCloser) (ref.ReflogReader, error)

Types

type Store

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

func NewStore

func NewStore(rootDir string) *Store

func (*Store) Copy

func (s *Store) Copy(srcKey, dstKey string) (err error)

func (*Store) Delete

func (s *Store) Delete(key string) error

func (*Store) DeleteTransaction

func (s *Store) DeleteTransaction(id uuid.UUID) error

func (*Store) Filter

func (s *Store) Filter(prefixes, notPrefixes []string) (m map[string][]byte, err error)

func (*Store) FilterKey

func (s *Store) FilterKey(prefixes, notPrefixes []string) (keys []string, err error)

func (*Store) GCTransactions

func (s *Store) GCTransactions(txTTL time.Duration) (ids []uuid.UUID, err error)

func (*Store) Get

func (s *Store) Get(key string) (val []byte, err error)

func (*Store) GetTransaction

func (s *Store) GetTransaction(id uuid.UUID) (*ref.Transaction, error)

func (*Store) GetTransactionLogs

func (s *Store) GetTransactionLogs(txid uuid.UUID) (logs map[string]*ref.Reflog, err error)

func (*Store) ListTransactions

func (s *Store) ListTransactions(offset, limit int) (txs []*ref.Transaction, err error)

func (*Store) LogReader

func (s *Store) LogReader(key string) (ref.ReflogReader, error)

func (*Store) NewTransaction

func (s *Store) NewTransaction(tx *ref.Transaction) (*uuid.UUID, error)

func (*Store) Rename

func (s *Store) Rename(oldKey, newKey string) (err error)

func (*Store) Set

func (s *Store) Set(key string, val []byte) error

func (*Store) SetWithLog

func (s *Store) SetWithLog(key string, val []byte, log *ref.Reflog) error

func (*Store) UpdateTransaction

func (s *Store) UpdateTransaction(tx *ref.Transaction) error