query

Documentation

Index

• type Outcome
• type Service
  • func (s *Service) FetchPage(cursor string) (result.QueryPage, error)
  • func (s *Service) Run(ctx context.Context, conn config.Connection, sql string, limit int, ...) (Outcome, error)

Types

type Outcome

type Outcome struct {
	Result       any    `json:"result"`
	NextCursor   string `json:"next_cursor,omitempty"`
	RowsAffected int64  `json:"rows_affected,omitempty"`
}

type Service

type Service struct {
	Registry  *adapter.Registry
	PageStore *result.PageStore
	Logger    *activity.Logger
}

func (*Service) FetchPage

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

func (*Service) Run

func (s *Service) Run(ctx context.Context, conn config.Connection, sql string, limit int, meta activity.CaptureMeta) (Outcome, error)