embed

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Oct 6, 2020 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Directory string
)

Functions

func Build

func Build(json string, timestamp string, keys []string) error

func BuildFromFiles

func BuildFromFiles(files []string, timestamp string, keys []string) (int64, error)

func Query

func Query(ctx context.Context, stmt *ssql.Statement) []byte

func Verify

func Verify() (func(), error)

Types

type WaveStream

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

func NewWave

func NewWave(dir, ts string, keys []string) *WaveStream

func (*WaveStream) Close

func (s *WaveStream) Close()

func (*WaveStream) OnNewDocument

func (s *WaveStream) OnNewDocument(json []byte) error

func (*WaveStream) Query

func (s *WaveStream) Query(ctx context.Context, query string) ([]byte, error)

Jump to

Keyboard shortcuts

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