field

package
v0.22.0 Latest Latest
Warning

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

Go to latest
Published: Sep 25, 2020 License: BSD-3-Clause Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Double

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

func (*Double) Consume

func (d *Double) Consume(v zng.Value) error

func (*Double) Result

func (d *Double) Result() zng.Value

type Duration added in v0.2.0

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

func (*Duration) Consume added in v0.2.0

func (d *Duration) Consume(v zng.Value) error

func (*Duration) Result added in v0.2.0

func (d *Duration) Result() zng.Value

type FieldReducer

type FieldReducer struct {
	reducer.Reducer
	Op       string
	Resolver expr.FieldExprResolver
	// contains filtered or unexported fields
}

func (*FieldReducer) Consume

func (fr *FieldReducer) Consume(r *zng.Record)

func (*FieldReducer) ConsumePart added in v0.15.0

func (fr *FieldReducer) ConsumePart(v zng.Value) error

func (*FieldReducer) Result

func (fr *FieldReducer) Result() zng.Value

func (*FieldReducer) ResultPart added in v0.15.0

func (fr *FieldReducer) ResultPart(*resolver.Context) (zng.Value, error)

type Int

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

func (*Int) Consume

func (i *Int) Consume(v zng.Value) error

func (*Int) Result

func (i *Int) Result() zng.Value

type Streamfn

type Streamfn interface {
	Result() zng.Value
	Consume(zng.Value) error
}

func NewDurationStreamfn added in v0.2.0

func NewDurationStreamfn(op string) Streamfn

func NewFloat64Streamfn added in v0.2.0

func NewFloat64Streamfn(op string) Streamfn

func NewIntStreamfn

func NewIntStreamfn(op string) Streamfn

func NewTimeStreamfn

func NewTimeStreamfn(op string) Streamfn

func NewUintStreamfn added in v0.2.0

func NewUintStreamfn(op string) Streamfn

type Time

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

func (*Time) Consume

func (t *Time) Consume(v zng.Value) error

func (*Time) Result

func (t *Time) Result() zng.Value

type Uint added in v0.2.0

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

func (*Uint) Consume added in v0.2.0

func (u *Uint) Consume(v zng.Value) error

func (*Uint) Result added in v0.2.0

func (u *Uint) Result() zng.Value

Jump to

Keyboard shortcuts

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