v1

package
v0.0.0-...-2f63041 Latest Latest
Warning

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

 Go to latest Published: Aug 22, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DataprimeQueryService_Query_FullMethodName = "/com.coralogixapis.dataprime.v1.DataprimeQueryService/Query"
)

Variables

View Source 
var (
	Metadata_Tier_name = map[int32]string{
		0: "TIER_UNSPECIFIED",
		1: "TIER_ARCHIVE",
		2: "TIER_FREQUENT_SEARCH",
	}
	Metadata_Tier_value = map[string]int32{
		"TIER_UNSPECIFIED":     0,
		"TIER_ARCHIVE":         1,
		"TIER_FREQUENT_SEARCH": 2,
	}
)

Enum value maps for Metadata_Tier.

View Source 
var (
	Metadata_QuerySyntax_name = map[int32]string{
		0: "QUERY_SYNTAX_UNSPECIFIED",
		1: "QUERY_SYNTAX_LUCENE",
		2: "QUERY_SYNTAX_DATAPRIME",
	}
	Metadata_QuerySyntax_value = map[string]int32{
		"QUERY_SYNTAX_UNSPECIFIED": 0,
		"QUERY_SYNTAX_LUCENE":      1,
		"QUERY_SYNTAX_DATAPRIME":   2,
	}
)

Enum value maps for Metadata_QuerySyntax.

View Source 
var DataprimeQueryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.coralogixapis.dataprime.v1.DataprimeQueryService",
	HandlerType: (*DataprimeQueryServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Query",
			Handler:       _DataprimeQueryService_Query_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "com/coralogixapis/dataprime/v1/query_service.proto",
}

DataprimeQueryService_ServiceDesc is the grpc.ServiceDesc for DataprimeQueryService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_com_coralogixapis_dataprime_v1_query_service_proto protoreflect.FileDescriptor
View Source 
var File_com_coralogixapis_dataprime_v1_request_proto protoreflect.FileDescriptor
View Source 
var File_com_coralogixapis_dataprime_v1_response_proto protoreflect.FileDescriptor

Functions

func RegisterDataprimeQueryServiceServer 

func RegisterDataprimeQueryServiceServer(s grpc.ServiceRegistrar, srv DataprimeQueryServiceServer)

Types

type AggregationBucketsLimitWarning 

type AggregationBucketsLimitWarning struct {
	AggregationBucketsLimit int32 `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

warning for reaching aggregation buckets limit

func (*AggregationBucketsLimitWarning) Descriptor deprecated 

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

Deprecated: Use AggregationBucketsLimitWarning.ProtoReflect.Descriptor instead.

func (*AggregationBucketsLimitWarning) GetAggregationBucketsLimit 

func (x *AggregationBucketsLimitWarning) GetAggregationBucketsLimit() int32

func (*AggregationBucketsLimitWarning) ProtoMessage 

func (*AggregationBucketsLimitWarning) ProtoMessage()

func (*AggregationBucketsLimitWarning) ProtoReflect 

func (x *AggregationBucketsLimitWarning) ProtoReflect() protoreflect.Message

func (*AggregationBucketsLimitWarning) Reset 

func (x *AggregationBucketsLimitWarning) Reset()

func (*AggregationBucketsLimitWarning) String 

func (x *AggregationBucketsLimitWarning) String() string

type ArchiveWarning 

type ArchiveWarning struct {

	// Types that are assignable to WarningType:
	//
	//	*ArchiveWarning_NoMetastoreData_
	//	*ArchiveWarning_BucketAccessDenied_
	//	*ArchiveWarning_BucketReadFailed_
	//	*ArchiveWarning_MissingData_
	WarningType isArchiveWarning_WarningType `protobuf_oneof:"warning_type"`
	// contains filtered or unexported fields
}

wrapper for archive related warnings

func (*ArchiveWarning) Descriptor deprecated 

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

Deprecated: Use ArchiveWarning.ProtoReflect.Descriptor instead.

func (*ArchiveWarning) GetBucketAccessDenied 

func (x *ArchiveWarning) GetBucketAccessDenied() *ArchiveWarning_BucketAccessDenied

func (*ArchiveWarning) GetBucketReadFailed 

func (x *ArchiveWarning) GetBucketReadFailed() *ArchiveWarning_BucketReadFailed

func (*ArchiveWarning) GetMissingData 

func (x *ArchiveWarning) GetMissingData() *ArchiveWarning_MissingData

func (*ArchiveWarning) GetNoMetastoreData 

func (x *ArchiveWarning) GetNoMetastoreData() *ArchiveWarning_NoMetastoreData

func (*ArchiveWarning) GetWarningType 

func (m *ArchiveWarning) GetWarningType() isArchiveWarning_WarningType

func (*ArchiveWarning) ProtoMessage 

func (*ArchiveWarning) ProtoMessage()

func (*ArchiveWarning) ProtoReflect 

func (x *ArchiveWarning) ProtoReflect() protoreflect.Message

func (*ArchiveWarning) Reset 

func (x *ArchiveWarning) Reset()

func (*ArchiveWarning) String 

func (x *ArchiveWarning) String() string

type ArchiveWarning_BucketAccessDenied 

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

func (*ArchiveWarning_BucketAccessDenied) Descriptor deprecated 

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

Deprecated: Use ArchiveWarning_BucketAccessDenied.ProtoReflect.Descriptor instead.

func (*ArchiveWarning_BucketAccessDenied) ProtoMessage 

func (*ArchiveWarning_BucketAccessDenied) ProtoMessage()

func (*ArchiveWarning_BucketAccessDenied) ProtoReflect 

func (x *ArchiveWarning_BucketAccessDenied) ProtoReflect() protoreflect.Message

func (*ArchiveWarning_BucketAccessDenied) Reset 

func (x *ArchiveWarning_BucketAccessDenied) Reset()

func (*ArchiveWarning_BucketAccessDenied) String 

func (x *ArchiveWarning_BucketAccessDenied) String() string

type ArchiveWarning_BucketAccessDenied_ 

type ArchiveWarning_BucketAccessDenied_ struct {
	BucketAccessDenied *ArchiveWarning_BucketAccessDenied `protobuf:"bytes,2,opt,name=bucket_access_denied,json=bucketAccessDenied,proto3,oneof"`
}

type ArchiveWarning_BucketReadFailed 

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

func (*ArchiveWarning_BucketReadFailed) Descriptor deprecated 

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

Deprecated: Use ArchiveWarning_BucketReadFailed.ProtoReflect.Descriptor instead.

func (*ArchiveWarning_BucketReadFailed) ProtoMessage 

func (*ArchiveWarning_BucketReadFailed) ProtoMessage()

func (*ArchiveWarning_BucketReadFailed) ProtoReflect 

func (x *ArchiveWarning_BucketReadFailed) ProtoReflect() protoreflect.Message

func (*ArchiveWarning_BucketReadFailed) Reset 

func (x *ArchiveWarning_BucketReadFailed) Reset()

func (*ArchiveWarning_BucketReadFailed) String 

func (x *ArchiveWarning_BucketReadFailed) String() string

type ArchiveWarning_BucketReadFailed_ 

type ArchiveWarning_BucketReadFailed_ struct {
	BucketReadFailed *ArchiveWarning_BucketReadFailed `protobuf:"bytes,3,opt,name=bucket_read_failed,json=bucketReadFailed,proto3,oneof"`
}

type ArchiveWarning_MissingData 

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

func (*ArchiveWarning_MissingData) Descriptor deprecated 

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

Deprecated: Use ArchiveWarning_MissingData.ProtoReflect.Descriptor instead.

func (*ArchiveWarning_MissingData) ProtoMessage 

func (*ArchiveWarning_MissingData) ProtoMessage()

func (*ArchiveWarning_MissingData) ProtoReflect 

func (x *ArchiveWarning_MissingData) ProtoReflect() protoreflect.Message

func (*ArchiveWarning_MissingData) Reset 

func (x *ArchiveWarning_MissingData) Reset()

func (*ArchiveWarning_MissingData) String 

func (x *ArchiveWarning_MissingData) String() string

type ArchiveWarning_MissingData_ 

type ArchiveWarning_MissingData_ struct {
	MissingData *ArchiveWarning_MissingData `protobuf:"bytes,4,opt,name=missing_data,json=missingData,proto3,oneof"`
}

type ArchiveWarning_NoMetastoreData 

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

func (*ArchiveWarning_NoMetastoreData) Descriptor deprecated 

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

Deprecated: Use ArchiveWarning_NoMetastoreData.ProtoReflect.Descriptor instead.

func (*ArchiveWarning_NoMetastoreData) ProtoMessage 

func (*ArchiveWarning_NoMetastoreData) ProtoMessage()

func (*ArchiveWarning_NoMetastoreData) ProtoReflect 

func (x *ArchiveWarning_NoMetastoreData) ProtoReflect() protoreflect.Message

func (*ArchiveWarning_NoMetastoreData) Reset 

func (x *ArchiveWarning_NoMetastoreData) Reset()

func (*ArchiveWarning_NoMetastoreData) String 

func (x *ArchiveWarning_NoMetastoreData) String() string

type ArchiveWarning_NoMetastoreData_ 

type ArchiveWarning_NoMetastoreData_ struct {
	NoMetastoreData *ArchiveWarning_NoMetastoreData `protobuf:"bytes,1,opt,name=no_metastore_data,json=noMetastoreData,proto3,oneof"`
}

type BlocksLimitWarning 

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

Warning for when query has reached maximum number of parquet blocks

func (*BlocksLimitWarning) Descriptor deprecated 

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

Deprecated: Use BlocksLimitWarning.ProtoReflect.Descriptor instead.

func (*BlocksLimitWarning) ProtoMessage 

func (*BlocksLimitWarning) ProtoMessage()

func (*BlocksLimitWarning) ProtoReflect 

func (x *BlocksLimitWarning) ProtoReflect() protoreflect.Message

func (*BlocksLimitWarning) Reset 

func (x *BlocksLimitWarning) Reset()

func (*BlocksLimitWarning) String 

func (x *BlocksLimitWarning) String() string

type BytesScannedLimitWarning 

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

warning for reaching bytes scanned limit

func (*BytesScannedLimitWarning) Descriptor deprecated 

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

Deprecated: Use BytesScannedLimitWarning.ProtoReflect.Descriptor instead.

func (*BytesScannedLimitWarning) ProtoMessage 

func (*BytesScannedLimitWarning) ProtoMessage()

func (*BytesScannedLimitWarning) ProtoReflect 

func (x *BytesScannedLimitWarning) ProtoReflect() protoreflect.Message

func (*BytesScannedLimitWarning) Reset 

func (x *BytesScannedLimitWarning) Reset()

func (*BytesScannedLimitWarning) String 

func (x *BytesScannedLimitWarning) String() string

type CompileWarning 

type CompileWarning struct {
	WarningMessage string `protobuf:"bytes,1,opt,name=warning_message,json=warningMessage,proto3" json:"warning_message,omitempty"`
	// contains filtered or unexported fields
}

warning from Dataprime compilation

func (*CompileWarning) Descriptor deprecated 

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

Deprecated: Use CompileWarning.ProtoReflect.Descriptor instead.

func (*CompileWarning) GetWarningMessage 

func (x *CompileWarning) GetWarningMessage() string

func (*CompileWarning) ProtoMessage 

func (*CompileWarning) ProtoMessage()

func (*CompileWarning) ProtoReflect 

func (x *CompileWarning) ProtoReflect() protoreflect.Message

func (*CompileWarning) Reset 

func (x *CompileWarning) Reset()

func (*CompileWarning) String 

func (x *CompileWarning) String() string

type DataprimeError 

type DataprimeError struct {
	Message *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Code    *DataprimeError_Code    `protobuf:"bytes,2,opt,name=code,proto3,oneof" json:"code,omitempty"`
	// contains filtered or unexported fields
}

wrapper for dataprime error

func (*DataprimeError) Descriptor deprecated 

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

Deprecated: Use DataprimeError.ProtoReflect.Descriptor instead.

func (*DataprimeError) GetCode 

func (x *DataprimeError) GetCode() *DataprimeError_Code

func (*DataprimeError) GetMessage 

func (x *DataprimeError) GetMessage() *wrapperspb.StringValue

func (*DataprimeError) ProtoMessage 

func (*DataprimeError) ProtoMessage()

func (*DataprimeError) ProtoReflect 

func (x *DataprimeError) ProtoReflect() protoreflect.Message

func (*DataprimeError) Reset 

func (x *DataprimeError) Reset()

func (*DataprimeError) String 

func (x *DataprimeError) String() string

type DataprimeError_Code 

type DataprimeError_Code struct {

	// Types that are assignable to Message:
	//
	//	*DataprimeError_Code_RateLimitReached
	Message isDataprimeError_Code_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*DataprimeError_Code) Descriptor deprecated 

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

Deprecated: Use DataprimeError_Code.ProtoReflect.Descriptor instead.

func (*DataprimeError_Code) GetMessage 

func (m *DataprimeError_Code) GetMessage() isDataprimeError_Code_Message

func (*DataprimeError_Code) GetRateLimitReached 

func (x *DataprimeError_Code) GetRateLimitReached() *DataprimeError_RateLimitReached

func (*DataprimeError_Code) ProtoMessage 

func (*DataprimeError_Code) ProtoMessage()

func (*DataprimeError_Code) ProtoReflect 

func (x *DataprimeError_Code) ProtoReflect() protoreflect.Message

func (*DataprimeError_Code) Reset 

func (x *DataprimeError_Code) Reset()

func (*DataprimeError_Code) String 

func (x *DataprimeError_Code) String() string

type DataprimeError_Code_RateLimitReached 

type DataprimeError_Code_RateLimitReached struct {
	RateLimitReached *DataprimeError_RateLimitReached `protobuf:"bytes,1,opt,name=rate_limit_reached,json=rateLimitReached,proto3,oneof"`
}

type DataprimeError_RateLimitReached 

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

func (*DataprimeError_RateLimitReached) Descriptor deprecated 

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

Deprecated: Use DataprimeError_RateLimitReached.ProtoReflect.Descriptor instead.

func (*DataprimeError_RateLimitReached) ProtoMessage 

func (*DataprimeError_RateLimitReached) ProtoMessage()

func (*DataprimeError_RateLimitReached) ProtoReflect 

func (x *DataprimeError_RateLimitReached) ProtoReflect() protoreflect.Message

func (*DataprimeError_RateLimitReached) Reset 

func (x *DataprimeError_RateLimitReached) Reset()

func (*DataprimeError_RateLimitReached) String 

func (x *DataprimeError_RateLimitReached) String() string

type DataprimeQueryServiceClient 

type DataprimeQueryServiceClient interface {
	// method to run dataprime text queries
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (DataprimeQueryService_QueryClient, error)
}

DataprimeQueryServiceClient is the client API for DataprimeQueryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

public service for running dataprime queries (text)

func NewDataprimeQueryServiceClient 

func NewDataprimeQueryServiceClient(cc grpc.ClientConnInterface) DataprimeQueryServiceClient

type DataprimeQueryServiceServer 

type DataprimeQueryServiceServer interface {
	// method to run dataprime text queries
	Query(*QueryRequest, DataprimeQueryService_QueryServer) error
	// contains filtered or unexported methods
}

DataprimeQueryServiceServer is the server API for DataprimeQueryService service. All implementations must embed UnimplementedDataprimeQueryServiceServer for forward compatibility

public service for running dataprime queries (text)

type DataprimeQueryService_QueryClient 

type DataprimeQueryService_QueryClient interface {
	Recv() (*QueryResponse, error)
	grpc.ClientStream
}

type DataprimeQueryService_QueryServer 

type DataprimeQueryService_QueryServer interface {
	Send(*QueryResponse) error
	grpc.ServerStream
}

type DataprimeResult 

type DataprimeResult struct {
	Results []*DataprimeResults `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

batch of results

func (*DataprimeResult) Descriptor deprecated 

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

Deprecated: Use DataprimeResult.ProtoReflect.Descriptor instead.

func (*DataprimeResult) GetResults 

func (x *DataprimeResult) GetResults() []*DataprimeResults

func (*DataprimeResult) ProtoMessage 

func (*DataprimeResult) ProtoMessage()

func (*DataprimeResult) ProtoReflect 

func (x *DataprimeResult) ProtoReflect() protoreflect.Message

func (*DataprimeResult) Reset 

func (x *DataprimeResult) Reset()

func (*DataprimeResult) String 

func (x *DataprimeResult) String() string

type DataprimeResults 

type DataprimeResults struct {
	Metadata []*DataprimeResults_KeyValue `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
	Labels   []*DataprimeResults_KeyValue `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"`
	UserData string                       `protobuf:"bytes,3,opt,name=user_data,json=userData,proto3" json:"user_data,omitempty"`
	// contains filtered or unexported fields
}

wrapper for dataprime results

func (*DataprimeResults) Descriptor deprecated 

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

Deprecated: Use DataprimeResults.ProtoReflect.Descriptor instead.

func (*DataprimeResults) GetLabels 

func (x *DataprimeResults) GetLabels() []*DataprimeResults_KeyValue

func (*DataprimeResults) GetMetadata 

func (x *DataprimeResults) GetMetadata() []*DataprimeResults_KeyValue

func (*DataprimeResults) GetUserData 

func (x *DataprimeResults) GetUserData() string

func (*DataprimeResults) ProtoMessage 

func (*DataprimeResults) ProtoMessage()

func (*DataprimeResults) ProtoReflect 

func (x *DataprimeResults) ProtoReflect() protoreflect.Message

func (*DataprimeResults) Reset 

func (x *DataprimeResults) Reset()

func (*DataprimeResults) String 

func (x *DataprimeResults) String() string

type DataprimeResults_KeyValue 

type DataprimeResults_KeyValue 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"`
	// contains filtered or unexported fields
}

func (*DataprimeResults_KeyValue) Descriptor deprecated 

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

Deprecated: Use DataprimeResults_KeyValue.ProtoReflect.Descriptor instead.

func (*DataprimeResults_KeyValue) GetKey 

func (x *DataprimeResults_KeyValue) GetKey() string

func (*DataprimeResults_KeyValue) GetValue 

func (x *DataprimeResults_KeyValue) GetValue() string

func (*DataprimeResults_KeyValue) ProtoMessage 

func (*DataprimeResults_KeyValue) ProtoMessage()

func (*DataprimeResults_KeyValue) ProtoReflect 

func (x *DataprimeResults_KeyValue) ProtoReflect() protoreflect.Message

func (*DataprimeResults_KeyValue) Reset 

func (x *DataprimeResults_KeyValue) Reset()

func (*DataprimeResults_KeyValue) String 

func (x *DataprimeResults_KeyValue) String() string

type DataprimeWarning 

type DataprimeWarning struct {

	// Types that are assignable to WarningType:
	//
	//	*DataprimeWarning_CompileWarning
	//	*DataprimeWarning_TimeRangeWarning
	//	*DataprimeWarning_NumberOfResultsLimitWarning
	//	*DataprimeWarning_BytesScannedLimitWarning
	//	*DataprimeWarning_DeprecationWarning
	//	*DataprimeWarning_BlocksLimitWarning
	//	*DataprimeWarning_AggregationBucketsLimitWarning
	//	*DataprimeWarning_ArchiveWarning
	//	*DataprimeWarning_ScrollTimeoutWarning
	WarningType isDataprimeWarning_WarningType `protobuf_oneof:"warning_type"`
	// contains filtered or unexported fields
}

warning message

func (*DataprimeWarning) Descriptor deprecated 

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

Deprecated: Use DataprimeWarning.ProtoReflect.Descriptor instead.

func (*DataprimeWarning) GetAggregationBucketsLimitWarning 

func (x *DataprimeWarning) GetAggregationBucketsLimitWarning() *AggregationBucketsLimitWarning

func (*DataprimeWarning) GetArchiveWarning 

func (x *DataprimeWarning) GetArchiveWarning() *ArchiveWarning

func (*DataprimeWarning) GetBlocksLimitWarning 

func (x *DataprimeWarning) GetBlocksLimitWarning() *BlocksLimitWarning

func (*DataprimeWarning) GetBytesScannedLimitWarning 

func (x *DataprimeWarning) GetBytesScannedLimitWarning() *BytesScannedLimitWarning

func (*DataprimeWarning) GetCompileWarning 

func (x *DataprimeWarning) GetCompileWarning() *CompileWarning

func (*DataprimeWarning) GetDeprecationWarning 

func (x *DataprimeWarning) GetDeprecationWarning() *DeprecationWarning

func (*DataprimeWarning) GetNumberOfResultsLimitWarning 

func (x *DataprimeWarning) GetNumberOfResultsLimitWarning() *NumberOfResultsLimitWarning

func (*DataprimeWarning) GetScrollTimeoutWarning 

func (x *DataprimeWarning) GetScrollTimeoutWarning() *ScrollTimeoutWarning

func (*DataprimeWarning) GetTimeRangeWarning 

func (x *DataprimeWarning) GetTimeRangeWarning() *TimeRangeWarning

func (*DataprimeWarning) GetWarningType 

func (m *DataprimeWarning) GetWarningType() isDataprimeWarning_WarningType

func (*DataprimeWarning) ProtoMessage 

func (*DataprimeWarning) ProtoMessage()

func (*DataprimeWarning) ProtoReflect 

func (x *DataprimeWarning) ProtoReflect() protoreflect.Message

func (*DataprimeWarning) Reset 

func (x *DataprimeWarning) Reset()

func (*DataprimeWarning) String 

func (x *DataprimeWarning) String() string

type DataprimeWarning_AggregationBucketsLimitWarning 

type DataprimeWarning_AggregationBucketsLimitWarning struct {
	AggregationBucketsLimitWarning *AggregationBucketsLimitWarning `protobuf:"bytes,7,opt,name=aggregation_buckets_limit_warning,json=aggregationBucketsLimitWarning,proto3,oneof"`
}

type DataprimeWarning_ArchiveWarning 

type DataprimeWarning_ArchiveWarning struct {
	ArchiveWarning *ArchiveWarning `protobuf:"bytes,8,opt,name=archive_warning,json=archiveWarning,proto3,oneof"`
}

type DataprimeWarning_BlocksLimitWarning 

type DataprimeWarning_BlocksLimitWarning struct {
	BlocksLimitWarning *BlocksLimitWarning `protobuf:"bytes,6,opt,name=blocks_limit_warning,json=blocksLimitWarning,proto3,oneof"`
}

type DataprimeWarning_BytesScannedLimitWarning 

type DataprimeWarning_BytesScannedLimitWarning struct {
	BytesScannedLimitWarning *BytesScannedLimitWarning `protobuf:"bytes,4,opt,name=bytes_scanned_limit_warning,json=bytesScannedLimitWarning,proto3,oneof"`
}

type DataprimeWarning_CompileWarning 

type DataprimeWarning_CompileWarning struct {
	CompileWarning *CompileWarning `protobuf:"bytes,1,opt,name=compile_warning,json=compileWarning,proto3,oneof"`
}

type DataprimeWarning_DeprecationWarning 

type DataprimeWarning_DeprecationWarning struct {
	DeprecationWarning *DeprecationWarning `protobuf:"bytes,5,opt,name=deprecation_warning,json=deprecationWarning,proto3,oneof"`
}

type DataprimeWarning_NumberOfResultsLimitWarning 

type DataprimeWarning_NumberOfResultsLimitWarning struct {
	NumberOfResultsLimitWarning *NumberOfResultsLimitWarning `protobuf:"bytes,3,opt,name=number_of_results_limit_warning,json=numberOfResultsLimitWarning,proto3,oneof"`
}

type DataprimeWarning_ScrollTimeoutWarning 

type DataprimeWarning_ScrollTimeoutWarning struct {
	ScrollTimeoutWarning *ScrollTimeoutWarning `protobuf:"bytes,9,opt,name=scroll_timeout_warning,json=scrollTimeoutWarning,proto3,oneof"`
}

type DataprimeWarning_TimeRangeWarning 

type DataprimeWarning_TimeRangeWarning struct {
	TimeRangeWarning *TimeRangeWarning `protobuf:"bytes,2,opt,name=time_range_warning,json=timeRangeWarning,proto3,oneof"`
}

type DeprecationWarning 

type DeprecationWarning struct {
	WarningMessage string `protobuf:"bytes,1,opt,name=warning_message,json=warningMessage,proto3" json:"warning_message,omitempty"`
	// contains filtered or unexported fields
}

warning about deprecated elements

func (*DeprecationWarning) Descriptor deprecated 

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

Deprecated: Use DeprecationWarning.ProtoReflect.Descriptor instead.

func (*DeprecationWarning) GetWarningMessage 

func (x *DeprecationWarning) GetWarningMessage() string

func (*DeprecationWarning) ProtoMessage 

func (*DeprecationWarning) ProtoMessage()

func (*DeprecationWarning) ProtoReflect 

func (x *DeprecationWarning) ProtoReflect() protoreflect.Message

func (*DeprecationWarning) Reset 

func (x *DeprecationWarning) Reset()

func (*DeprecationWarning) String 

func (x *DeprecationWarning) String() string

type Metadata 

type Metadata struct {

	// beginning of the time range for the query, default: end - 15 min or current time - 15 min if end is not defined
	StartDate *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_date,json=startDate,proto3,oneof" json:"start_date,omitempty"`
	// end of the time range for the query, default: start + 15 min or current time if start is not defined
	EndDate *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_date,json=endDate,proto3,oneof" json:"end_date,omitempty"`
	// default value for source to be used when source is omitted in a query
	DefaultSource *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=default_source,json=defaultSource,proto3,oneof" json:"default_source,omitempty"`
	// tier on which query runs
	Tier *Metadata_Tier `protobuf:"varint,4,opt,name=tier,proto3,enum=com.coralogixapis.dataprime.v1.Metadata_Tier,oneof" json:"tier,omitempty"`
	// which syntax query is written in
	Syntax *Metadata_QuerySyntax `` /* 129-byte string literal not displayed */
	// limit number of results, default: 2000; max for TIER_FREQUENT_SEARCH: 12000;  max for TIER_ARCHIVE: 50000
	Limit *int32 `protobuf:"varint,6,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// prohibit using unknown fields, ones which were not detected in the ingested data, default = false
	StrictFieldsValidation *bool `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

configuration of query execution

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetDefaultSource 

func (x *Metadata) GetDefaultSource() *wrapperspb.StringValue

func (*Metadata) GetEndDate 

func (x *Metadata) GetEndDate() *timestamppb.Timestamp

func (*Metadata) GetLimit 

func (x *Metadata) GetLimit() int32

func (*Metadata) GetStartDate 

func (x *Metadata) GetStartDate() *timestamppb.Timestamp

func (*Metadata) GetStrictFieldsValidation 

func (x *Metadata) GetStrictFieldsValidation() bool

func (*Metadata) GetSyntax 

func (x *Metadata) GetSyntax() Metadata_QuerySyntax

func (*Metadata) GetTier 

func (x *Metadata) GetTier() Metadata_Tier

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

func (x *Metadata) ProtoReflect() protoreflect.Message

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type Metadata_QuerySyntax 

type Metadata_QuerySyntax int32

syntax of the query, default: QUERY_SYNTAX_DATAPRIME 

const (
	Metadata_QUERY_SYNTAX_UNSPECIFIED Metadata_QuerySyntax = 0
	Metadata_QUERY_SYNTAX_LUCENE      Metadata_QuerySyntax = 1
	Metadata_QUERY_SYNTAX_DATAPRIME   Metadata_QuerySyntax = 2
)

func (Metadata_QuerySyntax) Descriptor 

func (Metadata_QuerySyntax) Descriptor() protoreflect.EnumDescriptor

func (Metadata_QuerySyntax) Enum 

func (x Metadata_QuerySyntax) Enum() *Metadata_QuerySyntax

func (Metadata_QuerySyntax) EnumDescriptor deprecated 

func (Metadata_QuerySyntax) EnumDescriptor() ([]byte, []int)

Deprecated: Use Metadata_QuerySyntax.Descriptor instead.

func (Metadata_QuerySyntax) Number 

func (x Metadata_QuerySyntax) Number() protoreflect.EnumNumber

func (Metadata_QuerySyntax) String 

func (x Metadata_QuerySyntax) String() string

func (Metadata_QuerySyntax) Type 

func (Metadata_QuerySyntax) Type() protoreflect.EnumType

type Metadata_Tier 

type Metadata_Tier int32

tier on which query runs, default: TIER_FREQUENT_SEARCH 

const (
	Metadata_TIER_UNSPECIFIED     Metadata_Tier = 0
	Metadata_TIER_ARCHIVE         Metadata_Tier = 1
	Metadata_TIER_FREQUENT_SEARCH Metadata_Tier = 2
)

func (Metadata_Tier) Descriptor 

func (Metadata_Tier) Descriptor() protoreflect.EnumDescriptor

func (Metadata_Tier) Enum 

func (x Metadata_Tier) Enum() *Metadata_Tier

func (Metadata_Tier) EnumDescriptor deprecated 

func (Metadata_Tier) EnumDescriptor() ([]byte, []int)

Deprecated: Use Metadata_Tier.Descriptor instead.

func (Metadata_Tier) Number 

func (x Metadata_Tier) Number() protoreflect.EnumNumber

func (Metadata_Tier) String 

func (x Metadata_Tier) String() string

func (Metadata_Tier) Type 

func (Metadata_Tier) Type() protoreflect.EnumType

type NumberOfResultsLimitWarning 

type NumberOfResultsLimitWarning struct {
	NumberOfResultsLimit int32 `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

warning from applying limit on number of results

func (*NumberOfResultsLimitWarning) Descriptor deprecated 

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

Deprecated: Use NumberOfResultsLimitWarning.ProtoReflect.Descriptor instead.

func (*NumberOfResultsLimitWarning) GetNumberOfResultsLimit 

func (x *NumberOfResultsLimitWarning) GetNumberOfResultsLimit() int32

func (*NumberOfResultsLimitWarning) ProtoMessage 

func (*NumberOfResultsLimitWarning) ProtoMessage()

func (*NumberOfResultsLimitWarning) ProtoReflect 

func (x *NumberOfResultsLimitWarning) ProtoReflect() protoreflect.Message

func (*NumberOfResultsLimitWarning) Reset 

func (x *NumberOfResultsLimitWarning) Reset()

func (*NumberOfResultsLimitWarning) String 

func (x *NumberOfResultsLimitWarning) String() string

type QueryId 

type QueryId struct {
	QueryId string `protobuf:"bytes,1,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	// contains filtered or unexported fields
}

internal identifier of the query. Can be used to simplify investigation of issues

func (*QueryId) Descriptor deprecated 

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

Deprecated: Use QueryId.ProtoReflect.Descriptor instead.

func (*QueryId) GetQueryId 

func (x *QueryId) GetQueryId() string

func (*QueryId) ProtoMessage 

func (*QueryId) ProtoMessage()

func (*QueryId) ProtoReflect 

func (x *QueryId) ProtoReflect() protoreflect.Message

func (*QueryId) Reset 

func (x *QueryId) Reset()

func (*QueryId) String 

func (x *QueryId) String() string

type QueryRequest 

type QueryRequest struct {

	// query for which you seek results
	Query *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// configuration of query execution
	Metadata *Metadata `protobuf:"bytes,2,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

dataprime text query request

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetMetadata 

func (x *QueryRequest) GetMetadata() *Metadata

func (*QueryRequest) GetQuery 

func (x *QueryRequest) GetQuery() *wrapperspb.StringValue

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

func (x *QueryRequest) ProtoReflect() protoreflect.Message

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueryResponse 

type QueryResponse struct {

	// Types that are assignable to Message:
	//
	//	*QueryResponse_Error
	//	*QueryResponse_Result
	//	*QueryResponse_Warning
	//	*QueryResponse_QueryId
	Message isQueryResponse_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

dataprime response for text query

func (*QueryResponse) Descriptor deprecated 

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

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetError 

func (x *QueryResponse) GetError() *DataprimeError

func (*QueryResponse) GetMessage 

func (m *QueryResponse) GetMessage() isQueryResponse_Message

func (*QueryResponse) GetQueryId 

func (x *QueryResponse) GetQueryId() *QueryId

func (*QueryResponse) GetResult 

func (x *QueryResponse) GetResult() *DataprimeResult

func (*QueryResponse) GetWarning 

func (x *QueryResponse) GetWarning() *DataprimeWarning

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect 

func (x *QueryResponse) ProtoReflect() protoreflect.Message

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) String 

func (x *QueryResponse) String() string

type QueryResponse_Error 

type QueryResponse_Error struct {
	Error *DataprimeError `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type QueryResponse_QueryId 

type QueryResponse_QueryId struct {
	QueryId *QueryId `protobuf:"bytes,4,opt,name=query_id,json=queryId,proto3,oneof"`
}

type QueryResponse_Result 

type QueryResponse_Result struct {
	Result *DataprimeResult `protobuf:"bytes,2,opt,name=result,proto3,oneof"`
}

type QueryResponse_Warning 

type QueryResponse_Warning struct {
	Warning *DataprimeWarning `protobuf:"bytes,3,opt,name=warning,proto3,oneof"`
}

type ScrollTimeoutWarning 

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

func (*ScrollTimeoutWarning) Descriptor deprecated 

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

Deprecated: Use ScrollTimeoutWarning.ProtoReflect.Descriptor instead.

func (*ScrollTimeoutWarning) ProtoMessage 

func (*ScrollTimeoutWarning) ProtoMessage()

func (*ScrollTimeoutWarning) ProtoReflect 

func (x *ScrollTimeoutWarning) ProtoReflect() protoreflect.Message

func (*ScrollTimeoutWarning) Reset 

func (x *ScrollTimeoutWarning) Reset()

func (*ScrollTimeoutWarning) String 

func (x *ScrollTimeoutWarning) String() string

type SerializedDataprime 

type SerializedDataprime struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

wrapper for byte AST representation

func (*SerializedDataprime) Descriptor deprecated 

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

Deprecated: Use SerializedDataprime.ProtoReflect.Descriptor instead.

func (*SerializedDataprime) GetData 

func (x *SerializedDataprime) GetData() []byte

func (*SerializedDataprime) ProtoMessage 

func (*SerializedDataprime) ProtoMessage()

func (*SerializedDataprime) ProtoReflect 

func (x *SerializedDataprime) ProtoReflect() protoreflect.Message

func (*SerializedDataprime) Reset 

func (x *SerializedDataprime) Reset()

func (*SerializedDataprime) String 

func (x *SerializedDataprime) String() string

type TimeRangeWarning 

type TimeRangeWarning struct {
	WarningMessage string                 `protobuf:"bytes,1,opt,name=warning_message,json=warningMessage,proto3" json:"warning_message,omitempty"`
	StartDate      *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_date,json=startDate,proto3,oneof" json:"start_date,omitempty"`
	EndDate        *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end_date,json=endDate,proto3,oneof" json:"end_date,omitempty"`
	// contains filtered or unexported fields
}

warning from applying time range to query

func (*TimeRangeWarning) Descriptor deprecated 

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

Deprecated: Use TimeRangeWarning.ProtoReflect.Descriptor instead.

func (*TimeRangeWarning) GetEndDate 

func (x *TimeRangeWarning) GetEndDate() *timestamppb.Timestamp

func (*TimeRangeWarning) GetStartDate 

func (x *TimeRangeWarning) GetStartDate() *timestamppb.Timestamp

func (*TimeRangeWarning) GetWarningMessage 

func (x *TimeRangeWarning) GetWarningMessage() string

func (*TimeRangeWarning) ProtoMessage 

func (*TimeRangeWarning) ProtoMessage()

func (*TimeRangeWarning) ProtoReflect 

func (x *TimeRangeWarning) ProtoReflect() protoreflect.Message

func (*TimeRangeWarning) Reset 

func (x *TimeRangeWarning) Reset()

func (*TimeRangeWarning) String 

func (x *TimeRangeWarning) String() string

type UnimplementedDataprimeQueryServiceServer 

type UnimplementedDataprimeQueryServiceServer struct {
}

UnimplementedDataprimeQueryServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDataprimeQueryServiceServer) Query 

func (UnimplementedDataprimeQueryServiceServer) Query(*QueryRequest, DataprimeQueryService_QueryServer) error

type UnsafeDataprimeQueryServiceServer 

type UnsafeDataprimeQueryServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDataprimeQueryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DataprimeQueryServiceServer will result in compilation errors.

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.