state

Documentation

Overview

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

Index

• Constants
• func CreateTableLogFileSeekInfo(ctx context.Context, db *sql.DB) error
• func GetLogFileSeekInfo(ctx context.Context, db *sql.DB, file string) (int64, int64, error)
• func InsertLogFileSeekInfo(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 TableNameLogFileSeekInfo = "components_query_log_seek_info"

Functions

func CreateTableLogFileSeekInfo

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

func GetLogFileSeekInfo

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

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

func InsertLogFileSeekInfo

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