query

Documentation

Index

• type QueryExecuter
• type Service
  • func NewService(docService *service.DefaultDocumentService, qExec QueryExecuter) *Service
  • func (s *Service) ExecQuery(ctx context.Context, query *model.QueryRequest) (*model.QueryResponse, error)
  • func (s *Service) ExecStoredQuery(ctx context.Context, userID, systemID, qualifiedQueryName string, ...) (*model.QueryResponse, error)
  • func (s *Service) GetByVersion(ctx context.Context, userID, systemID, name string, ...) (*model.StoredQuery, error)
  • func (s *Service) List(ctx context.Context, userID, systemID, qualifiedQueryName string) ([]*model.StoredQuery, error)
  • func (s *Service) Store(ctx context.Context, userID, systemID, reqID, qType, name, q string) (*model.StoredQuery, error)
  • func (s *Service) StoreVersion(ctx context.Context, userID, systemID, reqID, qType, name string, ...) (*model.StoredQuery, error)
  • func (s *Service) Validate(data []byte) bool

Types

type QueryExecuter

type QueryExecuter interface {
	//Validate(q string) error
	ExecQuery(ctx context.Context, query *model.QueryRequest) (*model.QueryResponse, error)
}

type Service

type Service struct {
	*service.DefaultDocumentService
	// contains filtered or unexported fields
}

func NewService

func NewService(docService *service.DefaultDocumentService, qExec QueryExecuter) *Service

func (*Service) ExecQuery

func (s *Service) ExecQuery(ctx context.Context, query *model.QueryRequest) (*model.QueryResponse, error)

func (*Service) ExecStoredQuery

func (s *Service) ExecStoredQuery(ctx context.Context, userID, systemID, qualifiedQueryName string, query *model.QueryRequest) (*model.QueryResponse, error)

func (*Service) GetByVersion

func (s *Service) GetByVersion(ctx context.Context, userID, systemID, name string, version *base.VersionTreeID) (*model.StoredQuery, error)

func (*Service) List

func (s *Service) List(ctx context.Context, userID, systemID, qualifiedQueryName string) ([]*model.StoredQuery, error)

func (*Service) Store

func (s *Service) Store(ctx context.Context, userID, systemID, reqID, qType, name, q string) (*model.StoredQuery, error)

func (*Service) StoreVersion

func (s *Service) StoreVersion(ctx context.Context, userID, systemID, reqID, qType, name string, version *base.VersionTreeID, q string) (*model.StoredQuery, error)

func (*Service) Validate

func (s *Service) Validate(data []byte) bool