frames

type BackendConfig struct {
	Type    string `json:"type"` // v3io, csv, ...
	Name    string `json:"name"`
	Workers int    `json:"workers"`
	// backend specific options
	Options map[string]interface{} `json:"options"`

	// CSV backend
	RootDir string `json:"rootdir,omitempty"`
}

type Client interface {
	// Read reads data from server
	Read(request *ReadRequest) (FrameIterator, error)
	// Write writes data to server
	Write(request *WriteRequest) (FrameAppender, error)
	// Create creates a table
	Create(request *CreateRequest) error
	// Delete deletes data or table
	Delete(request *DeleteRequest) error
	// Exec executes a command on the backend
	Exec(request *ExecRequest) error
}

type Column interface {
	Len() int                                 // Number of elements
	Name() string                             // Column name
	DType() DType                             // Data type (e.g. IntType, FloatType ...)
	Ints() ([]int64, error)                   // Data as []int64
	IntAt(i int) (int64, error)               // Int value at index i
	Floats() ([]float64, error)               // Data as []float64
	FloatAt(i int) (float64, error)           // Float value at index i
	Strings() []string                        // Data as []string
	StringAt(i int) (string, error)           // String value at index i
	Times() ([]time.Time, error)              // Data as []time.Time
	TimeAt(i int) (time.Time, error)          // time.Time value at index i
	Bools() ([]bool, error)                   // Data as []bool
	BoolAt(i int) (bool, error)               // bool value at index i
	Slice(start int, end int) (Column, error) // Slice of data
}

type Config struct {
	Log            LogConfig `json:"log"`
	DefaultLimit   int       `json:"limit,omitempty"`
	DefaultTimeout int       `json:"timeout,omitempty"`

	// default V3IO connection details
	WebAPIEndpoint string `json:"webApiEndpoint"`
	Container      string `json:"container"`
	Username       string `json:"username,omitempty"`
	Password       string `json:"password,omitempty"`

	// Number of parallel V3IO worker routines
	Workers int `json:"workers"`

	Backends []*BackendConfig `json:"backends,omitempty"`
}

type CreateRequest = pb.CreateRequest

type DType pb.DType

type DataBackend interface {
	// TODO: Expose name, type, config ... ?
	Read(request *ReadRequest) (FrameIterator, error)
	Write(request *WriteRequest) (FrameAppender, error) // TODO: use Appender for write streaming
	Create(request *CreateRequest) error
	Delete(request *DeleteRequest) error
	Exec(request *ExecRequest) error
}

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

type DeleteRequest = pb.DeleteRequest

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

type ExecRequest = pb.ExecRequest

type Frame interface {
	Labels() map[string]interface{}          // Label set
	Names() []string                         // Column names
	Indices() []Column                       // Index columns
	Len() int                                // Number of rows
	Column(name string) (Column, error)      // Column by name
	Slice(start int, end int) (Frame, error) // Slice of Frame
	IterRows(includeIndex bool) RowIterator  // Iterate over rows
}

type FrameAppender interface {
	Add(frame Frame) error
	WaitForComplete(timeout time.Duration) error
}

type FrameIterator interface {
	Next() bool
	Err() error
	At() Frame
}

type JoinStruct = pb.JoinStruct

type LogConfig struct {
	Level string `json:"level,omitempty"`
}

type Query struct {
	Table   string
	Columns []string
	Filter  string
	GroupBy string
}

type ReadRequest = pb.ReadRequest

type RowIterator interface {
	Next() bool                      // Advance to next row
	Row() map[string]interface{}     // Row as map of name->value
	RowNum() int                     // Current row number
	Indices() map[string]interface{} // MultiIndex as name->value
	Err() error                      // Iteration error
}

type SchemaField = pb.SchemaField

type SchemaKey = pb.SchemaKey

type Server interface {
	Start() error
	State() ServerState
	Err() error
}

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

type ServerState string

type Session = pb.Session

type TableSchema = pb.TableSchema

type WriteRequest struct {
	Session *Session `msgpack:"session"`
	Backend string   `msgpack:"backend"` // backend name
	Table   string   `msgpack:"table"`   // Table name (path)
	// Data message sent with the write request (in case of a stream multiple messages can follow)
	ImmidiateData Frame `msgpack:"intermidate,omitempty"`
	// Expression template, for update expressions generated from combining columns data with expression
	Expression string `msgpack:"expression,omitempty"`
	// Will we get more message chunks (in a stream), if not we can complete
	HaveMore bool `msgpack:"more"`
}