core

Documentation

Index

• func NewRegistry() *adapter.Registry
• type Services
  • func NewServices(store *config.Store, timeout time.Duration) *Services
  • func (s *Services) Connections() []config.Connection
  • func (s *Services) FetchPage(cursor string) (result.QueryPage, error)
  • func (s *Services) FindConnection(name string) (config.Connection, bool, error)
  • func (s *Services) RunQuery(ctx context.Context, name string, sqlText string, limit int) (config.Connection, query.Outcome, error)
  • func (s *Services) RunQueryConnection(ctx context.Context, conn config.Connection, sqlText string, limit int) (query.Outcome, error)
  • func (s *Services) SchemaTree(ctx context.Context, name string) (config.Connection, any, error)
  • func (s *Services) TestConnection(ctx context.Context, name string) (config.Connection, error)

Functions

func NewRegistry

func NewRegistry() *adapter.Registry

Types

type Services

type Services struct {
	Store     *config.Store
	Registry  *adapter.Registry
	PageStore *result.PageStore
	Timeout   time.Duration
}

func NewServices

func NewServices(store *config.Store, timeout time.Duration) *Services

func (*Services) Connections

func (s *Services) Connections() []config.Connection

func (*Services) FetchPage

func (s *Services) FetchPage(cursor string) (result.QueryPage, error)

func (*Services) FindConnection

func (s *Services) FindConnection(name string) (config.Connection, bool, error)

func (*Services) RunQuery

func (s *Services) RunQuery(ctx context.Context, name string, sqlText string, limit int) (config.Connection, query.Outcome, error)

func (*Services) RunQueryConnection

func (s *Services) RunQueryConnection(ctx context.Context, conn config.Connection, sqlText string, limit int) (query.Outcome, error)

func (*Services) SchemaTree

func (s *Services) SchemaTree(ctx context.Context, name string) (config.Connection, any, error)

func (*Services) TestConnection

func (s *Services) TestConnection(ctx context.Context, name string) (config.Connection, error)