membtree

package
v0.0.0-...-8371fe2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 17, 2016 License: MIT Imports: 13 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 (*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

Jump to

Keyboard shortcuts

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