v2

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: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Events2MetricInternalService_ListE2MInternal_FullMethodName   = "/com.coralogixapis.events2metrics.v2.Events2MetricInternalService/ListE2MInternal"
	Events2MetricInternalService_ReplaceE2M_FullMethodName        = "/com.coralogixapis.events2metrics.v2.Events2MetricInternalService/ReplaceE2M"
	Events2MetricInternalService_CreateE2MInternal_FullMethodName = "/com.coralogixapis.events2metrics.v2.Events2MetricInternalService/CreateE2MInternal"
	Events2MetricInternalService_DeleteE2MInternal_FullMethodName = "/com.coralogixapis.events2metrics.v2.Events2MetricInternalService/DeleteE2MInternal"
)
View Source 
const (
	Events2MetricService_CreateE2M_FullMethodName             = "/com.coralogixapis.events2metrics.v2.Events2MetricService/CreateE2M"
	Events2MetricService_ListE2M_FullMethodName               = "/com.coralogixapis.events2metrics.v2.Events2MetricService/ListE2M"
	Events2MetricService_ReplaceE2M_FullMethodName            = "/com.coralogixapis.events2metrics.v2.Events2MetricService/ReplaceE2M"
	Events2MetricService_GetE2M_FullMethodName                = "/com.coralogixapis.events2metrics.v2.Events2MetricService/GetE2M"
	Events2MetricService_DeleteE2M_FullMethodName             = "/com.coralogixapis.events2metrics.v2.Events2MetricService/DeleteE2M"
	Events2MetricService_AtomicBatchExecuteE2M_FullMethodName = "/com.coralogixapis.events2metrics.v2.Events2MetricService/AtomicBatchExecuteE2M"
	Events2MetricService_ListLabelsCardinality_FullMethodName = "/com.coralogixapis.events2metrics.v2.Events2MetricService/ListLabelsCardinality"
	Events2MetricService_GetLimits_FullMethodName             = "/com.coralogixapis.events2metrics.v2.Events2MetricService/GetLimits"
)

Variables

View Source 
var (
	E2MType_name = map[int32]string{
		0: "E2M_TYPE_UNSPECIFIED",
		1: "E2M_TYPE_LOGS2METRICS",
		2: "E2M_TYPE_SPANS2METRICS",
	}
	E2MType_value = map[string]int32{
		"E2M_TYPE_UNSPECIFIED":   0,
		"E2M_TYPE_LOGS2METRICS":  1,
		"E2M_TYPE_SPANS2METRICS": 2,
	}
)

Enum value maps for E2MType.

View Source 
var (
	Aggregation_AggType_name = map[int32]string{
		0: "AGG_TYPE_UNSPECIFIED",
		1: "AGG_TYPE_MIN",
		2: "AGG_TYPE_MAX",
		3: "AGG_TYPE_COUNT",
		4: "AGG_TYPE_AVG",
		5: "AGG_TYPE_SUM",
		6: "AGG_TYPE_HISTOGRAM",
		7: "AGG_TYPE_SAMPLES",
	}
	Aggregation_AggType_value = map[string]int32{
		"AGG_TYPE_UNSPECIFIED": 0,
		"AGG_TYPE_MIN":         1,
		"AGG_TYPE_MAX":         2,
		"AGG_TYPE_COUNT":       3,
		"AGG_TYPE_AVG":         4,
		"AGG_TYPE_SUM":         5,
		"AGG_TYPE_HISTOGRAM":   6,
		"AGG_TYPE_SAMPLES":     7,
	}
)

Enum value maps for Aggregation_AggType.

View Source 
var (
	E2MAggSamples_SampleType_name = map[int32]string{
		0: "SAMPLE_TYPE_UNSPECIFIED",
		1: "SAMPLE_TYPE_MIN",
		2: "SAMPLE_TYPE_MAX",
	}
	E2MAggSamples_SampleType_value = map[string]int32{
		"SAMPLE_TYPE_UNSPECIFIED": 0,
		"SAMPLE_TYPE_MIN":         1,
		"SAMPLE_TYPE_MAX":         2,
	}
)

Enum value maps for E2MAggSamples_SampleType.

View Source 
var Events2MetricInternalService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.coralogixapis.events2metrics.v2.Events2MetricInternalService",
	HandlerType: (*Events2MetricInternalServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListE2MInternal",
			Handler:    _Events2MetricInternalService_ListE2MInternal_Handler,
		},
		{
			MethodName: "ReplaceE2M",
			Handler:    _Events2MetricInternalService_ReplaceE2M_Handler,
		},
		{
			MethodName: "CreateE2MInternal",
			Handler:    _Events2MetricInternalService_CreateE2MInternal_Handler,
		},
		{
			MethodName: "DeleteE2MInternal",
			Handler:    _Events2MetricInternalService_DeleteE2MInternal_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "com/coralogixapis/events2metrics/v2/events2metrics_internal_service.proto",
}

Events2MetricInternalService_ServiceDesc is the grpc.ServiceDesc for Events2MetricInternalService 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 Events2MetricService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.coralogixapis.events2metrics.v2.Events2MetricService",
	HandlerType: (*Events2MetricServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateE2M",
			Handler:    _Events2MetricService_CreateE2M_Handler,
		},
		{
			MethodName: "ListE2M",
			Handler:    _Events2MetricService_ListE2M_Handler,
		},
		{
			MethodName: "ReplaceE2M",
			Handler:    _Events2MetricService_ReplaceE2M_Handler,
		},
		{
			MethodName: "GetE2M",
			Handler:    _Events2MetricService_GetE2M_Handler,
		},
		{
			MethodName: "DeleteE2M",
			Handler:    _Events2MetricService_DeleteE2M_Handler,
		},
		{
			MethodName: "AtomicBatchExecuteE2M",
			Handler:    _Events2MetricService_AtomicBatchExecuteE2M_Handler,
		},
		{
			MethodName: "ListLabelsCardinality",
			Handler:    _Events2MetricService_ListLabelsCardinality_Handler,
		},
		{
			MethodName: "GetLimits",
			Handler:    _Events2MetricService_GetLimits_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "com/coralogixapis/events2metrics/v2/events2metrics_service.proto",
}

Events2MetricService_ServiceDesc is the grpc.ServiceDesc for Events2MetricService 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_events2metrics_v2_events2metrics_definition_proto protoreflect.FileDescriptor
View Source 
var File_com_coralogixapis_events2metrics_v2_events2metrics_internal_service_proto protoreflect.FileDescriptor
View Source 
var File_com_coralogixapis_events2metrics_v2_events2metrics_service_proto protoreflect.FileDescriptor

Functions

func RegisterEvents2MetricInternalServiceServer 

func RegisterEvents2MetricInternalServiceServer(s grpc.ServiceRegistrar, srv Events2MetricInternalServiceServer)

func RegisterEvents2MetricServiceServer 

func RegisterEvents2MetricServiceServer(s grpc.ServiceRegistrar, srv Events2MetricServiceServer)

Types

type Aggregation 

type Aggregation struct {

	// Is enabled
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Aggregation type
	AggType Aggregation_AggType `` /* 144-byte string literal not displayed */
	// Target metric field alias name
	TargetMetricName string `protobuf:"bytes,3,opt,name=target_metric_name,json=targetMetricName,proto3" json:"target_metric_name,omitempty"`
	// Aggregate metadata, samples or histogram type
	//
	// Types that are assignable to AggMetadata:
	//
	//	*Aggregation_Samples
	//	*Aggregation_Histogram
	AggMetadata isAggregation_AggMetadata `protobuf_oneof:"agg_metadata"`
	// contains filtered or unexported fields
}

E2M aggregation

func (*Aggregation) Descriptor deprecated 

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

Deprecated: Use Aggregation.ProtoReflect.Descriptor instead.

func (*Aggregation) GetAggMetadata 

func (m *Aggregation) GetAggMetadata() isAggregation_AggMetadata

func (*Aggregation) GetAggType 

func (x *Aggregation) GetAggType() Aggregation_AggType

func (*Aggregation) GetEnabled 

func (x *Aggregation) GetEnabled() bool

func (*Aggregation) GetHistogram 

func (x *Aggregation) GetHistogram() *E2MAggHistogram

func (*Aggregation) GetSamples 

func (x *Aggregation) GetSamples() *E2MAggSamples

func (*Aggregation) GetTargetMetricName 

func (x *Aggregation) GetTargetMetricName() string

func (*Aggregation) ProtoMessage 

func (*Aggregation) ProtoMessage()

func (*Aggregation) ProtoReflect 

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

func (*Aggregation) Reset 

func (x *Aggregation) Reset()

func (*Aggregation) String 

func (x *Aggregation) String() string

type Aggregation_AggType 

type Aggregation_AggType int32

Enum - Aggregation type 

const (
	Aggregation_AGG_TYPE_UNSPECIFIED Aggregation_AggType = 0
	Aggregation_AGG_TYPE_MIN         Aggregation_AggType = 1
	Aggregation_AGG_TYPE_MAX         Aggregation_AggType = 2
	Aggregation_AGG_TYPE_COUNT       Aggregation_AggType = 3
	Aggregation_AGG_TYPE_AVG         Aggregation_AggType = 4
	Aggregation_AGG_TYPE_SUM         Aggregation_AggType = 5
	Aggregation_AGG_TYPE_HISTOGRAM   Aggregation_AggType = 6
	Aggregation_AGG_TYPE_SAMPLES     Aggregation_AggType = 7
)

func (Aggregation_AggType) Descriptor 

func (Aggregation_AggType) Descriptor() protoreflect.EnumDescriptor

func (Aggregation_AggType) Enum 

func (x Aggregation_AggType) Enum() *Aggregation_AggType

func (Aggregation_AggType) EnumDescriptor deprecated 

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

Deprecated: Use Aggregation_AggType.Descriptor instead.

func (Aggregation_AggType) Number 

func (x Aggregation_AggType) Number() protoreflect.EnumNumber

func (Aggregation_AggType) String 

func (x Aggregation_AggType) String() string

func (Aggregation_AggType) Type 

func (Aggregation_AggType) Type() protoreflect.EnumType

type Aggregation_Histogram 

type Aggregation_Histogram struct {
	// E2M aggregate histogram type metadata
	Histogram *E2MAggHistogram `protobuf:"bytes,5,opt,name=histogram,proto3,oneof"`
}

type Aggregation_Samples 

type Aggregation_Samples struct {
	// E2M sample type metadata
	Samples *E2MAggSamples `protobuf:"bytes,4,opt,name=samples,proto3,oneof"`
}

type AtomicBatchExecuteE2MRequest 

type AtomicBatchExecuteE2MRequest struct {
	Requests []*E2MExecutionRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

an atomic list of e2m action that are executed in the same request

func (*AtomicBatchExecuteE2MRequest) Descriptor deprecated 

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

Deprecated: Use AtomicBatchExecuteE2MRequest.ProtoReflect.Descriptor instead.

func (*AtomicBatchExecuteE2MRequest) GetRequests 

func (x *AtomicBatchExecuteE2MRequest) GetRequests() []*E2MExecutionRequest

func (*AtomicBatchExecuteE2MRequest) ProtoMessage 

func (*AtomicBatchExecuteE2MRequest) ProtoMessage()

func (*AtomicBatchExecuteE2MRequest) ProtoReflect 

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

func (*AtomicBatchExecuteE2MRequest) Reset 

func (x *AtomicBatchExecuteE2MRequest) Reset()

func (*AtomicBatchExecuteE2MRequest) String 

func (x *AtomicBatchExecuteE2MRequest) String() string

type AtomicBatchExecuteE2MResponse 

type AtomicBatchExecuteE2MResponse struct {
	MatchingResponses []*E2MExecutionResponse `protobuf:"bytes,1,rep,name=matching_responses,json=matchingResponses,proto3" json:"matching_responses,omitempty"`
	// contains filtered or unexported fields
}

represents a response to atomic list of e2m actions

func (*AtomicBatchExecuteE2MResponse) Descriptor deprecated 

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

Deprecated: Use AtomicBatchExecuteE2MResponse.ProtoReflect.Descriptor instead.

func (*AtomicBatchExecuteE2MResponse) GetMatchingResponses 

func (x *AtomicBatchExecuteE2MResponse) GetMatchingResponses() []*E2MExecutionResponse

func (*AtomicBatchExecuteE2MResponse) ProtoMessage 

func (*AtomicBatchExecuteE2MResponse) ProtoMessage()

func (*AtomicBatchExecuteE2MResponse) ProtoReflect 

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

func (*AtomicBatchExecuteE2MResponse) Reset 

func (x *AtomicBatchExecuteE2MResponse) Reset()

func (*AtomicBatchExecuteE2MResponse) String 

func (x *AtomicBatchExecuteE2MResponse) String() string

type CreateE2MRequest 

type CreateE2MRequest struct {
	E2M *E2MCreateParams `protobuf:"bytes,1,opt,name=e2m,proto3" json:"e2m,omitempty"`
	// contains filtered or unexported fields
}

represents e2m create request

func (*CreateE2MRequest) Descriptor deprecated 

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

Deprecated: Use CreateE2MRequest.ProtoReflect.Descriptor instead.

func (*CreateE2MRequest) GetE2M 

func (x *CreateE2MRequest) GetE2M() *E2MCreateParams

func (*CreateE2MRequest) ProtoMessage 

func (*CreateE2MRequest) ProtoMessage()

func (*CreateE2MRequest) ProtoReflect 

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

func (*CreateE2MRequest) Reset 

func (x *CreateE2MRequest) Reset()

func (*CreateE2MRequest) String 

func (x *CreateE2MRequest) String() string

type CreateE2MRequestInternal 

type CreateE2MRequestInternal struct {
	E2M        *E2MCreateParams      `protobuf:"bytes,1,opt,name=e2m,proto3" json:"e2m,omitempty"`
	IsInternal *wrapperspb.BoolValue `protobuf:"bytes,2,opt,name=is_internal,json=isInternal,proto3" json:"is_internal,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateE2MRequestInternal) Descriptor deprecated 

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

Deprecated: Use CreateE2MRequestInternal.ProtoReflect.Descriptor instead.

func (*CreateE2MRequestInternal) GetE2M 

func (x *CreateE2MRequestInternal) GetE2M() *E2MCreateParams

func (*CreateE2MRequestInternal) GetIsInternal 

func (x *CreateE2MRequestInternal) GetIsInternal() *wrapperspb.BoolValue

func (*CreateE2MRequestInternal) ProtoMessage 

func (*CreateE2MRequestInternal) ProtoMessage()

func (*CreateE2MRequestInternal) ProtoReflect 

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

func (*CreateE2MRequestInternal) Reset 

func (x *CreateE2MRequestInternal) Reset()

func (*CreateE2MRequestInternal) String 

func (x *CreateE2MRequestInternal) String() string

type CreateE2MResponse 

type CreateE2MResponse struct {
	E2M *E2M `protobuf:"bytes,1,opt,name=e2m,proto3" json:"e2m,omitempty"`
	// contains filtered or unexported fields
}

represents e2m create response

func (*CreateE2MResponse) Descriptor deprecated 

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

Deprecated: Use CreateE2MResponse.ProtoReflect.Descriptor instead.

func (*CreateE2MResponse) GetE2M 

func (x *CreateE2MResponse) GetE2M() *E2M

func (*CreateE2MResponse) ProtoMessage 

func (*CreateE2MResponse) ProtoMessage()

func (*CreateE2MResponse) ProtoReflect 

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

func (*CreateE2MResponse) Reset 

func (x *CreateE2MResponse) Reset()

func (*CreateE2MResponse) String 

func (x *CreateE2MResponse) String() string

type CreateE2MResponseInternal 

type CreateE2MResponseInternal struct {
	E2M *E2M `protobuf:"bytes,1,opt,name=e2m,proto3" json:"e2m,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateE2MResponseInternal) Descriptor deprecated 

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

Deprecated: Use CreateE2MResponseInternal.ProtoReflect.Descriptor instead.

func (*CreateE2MResponseInternal) GetE2M 

func (x *CreateE2MResponseInternal) GetE2M() *E2M

func (*CreateE2MResponseInternal) ProtoMessage 

func (*CreateE2MResponseInternal) ProtoMessage()

func (*CreateE2MResponseInternal) ProtoReflect 

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

func (*CreateE2MResponseInternal) Reset 

func (x *CreateE2MResponseInternal) Reset()

func (*CreateE2MResponseInternal) String 

func (x *CreateE2MResponseInternal) String() string

type DeleteE2MRequest 

type DeleteE2MRequest struct {

	// id of e2m to be deleted
	Id *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

represents e2m delete request

func (*DeleteE2MRequest) Descriptor deprecated 

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

Deprecated: Use DeleteE2MRequest.ProtoReflect.Descriptor instead.

func (*DeleteE2MRequest) GetId 

func (x *DeleteE2MRequest) GetId() *wrapperspb.StringValue

func (*DeleteE2MRequest) ProtoMessage 

func (*DeleteE2MRequest) ProtoMessage()

func (*DeleteE2MRequest) ProtoReflect 

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

func (*DeleteE2MRequest) Reset 

func (x *DeleteE2MRequest) Reset()

func (*DeleteE2MRequest) String 

func (x *DeleteE2MRequest) String() string

type DeleteE2MRequestInternal 

type DeleteE2MRequestInternal struct {
	Id *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteE2MRequestInternal) Descriptor deprecated 

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

Deprecated: Use DeleteE2MRequestInternal.ProtoReflect.Descriptor instead.

func (*DeleteE2MRequestInternal) GetId 

func (x *DeleteE2MRequestInternal) GetId() *wrapperspb.StringValue

func (*DeleteE2MRequestInternal) ProtoMessage 

func (*DeleteE2MRequestInternal) ProtoMessage()

func (*DeleteE2MRequestInternal) ProtoReflect 

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

func (*DeleteE2MRequestInternal) Reset 

func (x *DeleteE2MRequestInternal) Reset()

func (*DeleteE2MRequestInternal) String 

func (x *DeleteE2MRequestInternal) String() string

type DeleteE2MResponse 

type DeleteE2MResponse struct {

	// id of deleted e2m
	Id *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

represents e2m delete response

func (*DeleteE2MResponse) Descriptor deprecated 

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

Deprecated: Use DeleteE2MResponse.ProtoReflect.Descriptor instead.

func (*DeleteE2MResponse) GetId 

func (x *DeleteE2MResponse) GetId() *wrapperspb.StringValue

func (*DeleteE2MResponse) ProtoMessage 

func (*DeleteE2MResponse) ProtoMessage()

func (*DeleteE2MResponse) ProtoReflect 

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

func (*DeleteE2MResponse) Reset 

func (x *DeleteE2MResponse) Reset()

func (*DeleteE2MResponse) String 

func (x *DeleteE2MResponse) String() string

type DeleteE2MResponseInternal 

type DeleteE2MResponseInternal struct {
	Id *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteE2MResponseInternal) Descriptor deprecated 

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

Deprecated: Use DeleteE2MResponseInternal.ProtoReflect.Descriptor instead.

func (*DeleteE2MResponseInternal) GetId 

func (x *DeleteE2MResponseInternal) GetId() *wrapperspb.StringValue

func (*DeleteE2MResponseInternal) ProtoMessage 

func (*DeleteE2MResponseInternal) ProtoMessage()

func (*DeleteE2MResponseInternal) ProtoReflect 

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

func (*DeleteE2MResponseInternal) Reset 

func (x *DeleteE2MResponseInternal) Reset()

func (*DeleteE2MResponseInternal) String 

func (x *DeleteE2MResponseInternal) String() string

type E2M 

type E2M struct {

	// E2M unique ID, required on update requests
	Id *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of the E2M
	Name *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the E2M
	Description *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// E2M create time
	CreateTime *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// E2M update time
	UpdateTime *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Represents the limit of the permutations and if the limit was exceeded
	Permutations *E2MPermutations `protobuf:"bytes,6,opt,name=permutations,proto3" json:"permutations,omitempty"`
	// E2M metric labels
	MetricLabels []*MetricLabel `protobuf:"bytes,7,rep,name=metric_labels,json=metricLabels,proto3" json:"metric_labels,omitempty"`
	// E2M metric fields
	MetricFields []*MetricField `protobuf:"bytes,8,rep,name=metric_fields,json=metricFields,proto3" json:"metric_fields,omitempty"`
	// E2M type logs2metrics/spans2metrics
	Type E2MType `protobuf:"varint,9,opt,name=type,proto3,enum=com.coralogixapis.events2metrics.v2.E2MType" json:"type,omitempty"`
	// Spans or logs type query
	//
	// Types that are assignable to Query:
	//
	//	*E2M_SpansQuery
	//	*E2M_LogsQuery
	Query isE2M_Query `protobuf_oneof:"query"`
	// A flag that represents if the e2m is for internal usage
	IsInternal *wrapperspb.BoolValue `protobuf:"bytes,12,opt,name=is_internal,json=isInternal,proto3" json:"is_internal,omitempty"`
	// contains filtered or unexported fields
}

E2M represents the Event to metrics base model.

func (*E2M) Descriptor deprecated 

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

Deprecated: Use E2M.ProtoReflect.Descriptor instead.

func (*E2M) GetCreateTime 

func (x *E2M) GetCreateTime() *wrapperspb.StringValue

func (*E2M) GetDescription 

func (x *E2M) GetDescription() *wrapperspb.StringValue

func (*E2M) GetId 

func (x *E2M) GetId() *wrapperspb.StringValue

func (*E2M) GetIsInternal 

func (x *E2M) GetIsInternal() *wrapperspb.BoolValue

func (*E2M) GetLogsQuery 

func (x *E2M) GetLogsQuery() *v21.LogsQuery

func (*E2M) GetMetricFields 

func (x *E2M) GetMetricFields() []*MetricField

func (*E2M) GetMetricLabels 

func (x *E2M) GetMetricLabels() []*MetricLabel

func (*E2M) GetName 

func (x *E2M) GetName() *wrapperspb.StringValue

func (*E2M) GetPermutations 

func (x *E2M) GetPermutations() *E2MPermutations

func (*E2M) GetQuery 

func (m *E2M) GetQuery() isE2M_Query

func (*E2M) GetSpansQuery 

func (x *E2M) GetSpansQuery() *v2.SpansQuery

func (*E2M) GetType 

func (x *E2M) GetType() E2MType

func (*E2M) GetUpdateTime 

func (x *E2M) GetUpdateTime() *wrapperspb.StringValue

func (*E2M) ProtoMessage 

func (*E2M) ProtoMessage()

func (*E2M) ProtoReflect 

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

func (*E2M) Reset 

func (x *E2M) Reset()

func (*E2M) String 

func (x *E2M) String() string

type E2MAggHistogram 

type E2MAggHistogram struct {

	// Buckets of the E2M
	Buckets []float32 `protobuf:"fixed32,1,rep,packed,name=buckets,proto3" json:"buckets,omitempty"`
	// contains filtered or unexported fields
}

Represents the e2m aggregate histogram

func (*E2MAggHistogram) Descriptor deprecated 

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

Deprecated: Use E2MAggHistogram.ProtoReflect.Descriptor instead.

func (*E2MAggHistogram) GetBuckets 

func (x *E2MAggHistogram) GetBuckets() []float32

func (*E2MAggHistogram) ProtoMessage 

func (*E2MAggHistogram) ProtoMessage()

func (*E2MAggHistogram) ProtoReflect 

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

func (*E2MAggHistogram) Reset 

func (x *E2MAggHistogram) Reset()

func (*E2MAggHistogram) String 

func (x *E2MAggHistogram) String() string

type E2MAggSamples 

type E2MAggSamples struct {

	// Sample type min/max
	SampleType E2MAggSamples_SampleType `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

E2M aggregate sample type

func (*E2MAggSamples) Descriptor deprecated 

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

Deprecated: Use E2MAggSamples.ProtoReflect.Descriptor instead.

func (*E2MAggSamples) GetSampleType 

func (x *E2MAggSamples) GetSampleType() E2MAggSamples_SampleType

func (*E2MAggSamples) ProtoMessage 

func (*E2MAggSamples) ProtoMessage()

func (*E2MAggSamples) ProtoReflect 

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

func (*E2MAggSamples) Reset 

func (x *E2MAggSamples) Reset()

func (*E2MAggSamples) String 

func (x *E2MAggSamples) String() string

type E2MAggSamples_SampleType 

type E2MAggSamples_SampleType int32

Enum of aggregate type 

const (
	E2MAggSamples_SAMPLE_TYPE_UNSPECIFIED E2MAggSamples_SampleType = 0
	E2MAggSamples_SAMPLE_TYPE_MIN         E2MAggSamples_SampleType = 1
	E2MAggSamples_SAMPLE_TYPE_MAX         E2MAggSamples_SampleType = 2
)

func (E2MAggSamples_SampleType) Descriptor 

func (E2MAggSamples_SampleType) Descriptor() protoreflect.EnumDescriptor

func (E2MAggSamples_SampleType) Enum 

func (x E2MAggSamples_SampleType) Enum() *E2MAggSamples_SampleType

func (E2MAggSamples_SampleType) EnumDescriptor deprecated 

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

Deprecated: Use E2MAggSamples_SampleType.Descriptor instead.

func (E2MAggSamples_SampleType) Number 

func (x E2MAggSamples_SampleType) Number() protoreflect.EnumNumber

func (E2MAggSamples_SampleType) String 

func (x E2MAggSamples_SampleType) String() string

func (E2MAggSamples_SampleType) Type 

func (E2MAggSamples_SampleType) Type() protoreflect.EnumType

type E2MCreateParams 

type E2MCreateParams struct {

	// Name of E2M to create
	Name *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Description of E2M to create
	Description *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// The permutation limit of the E2M
	PermutationsLimit *wrapperspb.Int32Value `protobuf:"bytes,3,opt,name=permutations_limit,json=permutationsLimit,proto3" json:"permutations_limit,omitempty"`
	// E2M metric labels
	MetricLabels []*MetricLabel `protobuf:"bytes,4,rep,name=metric_labels,json=metricLabels,proto3" json:"metric_labels,omitempty"`
	// E2M metric fields
	MetricFields []*MetricField `protobuf:"bytes,5,rep,name=metric_fields,json=metricFields,proto3" json:"metric_fields,omitempty"`
	// E2M type
	Type E2MType `protobuf:"varint,6,opt,name=type,proto3,enum=com.coralogixapis.events2metrics.v2.E2MType" json:"type,omitempty"`
	// E2M spans or logs query type
	//
	// Types that are assignable to Query:
	//
	//	*E2MCreateParams_SpansQuery
	//	*E2MCreateParams_LogsQuery
	Query isE2MCreateParams_Query `protobuf_oneof:"query"`
	// contains filtered or unexported fields
}

E2M Create message

func (*E2MCreateParams) Descriptor deprecated 

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

Deprecated: Use E2MCreateParams.ProtoReflect.Descriptor instead.

func (*E2MCreateParams) GetDescription 

func (x *E2MCreateParams) GetDescription() *wrapperspb.StringValue

func (*E2MCreateParams) GetLogsQuery 

func (x *E2MCreateParams) GetLogsQuery() *v21.LogsQuery

func (*E2MCreateParams) GetMetricFields 

func (x *E2MCreateParams) GetMetricFields() []*MetricField

func (*E2MCreateParams) GetMetricLabels 

func (x *E2MCreateParams) GetMetricLabels() []*MetricLabel

func (*E2MCreateParams) GetName 

func (x *E2MCreateParams) GetName() *wrapperspb.StringValue

func (*E2MCreateParams) GetPermutationsLimit 

func (x *E2MCreateParams) GetPermutationsLimit() *wrapperspb.Int32Value

func (*E2MCreateParams) GetQuery 

func (m *E2MCreateParams) GetQuery() isE2MCreateParams_Query

func (*E2MCreateParams) GetSpansQuery 

func (x *E2MCreateParams) GetSpansQuery() *v2.SpansQuery

func (*E2MCreateParams) GetType 

func (x *E2MCreateParams) GetType() E2MType

func (*E2MCreateParams) ProtoMessage 

func (*E2MCreateParams) ProtoMessage()

func (*E2MCreateParams) ProtoReflect 

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

func (*E2MCreateParams) Reset 

func (x *E2MCreateParams) Reset()

func (*E2MCreateParams) String 

func (x *E2MCreateParams) String() string

type E2MCreateParams_LogsQuery 

type E2MCreateParams_LogsQuery struct {
	// E2M logs query
	LogsQuery *v21.LogsQuery `protobuf:"bytes,8,opt,name=logs_query,json=logsQuery,proto3,oneof"`
}

type E2MCreateParams_SpansQuery 

type E2MCreateParams_SpansQuery struct {
	// E2M span query
	SpansQuery *v2.SpansQuery `protobuf:"bytes,7,opt,name=spans_query,json=spansQuery,proto3,oneof"`
}

type E2MExecutionRequest 

type E2MExecutionRequest struct {

	// Types that are assignable to Request:
	//
	//	*E2MExecutionRequest_Create
	//	*E2MExecutionRequest_Replace
	//	*E2MExecutionRequest_Delete
	Request isE2MExecutionRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

represents one of e2m actions create/replace/delete

func (*E2MExecutionRequest) Descriptor deprecated 

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

Deprecated: Use E2MExecutionRequest.ProtoReflect.Descriptor instead.

func (*E2MExecutionRequest) GetCreate 

func (x *E2MExecutionRequest) GetCreate() *CreateE2MRequest

func (*E2MExecutionRequest) GetDelete 

func (x *E2MExecutionRequest) GetDelete() *DeleteE2MRequest

func (*E2MExecutionRequest) GetReplace 

func (x *E2MExecutionRequest) GetReplace() *ReplaceE2MRequest

func (*E2MExecutionRequest) GetRequest 

func (m *E2MExecutionRequest) GetRequest() isE2MExecutionRequest_Request

func (*E2MExecutionRequest) ProtoMessage 

func (*E2MExecutionRequest) ProtoMessage()

func (*E2MExecutionRequest) ProtoReflect 

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

func (*E2MExecutionRequest) Reset 

func (x *E2MExecutionRequest) Reset()

func (*E2MExecutionRequest) String 

func (x *E2MExecutionRequest) String() string

type E2MExecutionRequest_Create 

type E2MExecutionRequest_Create struct {
	Create *CreateE2MRequest `protobuf:"bytes,1,opt,name=create,proto3,oneof"`
}

type E2MExecutionRequest_Delete 

type E2MExecutionRequest_Delete struct {
	Delete *DeleteE2MRequest `protobuf:"bytes,3,opt,name=delete,proto3,oneof"`
}

type E2MExecutionRequest_Replace 

type E2MExecutionRequest_Replace struct {
	Replace *ReplaceE2MRequest `protobuf:"bytes,2,opt,name=replace,proto3,oneof"`
}

type E2MExecutionResponse 

type E2MExecutionResponse struct {

	// Types that are assignable to Response:
	//
	//	*E2MExecutionResponse_Created
	//	*E2MExecutionResponse_Replaced
	//	*E2MExecutionResponse_Deleted
	Response isE2MExecutionResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

represents a response of e2m execution

func (*E2MExecutionResponse) Descriptor deprecated 

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

Deprecated: Use E2MExecutionResponse.ProtoReflect.Descriptor instead.

func (*E2MExecutionResponse) GetCreated 

func (x *E2MExecutionResponse) GetCreated() *CreateE2MResponse

func (*E2MExecutionResponse) GetDeleted 

func (x *E2MExecutionResponse) GetDeleted() *DeleteE2MResponse

func (*E2MExecutionResponse) GetReplaced 

func (x *E2MExecutionResponse) GetReplaced() *ReplaceE2MResponse

func (*E2MExecutionResponse) GetResponse 

func (m *E2MExecutionResponse) GetResponse() isE2MExecutionResponse_Response

func (*E2MExecutionResponse) ProtoMessage 

func (*E2MExecutionResponse) ProtoMessage()

func (*E2MExecutionResponse) ProtoReflect 

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

func (*E2MExecutionResponse) Reset 

func (x *E2MExecutionResponse) Reset()

func (*E2MExecutionResponse) String 

func (x *E2MExecutionResponse) String() string

type E2MExecutionResponse_Created 

type E2MExecutionResponse_Created struct {
	Created *CreateE2MResponse `protobuf:"bytes,1,opt,name=created,proto3,oneof"`
}

type E2MExecutionResponse_Deleted 

type E2MExecutionResponse_Deleted struct {
	Deleted *DeleteE2MResponse `protobuf:"bytes,3,opt,name=deleted,proto3,oneof"`
}

type E2MExecutionResponse_Replaced 

type E2MExecutionResponse_Replaced struct {
	Replaced *ReplaceE2MResponse `protobuf:"bytes,2,opt,name=replaced,proto3,oneof"`
}

type E2MPermutations 

type E2MPermutations struct {

	// E2M permutation limit
	Limit int32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// Flag to indicate if limit was exceeded
	HasExceededLimit bool `protobuf:"varint,2,opt,name=has_exceeded_limit,json=hasExceededLimit,proto3" json:"has_exceeded_limit,omitempty"`
	// contains filtered or unexported fields
}

Represents e2m permutation limit

func (*E2MPermutations) Descriptor deprecated 

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

Deprecated: Use E2MPermutations.ProtoReflect.Descriptor instead.

func (*E2MPermutations) GetHasExceededLimit 

func (x *E2MPermutations) GetHasExceededLimit() bool

func (*E2MPermutations) GetLimit 

func (x *E2MPermutations) GetLimit() int32

func (*E2MPermutations) ProtoMessage 

func (*E2MPermutations) ProtoMessage()

func (*E2MPermutations) ProtoReflect 

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

func (*E2MPermutations) Reset 

func (x *E2MPermutations) Reset()

func (*E2MPermutations) String 

func (x *E2MPermutations) String() string

type E2MType 

type E2MType int32

Enum defining e2m type 

const (
	E2MType_E2M_TYPE_UNSPECIFIED   E2MType = 0
	E2MType_E2M_TYPE_LOGS2METRICS  E2MType = 1
	E2MType_E2M_TYPE_SPANS2METRICS E2MType = 2
)

func (E2MType) Descriptor 

func (E2MType) Descriptor() protoreflect.EnumDescriptor

func (E2MType) Enum 

func (x E2MType) Enum() *E2MType

func (E2MType) EnumDescriptor deprecated 

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

Deprecated: Use E2MType.Descriptor instead.

func (E2MType) Number 

func (x E2MType) Number() protoreflect.EnumNumber

func (E2MType) String 

func (x E2MType) String() string

func (E2MType) Type 

func (E2MType) Type() protoreflect.EnumType

type E2M_LogsQuery 

type E2M_LogsQuery struct {
	// E2M logs query
	LogsQuery *v21.LogsQuery `protobuf:"bytes,11,opt,name=logs_query,json=logsQuery,proto3,oneof"`
}

type E2M_SpansQuery 

type E2M_SpansQuery struct {
	// E2M spans query
	SpansQuery *v2.SpansQuery `protobuf:"bytes,10,opt,name=spans_query,json=spansQuery,proto3,oneof"`
}

type Events2MetricInternalServiceClient 

type Events2MetricInternalServiceClient interface {
	ListE2MInternal(ctx context.Context, in *ListE2MRequestInternal, opts ...grpc.CallOption) (*ListE2MResponseInternal, error)
	ReplaceE2M(ctx context.Context, in *ReplaceE2MRequestInternal, opts ...grpc.CallOption) (*ReplaceE2MResponseInternal, error)
	CreateE2MInternal(ctx context.Context, in *CreateE2MRequestInternal, opts ...grpc.CallOption) (*CreateE2MResponseInternal, error)
	DeleteE2MInternal(ctx context.Context, in *DeleteE2MRequestInternal, opts ...grpc.CallOption) (*DeleteE2MResponseInternal, error)
}

Events2MetricInternalServiceClient is the client API for Events2MetricInternalService 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.

func NewEvents2MetricInternalServiceClient 

func NewEvents2MetricInternalServiceClient(cc grpc.ClientConnInterface) Events2MetricInternalServiceClient

type Events2MetricInternalServiceServer 

type Events2MetricInternalServiceServer interface {
	ListE2MInternal(context.Context, *ListE2MRequestInternal) (*ListE2MResponseInternal, error)
	ReplaceE2M(context.Context, *ReplaceE2MRequestInternal) (*ReplaceE2MResponseInternal, error)
	CreateE2MInternal(context.Context, *CreateE2MRequestInternal) (*CreateE2MResponseInternal, error)
	DeleteE2MInternal(context.Context, *DeleteE2MRequestInternal) (*DeleteE2MResponseInternal, error)
	// contains filtered or unexported methods
}

Events2MetricInternalServiceServer is the server API for Events2MetricInternalService service. All implementations must embed UnimplementedEvents2MetricInternalServiceServer for forward compatibility

type Events2MetricServiceClient 

type Events2MetricServiceClient interface {
	CreateE2M(ctx context.Context, in *CreateE2MRequest, opts ...grpc.CallOption) (*CreateE2MResponse, error)
	ListE2M(ctx context.Context, in *ListE2MRequest, opts ...grpc.CallOption) (*ListE2MResponse, error)
	ReplaceE2M(ctx context.Context, in *ReplaceE2MRequest, opts ...grpc.CallOption) (*ReplaceE2MResponse, error)
	GetE2M(ctx context.Context, in *GetE2MRequest, opts ...grpc.CallOption) (*GetE2MResponse, error)
	DeleteE2M(ctx context.Context, in *DeleteE2MRequest, opts ...grpc.CallOption) (*DeleteE2MResponse, error)
	AtomicBatchExecuteE2M(ctx context.Context, in *AtomicBatchExecuteE2MRequest, opts ...grpc.CallOption) (*AtomicBatchExecuteE2MResponse, error)
	ListLabelsCardinality(ctx context.Context, in *ListLabelsCardinalityRequest, opts ...grpc.CallOption) (*ListLabelsCardinalityResponse, error)
	GetLimits(ctx context.Context, in *GetLimitsRequest, opts ...grpc.CallOption) (*GetLimitsResponse, error)
}

Events2MetricServiceClient is the client API for Events2MetricService 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.

func NewEvents2MetricServiceClient 

func NewEvents2MetricServiceClient(cc grpc.ClientConnInterface) Events2MetricServiceClient

type Events2MetricServiceServer 

type Events2MetricServiceServer interface {
	CreateE2M(context.Context, *CreateE2MRequest) (*CreateE2MResponse, error)
	ListE2M(context.Context, *ListE2MRequest) (*ListE2MResponse, error)
	ReplaceE2M(context.Context, *ReplaceE2MRequest) (*ReplaceE2MResponse, error)
	GetE2M(context.Context, *GetE2MRequest) (*GetE2MResponse, error)
	DeleteE2M(context.Context, *DeleteE2MRequest) (*DeleteE2MResponse, error)
	AtomicBatchExecuteE2M(context.Context, *AtomicBatchExecuteE2MRequest) (*AtomicBatchExecuteE2MResponse, error)
	ListLabelsCardinality(context.Context, *ListLabelsCardinalityRequest) (*ListLabelsCardinalityResponse, error)
	GetLimits(context.Context, *GetLimitsRequest) (*GetLimitsResponse, error)
	// contains filtered or unexported methods
}

Events2MetricServiceServer is the server API for Events2MetricService service. All implementations must embed UnimplementedEvents2MetricServiceServer for forward compatibility

type GetE2MRequest 

type GetE2MRequest struct {
	Id *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

represents get request for a single e2m by id

func (*GetE2MRequest) Descriptor deprecated 

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

Deprecated: Use GetE2MRequest.ProtoReflect.Descriptor instead.

func (*GetE2MRequest) GetId 

func (x *GetE2MRequest) GetId() *wrapperspb.StringValue

func (*GetE2MRequest) ProtoMessage 

func (*GetE2MRequest) ProtoMessage()

func (*GetE2MRequest) ProtoReflect 

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

func (*GetE2MRequest) Reset 

func (x *GetE2MRequest) Reset()

func (*GetE2MRequest) String 

func (x *GetE2MRequest) String() string

type GetE2MResponse 

type GetE2MResponse struct {
	E2M *E2M `protobuf:"bytes,1,opt,name=e2m,proto3" json:"e2m,omitempty"`
	// contains filtered or unexported fields
}

represents response for a single e2m by id

func (*GetE2MResponse) Descriptor deprecated 

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

Deprecated: Use GetE2MResponse.ProtoReflect.Descriptor instead.

func (*GetE2MResponse) GetE2M 

func (x *GetE2MResponse) GetE2M() *E2M

func (*GetE2MResponse) ProtoMessage 

func (*GetE2MResponse) ProtoMessage()

func (*GetE2MResponse) ProtoReflect 

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

func (*GetE2MResponse) Reset 

func (x *GetE2MResponse) Reset()

func (*GetE2MResponse) String 

func (x *GetE2MResponse) String() string

type GetLimitsRequest 

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

get e2m limits request

func (*GetLimitsRequest) Descriptor deprecated 

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

Deprecated: Use GetLimitsRequest.ProtoReflect.Descriptor instead.

func (*GetLimitsRequest) ProtoMessage 

func (*GetLimitsRequest) ProtoMessage()

func (*GetLimitsRequest) ProtoReflect 

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

func (*GetLimitsRequest) Reset 

func (x *GetLimitsRequest) Reset()

func (*GetLimitsRequest) String 

func (x *GetLimitsRequest) String() string

type GetLimitsResponse 

type GetLimitsResponse struct {

	// company id
	CompanyId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=company_id,json=companyId,proto3" json:"company_id,omitempty"`
	// labels limit
	LabelsLimit int32 `protobuf:"varint,2,opt,name=labels_limit,json=labelsLimit,proto3" json:"labels_limit,omitempty"`
	// permutation limit/used
	PermutationsLimit *GetLimitsResponse_LimitUsage `protobuf:"bytes,3,opt,name=permutations_limit,json=permutationsLimit,proto3" json:"permutations_limit,omitempty"`
	// metrics limit/used5
	MetricsLimit *GetLimitsResponse_LimitUsage `protobuf:"bytes,4,opt,name=metrics_limit,json=metricsLimit,proto3" json:"metrics_limit,omitempty"`
	// contains filtered or unexported fields
}

get e2m limits response

func (*GetLimitsResponse) Descriptor deprecated 

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

Deprecated: Use GetLimitsResponse.ProtoReflect.Descriptor instead.

func (*GetLimitsResponse) GetCompanyId 

func (x *GetLimitsResponse) GetCompanyId() *wrapperspb.StringValue

func (*GetLimitsResponse) GetLabelsLimit 

func (x *GetLimitsResponse) GetLabelsLimit() int32

func (*GetLimitsResponse) GetMetricsLimit 

func (x *GetLimitsResponse) GetMetricsLimit() *GetLimitsResponse_LimitUsage

func (*GetLimitsResponse) GetPermutationsLimit 

func (x *GetLimitsResponse) GetPermutationsLimit() *GetLimitsResponse_LimitUsage

func (*GetLimitsResponse) ProtoMessage 

func (*GetLimitsResponse) ProtoMessage()

func (*GetLimitsResponse) ProtoReflect 

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

func (*GetLimitsResponse) Reset 

func (x *GetLimitsResponse) Reset()

func (*GetLimitsResponse) String 

func (x *GetLimitsResponse) String() string

type GetLimitsResponse_LimitUsage 

type GetLimitsResponse_LimitUsage struct {

	// the limit number of e2m creation
	Limit *wrapperspb.Int32Value `protobuf:"bytes,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// how many e2m's were created
	Used *wrapperspb.Int32Value `protobuf:"bytes,2,opt,name=used,proto3" json:"used,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLimitsResponse_LimitUsage) Descriptor deprecated 

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

Deprecated: Use GetLimitsResponse_LimitUsage.ProtoReflect.Descriptor instead.

func (*GetLimitsResponse_LimitUsage) GetLimit 

func (x *GetLimitsResponse_LimitUsage) GetLimit() *wrapperspb.Int32Value

func (*GetLimitsResponse_LimitUsage) GetUsed 

func (x *GetLimitsResponse_LimitUsage) GetUsed() *wrapperspb.Int32Value

func (*GetLimitsResponse_LimitUsage) ProtoMessage 

func (*GetLimitsResponse_LimitUsage) ProtoMessage()

func (*GetLimitsResponse_LimitUsage) ProtoReflect 

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

func (*GetLimitsResponse_LimitUsage) Reset 

func (x *GetLimitsResponse_LimitUsage) Reset()

func (*GetLimitsResponse_LimitUsage) String 

func (x *GetLimitsResponse_LimitUsage) String() string

type LabelsPermutationsCardinalityDay 

type LabelsPermutationsCardinalityDay struct {
	Day          string `protobuf:"bytes,1,opt,name=day,proto3" json:"day,omitempty"`
	Permutations int32  `protobuf:"varint,2,opt,name=permutations,proto3" json:"permutations,omitempty"`
	// contains filtered or unexported fields
}

represents labels permutation cardinality

func (*LabelsPermutationsCardinalityDay) Descriptor deprecated 

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

Deprecated: Use LabelsPermutationsCardinalityDay.ProtoReflect.Descriptor instead.

func (*LabelsPermutationsCardinalityDay) GetDay 

func (x *LabelsPermutationsCardinalityDay) GetDay() string

func (*LabelsPermutationsCardinalityDay) GetPermutations 

func (x *LabelsPermutationsCardinalityDay) GetPermutations() int32

func (*LabelsPermutationsCardinalityDay) ProtoMessage 

func (*LabelsPermutationsCardinalityDay) ProtoMessage()

func (*LabelsPermutationsCardinalityDay) ProtoReflect 

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

func (*LabelsPermutationsCardinalityDay) Reset 

func (x *LabelsPermutationsCardinalityDay) Reset()

func (*LabelsPermutationsCardinalityDay) String 

func (x *LabelsPermutationsCardinalityDay) String() string

type ListE2MRequest 

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

represents e2m get list request

func (*ListE2MRequest) Descriptor deprecated 

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

Deprecated: Use ListE2MRequest.ProtoReflect.Descriptor instead.

func (*ListE2MRequest) ProtoMessage 

func (*ListE2MRequest) ProtoMessage()

func (*ListE2MRequest) ProtoReflect 

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

func (*ListE2MRequest) Reset 

func (x *ListE2MRequest) Reset()

func (*ListE2MRequest) String 

func (x *ListE2MRequest) String() string

type ListE2MRequestInternal 

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

func (*ListE2MRequestInternal) Descriptor deprecated 

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

Deprecated: Use ListE2MRequestInternal.ProtoReflect.Descriptor instead.

func (*ListE2MRequestInternal) ProtoMessage 

func (*ListE2MRequestInternal) ProtoMessage()

func (*ListE2MRequestInternal) ProtoReflect 

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

func (*ListE2MRequestInternal) Reset 

func (x *ListE2MRequestInternal) Reset()

func (*ListE2MRequestInternal) String 

func (x *ListE2MRequestInternal) String() string

type ListE2MResponse 

type ListE2MResponse struct {

	// List of event to metrics definitions
	E2M []*E2M `protobuf:"bytes,1,rep,name=e2m,proto3" json:"e2m,omitempty"`
	// contains filtered or unexported fields
}

represents response of

func (*ListE2MResponse) Descriptor deprecated 

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

Deprecated: Use ListE2MResponse.ProtoReflect.Descriptor instead.

func (*ListE2MResponse) GetE2M 

func (x *ListE2MResponse) GetE2M() []*E2M

func (*ListE2MResponse) ProtoMessage 

func (*ListE2MResponse) ProtoMessage()

func (*ListE2MResponse) ProtoReflect 

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

func (*ListE2MResponse) Reset 

func (x *ListE2MResponse) Reset()

func (*ListE2MResponse) String 

func (x *ListE2MResponse) String() string

type ListE2MResponseInternal 

type ListE2MResponseInternal struct {
	E2M []*E2M `protobuf:"bytes,1,rep,name=e2m,proto3" json:"e2m,omitempty"`
	// contains filtered or unexported fields
}

func (*ListE2MResponseInternal) Descriptor deprecated 

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

Deprecated: Use ListE2MResponseInternal.ProtoReflect.Descriptor instead.

func (*ListE2MResponseInternal) GetE2M 

func (x *ListE2MResponseInternal) GetE2M() []*E2M

func (*ListE2MResponseInternal) ProtoMessage 

func (*ListE2MResponseInternal) ProtoMessage()

func (*ListE2MResponseInternal) ProtoReflect 

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

func (*ListE2MResponseInternal) Reset 

func (x *ListE2MResponseInternal) Reset()

func (*ListE2MResponseInternal) String 

func (x *ListE2MResponseInternal) String() string

type ListLabelsCardinalityRequest 

type ListLabelsCardinalityRequest struct {

	// Types that are assignable to Query:
	//
	//	*ListLabelsCardinalityRequest_SpansQuery
	//	*ListLabelsCardinalityRequest_LogsQuery
	Query        isListLabelsCardinalityRequest_Query `protobuf_oneof:"query"`
	MetricLabels []*MetricLabel                       `protobuf:"bytes,3,rep,name=metric_labels,json=metricLabels,proto3" json:"metric_labels,omitempty"`
	// contains filtered or unexported fields
}

represents a request of list label cardinality

func (*ListLabelsCardinalityRequest) Descriptor deprecated 

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

Deprecated: Use ListLabelsCardinalityRequest.ProtoReflect.Descriptor instead.

func (*ListLabelsCardinalityRequest) GetLogsQuery 

func (x *ListLabelsCardinalityRequest) GetLogsQuery() *v21.LogsQuery

func (*ListLabelsCardinalityRequest) GetMetricLabels 

func (x *ListLabelsCardinalityRequest) GetMetricLabels() []*MetricLabel

func (*ListLabelsCardinalityRequest) GetQuery 

func (m *ListLabelsCardinalityRequest) GetQuery() isListLabelsCardinalityRequest_Query

func (*ListLabelsCardinalityRequest) GetSpansQuery 

func (x *ListLabelsCardinalityRequest) GetSpansQuery() *v2.SpansQuery

func (*ListLabelsCardinalityRequest) ProtoMessage 

func (*ListLabelsCardinalityRequest) ProtoMessage()

func (*ListLabelsCardinalityRequest) ProtoReflect 

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

func (*ListLabelsCardinalityRequest) Reset 

func (x *ListLabelsCardinalityRequest) Reset()

func (*ListLabelsCardinalityRequest) String 

func (x *ListLabelsCardinalityRequest) String() string

type ListLabelsCardinalityRequest_LogsQuery 

type ListLabelsCardinalityRequest_LogsQuery struct {
	LogsQuery *v21.LogsQuery `protobuf:"bytes,2,opt,name=logs_query,json=logsQuery,proto3,oneof"`
}

type ListLabelsCardinalityRequest_SpansQuery 

type ListLabelsCardinalityRequest_SpansQuery struct {
	SpansQuery *v2.SpansQuery `protobuf:"bytes,1,opt,name=spans_query,json=spansQuery,proto3,oneof"`
}

type ListLabelsCardinalityResponse 

type ListLabelsCardinalityResponse struct {
	Permutations []*LabelsPermutationsCardinalityDay `protobuf:"bytes,1,rep,name=permutations,proto3" json:"permutations,omitempty"`
	// contains filtered or unexported fields
}

response represented by list of labels permutation cardinality

func (*ListLabelsCardinalityResponse) Descriptor deprecated 

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

Deprecated: Use ListLabelsCardinalityResponse.ProtoReflect.Descriptor instead.

func (*ListLabelsCardinalityResponse) GetPermutations 

func (x *ListLabelsCardinalityResponse) GetPermutations() []*LabelsPermutationsCardinalityDay

func (*ListLabelsCardinalityResponse) ProtoMessage 

func (*ListLabelsCardinalityResponse) ProtoMessage()

func (*ListLabelsCardinalityResponse) ProtoReflect 

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

func (*ListLabelsCardinalityResponse) Reset 

func (x *ListLabelsCardinalityResponse) Reset()

func (*ListLabelsCardinalityResponse) String 

func (x *ListLabelsCardinalityResponse) String() string

type MetricField 

type MetricField struct {

	// Target metric field alias name
	TargetBaseMetricName *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=target_base_metric_name,json=targetBaseMetricName,proto3" json:"target_base_metric_name,omitempty"`
	// Source field
	SourceField *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=source_field,json=sourceField,proto3" json:"source_field,omitempty"`
	// Represents Aggregation type list
	Aggregations []*Aggregation `protobuf:"bytes,7,rep,name=aggregations,proto3" json:"aggregations,omitempty"`
	// contains filtered or unexported fields
}

E2M metric field

func (*MetricField) Descriptor deprecated 

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

Deprecated: Use MetricField.ProtoReflect.Descriptor instead.

func (*MetricField) GetAggregations 

func (x *MetricField) GetAggregations() []*Aggregation

func (*MetricField) GetSourceField 

func (x *MetricField) GetSourceField() *wrapperspb.StringValue

func (*MetricField) GetTargetBaseMetricName 

func (x *MetricField) GetTargetBaseMetricName() *wrapperspb.StringValue

func (*MetricField) ProtoMessage 

func (*MetricField) ProtoMessage()

func (*MetricField) ProtoReflect 

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

func (*MetricField) Reset 

func (x *MetricField) Reset()

func (*MetricField) String 

func (x *MetricField) String() string

type MetricLabel 

type MetricLabel struct {

	// Metric label target alias name
	TargetLabel *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=target_label,json=targetLabel,proto3" json:"target_label,omitempty"`
	// Metric label source field
	SourceField *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=source_field,json=sourceField,proto3" json:"source_field,omitempty"`
	// contains filtered or unexported fields
}

E2M metric label

func (*MetricLabel) Descriptor deprecated 

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

Deprecated: Use MetricLabel.ProtoReflect.Descriptor instead.

func (*MetricLabel) GetSourceField 

func (x *MetricLabel) GetSourceField() *wrapperspb.StringValue

func (*MetricLabel) GetTargetLabel 

func (x *MetricLabel) GetTargetLabel() *wrapperspb.StringValue

func (*MetricLabel) ProtoMessage 

func (*MetricLabel) ProtoMessage()

func (*MetricLabel) ProtoReflect 

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

func (*MetricLabel) Reset 

func (x *MetricLabel) Reset()

func (*MetricLabel) String 

func (x *MetricLabel) String() string

type ReplaceE2MRequest 

type ReplaceE2MRequest struct {
	E2M *E2M `protobuf:"bytes,1,opt,name=e2m,proto3" json:"e2m,omitempty"`
	// contains filtered or unexported fields
}

represents e2m replace request

func (*ReplaceE2MRequest) Descriptor deprecated 

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

Deprecated: Use ReplaceE2MRequest.ProtoReflect.Descriptor instead.

func (*ReplaceE2MRequest) GetE2M 

func (x *ReplaceE2MRequest) GetE2M() *E2M

func (*ReplaceE2MRequest) ProtoMessage 

func (*ReplaceE2MRequest) ProtoMessage()

func (*ReplaceE2MRequest) ProtoReflect 

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

func (*ReplaceE2MRequest) Reset 

func (x *ReplaceE2MRequest) Reset()

func (*ReplaceE2MRequest) String 

func (x *ReplaceE2MRequest) String() string

type ReplaceE2MRequestInternal 

type ReplaceE2MRequestInternal struct {
	E2M *E2M `protobuf:"bytes,1,opt,name=e2m,proto3" json:"e2m,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceE2MRequestInternal) Descriptor deprecated 

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

Deprecated: Use ReplaceE2MRequestInternal.ProtoReflect.Descriptor instead.

func (*ReplaceE2MRequestInternal) GetE2M 

func (x *ReplaceE2MRequestInternal) GetE2M() *E2M

func (*ReplaceE2MRequestInternal) ProtoMessage 

func (*ReplaceE2MRequestInternal) ProtoMessage()

func (*ReplaceE2MRequestInternal) ProtoReflect 

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

func (*ReplaceE2MRequestInternal) Reset 

func (x *ReplaceE2MRequestInternal) Reset()

func (*ReplaceE2MRequestInternal) String 

func (x *ReplaceE2MRequestInternal) String() string

type ReplaceE2MResponse 

type ReplaceE2MResponse struct {
	E2M *E2M `protobuf:"bytes,1,opt,name=e2m,proto3" json:"e2m,omitempty"`
	// contains filtered or unexported fields
}

represents e2m replace response

func (*ReplaceE2MResponse) Descriptor deprecated 

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

Deprecated: Use ReplaceE2MResponse.ProtoReflect.Descriptor instead.

func (*ReplaceE2MResponse) GetE2M 

func (x *ReplaceE2MResponse) GetE2M() *E2M

func (*ReplaceE2MResponse) ProtoMessage 

func (*ReplaceE2MResponse) ProtoMessage()

func (*ReplaceE2MResponse) ProtoReflect 

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

func (*ReplaceE2MResponse) Reset 

func (x *ReplaceE2MResponse) Reset()

func (*ReplaceE2MResponse) String 

func (x *ReplaceE2MResponse) String() string

type ReplaceE2MResponseInternal 

type ReplaceE2MResponseInternal struct {
	E2M *E2M `protobuf:"bytes,1,opt,name=e2m,proto3" json:"e2m,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceE2MResponseInternal) Descriptor deprecated 

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

Deprecated: Use ReplaceE2MResponseInternal.ProtoReflect.Descriptor instead.

func (*ReplaceE2MResponseInternal) GetE2M 

func (x *ReplaceE2MResponseInternal) GetE2M() *E2M

func (*ReplaceE2MResponseInternal) ProtoMessage 

func (*ReplaceE2MResponseInternal) ProtoMessage()

func (*ReplaceE2MResponseInternal) ProtoReflect 

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

func (*ReplaceE2MResponseInternal) Reset 

func (x *ReplaceE2MResponseInternal) Reset()

func (*ReplaceE2MResponseInternal) String 

func (x *ReplaceE2MResponseInternal) String() string

type UnimplementedEvents2MetricInternalServiceServer 

type UnimplementedEvents2MetricInternalServiceServer struct {
}

UnimplementedEvents2MetricInternalServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEvents2MetricInternalServiceServer) CreateE2MInternal 

func (UnimplementedEvents2MetricInternalServiceServer) CreateE2MInternal(context.Context, *CreateE2MRequestInternal) (*CreateE2MResponseInternal, error)

func (UnimplementedEvents2MetricInternalServiceServer) DeleteE2MInternal 

func (UnimplementedEvents2MetricInternalServiceServer) DeleteE2MInternal(context.Context, *DeleteE2MRequestInternal) (*DeleteE2MResponseInternal, error)

func (UnimplementedEvents2MetricInternalServiceServer) ListE2MInternal 

func (UnimplementedEvents2MetricInternalServiceServer) ListE2MInternal(context.Context, *ListE2MRequestInternal) (*ListE2MResponseInternal, error)

func (UnimplementedEvents2MetricInternalServiceServer) ReplaceE2M 

func (UnimplementedEvents2MetricInternalServiceServer) ReplaceE2M(context.Context, *ReplaceE2MRequestInternal) (*ReplaceE2MResponseInternal, error)

type UnimplementedEvents2MetricServiceServer 

type UnimplementedEvents2MetricServiceServer struct {
}

UnimplementedEvents2MetricServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEvents2MetricServiceServer) AtomicBatchExecuteE2M 

func (UnimplementedEvents2MetricServiceServer) AtomicBatchExecuteE2M(context.Context, *AtomicBatchExecuteE2MRequest) (*AtomicBatchExecuteE2MResponse, error)

func (UnimplementedEvents2MetricServiceServer) CreateE2M 

func (UnimplementedEvents2MetricServiceServer) CreateE2M(context.Context, *CreateE2MRequest) (*CreateE2MResponse, error)

func (UnimplementedEvents2MetricServiceServer) DeleteE2M 

func (UnimplementedEvents2MetricServiceServer) DeleteE2M(context.Context, *DeleteE2MRequest) (*DeleteE2MResponse, error)

func (UnimplementedEvents2MetricServiceServer) GetE2M 

func (UnimplementedEvents2MetricServiceServer) GetE2M(context.Context, *GetE2MRequest) (*GetE2MResponse, error)

func (UnimplementedEvents2MetricServiceServer) GetLimits 

func (UnimplementedEvents2MetricServiceServer) GetLimits(context.Context, *GetLimitsRequest) (*GetLimitsResponse, error)

func (UnimplementedEvents2MetricServiceServer) ListE2M 

func (UnimplementedEvents2MetricServiceServer) ListE2M(context.Context, *ListE2MRequest) (*ListE2MResponse, error)

func (UnimplementedEvents2MetricServiceServer) ListLabelsCardinality 

func (UnimplementedEvents2MetricServiceServer) ListLabelsCardinality(context.Context, *ListLabelsCardinalityRequest) (*ListLabelsCardinalityResponse, error)

func (UnimplementedEvents2MetricServiceServer) ReplaceE2M 

func (UnimplementedEvents2MetricServiceServer) ReplaceE2M(context.Context, *ReplaceE2MRequest) (*ReplaceE2MResponse, error)

type UnsafeEvents2MetricInternalServiceServer 

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

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

type UnsafeEvents2MetricServiceServer 

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

UnsafeEvents2MetricServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to Events2MetricServiceServer 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.