sqllog

Documentation

Index

• Constants
• func RowsToEvents(rows *sql.Rows) ([]*server.Event, error)
• type Dialect
• type SQLLog
  • func New(d Dialect) *SQLLog
  • func (s *SQLLog) After(ctx context.Context, prefix string, revision, limit int64) (int64, []*server.Event, error)
  • func (s *SQLLog) Count(ctx context.Context, prefix, startKey string, revision int64) (int64, int64, error)
  • func (s *SQLLog) Create(ctx context.Context, key string, value []byte, lease int64) (int64, bool, error)
  • func (s *SQLLog) CurrentRevision(ctx context.Context) (int64, error)
  • func (s *SQLLog) DbSize(ctx context.Context) (int64, error)
  • func (s *SQLLog) Delete(ctx context.Context, key string, revision int64) (rev int64, deleted bool, err error)
  • func (s *SQLLog) DoCompact(ctx context.Context) (err error)
  • func (s *SQLLog) List(ctx context.Context, prefix, startKey string, limit, revision int64, ...) (int64, []*server.Event, error)
  • func (s *SQLLog) Start(ctx context.Context) (err error)
  • func (s *SQLLog) Update(ctx context.Context, key string, value []byte, prevRev, lease int64) (rev int64, updated bool, err error)
  • func (s *SQLLog) Wait()
  • func (s *SQLLog) Watch(ctx context.Context, prefix string) <-chan []*server.Event

Constants

const (
	SupersededCount = 100
)

Functions

func RowsToEvents

func RowsToEvents(rows *sql.Rows) ([]*server.Event, error)

Types

type Dialect

type Dialect interface {
	List(ctx context.Context, prefix, startKey string, limit, revision int64, includeDeleted bool) (*sql.Rows, error)
	Count(ctx context.Context, prefix, startKey string, revision int64) (int64, error)
	CurrentRevision(ctx context.Context) (int64, error)
	AfterPrefix(ctx context.Context, prefix string, rev, limit int64) (*sql.Rows, error)
	After(ctx context.Context, rev, limit int64) (*sql.Rows, error)
	Create(ctx context.Context, key string, value []byte, lease int64) (int64, bool, error)
	Update(ctx context.Context, key string, value []byte, prevRev, lease int64) (int64, bool, error)
	Delete(ctx context.Context, key string, revision int64) (int64, bool, error)
	DeleteRevision(ctx context.Context, revision int64) error
	GetCompactRevision(ctx context.Context) (int64, int64, error)
	Compact(ctx context.Context, revision int64) error
	Fill(ctx context.Context, revision int64) error
	IsFill(key string) bool
	GetSize(ctx context.Context) (int64, error)
	GetCompactInterval() time.Duration
	GetWatchQueryTimeout() time.Duration
	GetPollInterval() time.Duration
	Close() error
}

type SQLLog

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

func New

func New(d Dialect) *SQLLog

func (*SQLLog) After

func (s *SQLLog) After(ctx context.Context, prefix string, revision, limit int64) (int64, []*server.Event, error)

func (*SQLLog) Count

func (s *SQLLog) Count(ctx context.Context, prefix, startKey string, revision int64) (int64, int64, error)

func (*SQLLog) Create

func (s *SQLLog) Create(ctx context.Context, key string, value []byte, lease int64) (int64, bool, error)

func (*SQLLog) CurrentRevision

func (s *SQLLog) CurrentRevision(ctx context.Context) (int64, error)

func (*SQLLog) DbSize

func (s *SQLLog) DbSize(ctx context.Context) (int64, error)

func (*SQLLog) Delete

func (s *SQLLog) Delete(ctx context.Context, key string, revision int64) (rev int64, deleted bool, err error)

func (*SQLLog) DoCompact

func (s *SQLLog) DoCompact(ctx context.Context) (err error)

DoCompact makes a single compaction run when called. It is intended to be called from test functions that have access to the backend.

func (*SQLLog) List

func (s *SQLLog) List(ctx context.Context, prefix, startKey string, limit, revision int64, includeDeleted bool) (int64, []*server.Event, error)

func (*SQLLog) Start

func (s *SQLLog) Start(ctx context.Context) (err error)

func (*SQLLog) Update

func (s *SQLLog) Update(ctx context.Context, key string, value []byte, prevRev, lease int64) (rev int64, updated bool, err error)

func (*SQLLog) Wait

func (s *SQLLog) Wait()

func (*SQLLog) Watch

func (s *SQLLog) Watch(ctx context.Context, prefix string) <-chan []*server.Event