plannerpb

package
v0.0.0-...-8540621 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 25, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthService        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterPlannerServiceServer 

func RegisterPlannerServiceServer(s *grpc.Server, srv PlannerServiceServer)

Types

type CompileMutation 

type CompileMutation struct {
	// Types that are valid to be assigned to Mutation:
	//	*CompileMutation_Trace
	//	*CompileMutation_DeleteTracepoint
	//	*CompileMutation_ConfigUpdate
	Mutation isCompileMutation_Mutation `protobuf_oneof:"mutation"`
}

func (*CompileMutation) Descriptor 

func (*CompileMutation) Descriptor() ([]byte, []int)

func (*CompileMutation) Equal 

func (this *CompileMutation) Equal(that interface{}) bool

func (*CompileMutation) GetConfigUpdate 

func (m *CompileMutation) GetConfigUpdate() *ConfigUpdate

func (*CompileMutation) GetDeleteTracepoint 

func (m *CompileMutation) GetDeleteTracepoint() *DeleteTracepoint

func (*CompileMutation) GetMutation 

func (m *CompileMutation) GetMutation() isCompileMutation_Mutation

func (*CompileMutation) GetTrace 

func (m *CompileMutation) GetTrace() *logicalpb.TracepointDeployment

func (*CompileMutation) GoString 

func (this *CompileMutation) GoString() string

func (*CompileMutation) Marshal 

func (m *CompileMutation) Marshal() (dAtA []byte, err error)

func (*CompileMutation) MarshalTo 

func (m *CompileMutation) MarshalTo(dAtA []byte) (int, error)

func (*CompileMutation) MarshalToSizedBuffer 

func (m *CompileMutation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CompileMutation) ProtoMessage 

func (*CompileMutation) ProtoMessage()

func (*CompileMutation) Reset 

func (m *CompileMutation) Reset()

func (*CompileMutation) Size 

func (m *CompileMutation) Size() (n int)

func (*CompileMutation) String 

func (this *CompileMutation) String() string

func (*CompileMutation) Unmarshal 

func (m *CompileMutation) Unmarshal(dAtA []byte) error

func (*CompileMutation) XXX_DiscardUnknown 

func (m *CompileMutation) XXX_DiscardUnknown()

func (*CompileMutation) XXX_Marshal 

func (m *CompileMutation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompileMutation) XXX_Merge 

func (m *CompileMutation) XXX_Merge(src proto.Message)

func (*CompileMutation) XXX_OneofWrappers 

func (*CompileMutation) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CompileMutation) XXX_Size 

func (m *CompileMutation) XXX_Size() int

func (*CompileMutation) XXX_Unmarshal 

func (m *CompileMutation) XXX_Unmarshal(b []byte) error

type CompileMutation_ConfigUpdate 

type CompileMutation_ConfigUpdate struct {
	ConfigUpdate *ConfigUpdate `protobuf:"bytes,4,opt,name=config_update,json=configUpdate,proto3,oneof" json:"config_update,omitempty"`
}

func (*CompileMutation_ConfigUpdate) Equal 

func (this *CompileMutation_ConfigUpdate) Equal(that interface{}) bool

func (*CompileMutation_ConfigUpdate) GoString 

func (this *CompileMutation_ConfigUpdate) GoString() string

func (*CompileMutation_ConfigUpdate) MarshalTo 

func (m *CompileMutation_ConfigUpdate) MarshalTo(dAtA []byte) (int, error)

func (*CompileMutation_ConfigUpdate) MarshalToSizedBuffer 

func (m *CompileMutation_ConfigUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CompileMutation_ConfigUpdate) Size 

func (m *CompileMutation_ConfigUpdate) Size() (n int)

func (*CompileMutation_ConfigUpdate) String 

func (this *CompileMutation_ConfigUpdate) String() string

type CompileMutation_DeleteTracepoint 

type CompileMutation_DeleteTracepoint struct {
	DeleteTracepoint *DeleteTracepoint `protobuf:"bytes,3,opt,name=delete_tracepoint,json=deleteTracepoint,proto3,oneof" json:"delete_tracepoint,omitempty"`
}

func (*CompileMutation_DeleteTracepoint) Equal 

func (this *CompileMutation_DeleteTracepoint) Equal(that interface{}) bool

func (*CompileMutation_DeleteTracepoint) GoString 

func (this *CompileMutation_DeleteTracepoint) GoString() string

func (*CompileMutation_DeleteTracepoint) MarshalTo 

func (m *CompileMutation_DeleteTracepoint) MarshalTo(dAtA []byte) (int, error)

func (*CompileMutation_DeleteTracepoint) MarshalToSizedBuffer 

func (m *CompileMutation_DeleteTracepoint) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CompileMutation_DeleteTracepoint) Size 

func (m *CompileMutation_DeleteTracepoint) Size() (n int)

func (*CompileMutation_DeleteTracepoint) String 

func (this *CompileMutation_DeleteTracepoint) String() string

type CompileMutation_Trace 

type CompileMutation_Trace struct {
	Trace *logicalpb.TracepointDeployment `protobuf:"bytes,2,opt,name=trace,proto3,oneof" json:"trace,omitempty"`
}

func (*CompileMutation_Trace) Equal 

func (this *CompileMutation_Trace) Equal(that interface{}) bool

func (*CompileMutation_Trace) GoString 

func (this *CompileMutation_Trace) GoString() string

func (*CompileMutation_Trace) MarshalTo 

func (m *CompileMutation_Trace) MarshalTo(dAtA []byte) (int, error)

func (*CompileMutation_Trace) MarshalToSizedBuffer 

func (m *CompileMutation_Trace) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CompileMutation_Trace) Size 

func (m *CompileMutation_Trace) Size() (n int)

func (*CompileMutation_Trace) String 

func (this *CompileMutation_Trace) String() string

type CompileMutationsRequest 

type CompileMutationsRequest struct {
	LogicalPlannerState *distributedpb.LogicalPlannerState `protobuf:"bytes,5,opt,name=logical_planner_state,json=logicalPlannerState,proto3" json:"logical_planner_state,omitempty"`
	QueryStr            string                             `protobuf:"bytes,1,opt,name=query_str,json=queryStr,proto3" json:"query_str,omitempty"`
	ExecFuncs           []*FuncToExecute                   `protobuf:"bytes,3,rep,name=exec_funcs,json=execFuncs,proto3" json:"exec_funcs,omitempty"`
	Configs             *Configs                           `protobuf:"bytes,4,opt,name=configs,proto3" json:"configs,omitempty"`
}

func (*CompileMutationsRequest) Descriptor 

func (*CompileMutationsRequest) Descriptor() ([]byte, []int)

func (*CompileMutationsRequest) Equal 

func (this *CompileMutationsRequest) Equal(that interface{}) bool

func (*CompileMutationsRequest) GetConfigs 

func (m *CompileMutationsRequest) GetConfigs() *Configs

func (*CompileMutationsRequest) GetExecFuncs 

func (m *CompileMutationsRequest) GetExecFuncs() []*FuncToExecute

func (*CompileMutationsRequest) GetLogicalPlannerState 

func (m *CompileMutationsRequest) GetLogicalPlannerState() *distributedpb.LogicalPlannerState

func (*CompileMutationsRequest) GetQueryStr 

func (m *CompileMutationsRequest) GetQueryStr() string

func (*CompileMutationsRequest) GoString 

func (this *CompileMutationsRequest) GoString() string

func (*CompileMutationsRequest) Marshal 

func (m *CompileMutationsRequest) Marshal() (dAtA []byte, err error)

func (*CompileMutationsRequest) MarshalTo 

func (m *CompileMutationsRequest) MarshalTo(dAtA []byte) (int, error)

func (*CompileMutationsRequest) MarshalToSizedBuffer 

func (m *CompileMutationsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CompileMutationsRequest) ProtoMessage 

func (*CompileMutationsRequest) ProtoMessage()

func (*CompileMutationsRequest) Reset 

func (m *CompileMutationsRequest) Reset()

func (*CompileMutationsRequest) Size 

func (m *CompileMutationsRequest) Size() (n int)

func (*CompileMutationsRequest) String 

func (this *CompileMutationsRequest) String() string

func (*CompileMutationsRequest) Unmarshal 

func (m *CompileMutationsRequest) Unmarshal(dAtA []byte) error

func (*CompileMutationsRequest) XXX_DiscardUnknown 

func (m *CompileMutationsRequest) XXX_DiscardUnknown()

func (*CompileMutationsRequest) XXX_Marshal 

func (m *CompileMutationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompileMutationsRequest) XXX_Merge 

func (m *CompileMutationsRequest) XXX_Merge(src proto.Message)

func (*CompileMutationsRequest) XXX_Size 

func (m *CompileMutationsRequest) XXX_Size() int

func (*CompileMutationsRequest) XXX_Unmarshal 

func (m *CompileMutationsRequest) XXX_Unmarshal(b []byte) error

type CompileMutationsResponse 

type CompileMutationsResponse struct {
	Status    *statuspb.Status   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Mutations []*CompileMutation `protobuf:"bytes,2,rep,name=mutations,proto3" json:"mutations,omitempty"`
}

func (*CompileMutationsResponse) Descriptor 

func (*CompileMutationsResponse) Descriptor() ([]byte, []int)

func (*CompileMutationsResponse) Equal 

func (this *CompileMutationsResponse) Equal(that interface{}) bool

func (*CompileMutationsResponse) GetMutations 

func (m *CompileMutationsResponse) GetMutations() []*CompileMutation

func (*CompileMutationsResponse) GetStatus 

func (m *CompileMutationsResponse) GetStatus() *statuspb.Status

func (*CompileMutationsResponse) GoString 

func (this *CompileMutationsResponse) GoString() string

func (*CompileMutationsResponse) Marshal 

func (m *CompileMutationsResponse) Marshal() (dAtA []byte, err error)

func (*CompileMutationsResponse) MarshalTo 

func (m *CompileMutationsResponse) MarshalTo(dAtA []byte) (int, error)

func (*CompileMutationsResponse) MarshalToSizedBuffer 

func (m *CompileMutationsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CompileMutationsResponse) ProtoMessage 

func (*CompileMutationsResponse) ProtoMessage()

func (*CompileMutationsResponse) Reset 

func (m *CompileMutationsResponse) Reset()

func (*CompileMutationsResponse) Size 

func (m *CompileMutationsResponse) Size() (n int)

func (*CompileMutationsResponse) String 

func (this *CompileMutationsResponse) String() string

func (*CompileMutationsResponse) Unmarshal 

func (m *CompileMutationsResponse) Unmarshal(dAtA []byte) error

func (*CompileMutationsResponse) XXX_DiscardUnknown 

func (m *CompileMutationsResponse) XXX_DiscardUnknown()

func (*CompileMutationsResponse) XXX_Marshal 

func (m *CompileMutationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompileMutationsResponse) XXX_Merge 

func (m *CompileMutationsResponse) XXX_Merge(src proto.Message)

func (*CompileMutationsResponse) XXX_Size 

func (m *CompileMutationsResponse) XXX_Size() int

func (*CompileMutationsResponse) XXX_Unmarshal 

func (m *CompileMutationsResponse) XXX_Unmarshal(b []byte) error

type ConfigUpdate 

type ConfigUpdate struct {
	Key          string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value        string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	AgentPodName string `protobuf:"bytes,3,opt,name=agent_pod_name,json=agentPodName,proto3" json:"agent_pod_name,omitempty"`
}

func (*ConfigUpdate) Descriptor 

func (*ConfigUpdate) Descriptor() ([]byte, []int)

func (*ConfigUpdate) Equal 

func (this *ConfigUpdate) Equal(that interface{}) bool

func (*ConfigUpdate) GetAgentPodName 

func (m *ConfigUpdate) GetAgentPodName() string

func (*ConfigUpdate) GetKey 

func (m *ConfigUpdate) GetKey() string

func (*ConfigUpdate) GetValue 

func (m *ConfigUpdate) GetValue() string

func (*ConfigUpdate) GoString 

func (this *ConfigUpdate) GoString() string

func (*ConfigUpdate) Marshal 

func (m *ConfigUpdate) Marshal() (dAtA []byte, err error)

func (*ConfigUpdate) MarshalTo 

func (m *ConfigUpdate) MarshalTo(dAtA []byte) (int, error)

func (*ConfigUpdate) MarshalToSizedBuffer 

func (m *ConfigUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConfigUpdate) ProtoMessage 

func (*ConfigUpdate) ProtoMessage()

func (*ConfigUpdate) Reset 

func (m *ConfigUpdate) Reset()

func (*ConfigUpdate) Size 

func (m *ConfigUpdate) Size() (n int)

func (*ConfigUpdate) String 

func (this *ConfigUpdate) String() string

func (*ConfigUpdate) Unmarshal 

func (m *ConfigUpdate) Unmarshal(dAtA []byte) error

func (*ConfigUpdate) XXX_DiscardUnknown 

func (m *ConfigUpdate) XXX_DiscardUnknown()

func (*ConfigUpdate) XXX_Marshal 

func (m *ConfigUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigUpdate) XXX_Merge 

func (m *ConfigUpdate) XXX_Merge(src proto.Message)

func (*ConfigUpdate) XXX_Size 

func (m *ConfigUpdate) XXX_Size() int

func (*ConfigUpdate) XXX_Unmarshal 

func (m *ConfigUpdate) XXX_Unmarshal(b []byte) error

type Configs 

type Configs struct {
	OTelEndpointConfig *Configs_OTelEndpointConfig `protobuf:"bytes,1,opt,name=otel_endpoint_config,json=otelEndpointConfig,proto3" json:"otel_endpoint_config,omitempty"`
	PluginConfig       *Configs_PluginConfig       `protobuf:"bytes,2,opt,name=plugin_config,json=pluginConfig,proto3" json:"plugin_config,omitempty"`
}

func (*Configs) Descriptor 

func (*Configs) Descriptor() ([]byte, []int)

func (*Configs) Equal 

func (this *Configs) Equal(that interface{}) bool

func (*Configs) GetOTelEndpointConfig 

func (m *Configs) GetOTelEndpointConfig() *Configs_OTelEndpointConfig

func (*Configs) GetPluginConfig 

func (m *Configs) GetPluginConfig() *Configs_PluginConfig

func (*Configs) GoString 

func (this *Configs) GoString() string

func (*Configs) Marshal 

func (m *Configs) Marshal() (dAtA []byte, err error)

func (*Configs) MarshalTo 

func (m *Configs) MarshalTo(dAtA []byte) (int, error)

func (*Configs) MarshalToSizedBuffer 

func (m *Configs) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Configs) ProtoMessage 

func (*Configs) ProtoMessage()

func (*Configs) Reset 

func (m *Configs) Reset()

func (*Configs) Size 

func (m *Configs) Size() (n int)

func (*Configs) String 

func (this *Configs) String() string

func (*Configs) Unmarshal 

func (m *Configs) Unmarshal(dAtA []byte) error

func (*Configs) XXX_DiscardUnknown 

func (m *Configs) XXX_DiscardUnknown()

func (*Configs) XXX_Marshal 

func (m *Configs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Configs) XXX_Merge 

func (m *Configs) XXX_Merge(src proto.Message)

func (*Configs) XXX_Size 

func (m *Configs) XXX_Size() int

func (*Configs) XXX_Unmarshal 

func (m *Configs) XXX_Unmarshal(b []byte) error

type Configs_OTelEndpointConfig 

type Configs_OTelEndpointConfig struct {
	URL      string            `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Headers  map[string]string `` /* 155-byte string literal not displayed */
	Insecure bool              `protobuf:"varint,3,opt,name=insecure,proto3" json:"insecure,omitempty"`
	Timeout  int64             `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
}

func (*Configs_OTelEndpointConfig) Descriptor 

func (*Configs_OTelEndpointConfig) Descriptor() ([]byte, []int)

func (*Configs_OTelEndpointConfig) Equal 

func (this *Configs_OTelEndpointConfig) Equal(that interface{}) bool

func (*Configs_OTelEndpointConfig) GetHeaders 

func (m *Configs_OTelEndpointConfig) GetHeaders() map[string]string

func (*Configs_OTelEndpointConfig) GetInsecure 

func (m *Configs_OTelEndpointConfig) GetInsecure() bool

func (*Configs_OTelEndpointConfig) GetTimeout 

func (m *Configs_OTelEndpointConfig) GetTimeout() int64

func (*Configs_OTelEndpointConfig) GetURL 

func (m *Configs_OTelEndpointConfig) GetURL() string

func (*Configs_OTelEndpointConfig) GoString 

func (this *Configs_OTelEndpointConfig) GoString() string

func (*Configs_OTelEndpointConfig) Marshal 

func (m *Configs_OTelEndpointConfig) Marshal() (dAtA []byte, err error)

func (*Configs_OTelEndpointConfig) MarshalTo 

func (m *Configs_OTelEndpointConfig) MarshalTo(dAtA []byte) (int, error)

func (*Configs_OTelEndpointConfig) MarshalToSizedBuffer 

func (m *Configs_OTelEndpointConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Configs_OTelEndpointConfig) ProtoMessage 

func (*Configs_OTelEndpointConfig) ProtoMessage()

func (*Configs_OTelEndpointConfig) Reset 

func (m *Configs_OTelEndpointConfig) Reset()

func (*Configs_OTelEndpointConfig) Size 

func (m *Configs_OTelEndpointConfig) Size() (n int)

func (*Configs_OTelEndpointConfig) String 

func (this *Configs_OTelEndpointConfig) String() string

func (*Configs_OTelEndpointConfig) Unmarshal 

func (m *Configs_OTelEndpointConfig) Unmarshal(dAtA []byte) error

func (*Configs_OTelEndpointConfig) XXX_DiscardUnknown 

func (m *Configs_OTelEndpointConfig) XXX_DiscardUnknown()

func (*Configs_OTelEndpointConfig) XXX_Marshal 

func (m *Configs_OTelEndpointConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Configs_OTelEndpointConfig) XXX_Merge 

func (m *Configs_OTelEndpointConfig) XXX_Merge(src proto.Message)

func (*Configs_OTelEndpointConfig) XXX_Size 

func (m *Configs_OTelEndpointConfig) XXX_Size() int

func (*Configs_OTelEndpointConfig) XXX_Unmarshal 

func (m *Configs_OTelEndpointConfig) XXX_Unmarshal(b []byte) error

type Configs_PluginConfig 

type Configs_PluginConfig struct {
	StartTimeNs int64 `protobuf:"varint,1,opt,name=start_time_ns,json=startTimeNs,proto3" json:"start_time_ns,omitempty"`
	EndTimeNs   int64 `protobuf:"varint,2,opt,name=end_time_ns,json=endTimeNs,proto3" json:"end_time_ns,omitempty"`
}

func (*Configs_PluginConfig) Descriptor 

func (*Configs_PluginConfig) Descriptor() ([]byte, []int)

func (*Configs_PluginConfig) Equal 

func (this *Configs_PluginConfig) Equal(that interface{}) bool

func (*Configs_PluginConfig) GetEndTimeNs 

func (m *Configs_PluginConfig) GetEndTimeNs() int64

func (*Configs_PluginConfig) GetStartTimeNs 

func (m *Configs_PluginConfig) GetStartTimeNs() int64

func (*Configs_PluginConfig) GoString 

func (this *Configs_PluginConfig) GoString() string

func (*Configs_PluginConfig) Marshal 

func (m *Configs_PluginConfig) Marshal() (dAtA []byte, err error)

func (*Configs_PluginConfig) MarshalTo 

func (m *Configs_PluginConfig) MarshalTo(dAtA []byte) (int, error)

func (*Configs_PluginConfig) MarshalToSizedBuffer 

func (m *Configs_PluginConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Configs_PluginConfig) ProtoMessage 

func (*Configs_PluginConfig) ProtoMessage()

func (*Configs_PluginConfig) Reset 

func (m *Configs_PluginConfig) Reset()

func (*Configs_PluginConfig) Size 

func (m *Configs_PluginConfig) Size() (n int)

func (*Configs_PluginConfig) String 

func (this *Configs_PluginConfig) String() string

func (*Configs_PluginConfig) Unmarshal 

func (m *Configs_PluginConfig) Unmarshal(dAtA []byte) error

func (*Configs_PluginConfig) XXX_DiscardUnknown 

func (m *Configs_PluginConfig) XXX_DiscardUnknown()

func (*Configs_PluginConfig) XXX_Marshal 

func (m *Configs_PluginConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Configs_PluginConfig) XXX_Merge 

func (m *Configs_PluginConfig) XXX_Merge(src proto.Message)

func (*Configs_PluginConfig) XXX_Size 

func (m *Configs_PluginConfig) XXX_Size() int

func (*Configs_PluginConfig) XXX_Unmarshal 

func (m *Configs_PluginConfig) XXX_Unmarshal(b []byte) error

type DeleteTracepoint 

type DeleteTracepoint struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*DeleteTracepoint) Descriptor 

func (*DeleteTracepoint) Descriptor() ([]byte, []int)

func (*DeleteTracepoint) Equal 

func (this *DeleteTracepoint) Equal(that interface{}) bool

func (*DeleteTracepoint) GetName 

func (m *DeleteTracepoint) GetName() string

func (*DeleteTracepoint) GoString 

func (this *DeleteTracepoint) GoString() string

func (*DeleteTracepoint) Marshal 

func (m *DeleteTracepoint) Marshal() (dAtA []byte, err error)

func (*DeleteTracepoint) MarshalTo 

func (m *DeleteTracepoint) MarshalTo(dAtA []byte) (int, error)

func (*DeleteTracepoint) MarshalToSizedBuffer 

func (m *DeleteTracepoint) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteTracepoint) ProtoMessage 

func (*DeleteTracepoint) ProtoMessage()

func (*DeleteTracepoint) Reset 

func (m *DeleteTracepoint) Reset()

func (*DeleteTracepoint) Size 

func (m *DeleteTracepoint) Size() (n int)

func (*DeleteTracepoint) String 

func (this *DeleteTracepoint) String() string

func (*DeleteTracepoint) Unmarshal 

func (m *DeleteTracepoint) Unmarshal(dAtA []byte) error

func (*DeleteTracepoint) XXX_DiscardUnknown 

func (m *DeleteTracepoint) XXX_DiscardUnknown()

func (*DeleteTracepoint) XXX_Marshal 

func (m *DeleteTracepoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteTracepoint) XXX_Merge 

func (m *DeleteTracepoint) XXX_Merge(src proto.Message)

func (*DeleteTracepoint) XXX_Size 

func (m *DeleteTracepoint) XXX_Size() int

func (*DeleteTracepoint) XXX_Unmarshal 

func (m *DeleteTracepoint) XXX_Unmarshal(b []byte) error

type FuncToExecute 

type FuncToExecute struct {
	FuncName          string                    `protobuf:"bytes,1,opt,name=func_name,json=funcName,proto3" json:"func_name,omitempty"`
	ArgValues         []*FuncToExecute_ArgValue `protobuf:"bytes,2,rep,name=arg_values,json=argValues,proto3" json:"arg_values,omitempty"`
	OutputTablePrefix string                    `protobuf:"bytes,3,opt,name=output_table_prefix,json=outputTablePrefix,proto3" json:"output_table_prefix,omitempty"`
}

func (*FuncToExecute) Descriptor 

func (*FuncToExecute) Descriptor() ([]byte, []int)

func (*FuncToExecute) Equal 

func (this *FuncToExecute) Equal(that interface{}) bool

func (*FuncToExecute) GetArgValues 

func (m *FuncToExecute) GetArgValues() []*FuncToExecute_ArgValue

func (*FuncToExecute) GetFuncName 

func (m *FuncToExecute) GetFuncName() string

func (*FuncToExecute) GetOutputTablePrefix 

func (m *FuncToExecute) GetOutputTablePrefix() string

func (*FuncToExecute) GoString 

func (this *FuncToExecute) GoString() string

func (*FuncToExecute) Marshal 

func (m *FuncToExecute) Marshal() (dAtA []byte, err error)

func (*FuncToExecute) MarshalTo 

func (m *FuncToExecute) MarshalTo(dAtA []byte) (int, error)

func (*FuncToExecute) MarshalToSizedBuffer 

func (m *FuncToExecute) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FuncToExecute) ProtoMessage 

func (*FuncToExecute) ProtoMessage()

func (*FuncToExecute) Reset 

func (m *FuncToExecute) Reset()

func (*FuncToExecute) Size 

func (m *FuncToExecute) Size() (n int)

func (*FuncToExecute) String 

func (this *FuncToExecute) String() string

func (*FuncToExecute) Unmarshal 

func (m *FuncToExecute) Unmarshal(dAtA []byte) error

func (*FuncToExecute) XXX_DiscardUnknown 

func (m *FuncToExecute) XXX_DiscardUnknown()

func (*FuncToExecute) XXX_Marshal 

func (m *FuncToExecute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FuncToExecute) XXX_Merge 

func (m *FuncToExecute) XXX_Merge(src proto.Message)

func (*FuncToExecute) XXX_Size 

func (m *FuncToExecute) XXX_Size() int

func (*FuncToExecute) XXX_Unmarshal 

func (m *FuncToExecute) XXX_Unmarshal(b []byte) error

type FuncToExecute_ArgValue 

type FuncToExecute_ArgValue struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*FuncToExecute_ArgValue) Descriptor 

func (*FuncToExecute_ArgValue) Descriptor() ([]byte, []int)

func (*FuncToExecute_ArgValue) Equal 

func (this *FuncToExecute_ArgValue) Equal(that interface{}) bool

func (*FuncToExecute_ArgValue) GetName 

func (m *FuncToExecute_ArgValue) GetName() string

func (*FuncToExecute_ArgValue) GetValue 

func (m *FuncToExecute_ArgValue) GetValue() string

func (*FuncToExecute_ArgValue) GoString 

func (this *FuncToExecute_ArgValue) GoString() string

func (*FuncToExecute_ArgValue) Marshal 

func (m *FuncToExecute_ArgValue) Marshal() (dAtA []byte, err error)

func (*FuncToExecute_ArgValue) MarshalTo 

func (m *FuncToExecute_ArgValue) MarshalTo(dAtA []byte) (int, error)

func (*FuncToExecute_ArgValue) MarshalToSizedBuffer 

func (m *FuncToExecute_ArgValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FuncToExecute_ArgValue) ProtoMessage 

func (*FuncToExecute_ArgValue) ProtoMessage()

func (*FuncToExecute_ArgValue) Reset 

func (m *FuncToExecute_ArgValue) Reset()

func (*FuncToExecute_ArgValue) Size 

func (m *FuncToExecute_ArgValue) Size() (n int)

func (*FuncToExecute_ArgValue) String 

func (this *FuncToExecute_ArgValue) String() string

func (*FuncToExecute_ArgValue) Unmarshal 

func (m *FuncToExecute_ArgValue) Unmarshal(dAtA []byte) error

func (*FuncToExecute_ArgValue) XXX_DiscardUnknown 

func (m *FuncToExecute_ArgValue) XXX_DiscardUnknown()

func (*FuncToExecute_ArgValue) XXX_Marshal 

func (m *FuncToExecute_ArgValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FuncToExecute_ArgValue) XXX_Merge 

func (m *FuncToExecute_ArgValue) XXX_Merge(src proto.Message)

func (*FuncToExecute_ArgValue) XXX_Size 

func (m *FuncToExecute_ArgValue) XXX_Size() int

func (*FuncToExecute_ArgValue) XXX_Unmarshal 

func (m *FuncToExecute_ArgValue) XXX_Unmarshal(b []byte) error

type GenerateOTelScriptRequest 

type GenerateOTelScriptRequest struct {
	LogicalPlannerState *distributedpb.LogicalPlannerState `protobuf:"bytes,1,opt,name=logical_planner_state,json=logicalPlannerState,proto3" json:"logical_planner_state,omitempty"`
	PxlScript           string                             `protobuf:"bytes,2,opt,name=pxl_script,json=pxlScript,proto3" json:"pxl_script,omitempty"`
}

func (*GenerateOTelScriptRequest) Descriptor 

func (*GenerateOTelScriptRequest) Descriptor() ([]byte, []int)

func (*GenerateOTelScriptRequest) Equal 

func (this *GenerateOTelScriptRequest) Equal(that interface{}) bool

func (*GenerateOTelScriptRequest) GetLogicalPlannerState 

func (m *GenerateOTelScriptRequest) GetLogicalPlannerState() *distributedpb.LogicalPlannerState

func (*GenerateOTelScriptRequest) GetPxlScript 

func (m *GenerateOTelScriptRequest) GetPxlScript() string

func (*GenerateOTelScriptRequest) GoString 

func (this *GenerateOTelScriptRequest) GoString() string

func (*GenerateOTelScriptRequest) Marshal 

func (m *GenerateOTelScriptRequest) Marshal() (dAtA []byte, err error)

func (*GenerateOTelScriptRequest) MarshalTo 

func (m *GenerateOTelScriptRequest) MarshalTo(dAtA []byte) (int, error)

func (*GenerateOTelScriptRequest) MarshalToSizedBuffer 

func (m *GenerateOTelScriptRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenerateOTelScriptRequest) ProtoMessage 

func (*GenerateOTelScriptRequest) ProtoMessage()

func (*GenerateOTelScriptRequest) Reset 

func (m *GenerateOTelScriptRequest) Reset()

func (*GenerateOTelScriptRequest) Size 

func (m *GenerateOTelScriptRequest) Size() (n int)

func (*GenerateOTelScriptRequest) String 

func (this *GenerateOTelScriptRequest) String() string

func (*GenerateOTelScriptRequest) Unmarshal 

func (m *GenerateOTelScriptRequest) Unmarshal(dAtA []byte) error

func (*GenerateOTelScriptRequest) XXX_DiscardUnknown 

func (m *GenerateOTelScriptRequest) XXX_DiscardUnknown()

func (*GenerateOTelScriptRequest) XXX_Marshal 

func (m *GenerateOTelScriptRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenerateOTelScriptRequest) XXX_Merge 

func (m *GenerateOTelScriptRequest) XXX_Merge(src proto.Message)

func (*GenerateOTelScriptRequest) XXX_Size 

func (m *GenerateOTelScriptRequest) XXX_Size() int

func (*GenerateOTelScriptRequest) XXX_Unmarshal 

func (m *GenerateOTelScriptRequest) XXX_Unmarshal(b []byte) error

type GenerateOTelScriptResponse 

type GenerateOTelScriptResponse struct {
	Status     *statuspb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	OTelScript string           `protobuf:"bytes,2,opt,name=otel_script,json=otelScript,proto3" json:"otel_script,omitempty"`
}

func (*GenerateOTelScriptResponse) Descriptor 

func (*GenerateOTelScriptResponse) Descriptor() ([]byte, []int)

func (*GenerateOTelScriptResponse) Equal 

func (this *GenerateOTelScriptResponse) Equal(that interface{}) bool

func (*GenerateOTelScriptResponse) GetOTelScript 

func (m *GenerateOTelScriptResponse) GetOTelScript() string

func (*GenerateOTelScriptResponse) GetStatus 

func (m *GenerateOTelScriptResponse) GetStatus() *statuspb.Status

func (*GenerateOTelScriptResponse) GoString 

func (this *GenerateOTelScriptResponse) GoString() string

func (*GenerateOTelScriptResponse) Marshal 

func (m *GenerateOTelScriptResponse) Marshal() (dAtA []byte, err error)

func (*GenerateOTelScriptResponse) MarshalTo 

func (m *GenerateOTelScriptResponse) MarshalTo(dAtA []byte) (int, error)

func (*GenerateOTelScriptResponse) MarshalToSizedBuffer 

func (m *GenerateOTelScriptResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenerateOTelScriptResponse) ProtoMessage 

func (*GenerateOTelScriptResponse) ProtoMessage()

func (*GenerateOTelScriptResponse) Reset 

func (m *GenerateOTelScriptResponse) Reset()

func (*GenerateOTelScriptResponse) Size 

func (m *GenerateOTelScriptResponse) Size() (n int)

func (*GenerateOTelScriptResponse) String 

func (this *GenerateOTelScriptResponse) String() string

func (*GenerateOTelScriptResponse) Unmarshal 

func (m *GenerateOTelScriptResponse) Unmarshal(dAtA []byte) error

func (*GenerateOTelScriptResponse) XXX_DiscardUnknown 

func (m *GenerateOTelScriptResponse) XXX_DiscardUnknown()

func (*GenerateOTelScriptResponse) XXX_Marshal 

func (m *GenerateOTelScriptResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenerateOTelScriptResponse) XXX_Merge 

func (m *GenerateOTelScriptResponse) XXX_Merge(src proto.Message)

func (*GenerateOTelScriptResponse) XXX_Size 

func (m *GenerateOTelScriptResponse) XXX_Size() int

func (*GenerateOTelScriptResponse) XXX_Unmarshal 

func (m *GenerateOTelScriptResponse) XXX_Unmarshal(b []byte) error

type PlannerServiceClient 

type PlannerServiceClient interface {
	CompileQuery(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	CompileMutations(ctx context.Context, in *CompileMutationsRequest, opts ...grpc.CallOption) (*CompileMutationsResponse, error)
	GenerateOTelScript(ctx context.Context, in *GenerateOTelScriptRequest, opts ...grpc.CallOption) (*GenerateOTelScriptResponse, error)
}

PlannerServiceClient is the client API for PlannerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPlannerServiceClient 

func NewPlannerServiceClient(cc *grpc.ClientConn) PlannerServiceClient

type PlannerServiceServer 

type PlannerServiceServer interface {
	CompileQuery(context.Context, *QueryRequest) (*QueryResponse, error)
	CompileMutations(context.Context, *CompileMutationsRequest) (*CompileMutationsResponse, error)
	GenerateOTelScript(context.Context, *GenerateOTelScriptRequest) (*GenerateOTelScriptResponse, error)
}

PlannerServiceServer is the server API for PlannerService service.

type QueryRequest 

type QueryRequest struct {
	LogicalPlannerState *distributedpb.LogicalPlannerState `protobuf:"bytes,5,opt,name=logical_planner_state,json=logicalPlannerState,proto3" json:"logical_planner_state,omitempty"`
	QueryStr            string                             `protobuf:"bytes,1,opt,name=query_str,json=queryStr,proto3" json:"query_str,omitempty"`
	ExecFuncs           []*FuncToExecute                   `protobuf:"bytes,3,rep,name=exec_funcs,json=execFuncs,proto3" json:"exec_funcs,omitempty"`
	Configs             *Configs                           `protobuf:"bytes,4,opt,name=configs,proto3" json:"configs,omitempty"`
}

func (*QueryRequest) Descriptor 

func (*QueryRequest) Descriptor() ([]byte, []int)

func (*QueryRequest) Equal 

func (this *QueryRequest) Equal(that interface{}) bool

func (*QueryRequest) GetConfigs 

func (m *QueryRequest) GetConfigs() *Configs

func (*QueryRequest) GetExecFuncs 

func (m *QueryRequest) GetExecFuncs() []*FuncToExecute

func (*QueryRequest) GetLogicalPlannerState 

func (m *QueryRequest) GetLogicalPlannerState() *distributedpb.LogicalPlannerState

func (*QueryRequest) GetQueryStr 

func (m *QueryRequest) GetQueryStr() string

func (*QueryRequest) GoString 

func (this *QueryRequest) GoString() string

func (*QueryRequest) Marshal 

func (m *QueryRequest) Marshal() (dAtA []byte, err error)

func (*QueryRequest) MarshalTo 

func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryRequest) MarshalToSizedBuffer 

func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset 

func (m *QueryRequest) Reset()

func (*QueryRequest) Size 

func (m *QueryRequest) Size() (n int)

func (*QueryRequest) String 

func (this *QueryRequest) String() string

func (*QueryRequest) Unmarshal 

func (m *QueryRequest) Unmarshal(dAtA []byte) error

func (*QueryRequest) XXX_DiscardUnknown 

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal 

func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequest) XXX_Merge 

func (m *QueryRequest) XXX_Merge(src proto.Message)

func (*QueryRequest) XXX_Size 

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal 

func (m *QueryRequest) XXX_Unmarshal(b []byte) error

type QueryResponse 

type QueryResponse struct {
	Status *statuspb.Status               `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Plan   *distributedpb.DistributedPlan `protobuf:"bytes,2,opt,name=plan,proto3" json:"plan,omitempty"`
}

func (*QueryResponse) Descriptor 

func (*QueryResponse) Descriptor() ([]byte, []int)

func (*QueryResponse) Equal 

func (this *QueryResponse) Equal(that interface{}) bool

func (*QueryResponse) GetPlan 

func (m *QueryResponse) GetPlan() *distributedpb.DistributedPlan

func (*QueryResponse) GetStatus 

func (m *QueryResponse) GetStatus() *statuspb.Status

func (*QueryResponse) GoString 

func (this *QueryResponse) GoString() string

func (*QueryResponse) Marshal 

func (m *QueryResponse) Marshal() (dAtA []byte, err error)

func (*QueryResponse) MarshalTo 

func (m *QueryResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryResponse) MarshalToSizedBuffer 

func (m *QueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset 

func (m *QueryResponse) Reset()

func (*QueryResponse) Size 

func (m *QueryResponse) Size() (n int)

func (*QueryResponse) String 

func (this *QueryResponse) String() string

func (*QueryResponse) Unmarshal 

func (m *QueryResponse) Unmarshal(dAtA []byte) error

func (*QueryResponse) XXX_DiscardUnknown 

func (m *QueryResponse) XXX_DiscardUnknown()

func (*QueryResponse) XXX_Marshal 

func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryResponse) XXX_Merge 

func (m *QueryResponse) XXX_Merge(src proto.Message)

func (*QueryResponse) XXX_Size 

func (m *QueryResponse) XXX_Size() int

func (*QueryResponse) XXX_Unmarshal 

func (m *QueryResponse) XXX_Unmarshal(b []byte) error

type UnimplementedPlannerServiceServer 

type UnimplementedPlannerServiceServer struct {
}

UnimplementedPlannerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPlannerServiceServer) CompileMutations 

func (*UnimplementedPlannerServiceServer) CompileMutations(ctx context.Context, req *CompileMutationsRequest) (*CompileMutationsResponse, error)

func (*UnimplementedPlannerServiceServer) CompileQuery 

func (*UnimplementedPlannerServiceServer) CompileQuery(ctx context.Context, req *QueryRequest) (*QueryResponse, error)

func (*UnimplementedPlannerServiceServer) GenerateOTelScript 

func (*UnimplementedPlannerServiceServer) GenerateOTelScript(ctx context.Context, req *GenerateOTelScriptRequest) (*GenerateOTelScriptResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.