aerospike

package

v0.12.0 Latest Latest Go to latest Published: Nov 20, 2023 License: Apache-2.0 Imports: 25 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/viant/sqlx

Links

Open Source Insights

Documentation ¶

Index ¶

type Cache
- func New(namespace string, setName string, client *as.Client, timeToLiveInSec uint32, ...) (*Cache, error)
- func (a *Cache) AddValues(ctx context.Context, entry *cache.Entry, values []interface{}) error
- func (a *Cache) AsSource(ctx context.Context, entry *cache.Entry) (cache.Source, error)
- func (a *Cache) AssignRows(entry *cache.Entry, rows *sql.Rows) error
- func (a *Cache) Close(ctx context.Context, entry *cache.Entry) error
- func (a *Cache) Delete(ctx context.Context, entry *cache.Entry) error
- func (a *Cache) Get(ctx context.Context, SQL string, args []interface{}, options ...interface{}) (*cache.Entry, error)
- func (a *Cache) IndexBy(ctx context.Context, db *sql.DB, column, SQL string, args []interface{}) (int, error)
- func (a *Cache) Rollback(ctx context.Context, entry *cache.Entry) error
- func (a *Cache) UpdateType(ctx context.Context, entry *cache.Entry, args []interface{}) (bool, error)
type Errors
- func (e *Errors) Add(err error)
- func (e *Errors) Err() error
type FailureHandler
- func NewFailureHandler(limit int64, resetAfter *time.Duration) *FailureHandler
- func (f *FailureHandler) Close() error
- func (f *FailureHandler) HandleFailure()
- func (f *FailureHandler) HandleSuccess()
- func (f *FailureHandler) IsProbing() bool
type IndexSource
- func NewIndexSource(column string, ordered bool, fields []*cache.Field, dest chan *cache.Indexed) (IndexSource, error)
type MultiReader
- func NewMultiReader(matcher *cache.ParmetrizedQuery) *MultiReader
- func (m *MultiReader) AddReader(reader *Reader)
- func (m *MultiReader) Close() error
- func (m *MultiReader) Read(p []byte) (n int, err error)
- func (m *MultiReader) ReadLine() (line []byte, prefix bool, err error)
type OrderedSource
- func NewOrderedSource(dest chan *cache.Indexed, index int) *OrderedSource
- func (o *OrderedSource) Close() error
- func (o *OrderedSource) ColumnIndex() int
- func (o *OrderedSource) Index(value interface{}) *cache.Indexed
type Placeholders
- func NewPlaceholders(columnIndex int, fields []*cache.Field) *Placeholders
- func (p *Placeholders) ColumnValue() (interface{}, bool)
- func (p *Placeholders) CreatePlaceholderAt(i int)
- func (p *Placeholders) ScanPlaceholders() []interface{}
- func (p *Placeholders) Values() []interface{}
type Reader
- func (r *Reader) Close() error
- func (r *Reader) Read(b []byte) (int, error)
- func (r *Reader) ReadLine() (line []byte, prefix bool, err error)
type RecordMatched
type SingleSource
- func NewSingleSource(dest chan *cache.Indexed) *SingleSource
- func (s *SingleSource) Close() error
- func (s *SingleSource) ColumnIndex() int
- func (s *SingleSource) Index(value interface{}) *cache.Indexed
type Source
- func (s *Source) CheckType(ctx context.Context, values []interface{}) (bool, error)
- func (s *Source) Close(ctx context.Context) error
- func (s *Source) ConvertColumns() ([]io.Column, error)
- func (s *Source) Next() bool
- func (s *Source) Rollback(ctx context.Context) error
- func (s *Source) Scanner(ctx context.Context) cache.ScannerFn
- func (s *Source) XTypes() []*xunsafe.Type
type TimeoutConfig
- func (t *TimeoutConfig) Init()
type UnorderedSource
- func NewUnorderedSource(dest chan *cache.Indexed, index int) *UnorderedSource
- func (u *UnorderedSource) Close() error
- func (u *UnorderedSource) ColumnIndex() int
- func (u *UnorderedSource) Index(columnValue interface{}) *cache.Indexed
type Writer
- func (w *Writer) Close() error
- func (w *Writer) Flush() error
- func (w *Writer) Write(b []byte) (int, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Cache ¶

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

func New ¶

func New(namespace string, setName string, client *as.Client, timeToLiveInSec uint32, options ...interface{}) (*Cache, error)

func (*Cache) AddValues ¶

func (a *Cache) AddValues(ctx context.Context, entry *cache.Entry, values []interface{}) error

func (*Cache) AsSource ¶

func (a *Cache) AsSource(ctx context.Context, entry *cache.Entry) (cache.Source, error)

func (*Cache) AssignRows ¶

func (a *Cache) AssignRows(entry *cache.Entry, rows *sql.Rows) error

func (*Cache) Close ¶

func (a *Cache) Close(ctx context.Context, entry *cache.Entry) error

func (*Cache) Delete ¶

func (a *Cache) Delete(ctx context.Context, entry *cache.Entry) error

func (*Cache) Get ¶

func (a *Cache) Get(ctx context.Context, SQL string, args []interface{}, options ...interface{}) (*cache.Entry, error)

func (*Cache) IndexBy ¶

func (a *Cache) IndexBy(ctx context.Context, db *sql.DB, column, SQL string, args []interface{}) (int, error)

func (*Cache) Rollback ¶

func (a *Cache) Rollback(ctx context.Context, entry *cache.Entry) error

func (*Cache) UpdateType ¶

func (a *Cache) UpdateType(ctx context.Context, entry *cache.Entry, args []interface{}) (bool, error)

type Errors ¶

type Errors struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Errors) Add ¶

func (e *Errors) Add(err error)

func (*Errors) Err ¶

func (e *Errors) Err() error

type FailureHandler ¶ added in v0.2.0

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

func NewFailureHandler ¶ added in v0.2.0

func NewFailureHandler(limit int64, resetAfter *time.Duration) *FailureHandler

func (*FailureHandler) Close ¶ added in v0.2.0

func (f *FailureHandler) Close() error

func (*FailureHandler) HandleFailure ¶ added in v0.2.0

func (f *FailureHandler) HandleFailure()

func (*FailureHandler) HandleSuccess ¶ added in v0.2.0

func (f *FailureHandler) HandleSuccess()

func (*FailureHandler) IsProbing ¶ added in v0.2.0

func (f *FailureHandler) IsProbing() bool

type IndexSource ¶

type IndexSource interface {
	Close() error
	Index(value interface{}) *cache.Indexed
	ColumnIndex() int
}

func NewIndexSource ¶

func NewIndexSource(column string, ordered bool, fields []*cache.Field, dest chan *cache.Indexed) (IndexSource, error)

type MultiReader ¶

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

func NewMultiReader ¶

func NewMultiReader(matcher *cache.ParmetrizedQuery) *MultiReader

func (*MultiReader) AddReader ¶

func (m *MultiReader) AddReader(reader *Reader)

func (*MultiReader) Close ¶

func (m *MultiReader) Close() error

func (*MultiReader) Read ¶

func (m *MultiReader) Read(p []byte) (n int, err error)

func (*MultiReader) ReadLine ¶

func (m *MultiReader) ReadLine() (line []byte, prefix bool, err error)

type OrderedSource ¶

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

func NewOrderedSource ¶

func NewOrderedSource(dest chan *cache.Indexed, index int) *OrderedSource

func (*OrderedSource) Close ¶

func (o *OrderedSource) Close() error

func (*OrderedSource) ColumnIndex ¶

func (o *OrderedSource) ColumnIndex() int

func (*OrderedSource) Index ¶

func (o *OrderedSource) Index(value interface{}) *cache.Indexed

type Placeholders ¶

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

func NewPlaceholders ¶

func NewPlaceholders(columnIndex int, fields []*cache.Field) *Placeholders

func (*Placeholders) ColumnValue ¶

func (p *Placeholders) ColumnValue() (interface{}, bool)

func (*Placeholders) CreatePlaceholderAt ¶

func (p *Placeholders) CreatePlaceholderAt(i int)

func (*Placeholders) ScanPlaceholders ¶

func (p *Placeholders) ScanPlaceholders() []interface{}

func (*Placeholders) Values ¶

func (p *Placeholders) Values() []interface{}

type Reader ¶

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

func (*Reader) Close ¶

func (r *Reader) Close() error

func (*Reader) Read ¶

func (r *Reader) Read(b []byte) (int, error)

func (*Reader) ReadLine ¶

func (r *Reader) ReadLine() (line []byte, prefix bool, err error)

type RecordMatched ¶

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

type SingleSource ¶

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

func NewSingleSource ¶

func NewSingleSource(dest chan *cache.Indexed) *SingleSource

func (*SingleSource) Close ¶

func (s *SingleSource) Close() error

func (*SingleSource) ColumnIndex ¶

func (s *SingleSource) ColumnIndex() int

func (*SingleSource) Index ¶

func (s *SingleSource) Index(value interface{}) *cache.Indexed

type Source ¶

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

func (*Source) CheckType ¶

func (s *Source) CheckType(ctx context.Context, values []interface{}) (bool, error)

func (*Source) Close ¶

func (s *Source) Close(ctx context.Context) error

func (*Source) ConvertColumns ¶

func (s *Source) ConvertColumns() ([]io.Column, error)

func (*Source) Next ¶

func (s *Source) Next() bool

func (*Source) Rollback ¶

func (s *Source) Rollback(ctx context.Context) error

func (*Source) Scanner ¶

func (s *Source) Scanner(ctx context.Context) cache.ScannerFn

func (*Source) XTypes ¶

func (s *Source) XTypes() []*xunsafe.Type

type TimeoutConfig ¶

type TimeoutConfig struct {
	MaxRetries            int
	TotalTimeoutMs        int
	SleepBetweenRetriesMs int
}

func (*TimeoutConfig) Init ¶ added in v0.2.0

func (t *TimeoutConfig) Init()

type UnorderedSource ¶

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

func NewUnorderedSource ¶

func NewUnorderedSource(dest chan *cache.Indexed, index int) *UnorderedSource

func (*UnorderedSource) Close ¶

func (u *UnorderedSource) Close() error

func (*UnorderedSource) ColumnIndex ¶

func (u *UnorderedSource) ColumnIndex() int

func (*UnorderedSource) Index ¶

func (u *UnorderedSource) Index(columnValue interface{}) *cache.Indexed

type Writer ¶

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

func (*Writer) Close ¶

func (w *Writer) Close() error

func (*Writer) Flush ¶

func (w *Writer) Flush() error

func (*Writer) Write ¶

func (w *Writer) Write(b []byte) (int, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL