storage

Documentation

Index

• Variables
• type ClosableStorage
  • func NopCloser(storage interface{ ... }) ClosableStorage
• type DBStore
  • func NewDB(ctx context.Context, dialect string, dbURL string) (DBStore, error)
• type Dump
  • func (sd *Dump) Store(_ context.Context, table string, fields map[string]any) (map[string]any, error)
• type FileStore
  • func NewFileStore(rootDir string) *FileStore
  • func (fs *FileStore) Store(_ context.Context, table string, fields map[string]any) (map[string]any, error)

Variables

var ErrUnsupportedDatabase = errors.New("unsupported database schema")

Types

type ClosableStorage

type ClosableStorage interface {
	io.Closer
	Store(ctx context.Context, table string, fields map[string]any) (map[string]any, error)
}

func NopCloser

func NopCloser(storage interface {
	Store(ctx context.Context, table string, fields map[string]any) (map[string]any, error)
}) ClosableStorage

type DBStore

type DBStore interface {
	ClosableStorage
	Exec(ctx context.Context, query string) error
	Migrate(ctx context.Context, sourceDir string) error
}

func NewDB

func NewDB(ctx context.Context, dialect string, dbURL string) (DBStore, error)

type Dump

type Dump struct{}

Dump store just prints in JSON content of request.

func (*Dump) Store

func (sd *Dump) Store(_ context.Context, table string, fields map[string]any) (map[string]any, error)

type FileStore

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

FileStore stores each submission as single file in JSON with ULID + .json as name under directory, equal to table name. It DOES NOT escape table name AT ALL. Result set contains all source fields plus ID (string), equal to filename without extension.

func NewFileStore

func NewFileStore(rootDir string) *FileStore

func (*FileStore) Store

func (fs *FileStore) Store(_ context.Context, table string, fields map[string]any) (map[string]any, error)