afs

package

v0.2.2 Latest Latest Go to latest Published: Nov 17, 2022 License: Apache-2.0 Imports: 18 Imported by: 1

Details

View Source

const (
	NotExistStatus = iota
	InUseStatus
	ErrorStatus
	ExistsStatus
)

This section is empty.

This section is empty.

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

func NewCache(URL string, ttl time.Duration, signature string, stream *option.Stream, options ...interface{}) (*Cache, error)

NewCache creates new cache.

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

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

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

func (c *Cache) Close(ctx context.Context, e *cache.Entry) error

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

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

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

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

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

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

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(context.Context) cache.ScannerFn

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