Versions in this module Expand all Collapse all v0 v0.99.3 Jan 3, 2021 v0.99.2 Jan 3, 2021 Changes in this version + const TablesParameter + var MaxTime = Time + var MinTime = Time + var Now = Time + func ErrorCode(err error) codes.Code + func ErrorDocURL(err error) string + func FmtJSON(f *formatter) + func Formatted(q *Spec, opts ...FormatOption) fmt.Formatter + func FunctionValue(name string, c CreateOperationSpec, ft semantic.MonoType) (values.Value, error) + func FunctionValueWithSideEffect(name string, c CreateOperationSpec, ft semantic.MonoType) (values.Value, error) + func IsQueryTracingEnabled(ctx context.Context) bool + func MustValue(v values.Value, err error) values.Value + func NumberOfOperations() int + func RegisterOpSpec(k OperationKind, c NewOperationSpec) + func SemanticType(typ ColType) semantic.MonoType + func WithQueryTracingEnabled(parentCtx context.Context) context.Context + type ASTHandle interface + ASTHandle func() + GetError func() error + type Administration struct + func (a *Administration) AddParent(np *TableObject) + func (a *Administration) AddParentFromArgs(args Arguments) error + type Arguments struct + func (a Arguments) GetDuration(name string) (Duration, bool, error) + func (a Arguments) GetRequiredDuration(name string) (Duration, error) + func (a Arguments) GetRequiredTime(name string) (Time, error) + func (a Arguments) GetTime(name string) (Time, bool, error) + type Bounds struct + Now time.Time + Start Time + Stop Time + func (b Bounds) HasZero() bool + func (b Bounds) IsEmpty() bool + type BufferedTable interface + Buffer func(i int) ColReader + BufferN func() int + Copy func() BufferedTable + type ColMeta struct + Label string + Type ColType + type ColReader interface + Bools func(j int) *array.Boolean + Cols func() []ColMeta + Floats func(j int) *array.Float64 + Ints func(j int) *array.Int64 + Key func() GroupKey + Len func() int + Release func() + Retain func() + Strings func(j int) *array.Binary + Times func(j int) *array.Int64 + UInts func(j int) *array.Uint64 + type ColType int + const TBool + const TFloat + const TInt + const TInvalid + const TString + const TTime + const TUInt + func ColumnType(typ semantic.MonoType) ColType + func (t ColType) String() string + type Compiler interface + Compile func(ctx context.Context, runtime Runtime) (Program, error) + CompilerType func() CompilerType + type CompilerMappings map[CompilerType]CreateCompiler + func (m CompilerMappings) Add(t CompilerType, c CreateCompiler) error + type CompilerType string + type CreateCompiler func() Compiler + type CreateDialect func() Dialect + type CreateOperationSpec func(args Arguments, a *Administration) (OperationSpec, error) + type DelimitedMultiResultEncoder struct + Delimiter []byte + Encoder interface{ ... } + func (e *DelimitedMultiResultEncoder) Encode(w io.Writer, results ResultIterator) (int64, error) + type Dependencies interface + FilesystemService func() (filesystem.Service, error) + HTTPClient func() (http.Client, error) + SecretService func() (secret.Service, error) + URLValidator func() (url.Validator, error) + func GetDependencies(ctx context.Context) Dependencies + func NewEmptyDependencies() Dependencies + type Dependency interface + Inject func(ctx context.Context) context.Context + type Deps struct + Deps WrappedDeps + func NewDefaultDependencies() Deps + func (d Deps) FilesystemService() (filesystem.Service, error) + func (d Deps) HTTPClient() (http.Client, error) + func (d Deps) Inject(ctx context.Context) context.Context + func (d Deps) SecretService() (secret.Service, error) + func (d Deps) URLValidator() (url.Validator, error) + type Dialect interface + DialectType func() DialectType + Encoder func() MultiResultEncoder + type DialectMappings map[DialectType]CreateDialect + func (m DialectMappings) Add(t DialectType, c CreateDialect) error + type DialectType string + type Duration = values.Duration + func ConvertDuration(v time.Duration) Duration + type Edge struct + Child OperationID + Parent OperationID + type EncoderError interface + IsEncoderError func() bool + type Error = errors.Error + type FormatOption func(*formatter) + type GroupKey interface + Cols func() []ColMeta + Equal func(o GroupKey) bool + HasCol func(label string) bool + IsNull func(j int) bool + LabelValue func(label string) values.Value + Less func(o GroupKey) bool + String func() string + Value func(j int) values.Value + ValueBool func(j int) bool + ValueDuration func(j int) values.Duration + ValueFloat func(j int) float64 + ValueInt func(j int) int64 + ValueString func(j int) string + ValueTime func(j int) values.Time + ValueUInt func(j int) uint64 + Values func() []values.Value + type GroupKeys []GroupKey + func (a GroupKeys) Len() int + func (a GroupKeys) Less(i, j int) bool + func (a GroupKeys) String() string + func (a GroupKeys) Swap(i, j int) + type GroupMode int + const GroupModeBy + const GroupModeExcept + const GroupModeNone + type IDer interface + ID func(*TableObject) OperationID + type IDerOpSpec interface + IDer func(ider IDer) + type MultiResultDecoder interface + Decode func(r io.ReadCloser) (ResultIterator, error) + type MultiResultEncoder interface + Encode func(w io.Writer, results ResultIterator) (int64, error) + type NewOperationSpec func() OperationSpec + func OperationSpecNewFn(k OperationKind) NewOperationSpec + type Operation struct + ID OperationID + Source OperationSource + Spec OperationSpec + func (o *Operation) UnmarshalJSON(data []byte) error + func (o Operation) MarshalJSON() ([]byte, error) + type OperationID string + type OperationKind string + type OperationSource struct + Stack []interpreter.StackEntry + type OperationSpec interface + Kind func() OperationKind + type Priority int32 + const High + const Low + func (p *Priority) UnmarshalText(txt []byte) error + func (p Priority) MarshalText() ([]byte, error) + type Program interface + Start func(context.Context, *memory.Allocator) (Query, error) + type Query interface + Cancel func() + Done func() + Err func() error + ProfilerResults func() (ResultIterator, error) + Results func() <-chan Result + Statistics func() Statistics + type ResourceManagement struct + ConcurrencyQuota int + MemoryBytesQuota int64 + Priority Priority + type Result interface + Name func() string + Tables func() TableIterator + type ResultDecoder interface + Decode func(r io.Reader) (Result, error) + type ResultEncoder interface + Encode func(w io.Writer, result Result) (int64, error) + type ResultIterator interface + Err func() error + More func() bool + Next func() Result + Release func() + Statistics func() Statistics + func NewMapResultIterator(results map[string]Result) ResultIterator + func NewResultIteratorFromQuery(q Query) ResultIterator + func NewSliceResultIterator(results []Result) ResultIterator + type Runtime interface + Eval func(ctx context.Context, astPkg ASTHandle, es interpreter.ExecOptsConfig, ...) ([]interpreter.SideEffect, values.Scope, error) + IsPreludePackage func(pkg string) bool + JSONToHandle func(json []byte) (ASTHandle, error) + LookupBuiltinType func(pkg, name string) (semantic.MonoType, error) + MergePackages func(dst, src ASTHandle) error + Parse func(flux string) (ASTHandle, error) + type ScopeMutator = func(r Runtime, scope values.Scope) + func SetNowOption(now time.Time) ScopeMutator + func SetOption(pkg, name string, fn func(r Runtime) values.Value) ScopeMutator + type Spec struct + Edges []Edge + Now time.Time + Operations []*Operation + Resources ResourceManagement + func (q *Spec) Children(id OperationID) []*Operation + func (q *Spec) Functions() ([]string, error) + func (q *Spec) Parents(id OperationID) []*Operation + func (q *Spec) Validate() error + func (q *Spec) Walk(f func(o *Operation) error) error + type Statistics struct + CompileDuration time.Duration + Concurrency int + ExecuteDuration time.Duration + MaxAllocated int64 + Metadata metadata.Metadata + PlanDuration time.Duration + QueueDuration time.Duration + RequeueDuration time.Duration + RuntimeErrors []string + TotalAllocated int64 + TotalDuration time.Duration + func (s Statistics) Add(other Statistics) Statistics + type Table interface + Cols func() []ColMeta + Do func(f func(ColReader) error) error + Done func() + Empty func() bool + Key func() GroupKey + type TableIterator interface + Do func(f func(Table) error) error + type TableObject struct + Kind OperationKind + Parents []*TableObject + Source OperationSource + Spec OperationSpec + func (t *TableObject) Append(v values.Value) + func (t *TableObject) Array() values.Array + func (t *TableObject) Bool() bool + func (t *TableObject) Bytes() []byte + func (t *TableObject) Dict() values.Dictionary + func (t *TableObject) Duration() values.Duration + func (t *TableObject) Equal(rhs values.Value) bool + func (t *TableObject) Float() float64 + func (t *TableObject) Function() values.Function + func (t *TableObject) Get(i int) values.Value + func (t *TableObject) Int() int64 + func (t *TableObject) IsNull() bool + func (t *TableObject) Len() int + func (t *TableObject) Object() values.Object + func (t *TableObject) Operation(ider IDer) *Operation + func (t *TableObject) Range(f func(i int, v values.Value)) + func (t *TableObject) Regexp() *regexp.Regexp + func (t *TableObject) Set(i int, v values.Value) + func (t *TableObject) Sort(f func(i, j values.Value) bool) + func (t *TableObject) Str() string + func (t *TableObject) String() string + func (t *TableObject) Time() values.Time + func (t *TableObject) Type() semantic.MonoType + func (t *TableObject) UInt() uint64 + type Time struct + Absolute time.Time + IsRelative bool + Relative time.Duration + func ToQueryTime(value values.Value) (Time, error) + func (t *Time) UnmarshalText(data []byte) error + func (t Time) IsZero() bool + func (t Time) MarshalText() ([]byte, error) + func (t Time) Time(now time.Time) time.Time + type WrappedDeps struct + FilesystemService filesystem.Service + HTTPClient http.Client + SecretService secret.Service + URLValidator url.Validator
Go to main page