state

Documentation

Overview

Package state provides the persistent storage layer for the log poller.

Index

• Constants
• func CreateTable(ctx context.Context, db *sql.DB) error
• func Get(ctx context.Context, db *sql.DB, file string) (int64, int64, error)
• func Insert(ctx context.Context, db *sql.DB, file string, offset int64, whence int64) error

Constants

const (
	ColumnFile = "file"

	// File seek info offset.
	ColumnOffset = "offset"
	// File seek info whence.
	ColumnWhence = "whence"
)

const TableName = "components_query_log_seek_info"

Functions

func CreateTable

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

func Get

func Get(ctx context.Context, db *sql.DB, file string) (int64, int64, error)

Returns "database/sql.ErrNoRows" if no record is found.

func Insert

func Insert(ctx context.Context, db *sql.DB, file string, offset int64, whence int64) error