deepql

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

type CommandRequest struct {
	Command    string
	Conditions []Condition
}

type Condition struct {
	Attribute string
	Op        Operator
	Operands  Operands
}

type Engine struct{}

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

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

type Operands []Static

type Operator int

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

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 struct {
	SnapshotID         []byte
	ServiceName        string
	FilePath           string
	LineNo             uint32
	StartTimeUnixNanos uint64
	DurationNanos      uint64
}

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

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

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

type StaticType int

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