Documentation ¶
Index ¶
- Variables
- type AggregateBackfill
- func (*AggregateBackfill) Descriptor() ([]byte, []int)deprecated
- func (x *AggregateBackfill) GetBucketDuration() *durationpb.Duration
- func (x *AggregateBackfill) GetDatetimeFeature() string
- func (x *AggregateBackfill) GetFiltersDescription() string
- func (x *AggregateBackfill) GetGroupBy() []string
- func (x *AggregateBackfill) GetLowerBound() *timestamppb.Timestamp
- func (x *AggregateBackfill) GetMaxRetention() *durationpb.Duration
- func (x *AggregateBackfill) GetResolver() string
- func (x *AggregateBackfill) GetSeries() []*AggregateTimeSeries
- func (x *AggregateBackfill) GetUpperBound() *timestamppb.Timestamp
- func (*AggregateBackfill) ProtoMessage()
- func (x *AggregateBackfill) ProtoReflect() protoreflect.Message
- func (x *AggregateBackfill) Reset()
- func (x *AggregateBackfill) String() string
- type AggregateBackfillCostEstimate
- func (*AggregateBackfillCostEstimate) Descriptor() ([]byte, []int)deprecated
- func (x *AggregateBackfillCostEstimate) GetExpectedBuckets() int64
- func (x *AggregateBackfillCostEstimate) GetExpectedBytes() int64
- func (x *AggregateBackfillCostEstimate) GetExpectedRuntime() *durationpb.Duration
- func (x *AggregateBackfillCostEstimate) GetExpectedStorageCost() float64
- func (x *AggregateBackfillCostEstimate) GetMaxBuckets() int64
- func (*AggregateBackfillCostEstimate) ProtoMessage()
- func (x *AggregateBackfillCostEstimate) ProtoReflect() protoreflect.Message
- func (x *AggregateBackfillCostEstimate) Reset()
- func (x *AggregateBackfillCostEstimate) String() string
- type AggregateBackfillJob
- func (*AggregateBackfillJob) Descriptor() ([]byte, []int)deprecated
- func (x *AggregateBackfillJob) GetAgentId() string
- func (x *AggregateBackfillJob) GetCreatedAt() *timestamppb.Timestamp
- func (x *AggregateBackfillJob) GetDeploymentId() string
- func (x *AggregateBackfillJob) GetEnvironmentId() string
- func (x *AggregateBackfillJob) GetFeatures() []string
- func (x *AggregateBackfillJob) GetId() string
- func (x *AggregateBackfillJob) GetResolver() string
- func (x *AggregateBackfillJob) GetResolvers() []string
- func (x *AggregateBackfillJob) GetUpdatedAt() *timestamppb.Timestamp
- func (*AggregateBackfillJob) ProtoMessage()
- func (x *AggregateBackfillJob) ProtoReflect() protoreflect.Message
- func (x *AggregateBackfillJob) Reset()
- func (x *AggregateBackfillJob) String() string
- type AggregateBackfillUserParams
- func (*AggregateBackfillUserParams) Descriptor() ([]byte, []int)deprecated
- func (x *AggregateBackfillUserParams) GetExact() bool
- func (x *AggregateBackfillUserParams) GetFeatures() []string
- func (x *AggregateBackfillUserParams) GetLowerBound() *timestamppb.Timestamp
- func (x *AggregateBackfillUserParams) GetResolver() string
- func (x *AggregateBackfillUserParams) GetTimestampColumnName() stringdeprecated
- func (x *AggregateBackfillUserParams) GetUpperBound() *timestamppb.Timestamp
- func (*AggregateBackfillUserParams) ProtoMessage()
- func (x *AggregateBackfillUserParams) ProtoReflect() protoreflect.Message
- func (x *AggregateBackfillUserParams) Reset()
- func (x *AggregateBackfillUserParams) String() string
- type AggregateBackfillWithCostEstimate
- func (*AggregateBackfillWithCostEstimate) Descriptor() ([]byte, []int)deprecated
- func (x *AggregateBackfillWithCostEstimate) GetBackfill() *AggregateBackfill
- func (x *AggregateBackfillWithCostEstimate) GetEstimate() *AggregateBackfillCostEstimate
- func (*AggregateBackfillWithCostEstimate) ProtoMessage()
- func (x *AggregateBackfillWithCostEstimate) ProtoReflect() protoreflect.Message
- func (x *AggregateBackfillWithCostEstimate) Reset()
- func (x *AggregateBackfillWithCostEstimate) String() string
- type AggregateTimeSeries
- func (*AggregateTimeSeries) Descriptor() ([]byte, []int)deprecated
- func (x *AggregateTimeSeries) GetAggregateOn() string
- func (x *AggregateTimeSeries) GetBucketFeature() string
- func (x *AggregateTimeSeries) GetFiltersDescription() string
- func (x *AggregateTimeSeries) GetGroupBy() []string
- func (x *AggregateTimeSeries) GetNamespace() string
- func (x *AggregateTimeSeries) GetRules() []*AggregateTimeSeriesRule
- func (*AggregateTimeSeries) ProtoMessage()
- func (x *AggregateTimeSeries) ProtoReflect() protoreflect.Message
- func (x *AggregateTimeSeries) Reset()
- func (x *AggregateTimeSeries) String() string
- type AggregateTimeSeriesRule
- func (*AggregateTimeSeriesRule) Descriptor() ([]byte, []int)deprecated
- func (x *AggregateTimeSeriesRule) GetAggregation() string
- func (x *AggregateTimeSeriesRule) GetBucketDuration() *durationpb.Duration
- func (x *AggregateTimeSeriesRule) GetDatetimeFeature() string
- func (x *AggregateTimeSeriesRule) GetDependentFeatures() []string
- func (x *AggregateTimeSeriesRule) GetRetention() *durationpb.Duration
- func (*AggregateTimeSeriesRule) ProtoMessage()
- func (x *AggregateTimeSeriesRule) ProtoReflect() protoreflect.Message
- func (x *AggregateTimeSeriesRule) Reset()
- func (x *AggregateTimeSeriesRule) String() string
- type GetAggregateBackfillJobRequest
- func (*GetAggregateBackfillJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetAggregateBackfillJobRequest) GetAggregateBackfillId() string
- func (*GetAggregateBackfillJobRequest) ProtoMessage()
- func (x *GetAggregateBackfillJobRequest) ProtoReflect() protoreflect.Message
- func (x *GetAggregateBackfillJobRequest) Reset()
- func (x *GetAggregateBackfillJobRequest) String() string
- type GetAggregateBackfillJobResponse
- func (*GetAggregateBackfillJobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetAggregateBackfillJobResponse) GetJob() *AggregateBackfillJob
- func (*GetAggregateBackfillJobResponse) ProtoMessage()
- func (x *GetAggregateBackfillJobResponse) ProtoReflect() protoreflect.Message
- func (x *GetAggregateBackfillJobResponse) Reset()
- func (x *GetAggregateBackfillJobResponse) String() string
- type GetAggregateBackfillJobsRequest
- func (*GetAggregateBackfillJobsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetAggregateBackfillJobsRequest) GetCursor() string
- func (x *GetAggregateBackfillJobsRequest) GetLimit() int32
- func (*GetAggregateBackfillJobsRequest) ProtoMessage()
- func (x *GetAggregateBackfillJobsRequest) ProtoReflect() protoreflect.Message
- func (x *GetAggregateBackfillJobsRequest) Reset()
- func (x *GetAggregateBackfillJobsRequest) String() string
- type GetAggregateBackfillJobsResponse
- func (*GetAggregateBackfillJobsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetAggregateBackfillJobsResponse) GetCursor() string
- func (x *GetAggregateBackfillJobsResponse) GetJobs() []*AggregateBackfillJob
- func (*GetAggregateBackfillJobsResponse) ProtoMessage()
- func (x *GetAggregateBackfillJobsResponse) ProtoReflect() protoreflect.Message
- func (x *GetAggregateBackfillJobsResponse) Reset()
- func (x *GetAggregateBackfillJobsResponse) String() string
- type GetAggregatesRequest
- func (*GetAggregatesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetAggregatesRequest) GetForFeatures() []string
- func (*GetAggregatesRequest) ProtoMessage()
- func (x *GetAggregatesRequest) ProtoReflect() protoreflect.Message
- func (x *GetAggregatesRequest) Reset()
- func (x *GetAggregatesRequest) String() string
- type GetAggregatesResponse
- func (*GetAggregatesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetAggregatesResponse) GetErrors() []string
- func (x *GetAggregatesResponse) GetSeries() []*AggregateTimeSeries
- func (*GetAggregatesResponse) ProtoMessage()
- func (x *GetAggregatesResponse) ProtoReflect() protoreflect.Message
- func (x *GetAggregatesResponse) Reset()
- func (x *GetAggregatesResponse) String() string
- type PlanAggregateBackfillRequest
- func (*PlanAggregateBackfillRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PlanAggregateBackfillRequest) GetParams() *AggregateBackfillUserParams
- func (*PlanAggregateBackfillRequest) ProtoMessage()
- func (x *PlanAggregateBackfillRequest) ProtoReflect() protoreflect.Message
- func (x *PlanAggregateBackfillRequest) Reset()
- func (x *PlanAggregateBackfillRequest) String() string
- type PlanAggregateBackfillResponse
- func (*PlanAggregateBackfillResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PlanAggregateBackfillResponse) GetAggregateBackfillId() string
- func (x *PlanAggregateBackfillResponse) GetBackfills() []*AggregateBackfillWithCostEstimate
- func (x *PlanAggregateBackfillResponse) GetErrors() []string
- func (x *PlanAggregateBackfillResponse) GetEstimate() *AggregateBackfillCostEstimate
- func (*PlanAggregateBackfillResponse) ProtoMessage()
- func (x *PlanAggregateBackfillResponse) ProtoReflect() protoreflect.Message
- func (x *PlanAggregateBackfillResponse) Reset()
- func (x *PlanAggregateBackfillResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var File_chalk_aggregate_v1_backfill_proto protoreflect.FileDescriptor
var File_chalk_aggregate_v1_service_proto protoreflect.FileDescriptor
var File_chalk_aggregate_v1_timeseries_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AggregateBackfill ¶ added in v0.15.4
type AggregateBackfill struct { Series []*AggregateTimeSeries `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"` Resolver string `protobuf:"bytes,2,opt,name=resolver,proto3" json:"resolver,omitempty"` DatetimeFeature string `protobuf:"bytes,3,opt,name=datetime_feature,json=datetimeFeature,proto3" json:"datetime_feature,omitempty"` BucketDuration *durationpb.Duration `protobuf:"bytes,4,opt,name=bucket_duration,json=bucketDuration,proto3" json:"bucket_duration,omitempty"` FiltersDescription string `protobuf:"bytes,5,opt,name=filters_description,json=filtersDescription,proto3" json:"filters_description,omitempty"` GroupBy []string `protobuf:"bytes,6,rep,name=group_by,json=groupBy,proto3" json:"group_by,omitempty"` MaxRetention *durationpb.Duration `protobuf:"bytes,7,opt,name=max_retention,json=maxRetention,proto3" json:"max_retention,omitempty"` LowerBound *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=lower_bound,json=lowerBound,proto3" json:"lower_bound,omitempty"` UpperBound *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=upper_bound,json=upperBound,proto3" json:"upper_bound,omitempty"` // contains filtered or unexported fields }
func (*AggregateBackfill) Descriptor
deprecated
added in
v0.15.4
func (*AggregateBackfill) Descriptor() ([]byte, []int)
Deprecated: Use AggregateBackfill.ProtoReflect.Descriptor instead.
func (*AggregateBackfill) GetBucketDuration ¶ added in v0.15.4
func (x *AggregateBackfill) GetBucketDuration() *durationpb.Duration
func (*AggregateBackfill) GetDatetimeFeature ¶ added in v0.15.4
func (x *AggregateBackfill) GetDatetimeFeature() string
func (*AggregateBackfill) GetFiltersDescription ¶ added in v0.15.4
func (x *AggregateBackfill) GetFiltersDescription() string
func (*AggregateBackfill) GetGroupBy ¶ added in v0.15.4
func (x *AggregateBackfill) GetGroupBy() []string
func (*AggregateBackfill) GetLowerBound ¶ added in v0.16.1
func (x *AggregateBackfill) GetLowerBound() *timestamppb.Timestamp
func (*AggregateBackfill) GetMaxRetention ¶ added in v0.15.4
func (x *AggregateBackfill) GetMaxRetention() *durationpb.Duration
func (*AggregateBackfill) GetResolver ¶ added in v0.15.4
func (x *AggregateBackfill) GetResolver() string
func (*AggregateBackfill) GetSeries ¶ added in v0.15.4
func (x *AggregateBackfill) GetSeries() []*AggregateTimeSeries
func (*AggregateBackfill) GetUpperBound ¶ added in v0.16.1
func (x *AggregateBackfill) GetUpperBound() *timestamppb.Timestamp
func (*AggregateBackfill) ProtoMessage ¶ added in v0.15.4
func (*AggregateBackfill) ProtoMessage()
func (*AggregateBackfill) ProtoReflect ¶ added in v0.15.4
func (x *AggregateBackfill) ProtoReflect() protoreflect.Message
func (*AggregateBackfill) Reset ¶ added in v0.15.4
func (x *AggregateBackfill) Reset()
func (*AggregateBackfill) String ¶ added in v0.15.4
func (x *AggregateBackfill) String() string
type AggregateBackfillCostEstimate ¶ added in v0.16.5
type AggregateBackfillCostEstimate struct { 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 (*AggregateBackfillCostEstimate) Descriptor
deprecated
added in
v0.16.5
func (*AggregateBackfillCostEstimate) Descriptor() ([]byte, []int)
Deprecated: Use AggregateBackfillCostEstimate.ProtoReflect.Descriptor instead.
func (*AggregateBackfillCostEstimate) GetExpectedBuckets ¶ added in v0.16.5
func (x *AggregateBackfillCostEstimate) GetExpectedBuckets() int64
func (*AggregateBackfillCostEstimate) GetExpectedBytes ¶ added in v0.16.5
func (x *AggregateBackfillCostEstimate) GetExpectedBytes() int64
func (*AggregateBackfillCostEstimate) GetExpectedRuntime ¶ added in v0.16.5
func (x *AggregateBackfillCostEstimate) GetExpectedRuntime() *durationpb.Duration
func (*AggregateBackfillCostEstimate) GetExpectedStorageCost ¶ added in v0.16.5
func (x *AggregateBackfillCostEstimate) GetExpectedStorageCost() float64
func (*AggregateBackfillCostEstimate) GetMaxBuckets ¶ added in v0.16.5
func (x *AggregateBackfillCostEstimate) GetMaxBuckets() int64
func (*AggregateBackfillCostEstimate) ProtoMessage ¶ added in v0.16.5
func (*AggregateBackfillCostEstimate) ProtoMessage()
func (*AggregateBackfillCostEstimate) ProtoReflect ¶ added in v0.16.5
func (x *AggregateBackfillCostEstimate) ProtoReflect() protoreflect.Message
func (*AggregateBackfillCostEstimate) Reset ¶ added in v0.16.5
func (x *AggregateBackfillCostEstimate) Reset()
func (*AggregateBackfillCostEstimate) String ¶ added in v0.16.5
func (x *AggregateBackfillCostEstimate) String() string
type AggregateBackfillJob ¶ added in v0.16.10
type AggregateBackfillJob struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` EnvironmentId string `protobuf:"bytes,2,opt,name=environment_id,json=environmentId,proto3" json:"environment_id,omitempty"` Resolver *string `protobuf:"bytes,3,opt,name=resolver,proto3,oneof" json:"resolver,omitempty"` Features []string `protobuf:"bytes,4,rep,name=features,proto3" json:"features,omitempty"` AgentId *string `protobuf:"bytes,5,opt,name=agent_id,json=agentId,proto3,oneof" json:"agent_id,omitempty"` DeploymentId *string `protobuf:"bytes,6,opt,name=deployment_id,json=deploymentId,proto3,oneof" json:"deployment_id,omitempty"` CreatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` Resolvers []string `protobuf:"bytes,9,rep,name=resolvers,proto3" json:"resolvers,omitempty"` // contains filtered or unexported fields }
func (*AggregateBackfillJob) Descriptor
deprecated
added in
v0.16.10
func (*AggregateBackfillJob) Descriptor() ([]byte, []int)
Deprecated: Use AggregateBackfillJob.ProtoReflect.Descriptor instead.
func (*AggregateBackfillJob) GetAgentId ¶ added in v0.16.10
func (x *AggregateBackfillJob) GetAgentId() string
func (*AggregateBackfillJob) GetCreatedAt ¶ added in v0.16.10
func (x *AggregateBackfillJob) GetCreatedAt() *timestamppb.Timestamp
func (*AggregateBackfillJob) GetDeploymentId ¶ added in v0.16.10
func (x *AggregateBackfillJob) GetDeploymentId() string
func (*AggregateBackfillJob) GetEnvironmentId ¶ added in v0.16.10
func (x *AggregateBackfillJob) GetEnvironmentId() string
func (*AggregateBackfillJob) GetFeatures ¶ added in v0.16.10
func (x *AggregateBackfillJob) GetFeatures() []string
func (*AggregateBackfillJob) GetId ¶ added in v0.16.10
func (x *AggregateBackfillJob) GetId() string
func (*AggregateBackfillJob) GetResolver ¶ added in v0.16.10
func (x *AggregateBackfillJob) GetResolver() string
func (*AggregateBackfillJob) GetResolvers ¶ added in v0.16.15
func (x *AggregateBackfillJob) GetResolvers() []string
func (*AggregateBackfillJob) GetUpdatedAt ¶ added in v0.16.10
func (x *AggregateBackfillJob) GetUpdatedAt() *timestamppb.Timestamp
func (*AggregateBackfillJob) ProtoMessage ¶ added in v0.16.10
func (*AggregateBackfillJob) ProtoMessage()
func (*AggregateBackfillJob) ProtoReflect ¶ added in v0.16.10
func (x *AggregateBackfillJob) ProtoReflect() protoreflect.Message
func (*AggregateBackfillJob) Reset ¶ added in v0.16.10
func (x *AggregateBackfillJob) Reset()
func (*AggregateBackfillJob) String ¶ added in v0.16.10
func (x *AggregateBackfillJob) 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"` // Deprecated: Marked as deprecated in chalk/aggregate/v1/backfill.proto. 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
deprecated
func (x *AggregateBackfillUserParams) GetTimestampColumnName() string
Deprecated: Marked as deprecated in chalk/aggregate/v1/backfill.proto.
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 AggregateBackfillWithCostEstimate ¶ added in v0.16.5
type AggregateBackfillWithCostEstimate struct { Backfill *AggregateBackfill `protobuf:"bytes,1,opt,name=backfill,proto3" json:"backfill,omitempty"` Estimate *AggregateBackfillCostEstimate `protobuf:"bytes,2,opt,name=estimate,proto3" json:"estimate,omitempty"` // contains filtered or unexported fields }
func (*AggregateBackfillWithCostEstimate) Descriptor
deprecated
added in
v0.16.5
func (*AggregateBackfillWithCostEstimate) Descriptor() ([]byte, []int)
Deprecated: Use AggregateBackfillWithCostEstimate.ProtoReflect.Descriptor instead.
func (*AggregateBackfillWithCostEstimate) GetBackfill ¶ added in v0.16.5
func (x *AggregateBackfillWithCostEstimate) GetBackfill() *AggregateBackfill
func (*AggregateBackfillWithCostEstimate) GetEstimate ¶ added in v0.16.5
func (x *AggregateBackfillWithCostEstimate) GetEstimate() *AggregateBackfillCostEstimate
func (*AggregateBackfillWithCostEstimate) ProtoMessage ¶ added in v0.16.5
func (*AggregateBackfillWithCostEstimate) ProtoMessage()
func (*AggregateBackfillWithCostEstimate) ProtoReflect ¶ added in v0.16.5
func (x *AggregateBackfillWithCostEstimate) ProtoReflect() protoreflect.Message
func (*AggregateBackfillWithCostEstimate) Reset ¶ added in v0.16.5
func (x *AggregateBackfillWithCostEstimate) Reset()
func (*AggregateBackfillWithCostEstimate) String ¶ added in v0.16.5
func (x *AggregateBackfillWithCostEstimate) 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"` BucketFeature string `protobuf:"bytes,7,opt,name=bucket_feature,json=bucketFeature,proto3" json:"bucket_feature,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) GetBucketFeature ¶ added in v0.16.5
func (x *AggregateTimeSeries) GetBucketFeature() 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"` DatetimeFeature string `protobuf:"bytes,5,opt,name=datetime_feature,json=datetimeFeature,proto3" json:"datetime_feature,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) GetDatetimeFeature ¶ added in v0.16.4
func (x *AggregateTimeSeriesRule) GetDatetimeFeature() string
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 GetAggregateBackfillJobRequest ¶ added in v0.16.10
type GetAggregateBackfillJobRequest struct { AggregateBackfillId string `protobuf:"bytes,1,opt,name=aggregate_backfill_id,json=aggregateBackfillId,proto3" json:"aggregate_backfill_id,omitempty"` // contains filtered or unexported fields }
func (*GetAggregateBackfillJobRequest) Descriptor
deprecated
added in
v0.16.10
func (*GetAggregateBackfillJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetAggregateBackfillJobRequest.ProtoReflect.Descriptor instead.
func (*GetAggregateBackfillJobRequest) GetAggregateBackfillId ¶ added in v0.16.10
func (x *GetAggregateBackfillJobRequest) GetAggregateBackfillId() string
func (*GetAggregateBackfillJobRequest) ProtoMessage ¶ added in v0.16.10
func (*GetAggregateBackfillJobRequest) ProtoMessage()
func (*GetAggregateBackfillJobRequest) ProtoReflect ¶ added in v0.16.10
func (x *GetAggregateBackfillJobRequest) ProtoReflect() protoreflect.Message
func (*GetAggregateBackfillJobRequest) Reset ¶ added in v0.16.10
func (x *GetAggregateBackfillJobRequest) Reset()
func (*GetAggregateBackfillJobRequest) String ¶ added in v0.16.10
func (x *GetAggregateBackfillJobRequest) String() string
type GetAggregateBackfillJobResponse ¶ added in v0.16.10
type GetAggregateBackfillJobResponse struct { Job *AggregateBackfillJob `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` // contains filtered or unexported fields }
func (*GetAggregateBackfillJobResponse) Descriptor
deprecated
added in
v0.16.10
func (*GetAggregateBackfillJobResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetAggregateBackfillJobResponse.ProtoReflect.Descriptor instead.
func (*GetAggregateBackfillJobResponse) GetJob ¶ added in v0.16.10
func (x *GetAggregateBackfillJobResponse) GetJob() *AggregateBackfillJob
func (*GetAggregateBackfillJobResponse) ProtoMessage ¶ added in v0.16.10
func (*GetAggregateBackfillJobResponse) ProtoMessage()
func (*GetAggregateBackfillJobResponse) ProtoReflect ¶ added in v0.16.10
func (x *GetAggregateBackfillJobResponse) ProtoReflect() protoreflect.Message
func (*GetAggregateBackfillJobResponse) Reset ¶ added in v0.16.10
func (x *GetAggregateBackfillJobResponse) Reset()
func (*GetAggregateBackfillJobResponse) String ¶ added in v0.16.10
func (x *GetAggregateBackfillJobResponse) String() string
type GetAggregateBackfillJobsRequest ¶ added in v0.16.10
type GetAggregateBackfillJobsRequest struct { Limit int32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"` Cursor string `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"` // contains filtered or unexported fields }
func (*GetAggregateBackfillJobsRequest) Descriptor
deprecated
added in
v0.16.10
func (*GetAggregateBackfillJobsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetAggregateBackfillJobsRequest.ProtoReflect.Descriptor instead.
func (*GetAggregateBackfillJobsRequest) GetCursor ¶ added in v0.16.10
func (x *GetAggregateBackfillJobsRequest) GetCursor() string
func (*GetAggregateBackfillJobsRequest) GetLimit ¶ added in v0.16.10
func (x *GetAggregateBackfillJobsRequest) GetLimit() int32
func (*GetAggregateBackfillJobsRequest) ProtoMessage ¶ added in v0.16.10
func (*GetAggregateBackfillJobsRequest) ProtoMessage()
func (*GetAggregateBackfillJobsRequest) ProtoReflect ¶ added in v0.16.10
func (x *GetAggregateBackfillJobsRequest) ProtoReflect() protoreflect.Message
func (*GetAggregateBackfillJobsRequest) Reset ¶ added in v0.16.10
func (x *GetAggregateBackfillJobsRequest) Reset()
func (*GetAggregateBackfillJobsRequest) String ¶ added in v0.16.10
func (x *GetAggregateBackfillJobsRequest) String() string
type GetAggregateBackfillJobsResponse ¶ added in v0.16.10
type GetAggregateBackfillJobsResponse struct { Jobs []*AggregateBackfillJob `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"` Cursor string `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"` // contains filtered or unexported fields }
func (*GetAggregateBackfillJobsResponse) Descriptor
deprecated
added in
v0.16.10
func (*GetAggregateBackfillJobsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetAggregateBackfillJobsResponse.ProtoReflect.Descriptor instead.
func (*GetAggregateBackfillJobsResponse) GetCursor ¶ added in v0.16.10
func (x *GetAggregateBackfillJobsResponse) GetCursor() string
func (*GetAggregateBackfillJobsResponse) GetJobs ¶ added in v0.16.10
func (x *GetAggregateBackfillJobsResponse) GetJobs() []*AggregateBackfillJob
func (*GetAggregateBackfillJobsResponse) ProtoMessage ¶ added in v0.16.10
func (*GetAggregateBackfillJobsResponse) ProtoMessage()
func (*GetAggregateBackfillJobsResponse) ProtoReflect ¶ added in v0.16.10
func (x *GetAggregateBackfillJobsResponse) ProtoReflect() protoreflect.Message
func (*GetAggregateBackfillJobsResponse) Reset ¶ added in v0.16.10
func (x *GetAggregateBackfillJobsResponse) Reset()
func (*GetAggregateBackfillJobsResponse) String ¶ added in v0.16.10
func (x *GetAggregateBackfillJobsResponse) 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 { Estimate *AggregateBackfillCostEstimate `protobuf:"bytes,2,opt,name=estimate,proto3" json:"estimate,omitempty"` Errors []string `protobuf:"bytes,4,rep,name=errors,proto3" json:"errors,omitempty"` Backfills []*AggregateBackfillWithCostEstimate `protobuf:"bytes,6,rep,name=backfills,proto3" json:"backfills,omitempty"` AggregateBackfillId string `protobuf:"bytes,7,opt,name=aggregate_backfill_id,json=aggregateBackfillId,proto3" json:"aggregate_backfill_id,omitempty"` // contains filtered or unexported fields }
func (*PlanAggregateBackfillResponse) Descriptor
deprecated
func (*PlanAggregateBackfillResponse) Descriptor() ([]byte, []int)
Deprecated: Use PlanAggregateBackfillResponse.ProtoReflect.Descriptor instead.
func (*PlanAggregateBackfillResponse) GetAggregateBackfillId ¶ added in v0.16.10
func (x *PlanAggregateBackfillResponse) GetAggregateBackfillId() string
func (*PlanAggregateBackfillResponse) GetBackfills ¶ added in v0.16.5
func (x *PlanAggregateBackfillResponse) GetBackfills() []*AggregateBackfillWithCostEstimate
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() *AggregateBackfillCostEstimate
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