rpcserver

Documentation

Index

• func PrepareServer(db DB, l net.Listener, opts *Opts) (func() error, func())
• type DB
• type Opts

Functions

func PrepareServer

func PrepareServer(db DB, l net.Listener, opts *Opts) (func() error, func())

Types

type DB

type DB interface {
	InsertRaw(stream string, ts time.Time, dims bytemap.ByteMap, vals bytemap.ByteMap) error

	Query(sqlString string, isSubQuery bool, subQueryResults [][]interface{}, includeMemStore bool) (core.FlatRowSource, error)

	Follow(f *common.Follow, cb func([]byte, wal.Offset) error)

	RegisterQueryHandler(partition int, query planner.QueryClusterFN)
}

DB is an interface for database-like things (implemented by common.DB).

type Opts

type Opts struct {
	// ID uniquely identifies this server
	ID int

	// Password, if specified, is the password that clients must present in order
	// to access the server.
	Password string
}