deepql

Documentation

Overview

Code generated by goyacc -l -o pkg/deepql/deepql.y.go pkg/deepql/deepql.y. DO NOT EDIT.

Index

• Constants
• type CommandHandler
• type CommandRequest
• type Condition
  • func (c Condition) MatchesInt(value int) bool
  • func (c Condition) MatchesString(value string) bool
• type Engine
  • func NewEngine() *Engine
  • func (e *Engine) ExecuteCommandQuery(ctx context.Context, expr *RootExpr, handler CommandHandler) ([]*deeptp.TracePointConfig, []*deeptp.TracePointConfig, string, error)
  • func (e *Engine) ExecuteSearch(ctx context.Context, searchReq *deeppb.SearchRequest, ...) (*deeppb.SearchResponse, error)
  • func (e *Engine) ExecuteTriggerQuery(ctx context.Context, expr *RootExpr, handler TriggerHandler) (*deeptp.TracePointConfig, []*deeptp.TracePointConfig, error)
• type FetchSnapshotRequest
• type FetchSnapshotResponse
• type Operands
• type Operator
• type RootExpr
  • func ParseString(str string) (*RootExpr, error)
  • func (e RootExpr) IsCommand() bool
  • func (e RootExpr) IsSearch() bool
  • func (e RootExpr) IsTrigger() bool
• type Snapshot
• type SnapshotResult
• type SnapshotResultFetcher
• type SnapshotResultIterator
• type Static
  • func NewStaticBool(b bool) Static
  • func NewStaticDuration(d time.Duration) Static
  • func NewStaticFloat(f float64) Static
  • func NewStaticInt(n int) Static
  • func NewStaticNil() Static
  • func NewStaticString(s string) Static
  • func (s Static) String() string
• type StaticType
• type TriggerHandler

Constants

const (
	List       = "list"
	DeleteType = "delete"
)

const CLOSE_BRACE = 57354

const CLOSE_BRACK = 57362

const CLOSE_PARAN = 57360

const COMMAND = 57349

const DOT = 57358

const DURATION = 57352

const EQ = 57363

const FALSE = 57357

const FLOAT = 57351

const GT = 57367

const GTE = 57368

const IDENTIFIER = 57347

const INTEGER = 57350

const LT = 57365

const LTE = 57366

const NEQ = 57364

const NIL = 57355

const NREG = 57370

const OPEN_BRACE = 57353

const OPEN_BRACK = 57361

const OPEN_PARAN = 57359

const REG = 57369

const STRING = 57346

const TRIGGER = 57348

const TRUE = 57356

Types

type CommandHandler

type CommandHandler func(context.Context, *CommandRequest) ([]*deeptp.TracePointConfig, []*deeptp.TracePointConfig, string, error)

type CommandRequest

type CommandRequest struct {
	Command    string
	Conditions []Condition
}

type Condition

type Condition struct {
	Attribute string
	Op        Operator
	Operands  Operands
}

func (Condition) MatchesInt

func (c Condition) MatchesInt(value int) bool

func (Condition) MatchesString

func (c Condition) MatchesString(value string) bool

type Engine

type Engine struct{}

func NewEngine

func NewEngine() *Engine

func (*Engine) ExecuteCommandQuery

func (e *Engine) ExecuteCommandQuery(ctx context.Context, expr *RootExpr, handler CommandHandler) ([]*deeptp.TracePointConfig, []*deeptp.TracePointConfig, string, error)

func (*Engine) ExecuteSearch

func (e *Engine) ExecuteSearch(ctx context.Context, searchReq *deeppb.SearchRequest, snapshotResultFetcher SnapshotResultFetcher) (*deeppb.SearchResponse, error)

func (*Engine) ExecuteTriggerQuery

func (e *Engine) ExecuteTriggerQuery(ctx context.Context, expr *RootExpr, handler TriggerHandler) (*deeptp.TracePointConfig, []*deeptp.TracePointConfig, error)

type FetchSnapshotRequest

type FetchSnapshotRequest struct {
	StartTimeUnixNanos uint64
	EndTimeUnixNanos   uint64
	Conditions         []Condition
}

type FetchSnapshotResponse

type FetchSnapshotResponse struct {
	Results SnapshotResultIterator
	Bytes   func() uint64
}

type Operands

type Operands []Static

type Operator

type Operator int

const (
	OpNone Operator = iota
	OpEqual
	OpNotEqual
	OpGreater
	OpGreaterEqual
	OpLess
	OpLessEqual
	OpRegex
	OpNotRegex
)

type RootExpr

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

func ParseString

func ParseString(str string) (*RootExpr, error)

func (RootExpr) IsCommand

func (e RootExpr) IsCommand() bool

func (RootExpr) IsSearch

func (e RootExpr) IsSearch() bool

func (RootExpr) IsTrigger

func (e RootExpr) IsTrigger() bool

type Snapshot

type Snapshot interface {
	// Attributes are the actual fields used by the engine to evaluate queries
	// if a Filter parameter is passed the snapshots returned will only have this field populated
	Attributes() map[string]Static

	ID() []byte
	StartTimeUnixNanos() uint64
	EndTimeUnixNanos() uint64
}

type SnapshotResult

type SnapshotResult struct {
	SnapshotID         []byte
	ServiceName        string
	FilePath           string
	LineNo             uint32
	StartTimeUnixNanos uint64
	DurationNanos      uint64
}

type SnapshotResultFetcher

type SnapshotResultFetcher func(context.Context, FetchSnapshotRequest) (FetchSnapshotResponse, error)

type SnapshotResultIterator

type SnapshotResultIterator interface {
	Next(context.Context) (*SnapshotResult, error)
	Close()
}

type Static

type Static struct {
	Type StaticType
	N    int
	F    float64
	S    string
	B    bool
	D    time.Duration
}

func NewStaticBool

func NewStaticBool(b bool) Static

func NewStaticDuration

func NewStaticDuration(d time.Duration) Static

func NewStaticFloat

func NewStaticFloat(f float64) Static

func NewStaticInt

func NewStaticInt(n int) Static

func NewStaticNil

func NewStaticNil() Static

func NewStaticString

func NewStaticString(s string) Static

func (Static) String

func (s Static) String() string

type StaticType

type StaticType int

const (
	TypeNil StaticType = iota
	TypeInt
	TypeFloat
	TypeString
	TypeBoolean
	TypeDuration
)

type TriggerHandler

type TriggerHandler func(context.Context, *deeppb.CreateTracepointRequest) (*deeptp.TracePointConfig, []*deeptp.TracePointConfig, error)