protos

package
v0.0.0-...-3db8dec Latest Latest
Warning

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

 Go to latest Published: Sep 23, 2022 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// optional gen_druid_spec.DruidIngestionOptions druid_opts = 2021;
	E_DruidOpts = &file_druid_ingestion_proto_extTypes[0]
)

Extension fields to descriptor.MessageOptions.

View Source 
var (
	// optional gen_druid_spec.DruidSpecFieldOptions spec = 2021;
	E_Spec = &file_druid_spec_proto_extTypes[0]
)

Extension fields to descriptor.FieldOptions.

View Source 
var File_druid_ingestion_proto protoreflect.FileDescriptor
View Source 
var File_druid_spec_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type DruidDimensionFieldOptions 

type DruidDimensionFieldOptions struct {
	MultiValueHandling string                `protobuf:"bytes,2,opt,name=multi_value_handling,json=multiValueHandling,proto3" json:"multi_value_handling,omitempty"`
	CreateBitmapIndex  *wrapperspb.BoolValue `protobuf:"bytes,3,opt,name=create_bitmap_index,json=createBitmapIndex,proto3" json:"create_bitmap_index,omitempty"`
	// contains filtered or unexported fields
}

dimensionsSpec Druid applies ingestion spec components in a particular order: first flattenSpec (if any), then timestampSpec, then transformSpec, and finally dimensionsSpec and metricsSpec

func (*DruidDimensionFieldOptions) Descriptor deprecated 

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

Deprecated: Use DruidDimensionFieldOptions.ProtoReflect.Descriptor instead.

func (*DruidDimensionFieldOptions) GetCreateBitmapIndex 

func (x *DruidDimensionFieldOptions) GetCreateBitmapIndex() *wrapperspb.BoolValue

func (*DruidDimensionFieldOptions) GetMultiValueHandling 

func (x *DruidDimensionFieldOptions) GetMultiValueHandling() string

func (*DruidDimensionFieldOptions) ProtoMessage 

func (*DruidDimensionFieldOptions) ProtoMessage()

func (*DruidDimensionFieldOptions) ProtoReflect 

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

func (*DruidDimensionFieldOptions) Reset 

func (x *DruidDimensionFieldOptions) Reset()

func (*DruidDimensionFieldOptions) String 

func (x *DruidDimensionFieldOptions) String() string

type DruidFlattenFieldOptions 

type DruidFlattenFieldOptions struct {
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// type will be jq or path
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// don't include current field name to output flatten name
	IgnoreName bool   `protobuf:"varint,3,opt,name=ignore_name,json=ignoreName,proto3" json:"ignore_name,omitempty"`
	OutputName string `protobuf:"bytes,4,opt,name=output_name,json=outputName,proto3" json:"output_name,omitempty"`
	// contains filtered or unexported fields
}

flattenSpec

func (*DruidFlattenFieldOptions) Descriptor deprecated 

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

Deprecated: Use DruidFlattenFieldOptions.ProtoReflect.Descriptor instead.

func (*DruidFlattenFieldOptions) GetIgnoreName 

func (x *DruidFlattenFieldOptions) GetIgnoreName() bool

func (*DruidFlattenFieldOptions) GetOutputName 

func (x *DruidFlattenFieldOptions) GetOutputName() string

func (*DruidFlattenFieldOptions) GetPrefix 

func (x *DruidFlattenFieldOptions) GetPrefix() string

func (*DruidFlattenFieldOptions) GetType 

func (x *DruidFlattenFieldOptions) GetType() string

func (*DruidFlattenFieldOptions) ProtoMessage 

func (*DruidFlattenFieldOptions) ProtoMessage()

func (*DruidFlattenFieldOptions) ProtoReflect 

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

func (*DruidFlattenFieldOptions) Reset 

func (x *DruidFlattenFieldOptions) Reset()

func (*DruidFlattenFieldOptions) String 

func (x *DruidFlattenFieldOptions) String() string

type DruidGranularityMessageOptions 

type DruidGranularityMessageOptions struct {
	SegmentGranularity string `protobuf:"bytes,1,opt,name=segment_granularity,json=segmentGranularity,proto3" json:"segment_granularity,omitempty"`
	QueryGranularity   string `protobuf:"bytes,2,opt,name=query_granularity,json=queryGranularity,proto3" json:"query_granularity,omitempty"`
	Rollup             bool   `protobuf:"varint,3,opt,name=rollup,proto3" json:"rollup,omitempty"`
	// contains filtered or unexported fields
}

func (*DruidGranularityMessageOptions) Descriptor deprecated 

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

Deprecated: Use DruidGranularityMessageOptions.ProtoReflect.Descriptor instead.

func (*DruidGranularityMessageOptions) GetQueryGranularity 

func (x *DruidGranularityMessageOptions) GetQueryGranularity() string

func (*DruidGranularityMessageOptions) GetRollup 

func (x *DruidGranularityMessageOptions) GetRollup() bool

func (*DruidGranularityMessageOptions) GetSegmentGranularity 

func (x *DruidGranularityMessageOptions) GetSegmentGranularity() string

func (*DruidGranularityMessageOptions) ProtoMessage 

func (*DruidGranularityMessageOptions) ProtoMessage()

func (*DruidGranularityMessageOptions) ProtoReflect 

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

func (*DruidGranularityMessageOptions) Reset 

func (x *DruidGranularityMessageOptions) Reset()

func (*DruidGranularityMessageOptions) String 

func (x *DruidGranularityMessageOptions) String() string

type DruidIOConfigMessageOptions 

type DruidIOConfigMessageOptions struct {
	Topic             string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	UseFieldDiscovery bool   `protobuf:"varint,2,opt,name=use_field_discovery,json=useFieldDiscovery,proto3" json:"use_field_discovery,omitempty"`
	BootstrapServers  string `protobuf:"bytes,3,opt,name=bootstrap_servers,json=bootstrapServers,proto3" json:"bootstrap_servers,omitempty"`
	UseEarliestOffset bool   `protobuf:"varint,4,opt,name=use_earliest_offset,json=useEarliestOffset,proto3" json:"use_earliest_offset,omitempty"`
	Type              string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*DruidIOConfigMessageOptions) Descriptor deprecated 

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

Deprecated: Use DruidIOConfigMessageOptions.ProtoReflect.Descriptor instead.

func (*DruidIOConfigMessageOptions) GetBootstrapServers 

func (x *DruidIOConfigMessageOptions) GetBootstrapServers() string

func (*DruidIOConfigMessageOptions) GetTopic 

func (x *DruidIOConfigMessageOptions) GetTopic() string

func (*DruidIOConfigMessageOptions) GetType 

func (x *DruidIOConfigMessageOptions) GetType() string

func (*DruidIOConfigMessageOptions) GetUseEarliestOffset 

func (x *DruidIOConfigMessageOptions) GetUseEarliestOffset() bool

func (*DruidIOConfigMessageOptions) GetUseFieldDiscovery 

func (x *DruidIOConfigMessageOptions) GetUseFieldDiscovery() bool

func (*DruidIOConfigMessageOptions) ProtoMessage 

func (*DruidIOConfigMessageOptions) ProtoMessage()

func (*DruidIOConfigMessageOptions) ProtoReflect 

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

func (*DruidIOConfigMessageOptions) Reset 

func (x *DruidIOConfigMessageOptions) Reset()

func (*DruidIOConfigMessageOptions) String 

func (x *DruidIOConfigMessageOptions) String() string

type DruidIngestionOptions 

type DruidIngestionOptions struct {

	// If not blank, indicates the message is a type of record to be stored into Druid.
	DataSourceName string                          `protobuf:"bytes,1,opt,name=data_source_name,json=dataSourceName,proto3" json:"data_source_name,omitempty"`
	IngestionType  string                          `protobuf:"bytes,2,opt,name=ingestion_type,json=ingestionType,proto3" json:"ingestion_type,omitempty"`
	Granularity    *DruidGranularityMessageOptions `protobuf:"bytes,3,opt,name=granularity,proto3" json:"granularity,omitempty"`
	IoConfig       *DruidIOConfigMessageOptions    `protobuf:"bytes,4,opt,name=io_config,json=ioConfig,proto3" json:"io_config,omitempty"`
	// contains filtered or unexported fields
}

func (*DruidIngestionOptions) Descriptor deprecated 

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

Deprecated: Use DruidIngestionOptions.ProtoReflect.Descriptor instead.

func (*DruidIngestionOptions) GetDataSourceName 

func (x *DruidIngestionOptions) GetDataSourceName() string

func (*DruidIngestionOptions) GetGranularity 

func (x *DruidIngestionOptions) GetGranularity() *DruidGranularityMessageOptions

func (*DruidIngestionOptions) GetIngestionType 

func (x *DruidIngestionOptions) GetIngestionType() string

func (*DruidIngestionOptions) GetIoConfig 

func (x *DruidIngestionOptions) GetIoConfig() *DruidIOConfigMessageOptions

func (*DruidIngestionOptions) ProtoMessage 

func (*DruidIngestionOptions) ProtoMessage()

func (*DruidIngestionOptions) ProtoReflect 

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

func (*DruidIngestionOptions) Reset 

func (x *DruidIngestionOptions) Reset()

func (*DruidIngestionOptions) String 

func (x *DruidIngestionOptions) String() string

type DruidMetricFieldOptions 

type DruidMetricFieldOptions struct {
	MetricName         string `protobuf:"bytes,1,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"`
	Size               int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Type               string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	IsInputThetaSketch bool   `protobuf:"varint,4,opt,name=is_input_theta_sketch,json=isInputThetaSketch,proto3" json:"is_input_theta_sketch,omitempty"`
	// contains filtered or unexported fields
}

func (*DruidMetricFieldOptions) Descriptor deprecated 

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

Deprecated: Use DruidMetricFieldOptions.ProtoReflect.Descriptor instead.

func (*DruidMetricFieldOptions) GetIsInputThetaSketch 

func (x *DruidMetricFieldOptions) GetIsInputThetaSketch() bool

func (*DruidMetricFieldOptions) GetMetricName 

func (x *DruidMetricFieldOptions) GetMetricName() string

func (*DruidMetricFieldOptions) GetSize 

func (x *DruidMetricFieldOptions) GetSize() int64

func (*DruidMetricFieldOptions) GetType 

func (x *DruidMetricFieldOptions) GetType() string

func (*DruidMetricFieldOptions) ProtoMessage 

func (*DruidMetricFieldOptions) ProtoMessage()

func (*DruidMetricFieldOptions) ProtoReflect 

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

func (*DruidMetricFieldOptions) Reset 

func (x *DruidMetricFieldOptions) Reset()

func (*DruidMetricFieldOptions) String 

func (x *DruidMetricFieldOptions) String() string

type DruidSpecFieldOptions 

type DruidSpecFieldOptions struct {
	Dimension *DruidDimensionFieldOptions `protobuf:"bytes,1,opt,name=dimension,proto3" json:"dimension,omitempty"`
	Flatten   *DruidFlattenFieldOptions   `protobuf:"bytes,2,opt,name=flatten,proto3" json:"flatten,omitempty"`
	Timestamp *DruidTimestampFieldOptions `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Metric    *DruidMetricFieldOptions    `protobuf:"bytes,4,opt,name=metric,proto3" json:"metric,omitempty"`
	Ignore    bool                        `protobuf:"varint,5,opt,name=ignore,proto3" json:"ignore,omitempty"`
	// contains filtered or unexported fields
}

func (*DruidSpecFieldOptions) Descriptor deprecated 

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

Deprecated: Use DruidSpecFieldOptions.ProtoReflect.Descriptor instead.

func (*DruidSpecFieldOptions) GetDimension 

func (x *DruidSpecFieldOptions) GetDimension() *DruidDimensionFieldOptions

func (*DruidSpecFieldOptions) GetFlatten 

func (x *DruidSpecFieldOptions) GetFlatten() *DruidFlattenFieldOptions

func (*DruidSpecFieldOptions) GetIgnore 

func (x *DruidSpecFieldOptions) GetIgnore() bool

func (*DruidSpecFieldOptions) GetMetric 

func (x *DruidSpecFieldOptions) GetMetric() *DruidMetricFieldOptions

func (*DruidSpecFieldOptions) GetTimestamp 

func (x *DruidSpecFieldOptions) GetTimestamp() *DruidTimestampFieldOptions

func (*DruidSpecFieldOptions) ProtoMessage 

func (*DruidSpecFieldOptions) ProtoMessage()

func (*DruidSpecFieldOptions) ProtoReflect 

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

func (*DruidSpecFieldOptions) Reset 

func (x *DruidSpecFieldOptions) Reset()

func (*DruidSpecFieldOptions) String 

func (x *DruidSpecFieldOptions) String() string

type DruidTimestampFieldOptions 

type DruidTimestampFieldOptions struct {
	Format       string `protobuf:"bytes,1,opt,name=format,proto3" json:"format,omitempty"`
	MissingValue string `protobuf:"bytes,2,opt,name=missing_value,json=missingValue,proto3" json:"missing_value,omitempty"`
	// contains filtered or unexported fields
}

timestampSpec

func (*DruidTimestampFieldOptions) Descriptor deprecated 

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

Deprecated: Use DruidTimestampFieldOptions.ProtoReflect.Descriptor instead.

func (*DruidTimestampFieldOptions) GetFormat 

func (x *DruidTimestampFieldOptions) GetFormat() string

func (*DruidTimestampFieldOptions) GetMissingValue 

func (x *DruidTimestampFieldOptions) GetMissingValue() string

func (*DruidTimestampFieldOptions) ProtoMessage 

func (*DruidTimestampFieldOptions) ProtoMessage()

func (*DruidTimestampFieldOptions) ProtoReflect 

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

func (*DruidTimestampFieldOptions) Reset 

func (x *DruidTimestampFieldOptions) Reset()

func (*DruidTimestampFieldOptions) String 

func (x *DruidTimestampFieldOptions) String() string

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.