aggregatev1

package
v0.18.25 Latest Latest
Warning

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

 Go to latest Published: Dec 11, 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 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"`
	CronAggregateBackfillId *string                `` /* 141-byte string literal not displayed */
	PlanHash                *string                `protobuf:"bytes,11,opt,name=plan_hash,json=planHash,proto3,oneof" json:"plan_hash,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) GetCronAggregateBackfillId added in v0.18.22 

func (x *AggregateBackfillJob) GetCronAggregateBackfillId() string

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) GetPlanHash added in v0.18.22 

func (x *AggregateBackfillJob) GetPlanHash() 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 CronAggregateBackfill added in v0.18.22 

type CronAggregateBackfill 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"`
	DeploymentId  string                 `protobuf:"bytes,3,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	Schedule      string                 `protobuf:"bytes,4,opt,name=schedule,proto3" json:"schedule,omitempty"`
	PlanHash      string                 `protobuf:"bytes,5,opt,name=plan_hash,json=planHash,proto3" json:"plan_hash,omitempty"`
	Features      []string               `protobuf:"bytes,8,rep,name=features,proto3" json:"features,omitempty"`
	Resolvers     []string               `protobuf:"bytes,9,rep,name=resolvers,proto3" json:"resolvers,omitempty"`
	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt     *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*CronAggregateBackfill) Descriptor deprecated added in v0.18.22 

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

Deprecated: Use CronAggregateBackfill.ProtoReflect.Descriptor instead.

func (*CronAggregateBackfill) GetCreatedAt added in v0.18.22 

func (x *CronAggregateBackfill) GetCreatedAt() *timestamppb.Timestamp

func (*CronAggregateBackfill) GetDeploymentId added in v0.18.22 

func (x *CronAggregateBackfill) GetDeploymentId() string

func (*CronAggregateBackfill) GetEnvironmentId added in v0.18.22 

func (x *CronAggregateBackfill) GetEnvironmentId() string

func (*CronAggregateBackfill) GetFeatures added in v0.18.22 

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

func (*CronAggregateBackfill) GetId added in v0.18.22 

func (x *CronAggregateBackfill) GetId() string

func (*CronAggregateBackfill) GetPlanHash added in v0.18.22 

func (x *CronAggregateBackfill) GetPlanHash() string

func (*CronAggregateBackfill) GetResolvers added in v0.18.22 

func (x *CronAggregateBackfill) GetResolvers() []string

func (*CronAggregateBackfill) GetSchedule added in v0.18.22 

func (x *CronAggregateBackfill) GetSchedule() string

func (*CronAggregateBackfill) GetUpdatedAt added in v0.18.22 

func (x *CronAggregateBackfill) GetUpdatedAt() *timestamppb.Timestamp

func (*CronAggregateBackfill) ProtoMessage added in v0.18.22 

func (*CronAggregateBackfill) ProtoMessage()

func (*CronAggregateBackfill) ProtoReflect added in v0.18.22 

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

func (*CronAggregateBackfill) Reset added in v0.18.22 

func (x *CronAggregateBackfill) Reset()

func (*CronAggregateBackfill) String added in v0.18.22 

func (x *CronAggregateBackfill) String() string

type CronAggregateBackfillWithLatestRun added in v0.18.22 

type CronAggregateBackfillWithLatestRun struct {
	CronAggregateBackfill *CronAggregateBackfill `` /* 126-byte string literal not displayed */
	LatestJob             *AggregateBackfillJob  `protobuf:"bytes,2,opt,name=latest_job,json=latestJob,proto3" json:"latest_job,omitempty"`
	// contains filtered or unexported fields
}

func (*CronAggregateBackfillWithLatestRun) Descriptor deprecated added in v0.18.22 

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

Deprecated: Use CronAggregateBackfillWithLatestRun.ProtoReflect.Descriptor instead.

func (*CronAggregateBackfillWithLatestRun) GetCronAggregateBackfill added in v0.18.22 

func (x *CronAggregateBackfillWithLatestRun) GetCronAggregateBackfill() *CronAggregateBackfill

func (*CronAggregateBackfillWithLatestRun) GetLatestJob added in v0.18.22 

func (x *CronAggregateBackfillWithLatestRun) GetLatestJob() *AggregateBackfillJob

func (*CronAggregateBackfillWithLatestRun) ProtoMessage added in v0.18.22 

func (*CronAggregateBackfillWithLatestRun) ProtoMessage()

func (*CronAggregateBackfillWithLatestRun) ProtoReflect added in v0.18.22 

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

func (*CronAggregateBackfillWithLatestRun) Reset added in v0.18.22 

func (x *CronAggregateBackfillWithLatestRun) Reset()

func (*CronAggregateBackfillWithLatestRun) String added in v0.18.22 

func (x *CronAggregateBackfillWithLatestRun) String() string

type GetActiveCronAggregateBackfillsRequest added in v0.18.22 

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

func (*GetActiveCronAggregateBackfillsRequest) Descriptor deprecated added in v0.18.22 

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

Deprecated: Use GetActiveCronAggregateBackfillsRequest.ProtoReflect.Descriptor instead.

func (*GetActiveCronAggregateBackfillsRequest) ProtoMessage added in v0.18.22 

func (*GetActiveCronAggregateBackfillsRequest) ProtoMessage()

func (*GetActiveCronAggregateBackfillsRequest) ProtoReflect added in v0.18.22 

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

func (*GetActiveCronAggregateBackfillsRequest) Reset added in v0.18.22 

func (x *GetActiveCronAggregateBackfillsRequest) Reset()

func (*GetActiveCronAggregateBackfillsRequest) String added in v0.18.22 

func (x *GetActiveCronAggregateBackfillsRequest) String() string

type GetActiveCronAggregateBackfillsResponse added in v0.18.22 

type GetActiveCronAggregateBackfillsResponse struct {
	CronAggregateBackfills []*CronAggregateBackfillWithLatestRun `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetActiveCronAggregateBackfillsResponse) Descriptor deprecated added in v0.18.22 

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

Deprecated: Use GetActiveCronAggregateBackfillsResponse.ProtoReflect.Descriptor instead.

func (*GetActiveCronAggregateBackfillsResponse) GetCronAggregateBackfills added in v0.18.22 

func (x *GetActiveCronAggregateBackfillsResponse) GetCronAggregateBackfills() []*CronAggregateBackfillWithLatestRun

func (*GetActiveCronAggregateBackfillsResponse) ProtoMessage added in v0.18.22 

func (*GetActiveCronAggregateBackfillsResponse) ProtoMessage()

func (*GetActiveCronAggregateBackfillsResponse) ProtoReflect added in v0.18.22 

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

func (*GetActiveCronAggregateBackfillsResponse) Reset added in v0.18.22 

func (x *GetActiveCronAggregateBackfillsResponse) Reset()

func (*GetActiveCronAggregateBackfillsResponse) String added in v0.18.22 

func (x *GetActiveCronAggregateBackfillsResponse) 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"`
	PlanHash *string `protobuf:"bytes,3,opt,name=plan_hash,json=planHash,proto3,oneof" json:"plan_hash,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) GetPlanHash added in v0.18.22 

func (x *GetAggregateBackfillJobsRequest) GetPlanHash() string

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 GetCronAggregateBackfillRequest added in v0.18.22 

type GetCronAggregateBackfillRequest struct {

	// Deprecated: Marked as deprecated in chalk/aggregate/v1/service.proto.
	CronAggregateBackfillId string `` /* 134-byte string literal not displayed */
	PlanHash                string `protobuf:"bytes,2,opt,name=plan_hash,json=planHash,proto3" json:"plan_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCronAggregateBackfillRequest) Descriptor deprecated added in v0.18.22 

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

Deprecated: Use GetCronAggregateBackfillRequest.ProtoReflect.Descriptor instead.

func (*GetCronAggregateBackfillRequest) GetCronAggregateBackfillId deprecated added in v0.18.22 

func (x *GetCronAggregateBackfillRequest) GetCronAggregateBackfillId() string

Deprecated: Marked as deprecated in chalk/aggregate/v1/service.proto.

func (*GetCronAggregateBackfillRequest) GetPlanHash added in v0.18.23 

func (x *GetCronAggregateBackfillRequest) GetPlanHash() string

func (*GetCronAggregateBackfillRequest) ProtoMessage added in v0.18.22 

func (*GetCronAggregateBackfillRequest) ProtoMessage()

func (*GetCronAggregateBackfillRequest) ProtoReflect added in v0.18.22 

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

func (*GetCronAggregateBackfillRequest) Reset added in v0.18.22 

func (x *GetCronAggregateBackfillRequest) Reset()

func (*GetCronAggregateBackfillRequest) String added in v0.18.22 

func (x *GetCronAggregateBackfillRequest) String() string

type GetCronAggregateBackfillResponse added in v0.18.22 

type GetCronAggregateBackfillResponse struct {
	CronAggregateBackfill *CronAggregateBackfill `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetCronAggregateBackfillResponse) Descriptor deprecated added in v0.18.22 

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

Deprecated: Use GetCronAggregateBackfillResponse.ProtoReflect.Descriptor instead.

func (*GetCronAggregateBackfillResponse) GetCronAggregateBackfill added in v0.18.22 

func (x *GetCronAggregateBackfillResponse) GetCronAggregateBackfill() *CronAggregateBackfill

func (*GetCronAggregateBackfillResponse) ProtoMessage added in v0.18.22 

func (*GetCronAggregateBackfillResponse) ProtoMessage()

func (*GetCronAggregateBackfillResponse) ProtoReflect added in v0.18.22 

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

func (*GetCronAggregateBackfillResponse) Reset added in v0.18.22 

func (x *GetCronAggregateBackfillResponse) Reset()

func (*GetCronAggregateBackfillResponse) String added in v0.18.22 

func (x *GetCronAggregateBackfillResponse) 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

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.