disk

Documentation

Index

• type Storage
  • func New(path string, mode os.FileMode) (*Storage, error)
  • func (s *Storage) Delete(_ context.Context, keyspace, key string) error
  • func (s *Storage) Get(_ context.Context, keyspace, key string, into proto.Message) (version int64, err error)
  • func (s *Storage) List(_ context.Context, keyspace string) ([]string, error)
  • func (s *Storage) Put(ctx context.Context, keyspace, key string, version int64, obj proto.Message) (newVersion int64, err error)
  • func (s *Storage) PutWithExpiry(ctx context.Context, keyspace, key string, version int64, obj proto.Message, ...) (newVersion int64, err error)

Types

type Storage

type Storage struct {
	Now func() time.Time
	// contains filtered or unexported fields
}

func New

func New(path string, mode os.FileMode) (*Storage, error)

func (*Storage) Delete

func (s *Storage) Delete(_ context.Context, keyspace, key string) error

func (*Storage) Get

func (s *Storage) Get(_ context.Context, keyspace, key string, into proto.Message) (version int64, err error)

func (*Storage) List

func (s *Storage) List(_ context.Context, keyspace string) ([]string, error)

func (*Storage) Put

func (s *Storage) Put(ctx context.Context, keyspace, key string, version int64, obj proto.Message) (newVersion int64, err error)

func (*Storage) PutWithExpiry

func (s *Storage) PutWithExpiry(ctx context.Context, keyspace, key string, version int64, obj proto.Message, expires time.Time) (newVersion int64, err error)