controlledread

Documentation

Index

• type Service
  • func NewService(datasources datasourceReader, manager executorPool, secret []byte, ...) (*Service, error)
  • func (service *Service) Close() error
  • func (service *Service) Discover(ctx context.Context, username, datasourceID string, ...) (discovery.ScanResult, error)
  • func (service *Service) ListColumns(ctx context.Context, datasourceID string, tables []discovery.TableRef) ([]discovery.ColumnMeta, error)
  • func (service *Service) QueryColumns(ctx context.Context, datasourceID string, table discovery.TableRef, ...) (discovery.SampleBatch, error)

Types

type Service

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

Service is the server-internal, fail-closed discovery reader. It implements discovery's typed ports and never accepts caller-provided SQL.

func NewService

func NewService(datasources datasourceReader, manager executorPool, secret []byte, limiter rules.RateLimiter) (*Service, error)

func (*Service) Close

func (service *Service) Close() error

Close releases the read-only pools owned by the service.

func (*Service) Discover

func (service *Service) Discover(ctx context.Context, username, datasourceID string, request discovery.ScanRequest) (discovery.ScanResult, error)

Discover applies request-level admission and a fixed overall deadline, then delegates pure classification and sampling orchestration to discovery.Scanner.

func (*Service) ListColumns

func (service *Service) ListColumns(ctx context.Context, datasourceID string, tables []discovery.TableRef) ([]discovery.ColumnMeta, error)

func (*Service) QueryColumns

func (service *Service) QueryColumns(ctx context.Context, datasourceID string, table discovery.TableRef, columns []discovery.ColumnRef, limit int) (discovery.SampleBatch, error)