goplanner

Documentation

Index

• func GetCompilerErrorContext(status *statuspb.Status, errorPB *compilerpb.CompilerErrorGroup) error
• func HasContext(status *statuspb.Status) bool
• type GoPlanner
  • func New(udfInfo *udfspb.UDFInfo) (GoPlanner, error)
  • func (cm GoPlanner) CompileMutations(request *plannerpb.CompileMutationsRequest) (*plannerpb.CompileMutationsResponse, error)
  • func (cm GoPlanner) Free()
  • func (cm GoPlanner) GenerateOTelScript(request *plannerpb.GenerateOTelScriptRequest) (*plannerpb.GenerateOTelScriptResponse, error)
  • func (cm GoPlanner) Plan(queryRequest *plannerpb.QueryRequest) (*distributedpb.LogicalPlannerResult, error)

Functions

func GetCompilerErrorContext

func GetCompilerErrorContext(status *statuspb.Status, errorPB *compilerpb.CompilerErrorGroup) error

GetCompilerErrorContext inspects the context field (pb.Any msg) and converts into the CompilerErrorGroup message for proper use.

func HasContext

func HasContext(status *statuspb.Status) bool

HasContext returns true whether status has context or not.

Types

type GoPlanner

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

GoPlanner wraps the C Planner.

func New

func New(udfInfo *udfspb.UDFInfo) (GoPlanner, error)

New creates a new GoPlanner object.

func (GoPlanner) CompileMutations

func (cm GoPlanner) CompileMutations(request *plannerpb.CompileMutationsRequest) (*plannerpb.CompileMutationsResponse, error)

CompileMutations compiles the query into a mutation of Pixie Data Table.

func (GoPlanner) Free

func (cm GoPlanner) Free()

Free the memory used by the planner.

func (GoPlanner) GenerateOTelScript

func (cm GoPlanner) GenerateOTelScript(request *plannerpb.GenerateOTelScriptRequest) (*plannerpb.GenerateOTelScriptResponse, error)

GenerateOTelScript generates an OTel export script based on the script passed in.

func (GoPlanner) Plan

func (cm GoPlanner) Plan(queryRequest *plannerpb.QueryRequest) (*distributedpb.LogicalPlannerResult, error)

Plan the query with the passed in state, then return the result as a planner result protobuf.