Versions in this module Expand all Collapse all v0 v0.3.0 Jul 3, 2020 Changes in this version + type LogStatusCols struct + DirectoryID string + LogID int64 + WriteToLog bool + type Table struct + func New(client *spanner.Client) *Table + func (t *Table) AddLogs(ctx context.Context, directoryID string, logIDs ...int64) error + func (t *Table) HighWatermark(ctx context.Context, directoryID string, logID int64, start water.Mark, ...) (count int32, high water.Mark, err error) + func (t *Table) ListLogs(ctx context.Context, directoryID string, writable bool) ([]int64, error) + func (t *Table) ReadLog(ctx context.Context, directoryID string, logID int64, low, high water.Mark, ...) ([]*mutator.LogMessage, error) + func (t *Table) SendBatch(ctx context.Context, directoryID string, logID int64, batch []*pb.EntryUpdate) (water.Mark, error) + func (t *Table) SetWritable(ctx context.Context, directoryID string, logID int64, enabled bool) error
Go to main page