search

Documentation

Index

• type Model
• type Search
  • func NewSearch(sp *api.SP, logger zerolog.Logger) *Search
  • func (s *Search) GetDestTable(searchName string, spec Spec) (*schema.Table, error)
  • func (s *Search) Sync(ctx context.Context, metrics *source.TableClientMetrics, ...) error
• type Spec
  • func (*Spec) GetAlias(searchName string) string
  • func (s *Spec) SetDefault()
  • func (s *Spec) Validate() error

Types

type Model

type Model struct {
	Spec Spec
}

type Search

type Search struct {
	TablesMap map[string]Model // normalized table name to table metadata (map[CQ Table Name]Model)
	// contains filtered or unexported fields
}

func NewSearch

func NewSearch(sp *api.SP, logger zerolog.Logger) *Search

func (*Search) GetDestTable

func (s *Search) GetDestTable(searchName string, spec Spec) (*schema.Table, error)

func (*Search) Sync

func (s *Search) Sync(ctx context.Context, metrics *source.TableClientMetrics, res chan<- *schema.Resource, table *schema.Table) error

type Spec

type Spec struct {
	QueryText        string   `json:"query_text"`        // Required
	TrimDuplicates   bool     `json:"trim_duplicates"`   // Optional, default is false
	SourceID         string   `json:"source_id"`         // Optional, default is empty
	SelectProperties []string `json:"select_properties"` // Optional, default is empty array
	// contains filtered or unexported fields
}

Spec is the configuration for Search source

func (*Spec) GetAlias

func (*Spec) GetAlias(searchName string) string

GetAlias returns an alias for the list

func (*Spec) SetDefault

func (s *Spec) SetDefault()

SetDefault sets default values for list spec

func (*Spec) Validate

func (s *Spec) Validate() error

Validate validates search spec