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{}) (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 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

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

type ParmetrizedQuery struct {
	By      string
	SQL     string
	Ordered bool //SQL uses order by indexby column
	Args    []interface{}
	In      []interface{}
	Offset  int
	Limit   int
	OnSkip  func(values []interface{}) error
	// contains filtered or unexported fields
}

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
	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 WriteCloser struct {
	// contains filtered or unexported fields
}

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

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