Documentation
¶
Index ¶
- Variables
- func CreateIndex(ctx context.Context, db *sql.DB, tblName string) error
- func CreateTable(ctx context.Context, db *sql.DB, tblName string) error
- type Storage
- func (s *Storage) Destroy(ctx context.Context) error
- func (s *Storage) FindPartition(tblName, rowKey string) int
- func (s *Storage) Get(ctx context.Context, tblName, rowKey, columnKey string, refKey int64) (cell models.Cell, found bool, err error)
- func (s *Storage) GetDB() *sql.DB
- func (s *Storage) GetLatest(ctx context.Context, tblName, rowKey, columnKey string) (cell models.Cell, found bool, err error)
- func (s *Storage) PartitionRead(ctx context.Context, tblName string, partitionNumber int, location string, ...) (cells []models.Cell, found bool, err error)
- func (s *Storage) Put(ctx context.Context, tblName, rowKey, columnKey string, refKey int64, ...) (err error)
- func (s *Storage) ResetConnection(ctx context.Context, key string) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNotAtStorageLevel = errors.New("not implemented at storage level")
ErrNotAtStorageLevel marks methods that are not to be called at storage level
Functions ¶
Types ¶
type Storage ¶
type Storage struct {
// contains filtered or unexported fields
}
func (*Storage) FindPartition ¶
func (*Storage) PartitionRead ¶
Source Files
Click to show internal directories.
Click to hide internal directories.