mock

Documentation

Overview

Package mock contains mock implementations of the query package interfaces for testing.

Index

• Variables
• type AscendingTimeProvider
  • func (atp *AscendingTimeProvider) CurrentTime() values.Time
• type Compiler
  • func (c Compiler) Compile(ctx context.Context) (*flux.Spec, error)
  • func (c Compiler) CompilerType() flux.CompilerType
• type Executor
  • func NewExecutor() *Executor
  • func (e *Executor) Execute(ctx context.Context, p *plan.PlanSpec, a *memory.Allocator) (map[string]flux.Result, <-chan flux.Metadata, error)

Variables

var NoMetadata <-chan flux.Metadata

Types

type AscendingTimeProvider

type AscendingTimeProvider struct {
	Start int64
}

AscendingTimeProvider provides ascending timestamps every nanosecond starting from Start.

func (*AscendingTimeProvider) CurrentTime

func (atp *AscendingTimeProvider) CurrentTime() values.Time

type Compiler

type Compiler struct {
	CompileFn func(ctx context.Context) (*flux.Spec, error)
	Type      flux.CompilerType
}

func (Compiler) Compile

func (c Compiler) Compile(ctx context.Context) (*flux.Spec, error)

func (Compiler) CompilerType

func (c Compiler) CompilerType() flux.CompilerType

type Executor

type Executor struct {
	ExecuteFn func(ctx context.Context, p *plan.PlanSpec, a *memory.Allocator) (map[string]flux.Result, <-chan flux.Metadata, error)
}

Executor is a mock implementation of an execute.Executor.

func NewExecutor

func NewExecutor() *Executor

NewExecutor returns a mock Executor where its methods will return zero values.

func (*Executor) Execute

func (e *Executor) Execute(ctx context.Context, p *plan.PlanSpec, a *memory.Allocator) (map[string]flux.Result, <-chan flux.Metadata, error)