cache

type AllowSmart bool

type Cache interface {
	AsSource(ctx context.Context, entry *Entry) (Source, error)
	AddValues(ctx context.Context, entry *Entry, values []interface{}) error
	Get(ctx context.Context, sql string, args []interface{}, options ...interface{}) (*Entry, error)
	AssignRows(entry *Entry, rows *sql.Rows) error
	UpdateType(ctx context.Context, entry *Entry, args []interface{}) (bool, error)
	Close(ctx context.Context, entry *Entry) error
	Delete(todo context.Context, entry *Entry) error
	Rollback(ctx context.Context, entry *Entry) error
	IndexBy(ctx context.Context, db *sql.DB, column, SQL string, args []interface{}, options ...interface{}) (int, error)
}

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

type Decoder struct {
	Data []byte
	// contains filtered or unexported fields
}

type DecoderFn func(decoder *gojay.Decoder) (interface{}, error)

type Entry struct {
	Meta        Meta
	Data        []byte // Entry is used as Iterator, Data is last streamed line.
	Id          string
	WriteCloser *WriteCloser
	ReadCloser  *ReadCloser
	Refresh     bool

	RowAdded bool
	// contains filtered or unexported fields
}

type ErrorType string

type Field struct {
	ColumnName      string
	ColumnLength    int64
	ColumnPrecision int64
	ColumnScale     int64
	ColumnScanType  string

	ColumnNullable     bool
	ColumnDatabaseName string
	ColumnTag          *io.Tag
	// contains filtered or unexported fields
}

type IndexByResult struct {
	GroupsWritten int
	WarmupKey     string
	MarkerKey     string
}

type IndexProgress struct {
	View    string
	Dataset string
	Case    string
}

type IndexProgressEvent struct {
	View    string
	Dataset string
	Case    string
	Column  string
	Rows    int
	Elapsed time.Duration
	Done    bool
}

type IndexProgressFn func(event *IndexProgressEvent)

type Indexed struct {
	ColumnValue interface{}
	Data        *bytes.Buffer
	Column      string
}

type LineReader interface {
	ReadLine() (line []byte, prefix bool, err error)
}

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

type Meta struct {
	SQL          string
	Args         []byte
	Type         []string
	Signature    string
	ExpiryTimeMs int
	Fields       []*Field
	StoredFields []ProjectionField
	// ProjectedIndexes maps requested result columns to stored cached row ordinals.
	// It is runtime-only metadata used when reading a warmup superset as a subset.
	ProjectedIndexes []int `json:"-" yaml:"-"`

	URL string `json:"-" yaml:"-"`
}

type ParmetrizedQuery struct {
	By           string
	SQL          string
	IdentitySQL  string
	Ordered      bool //SQL uses order by indexby column
	Args         []interface{}
	IdentityArgs []interface{}
	StoredFields []ProjectionField
	// RequestedFields describes the caller's logical projection for warmup subset reads.
	RequestedFields []ProjectionField
	In              []interface{}
	Offset          int
	Limit           int
	OnSkip          func(values []interface{}) error
	// contains filtered or unexported fields
}

type ProjectionField struct {
	Name         string   `json:",omitempty"`
	FieldName    string   `json:",omitempty"`
	ColumnName   string   `json:",omitempty"`
	Source       string   `json:",omitempty"`
	DimensionKey string   `json:",omitempty"`
	MeasureKey   string   `json:",omitempty"`
	Lookup       []string `json:",omitempty"`
}

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

type Reader interface {
	io.Reader
	LineReader
}

type Recorder interface {
	AddValues(values []interface{})
	ScanValues(values []interface{})
}

type Refresh bool

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

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

type ScannerFn func(args ...interface{}) error

type Source interface {
	ConvertColumns() ([]io.Column, error)
	Scanner(context.Context) ScannerFn
	XTypes() []*xunsafe.Type
	CheckType(ctx context.Context, values []interface{}) (bool, error)
	Close(ctx context.Context) error
	Next() bool
	Rollback(ctx context.Context) error
	Err() error
}

type Stats struct {
	Type           Type
	RecordsCounter int
	Key            string
	WarmupKey      string
	MarkerKey      string
	Dataset        string
	Namespace      string
	FoundWarmup    bool             `json:",omitempty"`
	FoundLazy      bool             `json:",omitempty"`
	ErrorType      string           `json:",omitempty"`
	ErrorCode      types.ResultCode `json:",omitempty"`
	ExpiryTime     *time.Time
}

type Type string

type TypeMismatch struct {
	Index                int
	DestinationType      string
	NormalizedDestType   string
	CachedType           string
	NormalizedCachedType string
	Reason               string
}

type WarmupIdentityMeta struct {
	Source string
	Detail string
}

type WarmupIndexer interface {
	IndexByWithResult(ctx context.Context, db *sql.DB, column, SQL string, args []interface{}, options ...interface{}) (*IndexByResult, error)
}

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

type Writer interface {
	io.Writer
	Flush() error
}

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