tdb

README

traildb-go

Documentation

Index

• Constants
• Variables
• func FreeEventFilter(filter *EventFilter)
• func FreeMultiCursor(mcursor *MultiCursor)
• func GetTrail(trail *Trail, trail_id uint64) error
• type Event
  • func (evt *Event) Get(index int) string
  • func (evt *Event) Print()
  • func (evt *Event) ToMap() map[string]string
  • func (evt *Event) ToStruct(data interface{}) interface{}
• type EventFilter
• type FilterTerm
• type MultiCursor
  • func NewMultiCursor(cursors []*Trail) (*MultiCursor, error)
  • func (mcursor *MultiCursor) NextBatch() []*Event
  • func (mcursor *MultiCursor) Reset()
• type Trail
  • func NewCursor(db *TrailDB) (*Trail, error)
  • func NewTrail(db *TrailDB, trail_id uint64) (*Trail, error)
  • func (trail *Trail) Close()
  • func (trail *Trail) NextEvent() *Event
  • func (trail *Trail) NextTimestamp() (uint64, bool)
  • func (trail *Trail) SetFilter(filter *EventFilter) error
  • func (trail *Trail) UnsetFilter()
• type TrailDB
  • func Open(s string) (*TrailDB, error)
  • func (db *TrailDB) Close()
  • func (db *TrailDB) FindTrails(filters map[string]string) ([]*Trail, error)
  • func (db *TrailDB) GetField(field_name string) (uint64, error)
  • func (db *TrailDB) GetFieldNames() []string
  • func (db *TrailDB) GetTrailID(cookie string) (uint64, error)
  • func (db *TrailDB) GetUUID(trail_id uint64) string
  • func (db *TrailDB) NewEventFilter(query [][]FilterTerm) *EventFilter
  • func (db *TrailDB) SetFilter(filter *EventFilter) error
  • func (db *TrailDB) Version() uint64
• type TrailDBConstructor
  • func NewTrailDBConstructor(path string, ofields ...string) (*TrailDBConstructor, error)
  • func (cons *TrailDBConstructor) Add(cookie string, timestamp int64, values []string) error
  • func (cons *TrailDBConstructor) Append(db *TrailDB) error
  • func (cons *TrailDBConstructor) Close()
  • func (cons *TrailDBConstructor) Finalize() error
  • func (cons *TrailDBConstructor) GetOpt(key int, value int) (int, error)
  • func (cons *TrailDBConstructor) SetOpt(key int, value int) error

Constants

const (
	TDB_OPT_ONLY_DIFF_ITEMS          = 100
	TDB_OPT_EVENT_FILTER             = 101
	TDB_OPT_CURSOR_EVENT_BUFFER_SIZE = 102
	TDB_OPT_CONS_OUTPUT_FORMAT       = 1001
	TDB_OPT_CONS_NO_BIGRAMS          = 1002
)

tdb_opt_key

Variables

var MULTI_CURSOR_BUFFER_SIZE = 1000

NOTE: MULTI_CURSOR_BUFFER_SIZE must be less than (1 << 30) see MultiCursor.NextBatch for the reason

Functions

func FreeEventFilter

func FreeEventFilter(filter *EventFilter)

func FreeMultiCursor

func FreeMultiCursor(mcursor *MultiCursor)

func GetTrail

func GetTrail(trail *Trail, trail_id uint64) error

Types

type Event

type Event struct {
	Timestamp uint64
	Fields    map[string]string
	// contains filtered or unexported fields
}

func (*Event) Get

func (evt *Event) Get(index int) string

func (*Event) Print

func (evt *Event) Print()

func (*Event) ToMap

func (evt *Event) ToMap() map[string]string

func (*Event) ToStruct

func (evt *Event) ToStruct(data interface{}) interface{}

type EventFilter

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

type FilterTerm

type FilterTerm struct {
	IsNegative bool
	Value      string
	Field      string
}

type MultiCursor

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

func NewMultiCursor

func NewMultiCursor(cursors []*Trail) (*MultiCursor, error)

func (*MultiCursor) NextBatch

func (mcursor *MultiCursor) NextBatch() []*Event

func (*MultiCursor) Reset

func (mcursor *MultiCursor) Reset()

type Trail

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

func NewCursor

func NewCursor(db *TrailDB) (*Trail, error)

func NewTrail

func NewTrail(db *TrailDB, trail_id uint64) (*Trail, error)

func (*Trail) Close

func (trail *Trail) Close()

func (*Trail) NextEvent

func (trail *Trail) NextEvent() *Event

func (*Trail) NextTimestamp

func (trail *Trail) NextTimestamp() (uint64, bool)

func (*Trail) SetFilter

func (trail *Trail) SetFilter(filter *EventFilter) error

func (*Trail) UnsetFilter

func (trail *Trail) UnsetFilter()

type TrailDB

type TrailDB struct {
	NumTrails uint64
	NumFields uint64
	NumEvents uint64
	// contains filtered or unexported fields
}

func Open

func Open(s string) (*TrailDB, error)

func (*TrailDB) Close

func (db *TrailDB) Close()

func (*TrailDB) FindTrails

func (db *TrailDB) FindTrails(filters map[string]string) ([]*Trail, error)

func (*TrailDB) GetField

func (db *TrailDB) GetField(field_name string) (uint64, error)

func (*TrailDB) GetFieldNames

func (db *TrailDB) GetFieldNames() []string

func (*TrailDB) GetTrailID

func (db *TrailDB) GetTrailID(cookie string) (uint64, error)

func (*TrailDB) GetUUID

func (db *TrailDB) GetUUID(trail_id uint64) string

func (*TrailDB) NewEventFilter

func (db *TrailDB) NewEventFilter(query [][]FilterTerm) *EventFilter

func (*TrailDB) SetFilter

func (db *TrailDB) SetFilter(filter *EventFilter) error

func (*TrailDB) Version

func (db *TrailDB) Version() uint64

type TrailDBConstructor

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

func NewTrailDBConstructor

func NewTrailDBConstructor(path string, ofields ...string) (*TrailDBConstructor, error)

func (*TrailDBConstructor) Add

func (cons *TrailDBConstructor) Add(cookie string, timestamp int64, values []string) error

func (*TrailDBConstructor) Append

func (cons *TrailDBConstructor) Append(db *TrailDB) error

func (*TrailDBConstructor) Close

func (cons *TrailDBConstructor) Close()

func (*TrailDBConstructor) Finalize

func (cons *TrailDBConstructor) Finalize() error

func (*TrailDBConstructor) GetOpt

func (cons *TrailDBConstructor) GetOpt(key int, value int) (int, error)

func (*TrailDBConstructor) SetOpt

func (cons *TrailDBConstructor) SetOpt(key int, value int) error