objects

Documentation

Index

• Variables
• type Table
  • func NewTable(tbl flux.Table) (*Table, error)
  • func (t *Table) Array() values.Array
  • func (t *Table) Bool() bool
  • func (t *Table) Bytes() []byte
  • func (t *Table) Dict() values.Dictionary
  • func (t *Table) Duration() values.Duration
  • func (t *Table) Dynamic() values.Dynamic
  • func (t *Table) Equal(other values.Value) bool
  • func (t *Table) Float() float64
  • func (t *Table) Function() values.Function
  • func (t *Table) Get(name string) (values.Value, bool)
  • func (t *Table) Int() int64
  • func (t *Table) IsNull() bool
  • func (t *Table) Len() int
  • func (t *Table) Object() values.Object
  • func (t *Table) Range(fn func(name string, v values.Value))
  • func (t *Table) Regexp() *regexp.Regexp
  • func (t *Table) Release()
  • func (t *Table) Retain()
  • func (t *Table) Set(name string, v values.Value)
  • func (t *Table) Str() string
  • func (t *Table) String() string
  • func (t *Table) Table() flux.Table
  • func (t *Table) Time() values.Time
  • func (t *Table) Type() semantic.MonoType
  • func (t *Table) UInt() uint64
  • func (t *Table) Vector() values.Vector

Variables

var (
	SchemaMonoType = semantic.NewObjectType([]semantic.PropertyType{
		{
			Key:   []byte("label"),
			Value: semantic.BasicString,
		},
		{
			Key:   []byte("grouped"),
			Value: semantic.BasicBool,
		},
		{
			Key:   []byte("type"),
			Value: semantic.BasicString,
		},
	})
	TableMonoType = semantic.NewObjectType([]semantic.PropertyType{{
		Key:   []byte("schema"),
		Value: semantic.NewArrayType(SchemaMonoType),
	}})
)

A Table is an object with a schema. Schema is the only attribute that the table exposes. To extract records or columns one must use the provided functions (getRecord/getColumn). TODO(affo): we decided not to expose the schema, for now.

Types

type Table

type Table struct {
	flux.BufferedTable
	// contains filtered or unexported fields
}

Table is a values.Value that represents a table in Flux. (Unlike flux.TableObject which represents a stream of tables.)

func NewTable

func NewTable(tbl flux.Table) (*Table, error)

func (*Table) Array

func (t *Table) Array() values.Array

func (*Table) Bool

func (t *Table) Bool() bool

func (*Table) Bytes

func (t *Table) Bytes() []byte

func (*Table) Dict

func (t *Table) Dict() values.Dictionary

func (*Table) Duration

func (t *Table) Duration() values.Duration

func (*Table) Dynamic

func (t *Table) Dynamic() values.Dynamic

func (*Table) Equal

func (t *Table) Equal(other values.Value) bool

func (*Table) Float

func (t *Table) Float() float64

func (*Table) Function

func (t *Table) Function() values.Function

func (*Table) Get

func (t *Table) Get(name string) (values.Value, bool)

func (*Table) Int

func (t *Table) Int() int64

func (*Table) IsNull

func (t *Table) IsNull() bool

func (*Table) Len

func (t *Table) Len() int

func (*Table) Object

func (t *Table) Object() values.Object

func (*Table) Range

func (t *Table) Range(fn func(name string, v values.Value))

func (*Table) Regexp

func (t *Table) Regexp() *regexp.Regexp

func (*Table) Release

func (t *Table) Release()

func (*Table) Retain

func (t *Table) Retain()

func (*Table) Set

func (t *Table) Set(name string, v values.Value)

func (*Table) Str

func (t *Table) Str() string

func (*Table) String

func (t *Table) String() string

func (*Table) Table

func (t *Table) Table() flux.Table

Table returns a copy of the Table that can be called with Do. Either Do or Done must be called on the returned Table.

func (*Table) Time

func (t *Table) Time() values.Time

func (*Table) Type

func (t *Table) Type() semantic.MonoType

func (*Table) UInt

func (t *Table) UInt() uint64

func (*Table) Vector

func (t *Table) Vector() values.Vector