membtree

Documentation

Overview

Membtree implements a Datasource in-memory implemenation using the google btree.

Index

• type DriverItem
  • func (m *DriverItem) Less(than btree.Item) bool
• type Key
  • func NewKey(key uint64) *Key
  • func (m *Key) Key() driver.Value
  • func (m *Key) Less(than btree.Item) bool
• type StaticDataSource
  • func NewStaticData(name string) *StaticDataSource
  • func NewStaticDataSource(name string, indexedCol int, data [][]driver.Value, cols []string) *StaticDataSource
  • func NewStaticDataValue(name string, data interface{}) *StaticDataSource
  • func (m *StaticDataSource) CanSeek(sql *rel.SqlSelect) bool
  • func (m *StaticDataSource) Close() error
  • func (m *StaticDataSource) Columns() []string
  • func (m *StaticDataSource) CreateIterator() schema.Iterator
  • func (m *StaticDataSource) Delete(key driver.Value) (int, error)
  • func (m *StaticDataSource) DeleteExpression(p interface{}, where expr.Node) (int, error)
  • func (m *StaticDataSource) Get(key driver.Value) (schema.Message, error)
  • func (m *StaticDataSource) Length() int
  • func (m *StaticDataSource) MesgChan() <-chan schema.Message
  • func (m *StaticDataSource) MultiGet(keys []driver.Value) ([]schema.Message, error)
  • func (m *StaticDataSource) Next() schema.Message
  • func (m *StaticDataSource) Open(connInfo string) (schema.Conn, error)
  • func (m *StaticDataSource) Put(ctx context.Context, key schema.Key, row interface{}) (schema.Key, error)
  • func (m *StaticDataSource) PutMulti(ctx context.Context, keys []schema.Key, src interface{}) ([]schema.Key, error)
  • func (m *StaticDataSource) SetColumns(cols []string)
  • func (m *StaticDataSource) Table(table string) (*schema.Table, error)
  • func (m *StaticDataSource) Tables() []string

Types

type DriverItem

type DriverItem struct {
	*datasource.SqlDriverMessageMap
}

func (*DriverItem) Less

func (m *DriverItem) Less(than btree.Item) bool

type Key

type Key struct {
	Id uint64
}

func NewKey

func NewKey(key uint64) *Key

func (*Key) Key

func (m *Key) Key() driver.Value

func (*Key) Less

func (m *Key) Less(than btree.Item) bool

type StaticDataSource

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

Static DataSource, implements qlbridge DataSource to allow in memory native go data

to have a Schema and implement and be operated on by Sql Operations

Features - only a single column may (and must) be identified as the "Indexed" column - NOT threadsafe - each StaticDataSource = a single Table

func NewStaticData

func NewStaticData(name string) *StaticDataSource

func NewStaticDataSource

func NewStaticDataSource(name string, indexedCol int, data [][]driver.Value, cols []string) *StaticDataSource

func NewStaticDataValue

func NewStaticDataValue(name string, data interface{}) *StaticDataSource

StaticDataValue is used to create a static name=value pair that matches

DataSource interfaces

func (*StaticDataSource) CanSeek

func (m *StaticDataSource) CanSeek(sql *rel.SqlSelect) bool

interface for Seeker

func (*StaticDataSource) Close

func (m *StaticDataSource) Close() error

func (*StaticDataSource) Columns

func (m *StaticDataSource) Columns() []string

func (*StaticDataSource) CreateIterator

func (m *StaticDataSource) CreateIterator() schema.Iterator

func (*StaticDataSource) Delete

func (m *StaticDataSource) Delete(key driver.Value) (int, error)

Interface for Deletion

func (*StaticDataSource) DeleteExpression

func (m *StaticDataSource) DeleteExpression(p interface{}, where expr.Node) (int, error)

DeleteExpression Delete using a Where Expression

func (*StaticDataSource) Get

func (m *StaticDataSource) Get(key driver.Value) (schema.Message, error)

func (*StaticDataSource) Length

func (m *StaticDataSource) Length() int

func (*StaticDataSource) MesgChan

func (m *StaticDataSource) MesgChan() <-chan schema.Message

func (*StaticDataSource) MultiGet

func (m *StaticDataSource) MultiGet(keys []driver.Value) ([]schema.Message, error)

func (*StaticDataSource) Next

func (m *StaticDataSource) Next() schema.Message

func (*StaticDataSource) Open

func (m *StaticDataSource) Open(connInfo string) (schema.Conn, error)

func (*StaticDataSource) Put

func (m *StaticDataSource) Put(ctx context.Context, key schema.Key, row interface{}) (schema.Key, error)

interface for Upsert.Put()

func (*StaticDataSource) PutMulti

func (m *StaticDataSource) PutMulti(ctx context.Context, keys []schema.Key, src interface{}) ([]schema.Key, error)

func (*StaticDataSource) SetColumns

func (m *StaticDataSource) SetColumns(cols []string)

func (*StaticDataSource) Table

func (m *StaticDataSource) Table(table string) (*schema.Table, error)

func (*StaticDataSource) Tables

func (m *StaticDataSource) Tables() []string