storage

Documentation

Index

• Variables
• type SQLiteTableDetail
• type SQLiteTableProvider
• type SQLiteTableSummary
• type SqliteTableProvider
  • func NewSQLiteTableProvider(ctx nmq.Context, log *zap.Logger) *SqliteTableProvider
  • func (p *SqliteTableProvider) GetSQLiteTable(name string, page int, perPage int) (SQLiteTableDetail, error)
  • func (p *SqliteTableProvider) ListSQLiteTables() ([]SQLiteTableSummary, error)

Variables

var ErrSQLiteTableNotFound = errors.New("sqlite table not found")

Types

type SQLiteTableDetail

type SQLiteTableDetail struct {
	Name        string           `json:"name"`
	Type        string           `json:"type"`
	Columns     []string         `json:"columns"`
	PrimaryKeys []string         `json:"primaryKeys"`
	Rows        []map[string]any `json:"rows"`
	RowCount    int64            `json:"rowCount"`
	Page        int              `json:"page"`
	PerPage     int              `json:"perPage"`
}

type SQLiteTableProvider

type SQLiteTableProvider interface {
	ListSQLiteTables() ([]SQLiteTableSummary, error)
	GetSQLiteTable(name string, page int, perPage int) (SQLiteTableDetail, error)
}

type SQLiteTableSummary

type SQLiteTableSummary struct {
	Name         string   `json:"name"`
	Type         string   `json:"type"`
	RowCount     int64    `json:"rowCount"`
	ColumnCount  int      `json:"columnCount"`
	PrimaryKeys  []string `json:"primaryKeys"`
	PrimaryCount int      `json:"primaryCount"`
}

type SqliteTableProvider

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

func NewSQLiteTableProvider

func NewSQLiteTableProvider(ctx nmq.Context, log *zap.Logger) *SqliteTableProvider

func (*SqliteTableProvider) GetSQLiteTable

func (p *SqliteTableProvider) GetSQLiteTable(name string, page int, perPage int) (SQLiteTableDetail, error)

func (*SqliteTableProvider) ListSQLiteTables

func (p *SqliteTableProvider) ListSQLiteTables() ([]SQLiteTableSummary, error)