sql

Documentation

Index

• type Storage
  • func New(ctx context.Context, db *sql.DB) (*Storage, error)
  • func (s *Storage) Delete(ctx context.Context, keyspace, key string) error
  • func (s *Storage) Get(ctx context.Context, keyspace, key string, into proto.Message) (version int64, err error)
  • func (s *Storage) List(ctx context.Context, keyspace string) (keys []string, err 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 {
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, db *sql.DB) (*Storage, error)

func (*Storage) Delete

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

func (*Storage) Get

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

func (*Storage) List

func (s *Storage) List(ctx context.Context, keyspace string) (keys []string, err 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)