package test

import "go.cryptoscope.co/margaret/indexes/test"

Index ¶

• Variables
• func RegisterSeqSetterIndex(name string, f NewSeqSetterIndexFunc)
• func RegisterSetterIndex(name string, f NewSetterIndexFunc)
• func RunSeqSetterIndexTests(t *testing.T)
• func RunSetterIndexTests(t *testing.T)
• func RunSinkIndexTests(t *testing.T)
• func TestSeqSetterIndex(newIdx NewSeqSetterIndexFunc) func(*testing.T)
• func TestSeqSetterIndexSequential(newIdx NewSeqSetterIndexFunc) func(*testing.T)
• func TestSetterIndex(newIdx NewSetterIndexFunc) func(*testing.T)
• func TestSetterIndexObservable(newIdx NewSetterIndexFunc) func(*testing.T)
• func TestSetterIndexSequential(newIdx NewSetterIndexFunc) func(*testing.T)
• func TestSinkIndex(newLog mtest.NewLogFunc, newIdx NewSeqSetterIndexFunc) func(*testing.T)
• func TestSinkIndexWithBreak(newLog mtest.NewLogFunc, newIdx NewSeqSetterIndexFunc) func(*testing.T)
• type NewSeqSetterIndexFunc
• type NewSetterIndexFunc
• type NewSinkIndexFunc

Variables ¶

var (
	NewSetterIndexFuncs    map[string]NewSetterIndexFunc
	NewSeqSetterIndexFuncs map[string]NewSeqSetterIndexFunc
)

Functions ¶

func RegisterSeqSetterIndex ¶

func RegisterSeqSetterIndex(name string, f NewSeqSetterIndexFunc)

func RegisterSetterIndex ¶

func RegisterSetterIndex(name string, f NewSetterIndexFunc)

func RunSeqSetterIndexTests ¶

func RunSeqSetterIndexTests(t *testing.T)

func RunSetterIndexTests ¶

func RunSetterIndexTests(t *testing.T)

func RunSinkIndexTests ¶

func RunSinkIndexTests(t *testing.T)

func TestSeqSetterIndex ¶

func TestSeqSetterIndex(newIdx NewSeqSetterIndexFunc) func(*testing.T)

func TestSeqSetterIndexSequential ¶

func TestSeqSetterIndexSequential(newIdx NewSeqSetterIndexFunc) func(*testing.T)

func TestSetterIndex ¶

func TestSetterIndex(newIdx NewSetterIndexFunc) func(*testing.T)

func TestSetterIndexObservable ¶

func TestSetterIndexObservable(newIdx NewSetterIndexFunc) func(*testing.T)

func TestSetterIndexSequential ¶

func TestSetterIndexSequential(newIdx NewSetterIndexFunc) func(*testing.T)

func TestSinkIndex ¶

func TestSinkIndex(newLog mtest.NewLogFunc, newIdx NewSeqSetterIndexFunc) func(*testing.T)

func TestSinkIndexWithBreak ¶

func TestSinkIndexWithBreak(newLog mtest.NewLogFunc, newIdx NewSeqSetterIndexFunc) func(*testing.T)

Types ¶

type NewSeqSetterIndexFunc ¶

type NewSeqSetterIndexFunc func(name string, tipe interface{}) (indexes.SeqSetterIndex, error)

type NewSetterIndexFunc ¶

type NewSetterIndexFunc func(name string, tipe interface{}) (indexes.SetterIndex, error)

type NewSinkIndexFunc ¶

type NewSinkIndexFunc func(name string, tipe interface{}, f indexes.StreamProcFunc) (indexes.SinkIndex, error)

Source Files ¶

registry.go seqsetidx.go setidx.go sinkindex.go

Directories ¶