search

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

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

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

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

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

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

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

type Response struct {
	api.Response

	Status string
}

type ResultRow struct {
	Group []string
	Rows  []*Row
}

type Row struct {
	CreatedAt *internal.Timestamp
	UpdatedAt *internal.Timestamp
	Document  []byte
	Match     *api.Match
}

type Runner interface {
	Run(ctx context.Context, tenant *metadata.Tenant) (Response, error)
}

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

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

type Session interface {
	// Execute executes the request using the query runner
	Execute(ctx context.Context, runner Runner) (Response, error)

	// TxExecute executes in a fdb transaction. This is mainly used to manage search indexes. This metadata
	// is stored in fdb as part of project metadata and that modification is a transactional operation. This API
	// is automatically bumping up the metadata version as this should only be used for metadata operation.
	TxExecute(ctx context.Context, runner TxRunner, option SessionOptions) (Response, error)
}

type SessionManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type SessionOptions struct {
	IncVersion          bool
	DoNotReloadMetadata bool
}

type Streaming interface {
	api.Search_SearchServer
}

type TxRunner interface {
	Run(ctx context.Context, tx transaction.Tx, tenant *metadata.Tenant) (Response, error)
}

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