aggregatev1

package
v0.15.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_chalk_aggregate_v1_backfill_proto protoreflect.FileDescriptor
View Source 
var File_chalk_aggregate_v1_service_proto protoreflect.FileDescriptor
View Source 
var File_chalk_aggregate_v1_timeseries_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AggregateBackfillEstimate added in v0.14.6 

type AggregateBackfillEstimate struct {

	// The estimated number of rows to backfill.
	MaxBuckets          int64                `protobuf:"varint,1,opt,name=max_buckets,json=maxBuckets,proto3" json:"max_buckets,omitempty"`
	ExpectedBuckets     int64                `protobuf:"varint,2,opt,name=expected_buckets,json=expectedBuckets,proto3" json:"expected_buckets,omitempty"`
	ExpectedBytes       int64                `protobuf:"varint,3,opt,name=expected_bytes,json=expectedBytes,proto3" json:"expected_bytes,omitempty"`
	ExpectedStorageCost float64              `protobuf:"fixed64,4,opt,name=expected_storage_cost,json=expectedStorageCost,proto3" json:"expected_storage_cost,omitempty"`
	ExpectedRuntime     *durationpb.Duration `protobuf:"bytes,5,opt,name=expected_runtime,json=expectedRuntime,proto3" json:"expected_runtime,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregateBackfillEstimate) Descriptor deprecated added in v0.14.6 

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

Deprecated: Use AggregateBackfillEstimate.ProtoReflect.Descriptor instead.

func (*AggregateBackfillEstimate) GetExpectedBuckets added in v0.14.6 

func (x *AggregateBackfillEstimate) GetExpectedBuckets() int64

func (*AggregateBackfillEstimate) GetExpectedBytes added in v0.14.6 

func (x *AggregateBackfillEstimate) GetExpectedBytes() int64

func (*AggregateBackfillEstimate) GetExpectedRuntime added in v0.14.6 

func (x *AggregateBackfillEstimate) GetExpectedRuntime() *durationpb.Duration

func (*AggregateBackfillEstimate) GetExpectedStorageCost added in v0.14.6 

func (x *AggregateBackfillEstimate) GetExpectedStorageCost() float64

func (*AggregateBackfillEstimate) GetMaxBuckets added in v0.14.6 

func (x *AggregateBackfillEstimate) GetMaxBuckets() int64

func (*AggregateBackfillEstimate) ProtoMessage added in v0.14.6 

func (*AggregateBackfillEstimate) ProtoMessage()

func (*AggregateBackfillEstimate) ProtoReflect added in v0.14.6 

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

func (*AggregateBackfillEstimate) Reset added in v0.14.6 

func (x *AggregateBackfillEstimate) Reset()

func (*AggregateBackfillEstimate) String added in v0.14.6 

func (x *AggregateBackfillEstimate) String() string

type AggregateBackfillUserParams 

type AggregateBackfillUserParams struct {
	Features            []string               `protobuf:"bytes,1,rep,name=features,proto3" json:"features,omitempty"`
	Resolver            *string                `protobuf:"bytes,2,opt,name=resolver,proto3,oneof" json:"resolver,omitempty"`
	TimestampColumnName *string                `` /* 126-byte string literal not displayed */
	LowerBound          *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=lower_bound,json=lowerBound,proto3,oneof" json:"lower_bound,omitempty"`
	UpperBound          *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=upper_bound,json=upperBound,proto3,oneof" json:"upper_bound,omitempty"`
	Exact               bool                   `protobuf:"varint,6,opt,name=exact,proto3" json:"exact,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregateBackfillUserParams) Descriptor deprecated 

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

Deprecated: Use AggregateBackfillUserParams.ProtoReflect.Descriptor instead.

func (*AggregateBackfillUserParams) GetExact added in v0.14.6 

func (x *AggregateBackfillUserParams) GetExact() bool

func (*AggregateBackfillUserParams) GetFeatures 

func (x *AggregateBackfillUserParams) GetFeatures() []string

func (*AggregateBackfillUserParams) GetLowerBound added in v0.14.6 

func (x *AggregateBackfillUserParams) GetLowerBound() *timestamppb.Timestamp

func (*AggregateBackfillUserParams) GetResolver 

func (x *AggregateBackfillUserParams) GetResolver() string

func (*AggregateBackfillUserParams) GetTimestampColumnName 

func (x *AggregateBackfillUserParams) GetTimestampColumnName() string

func (*AggregateBackfillUserParams) GetUpperBound added in v0.14.6 

func (x *AggregateBackfillUserParams) GetUpperBound() *timestamppb.Timestamp

func (*AggregateBackfillUserParams) ProtoMessage 

func (*AggregateBackfillUserParams) ProtoMessage()

func (*AggregateBackfillUserParams) ProtoReflect 

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

func (*AggregateBackfillUserParams) Reset 

func (x *AggregateBackfillUserParams) Reset()

func (*AggregateBackfillUserParams) String 

func (x *AggregateBackfillUserParams) String() string

type AggregateTimeSeries 

type AggregateTimeSeries struct {
	Namespace          string                     `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	AggregateOn        string                     `protobuf:"bytes,2,opt,name=aggregate_on,json=aggregateOn,proto3" json:"aggregate_on,omitempty"`
	GroupBy            []string                   `protobuf:"bytes,3,rep,name=group_by,json=groupBy,proto3" json:"group_by,omitempty"`
	Rules              []*AggregateTimeSeriesRule `protobuf:"bytes,5,rep,name=rules,proto3" json:"rules,omitempty"`
	FiltersDescription string                     `protobuf:"bytes,6,opt,name=filters_description,json=filtersDescription,proto3" json:"filters_description,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregateTimeSeries) Descriptor deprecated 

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

Deprecated: Use AggregateTimeSeries.ProtoReflect.Descriptor instead.

func (*AggregateTimeSeries) GetAggregateOn added in v0.14.6 

func (x *AggregateTimeSeries) GetAggregateOn() string

func (*AggregateTimeSeries) GetFiltersDescription added in v0.14.6 

func (x *AggregateTimeSeries) GetFiltersDescription() string

func (*AggregateTimeSeries) GetGroupBy added in v0.14.6 

func (x *AggregateTimeSeries) GetGroupBy() []string

func (*AggregateTimeSeries) GetNamespace added in v0.14.6 

func (x *AggregateTimeSeries) GetNamespace() string

func (*AggregateTimeSeries) GetRules added in v0.14.6 

func (x *AggregateTimeSeries) GetRules() []*AggregateTimeSeriesRule

func (*AggregateTimeSeries) ProtoMessage 

func (*AggregateTimeSeries) ProtoMessage()

func (*AggregateTimeSeries) ProtoReflect 

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

func (*AggregateTimeSeries) Reset 

func (x *AggregateTimeSeries) Reset()

func (*AggregateTimeSeries) String 

func (x *AggregateTimeSeries) String() string

type AggregateTimeSeriesRule added in v0.14.6 

type AggregateTimeSeriesRule struct {
	Aggregation    string               `protobuf:"bytes,1,opt,name=aggregation,proto3" json:"aggregation,omitempty"`
	BucketDuration *durationpb.Duration `protobuf:"bytes,2,opt,name=bucket_duration,json=bucketDuration,proto3" json:"bucket_duration,omitempty"`
	// The features which depend on this rule.
	DependentFeatures []string             `protobuf:"bytes,3,rep,name=dependent_features,json=dependentFeatures,proto3" json:"dependent_features,omitempty"`
	Retention         *durationpb.Duration `protobuf:"bytes,4,opt,name=retention,proto3" json:"retention,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregateTimeSeriesRule) Descriptor deprecated added in v0.14.6 

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

Deprecated: Use AggregateTimeSeriesRule.ProtoReflect.Descriptor instead.

func (*AggregateTimeSeriesRule) GetAggregation added in v0.14.6 

func (x *AggregateTimeSeriesRule) GetAggregation() string

func (*AggregateTimeSeriesRule) GetBucketDuration added in v0.14.6 

func (x *AggregateTimeSeriesRule) GetBucketDuration() *durationpb.Duration

func (*AggregateTimeSeriesRule) GetDependentFeatures added in v0.14.6 

func (x *AggregateTimeSeriesRule) GetDependentFeatures() []string

func (*AggregateTimeSeriesRule) GetRetention added in v0.14.6 

func (x *AggregateTimeSeriesRule) GetRetention() *durationpb.Duration

func (*AggregateTimeSeriesRule) ProtoMessage added in v0.14.6 

func (*AggregateTimeSeriesRule) ProtoMessage()

func (*AggregateTimeSeriesRule) ProtoReflect added in v0.14.6 

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

func (*AggregateTimeSeriesRule) Reset added in v0.14.6 

func (x *AggregateTimeSeriesRule) Reset()

func (*AggregateTimeSeriesRule) String added in v0.14.6 

func (x *AggregateTimeSeriesRule) String() string

type GetAggregatesRequest added in v0.14.6 

type GetAggregatesRequest struct {
	ForFeatures []string `protobuf:"bytes,1,rep,name=for_features,json=forFeatures,proto3" json:"for_features,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAggregatesRequest) Descriptor deprecated added in v0.14.6 

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

Deprecated: Use GetAggregatesRequest.ProtoReflect.Descriptor instead.

func (*GetAggregatesRequest) GetForFeatures added in v0.14.6 

func (x *GetAggregatesRequest) GetForFeatures() []string

func (*GetAggregatesRequest) ProtoMessage added in v0.14.6 

func (*GetAggregatesRequest) ProtoMessage()

func (*GetAggregatesRequest) ProtoReflect added in v0.14.6 

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

func (*GetAggregatesRequest) Reset added in v0.14.6 

func (x *GetAggregatesRequest) Reset()

func (*GetAggregatesRequest) String added in v0.14.6 

func (x *GetAggregatesRequest) String() string

type GetAggregatesResponse added in v0.14.6 

type GetAggregatesResponse struct {
	Series []*AggregateTimeSeries `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"`
	Errors []string               `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAggregatesResponse) Descriptor deprecated added in v0.14.6 

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

Deprecated: Use GetAggregatesResponse.ProtoReflect.Descriptor instead.

func (*GetAggregatesResponse) GetErrors added in v0.14.6 

func (x *GetAggregatesResponse) GetErrors() []string

func (*GetAggregatesResponse) GetSeries added in v0.14.6 

func (x *GetAggregatesResponse) GetSeries() []*AggregateTimeSeries

func (*GetAggregatesResponse) ProtoMessage added in v0.14.6 

func (*GetAggregatesResponse) ProtoMessage()

func (*GetAggregatesResponse) ProtoReflect added in v0.14.6 

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

func (*GetAggregatesResponse) Reset added in v0.14.6 

func (x *GetAggregatesResponse) Reset()

func (*GetAggregatesResponse) String added in v0.14.6 

func (x *GetAggregatesResponse) String() string

type PlanAggregateBackfillRequest 

type PlanAggregateBackfillRequest struct {
	Params *AggregateBackfillUserParams `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*PlanAggregateBackfillRequest) Descriptor deprecated 

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

Deprecated: Use PlanAggregateBackfillRequest.ProtoReflect.Descriptor instead.

func (*PlanAggregateBackfillRequest) GetParams 

func (x *PlanAggregateBackfillRequest) GetParams() *AggregateBackfillUserParams

func (*PlanAggregateBackfillRequest) ProtoMessage 

func (*PlanAggregateBackfillRequest) ProtoMessage()

func (*PlanAggregateBackfillRequest) ProtoReflect 

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

func (*PlanAggregateBackfillRequest) Reset 

func (x *PlanAggregateBackfillRequest) Reset()

func (*PlanAggregateBackfillRequest) String 

func (x *PlanAggregateBackfillRequest) String() string

type PlanAggregateBackfillResponse 

type PlanAggregateBackfillResponse struct {
	Series   []*AggregateTimeSeries       `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"`
	Estimate *AggregateBackfillEstimate   `protobuf:"bytes,2,opt,name=estimate,proto3" json:"estimate,omitempty"`
	Params   *AggregateBackfillUserParams `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	Errors   []string                     `protobuf:"bytes,4,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*PlanAggregateBackfillResponse) Descriptor deprecated 

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

Deprecated: Use PlanAggregateBackfillResponse.ProtoReflect.Descriptor instead.

func (*PlanAggregateBackfillResponse) GetErrors added in v0.14.6 

func (x *PlanAggregateBackfillResponse) GetErrors() []string

func (*PlanAggregateBackfillResponse) GetEstimate added in v0.14.6 

func (x *PlanAggregateBackfillResponse) GetEstimate() *AggregateBackfillEstimate

func (*PlanAggregateBackfillResponse) GetParams added in v0.14.6 

func (x *PlanAggregateBackfillResponse) GetParams() *AggregateBackfillUserParams

func (*PlanAggregateBackfillResponse) GetSeries added in v0.14.6 

func (x *PlanAggregateBackfillResponse) GetSeries() []*AggregateTimeSeries

func (*PlanAggregateBackfillResponse) ProtoMessage 

func (*PlanAggregateBackfillResponse) ProtoMessage()

func (*PlanAggregateBackfillResponse) ProtoReflect 

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

func (*PlanAggregateBackfillResponse) Reset 

func (x *PlanAggregateBackfillResponse) Reset()

func (*PlanAggregateBackfillResponse) String 

func (x *PlanAggregateBackfillResponse) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.