pulse

May 28, 2026

Changes in this version

+ type LabelMatch struct

+ Key string

+ Score float64

+ Value string

+ type LabelTableInfo struct

+ Enumerable bool

+ Name string

+ RowCount int

type Options

+ AutoLabels []LabelBinding

type Pulse

+ func (p *Pulse) LabelTables() []LabelTableInfo

+ func (p *Pulse) ResolveLabel(table, query string, limit int) ([]LabelMatch, error)

May 27, 2026

Changes in this version

+ type ChangeEvent struct

+ Hash string

+ Kind ChangeKind

+ Path string

+ Timestamp time.Time

+ type ChangeKind int

+ const ChangeCreated

+ const ChangeModified

+ const ChangeRemoved

+ const ChangeRenamed

+ func (k ChangeKind) String() string

+ type FilterToFileRequest struct

+ Expression string

+ Filterers []*types.Filterer

+ OutputDir string

+ OutputName string

+ SourcePath string

+ type FilterToFileResult struct

+ ElapsedMs int64

+ OutputHash string

+ OutputPath string

+ Reused bool

+ RowCount int64

type Pulse

+ func (p *Pulse) FilterToFileWithRequest(ctx context.Context, req *FilterToFileRequest) (*FilterToFileResult, error)

+ func (p *Pulse) ProcessStreamResult(ctx context.Context, req *Request) (StreamResult[Row], error)

+ func (p *Pulse) SynthStream(ctx context.Context, spec *SynthSpec, opts SynthOptions) (StreamResult[Row], error)

+ func (p *Pulse) Watch(ctx context.Context, target string) <-chan ChangeEvent

+ func (p *Pulse) WatchDir(ctx context.Context, dir string, recursive bool) <-chan ChangeEvent

+ func (p *Pulse) WatchDirWithOptions(ctx context.Context, dir string, opts WatchOptions) <-chan ChangeEvent

+ func (p *Pulse) WatchWithOptions(ctx context.Context, target string, opts WatchOptions) <-chan ChangeEvent

+ type StreamChunk struct

+ Data T

+ Progress float64

+ Sequence int

+ type StreamHeader struct

+ EstimatedTotal int64

+ RequestHash string

+ StartedAt time.Time

+ type StreamResult struct

+ Chunks <-chan StreamChunk[T]

+ Done <-chan StreamTerminator

+ Header StreamHeader

+ type StreamStatus int

+ const StreamCancelled

+ const StreamCompleted

+ const StreamErrored

+ func (s StreamStatus) String() string

+ type StreamTerminator struct

+ CompletedAt time.Time

+ Error error

+ Status StreamStatus

+ TotalRows int64

+ type WatchOptions struct

+ CoalesceWindow time.Duration

+ HashPrefixBytes int

+ PollInterval time.Duration

+ Recursive bool

+ Suffix string

May 20, 2026

Changes in this version

+ const LabelModeAugment

+ const LabelModeReplace

type Extensions

+ LabelTables map[string]LabelTable

+ type LabelBinding = types.LabelBinding

+ type LabelMode = types.LabelMode

+ type LabelTable struct

+ Description string

+ Lookup func(key string) (label string, ok bool, err error)

+ Rows map[string]string

type Options

+ LabelTablesDir string

type Pulse

+ func (p *Pulse) SampleWithRequest(ctx context.Context, req *SampleRequest) (*SampleResult, error)

+ type SampleRequest = types.SampleRequest

+ type SampleResult struct

+ Rows []Record

+ Warnings []SampleWarning

+ type SampleWarning struct

+ Code string

+ Details map[string]any

+ Message string

May 20, 2026

Changes in this version

+ type ChainRequest = types.ChainRequest

+ type ChainResponse = types.ChainResponse

+ type ChainStage = types.ChainStage

type Pulse

+ func (p *Pulse) CountRecords(ctx context.Context, path string) (uint64, error)

+ func (p *Pulse) ProcessChain(ctx context.Context, req *ChainRequest) (*ChainResponse, error)

May 19, 2026

Changes in this version

type Options

+ Strict bool

May 18, 2026

Changes in this version

type Cohort

+ func (c *Cohort) RecordCount() (int64, error)

+ type LoadMemberSetResult = processing.LoadMemberSetResult

+ func LoadMemberSetFromReader(r io.Reader, schema *encoding.Schema, fieldName string) (LoadMemberSetResult, error)

+ type MemberSet = processing.MemberSet

type Pulse

+ func (p *Pulse) FilterToFileBySetAndExpr(ctx context.Context, src, dst, includeField string, set MemberSet, ...) (int64, error)

+ func (p *Pulse) ResolveCanonicalSchema(ctx context.Context, src string) (*encoding.Schema, error)

May 18, 2026

Changes in this version

type Pulse

+ func (p *Pulse) FilterToFile(ctx context.Context, src, dst, filterExpr string) (int64, error)

May 18, 2026

Changes in this version

type AggregatorRegistration

+ FieldInputs FieldInputsFunc

type AttributeRegistration

+ FieldInputs FieldInputsFunc

type Cohort

+ func (c *Cohort) Shards() []ShardEntry

type FeatureRegistration

+ FieldInputs FieldInputsFunc

+ type FieldInputsFunc func(raw json.RawMessage) []string

type FiltererRegistration

+ FieldInputs FieldInputsFunc

type GrouperRegistration

+ FieldInputs FieldInputsFunc

type Options

+ ProjectBufferedFields bool

+ ShardWorkers int

type Pulse

+ func (p *Pulse) AddShard(ctx context.Context, archivePath, shardPath string) error

+ func (p *Pulse) CompactShardArchive(ctx context.Context, archivePath string) error

+ func (p *Pulse) CreateShardArchive(ctx context.Context, archivePath string, shardPaths []string) error

+ func (p *Pulse) ExtractShard(ctx context.Context, archivePath, shardBasename string) (io.ReadCloser, error)

+ func (p *Pulse) ListShards(ctx context.Context, archivePath string) ([]ShardEntry, error)

+ func (p *Pulse) RemoveShard(ctx context.Context, archivePath, shardBasename string) error

+ func (p *Pulse) VerifyShardArchive(ctx context.Context, archivePath string) (*VerifyResult, error)

+ type ShardEntry = service.ShardEntry

+ type ShardInfo = descriptor.ShardInfo

type TestRegistration

+ FieldInputs FieldInputsFunc

+ type VerifyResult = service.VerifyResult

type WindowRegistration

+ FieldInputs FieldInputsFunc

May 15, 2026

Changes in this version

+ type AggregatorRegistration struct

+ Accepts []encoding.FieldType

+ Description string

+ Factory processing.AggregatorFactory

+ Name types.AggregationType

+ Params []ParamMeta

+ Streamable bool

+ type AttributeEmitType string

+ const AttributeEmitBool

+ const AttributeEmitFloat64

+ const AttributeEmitString

+ type AttributeMode string

+ const AttributeModeBuffered

+ const AttributeModeRowLocal

+ const AttributeModeTwoPass

+ type AttributeRegistration struct

+ Accepts []encoding.FieldType

+ Description string

+ Emits AttributeEmitType

+ Factory processing.AttributeFactory

+ Mode AttributeMode

+ Name types.AttributeType

+ Params []ParamMeta

+ type DistributionRegistration struct

+ Description string

+ Factory any

+ Name string

+ Params []ParamMeta

+ type ExprFunction struct

+ Description string

+ Fn any

+ Name string

+ Pure bool

+ Signature string

+ type Extensions struct

+ Aggregators []AggregatorRegistration

+ Attributes []AttributeRegistration

+ ExprFunctions []ExprFunction

+ Features []FeatureRegistration

+ Filterers []FiltererRegistration

+ Groupers []GrouperRegistration

+ LookupTables map[string]LookupTable

+ SynthDistributions []DistributionRegistration

+ Tests []TestRegistration

+ Windows []WindowRegistration

+ type FacetDiscrete = types.FacetDiscrete

+ type FacetField = types.FacetField

+ type FacetHistogram = types.FacetHistogram

+ type FacetNumeric = types.FacetNumeric

+ type FacetRequest = types.FacetRequest

+ type FacetResult = types.FacetResult

+ type FacetValueCount = types.FacetValueCount

+ type FeatureRegistration struct

+ Accepts []encoding.FieldType

+ Description string

+ Factory feature.Factory

+ Name types.FeatureType

+ Params []ParamMeta

+ Streamable bool

+ type FiltererRegistration struct

+ Accepts []encoding.FieldType

+ Description string

+ Factory processing.FiltererFactory

+ Name types.FiltererType

+ Params []ParamMeta

+ type GrouperRegistration struct

+ Accepts []encoding.FieldType

+ Description string

+ Factory processing.GrouperFactory

+ Name types.GroupType

+ Params []ParamMeta

+ Streamable bool

+ type LookupTable struct

+ Description string

+ Lookup func(keys ...string) (value float64, ok bool, err error)

+ Rows map[string]float64

type Options

+ Extensions Extensions

+ type ParamMeta struct

+ Default any

+ Description string

+ JSONType string

+ Name string

+ Required bool

type Pulse

+ func (p *Pulse) FacetSchema(ctx context.Context, req *FacetRequest) (*FacetResult, error)

+ func (p *Pulse) Service() *service.Service

+ type TestRegistration struct

+ Accepts []encoding.FieldType

+ Description string

+ Name types.TestType

+ Params []ParamMeta

+ PostFactory processing.PostTestFactory

+ RowFactory processing.RowTestFactory

+ Streamable bool

+ Tier TestTier

+ type TestTier string

+ const TestTierPost

+ const TestTierRow

+ type WindowRegistration struct

+ Accepts []encoding.FieldType

+ Description string

+ Factory window.WindowFactory

+ Name types.WindowType

+ Params []ParamMeta

May 13, 2026

Changes in this version

+ type AskRequest struct

+ File string

+ OnInvalid string

+ Predict bool

+ Query string

+ Request *types.Request

+ Source string

+ SourceFormat string

+ SourceHandle string

+ SourceOverwrite bool

+ SourceSheet string

+ SourceTTL string

+ type AskResponse struct

+ Errors []*descriptor.EnvelopeEntry

+ FormatVersion string

+ Import *ImportResult

+ Predict *descriptor.PredictResult

+ Process *Response

+ QueryResolution *QueryResolution

+ Suggestions []errors.Fixup

+ Warnings []*descriptor.EnvelopeEntry

+ type ErrorFixup = errors.Fixup

+ type ErrorMetadata = errors.LookupResult

+ type Example = examples.Example

+ type ExampleSummary = examples.ExampleSummary

+ type ImportEntry = imports.Entry

+ type ImportResult = imports.Result

+ type ImportSpec = imports.Spec

type Options

+ DisableDefaults bool

+ ImportSourceFS afero.Fs

+ ImportSourceJailRoot string

+ ImportTTL time.Duration

+ ImportsDir string

type Pulse

+ func (p *Pulse) Ask(ctx context.Context, req *AskRequest) (*AskResponse, error)

+ func (p *Pulse) Drop(ctx context.Context, handle string) error

+ func (p *Pulse) ErrorLookup(code string) (ErrorMetadata, bool)

+ func (p *Pulse) ErrorsByDomain(domain string) []ErrorMetadata

+ func (p *Pulse) ErrorsSearch(query string) []ErrorMetadata

+ func (p *Pulse) ExampleGet(name string) (*Example, bool)

+ func (p *Pulse) ExamplesSearch(query string, tags []string, category string) []ExampleSummary

+ func (p *Pulse) ImportFile(ctx context.Context, spec ImportSpec) (*ImportResult, error)

+ func (p *Pulse) Imports(ctx context.Context) ([]ImportEntry, error)

+ func (p *Pulse) Manifest(_ context.Context) *descriptor.Manifest

+ func (p *Pulse) ResolveImport(ctx context.Context, handle string) (string, error)

+ func (p *Pulse) SweepImports(ctx context.Context) ([]string, error)

+ type QueryResolution struct

+ Confidence float64

+ MatchedFields []string

+ Query string

May 11, 2026

Changes in this version

+ type ComposeOptions = service.ComposeOptions

+ type Profile = synth.Profile

+ type ProfileOptions = synth.ProfileOptions

type Pulse

+ func (p *Pulse) ComposeParallel(ctx context.Context, req *ComposedRequest, opts ComposeOptions) ([]*Response, error)

+ func (p *Pulse) Fs() afero.Fs

+ func (p *Pulse) ProcessStream(ctx context.Context, req *Request) (RowIter, error)

+ func (p *Pulse) Profile(_ context.Context, path string, opts ProfileOptions) (*Profile, error)

+ func (p *Pulse) Synth(_ context.Context, spec *SynthSpec, output string, opts SynthOptions) (*SynthResult, error)

+ type Row = service.Row

+ type RowIter = service.RowIter

+ type SynthOptions = synth.Options

+ type SynthResult = synth.Result

+ type SynthSpec = synth.Spec

Apr 27, 2026

Changes in this version

+ type Cohort struct

+ func (c *Cohort) Categorical(name string) (*encoding.Dictionary, bool)

+ func (c *Cohort) Field(name string) *encoding.Field

+ func (c *Cohort) Schema() *encoding.Schema

+ type ComposedRequest = types.ComposedRequest

+ type Options struct

+ DataDir string

+ FS afero.Fs

+ type Pulse struct

+ func New(opts Options) (*Pulse, error)

+ func (p *Pulse) Compose(ctx context.Context, req *ComposedRequest) ([]*Response, error)

+ func (p *Pulse) Convert(ctx context.Context, job *pio.ConvertJob) (*pio.ConvertReport, error)

+ func (p *Pulse) Export(ctx context.Context, job *pio.ExportJob) (*pio.ExportReport, error)

+ func (p *Pulse) Facet(ctx context.Context, path string, field string) ([]string, error)

+ func (p *Pulse) Import(ctx context.Context, job *pio.ImportJob) (*pio.ImportReport, error)

+ func (p *Pulse) Inspect(_ context.Context, path string) (*descriptor.InspectResult, error)

+ func (p *Pulse) Open(ctx context.Context, path string) (*Cohort, error)

+ func (p *Pulse) Predict(_ context.Context, req *Request) (*descriptor.PredictResult, error)

+ func (p *Pulse) Process(ctx context.Context, req *Request) (*Response, error)

+ func (p *Pulse) Sample(ctx context.Context, path string, n int) ([]Record, error)

+ type Record = map[string]any

+ type Request = types.Request

+ type Response = types.Response