database

Documentation

Index

• Variables
• func All() []config.Database
• func DetectDialectFromPod(pod v1.Pod) (config.Database, error)
• func DetectFormat(db config.DatabaseFile, path string) sqlformat.Format
• func GetExtension(db config.DatabaseFile, format sqlformat.Format) string
• func Names() []string
• func NamesForInterface[T any]() []string
• func New(name string) (config.Database, error)
• type DetectResult
  • func DetectDialect(ctx context.Context, client kubernetes.KubeClient) (DetectResult, error)

Variables

var ErrDatabaseNotFound = errors.New("could not detect a database")

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

Functions

func All

func All() []config.Database

func DetectDialectFromPod

func DetectDialectFromPod(pod v1.Pod) (config.Database, error)

func DetectFormat

func DetectFormat(db config.DatabaseFile, path string) sqlformat.Format

func GetExtension

func GetExtension(db config.DatabaseFile, format sqlformat.Format) string

func Names

func Names() []string

func NamesForInterface

func NamesForInterface[T any]() []string

func New

func New(name string) (config.Database, error)

Types

type DetectResult

type DetectResult map[config.Database][]v1.Pod

func DetectDialect

func DetectDialect(ctx context.Context, client kubernetes.KubeClient) (DetectResult, error)