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 (*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 (*DruidGranularityMessageOptions) Reset

func (x *DruidGranularityMessageOptions) Reset()

func (*DruidGranularityMessageOptions) 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 (*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 (*DruidIngestionOptions) GetIngestionType

func (x *DruidIngestionOptions) GetIngestionType() string

func (*DruidIngestionOptions) GetIoConfig

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 (*DruidSpecFieldOptions) GetFlatten

func (*DruidSpecFieldOptions) GetIgnore

func (x *DruidSpecFieldOptions) GetIgnore() bool

func (*DruidSpecFieldOptions) GetMetric

func (*DruidSpecFieldOptions) GetTimestamp

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 (*DruidTimestampFieldOptions) Reset

func (x *DruidTimestampFieldOptions) Reset()

func (*DruidTimestampFieldOptions) String

func (x *DruidTimestampFieldOptions) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL