enginev2

package
v0.20.6 Latest Latest
Warning

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

 Go to latest Published: Dec 24, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	FeatureValuesTimestampType_name = map[int32]string{
		0: "FEATURE_VALUES_TIMESTAMP_TYPE_UNSPECIFIED",
		1: "FEATURE_VALUES_TIMESTAMP_TYPE_INSERTED_AT",
		2: "FEATURE_VALUES_TIMESTAMP_TYPE_OBSERVED_AT",
	}
	FeatureValuesTimestampType_value = map[string]int32{
		"FEATURE_VALUES_TIMESTAMP_TYPE_UNSPECIFIED": 0,
		"FEATURE_VALUES_TIMESTAMP_TYPE_INSERTED_AT": 1,
		"FEATURE_VALUES_TIMESTAMP_TYPE_OBSERVED_AT": 2,
	}
)

Enum value maps for FeatureValuesTimestampType.

View Source 
var (
	FeatureValueBaseWindowFunction_name = map[int32]string{
		0: "FEATURE_VALUE_BASE_WINDOW_FUNCTION_UNSPECIFIED",
		1: "FEATURE_VALUE_BASE_WINDOW_FUNCTION_UNIQUE_VALUES",
		2: "FEATURE_VALUE_BASE_WINDOW_FUNCTION_TOTAL_OBSERVATIONS",
		3: "FEATURE_VALUE_BASE_WINDOW_FUNCTION_NULL_PERCENTAGE",
		4: "FEATURE_VALUE_BASE_WINDOW_FUNCTION_MAX_VALUE",
		5: "FEATURE_VALUE_BASE_WINDOW_FUNCTION_MIN_VALUE",
		6: "FEATURE_VALUE_BASE_WINDOW_FUNCTION_AVERAGE",
		7: "FEATURE_VALUE_BASE_WINDOW_FUNCTION_UNIQUE_PKEYS",
	}
	FeatureValueBaseWindowFunction_value = map[string]int32{
		"FEATURE_VALUE_BASE_WINDOW_FUNCTION_UNSPECIFIED":        0,
		"FEATURE_VALUE_BASE_WINDOW_FUNCTION_UNIQUE_VALUES":      1,
		"FEATURE_VALUE_BASE_WINDOW_FUNCTION_TOTAL_OBSERVATIONS": 2,
		"FEATURE_VALUE_BASE_WINDOW_FUNCTION_NULL_PERCENTAGE":    3,
		"FEATURE_VALUE_BASE_WINDOW_FUNCTION_MAX_VALUE":          4,
		"FEATURE_VALUE_BASE_WINDOW_FUNCTION_MIN_VALUE":          5,
		"FEATURE_VALUE_BASE_WINDOW_FUNCTION_AVERAGE":            6,
		"FEATURE_VALUE_BASE_WINDOW_FUNCTION_UNIQUE_PKEYS":       7,
	}
)

Enum value maps for FeatureValueBaseWindowFunction.

View Source 
var (
	FeatureValueGroupBy_name = map[int32]string{
		0: "FEATURE_VALUE_GROUP_BY_UNSPECIFIED",
		1: "FEATURE_VALUE_GROUP_BY_CATEGORICAL_VALUE",
		2: "FEATURE_VALUE_GROUP_BY_PRIMARY_KEY",
		3: "FEATURE_VALUE_GROUP_BY_DEPLOYMENT_ID",
		4: "FEATURE_VALUE_GROUP_BY_RESOLVER",
		5: "FEATURE_VALUE_GROUP_BY_OPERATION_KIND",
		6: "FEATURE_VALUE_GROUP_BY_OPERATION_ID",
		7: "FEATURE_VALUE_GROUP_BY_FEATURE_VERSION",
	}
	FeatureValueGroupBy_value = map[string]int32{
		"FEATURE_VALUE_GROUP_BY_UNSPECIFIED":       0,
		"FEATURE_VALUE_GROUP_BY_CATEGORICAL_VALUE": 1,
		"FEATURE_VALUE_GROUP_BY_PRIMARY_KEY":       2,
		"FEATURE_VALUE_GROUP_BY_DEPLOYMENT_ID":     3,
		"FEATURE_VALUE_GROUP_BY_RESOLVER":          4,
		"FEATURE_VALUE_GROUP_BY_OPERATION_KIND":    5,
		"FEATURE_VALUE_GROUP_BY_OPERATION_ID":      6,
		"FEATURE_VALUE_GROUP_BY_FEATURE_VERSION":   7,
	}
)

Enum value maps for FeatureValueGroupBy.

View Source 
var (
	FeatureValueTimeSeries_name = map[int32]string{
		0: "FEATURE_VALUE_TIME_SERIES_UNSPECIFIED",
		1: "FEATURE_VALUE_TIME_SERIES_INSERTED_AT",
		2: "FEATURE_VALUE_TIME_SERIES_OBSERVED_AT",
	}
	FeatureValueTimeSeries_value = map[string]int32{
		"FEATURE_VALUE_TIME_SERIES_UNSPECIFIED": 0,
		"FEATURE_VALUE_TIME_SERIES_INSERTED_AT": 1,
		"FEATURE_VALUE_TIME_SERIES_OBSERVED_AT": 2,
	}
)

Enum value maps for FeatureValueTimeSeries.

View Source 
var File_chalk_engine_v2_feature_values_chart_proto protoreflect.FileDescriptor
View Source 
var File_chalk_engine_v2_feature_values_proto protoreflect.FileDescriptor
View Source 
var File_chalk_engine_v2_offline_store_service_proto protoreflect.FileDescriptor
View Source 
var File_chalk_engine_v2_query_log_proto protoreflect.FileDescriptor
View Source 
var File_chalk_engine_v2_query_values_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type FeatureValueBaseWindowFunction 

type FeatureValueBaseWindowFunction int32
const (
	FeatureValueBaseWindowFunction_FEATURE_VALUE_BASE_WINDOW_FUNCTION_UNSPECIFIED        FeatureValueBaseWindowFunction = 0
	FeatureValueBaseWindowFunction_FEATURE_VALUE_BASE_WINDOW_FUNCTION_UNIQUE_VALUES      FeatureValueBaseWindowFunction = 1
	FeatureValueBaseWindowFunction_FEATURE_VALUE_BASE_WINDOW_FUNCTION_TOTAL_OBSERVATIONS FeatureValueBaseWindowFunction = 2
	FeatureValueBaseWindowFunction_FEATURE_VALUE_BASE_WINDOW_FUNCTION_NULL_PERCENTAGE    FeatureValueBaseWindowFunction = 3
	FeatureValueBaseWindowFunction_FEATURE_VALUE_BASE_WINDOW_FUNCTION_MAX_VALUE          FeatureValueBaseWindowFunction = 4
	FeatureValueBaseWindowFunction_FEATURE_VALUE_BASE_WINDOW_FUNCTION_MIN_VALUE          FeatureValueBaseWindowFunction = 5
	FeatureValueBaseWindowFunction_FEATURE_VALUE_BASE_WINDOW_FUNCTION_AVERAGE            FeatureValueBaseWindowFunction = 6
	FeatureValueBaseWindowFunction_FEATURE_VALUE_BASE_WINDOW_FUNCTION_UNIQUE_PKEYS       FeatureValueBaseWindowFunction = 7
)

func (FeatureValueBaseWindowFunction) Descriptor 

func (FeatureValueBaseWindowFunction) Descriptor() protoreflect.EnumDescriptor

func (FeatureValueBaseWindowFunction) Enum 

func (x FeatureValueBaseWindowFunction) Enum() *FeatureValueBaseWindowFunction

func (FeatureValueBaseWindowFunction) EnumDescriptor deprecated 

func (FeatureValueBaseWindowFunction) EnumDescriptor() ([]byte, []int)

Deprecated: Use FeatureValueBaseWindowFunction.Descriptor instead.

func (FeatureValueBaseWindowFunction) Number 

func (x FeatureValueBaseWindowFunction) Number() protoreflect.EnumNumber

func (FeatureValueBaseWindowFunction) String 

func (x FeatureValueBaseWindowFunction) String() string

func (FeatureValueBaseWindowFunction) Type 

func (FeatureValueBaseWindowFunction) Type() protoreflect.EnumType

type FeatureValueFilters 

type FeatureValueFilters struct {
	ResolverFqn   []string           `protobuf:"bytes,1,rep,name=resolver_fqn,json=resolverFqn,proto3" json:"resolver_fqn,omitempty"`
	DeploymentId  []string           `protobuf:"bytes,2,rep,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	OperationId   []string           `protobuf:"bytes,3,rep,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	OperationKind []v1.OperationKind `` /* 143-byte string literal not displayed */
	PrimaryKey    []*v11.ScalarValue `protobuf:"bytes,5,rep,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureValueFilters) Descriptor deprecated 

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

Deprecated: Use FeatureValueFilters.ProtoReflect.Descriptor instead.

func (*FeatureValueFilters) GetDeploymentId 

func (x *FeatureValueFilters) GetDeploymentId() []string

func (*FeatureValueFilters) GetOperationId 

func (x *FeatureValueFilters) GetOperationId() []string

func (*FeatureValueFilters) GetOperationKind 

func (x *FeatureValueFilters) GetOperationKind() []v1.OperationKind

func (*FeatureValueFilters) GetPrimaryKey 

func (x *FeatureValueFilters) GetPrimaryKey() []*v11.ScalarValue

func (*FeatureValueFilters) GetResolverFqn 

func (x *FeatureValueFilters) GetResolverFqn() []string

func (*FeatureValueFilters) ProtoMessage 

func (*FeatureValueFilters) ProtoMessage()

func (*FeatureValueFilters) ProtoReflect 

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

func (*FeatureValueFilters) Reset 

func (x *FeatureValueFilters) Reset()

func (*FeatureValueFilters) String 

func (x *FeatureValueFilters) String() string

type FeatureValueGroupBy added in v0.17.24 

type FeatureValueGroupBy int32
const (
	FeatureValueGroupBy_FEATURE_VALUE_GROUP_BY_UNSPECIFIED FeatureValueGroupBy = 0
	// Approximately ordered by cardinality / specificity
	FeatureValueGroupBy_FEATURE_VALUE_GROUP_BY_CATEGORICAL_VALUE FeatureValueGroupBy = 1
	FeatureValueGroupBy_FEATURE_VALUE_GROUP_BY_PRIMARY_KEY       FeatureValueGroupBy = 2
	FeatureValueGroupBy_FEATURE_VALUE_GROUP_BY_DEPLOYMENT_ID     FeatureValueGroupBy = 3
	FeatureValueGroupBy_FEATURE_VALUE_GROUP_BY_RESOLVER          FeatureValueGroupBy = 4
	FeatureValueGroupBy_FEATURE_VALUE_GROUP_BY_OPERATION_KIND    FeatureValueGroupBy = 5
	FeatureValueGroupBy_FEATURE_VALUE_GROUP_BY_OPERATION_ID      FeatureValueGroupBy = 6
	FeatureValueGroupBy_FEATURE_VALUE_GROUP_BY_FEATURE_VERSION   FeatureValueGroupBy = 7
)

func (FeatureValueGroupBy) Descriptor added in v0.17.24 

func (FeatureValueGroupBy) Descriptor() protoreflect.EnumDescriptor

func (FeatureValueGroupBy) Enum added in v0.17.24 

func (x FeatureValueGroupBy) Enum() *FeatureValueGroupBy

func (FeatureValueGroupBy) EnumDescriptor deprecated added in v0.17.24 

func (FeatureValueGroupBy) EnumDescriptor() ([]byte, []int)

Deprecated: Use FeatureValueGroupBy.Descriptor instead.

func (FeatureValueGroupBy) Number added in v0.17.24 

func (x FeatureValueGroupBy) Number() protoreflect.EnumNumber

func (FeatureValueGroupBy) String added in v0.17.24 

func (x FeatureValueGroupBy) String() string

func (FeatureValueGroupBy) Type added in v0.17.24 

func (FeatureValueGroupBy) Type() protoreflect.EnumType

type FeatureValuePercentileWindowFunction 

type FeatureValuePercentileWindowFunction struct {

	// Must be a value between 0 and 100.
	Percentile float64 `protobuf:"fixed64,1,opt,name=percentile,proto3" json:"percentile,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureValuePercentileWindowFunction) Descriptor deprecated 

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

Deprecated: Use FeatureValuePercentileWindowFunction.ProtoReflect.Descriptor instead.

func (*FeatureValuePercentileWindowFunction) GetPercentile 

func (x *FeatureValuePercentileWindowFunction) GetPercentile() float64

func (*FeatureValuePercentileWindowFunction) ProtoMessage 

func (*FeatureValuePercentileWindowFunction) ProtoMessage()

func (*FeatureValuePercentileWindowFunction) ProtoReflect 

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

func (*FeatureValuePercentileWindowFunction) Reset 

func (x *FeatureValuePercentileWindowFunction) Reset()

func (*FeatureValuePercentileWindowFunction) String 

func (x *FeatureValuePercentileWindowFunction) String() string

type FeatureValueSeries 

type FeatureValueSeries struct {
	FeatureFqn string `protobuf:"bytes,1,opt,name=feature_fqn,json=featureFqn,proto3" json:"feature_fqn,omitempty"`
	// If the user passes in a series title, uses that. Otherwise, will compose a title based on the fqn and the function used
	SeriesTitle *string `protobuf:"bytes,2,opt,name=series_title,json=seriesTitle,proto3,oneof" json:"series_title,omitempty"`
	// Types that are assignable to WindowFunction:
	//
	//	*FeatureValueSeries_BaseWindowFunction
	//	*FeatureValueSeries_PercentileWindowFunction
	WindowFunction isFeatureValueSeries_WindowFunction `protobuf_oneof:"window_function"`
	// contains filtered or unexported fields
}

func (*FeatureValueSeries) Descriptor deprecated 

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

Deprecated: Use FeatureValueSeries.ProtoReflect.Descriptor instead.

func (*FeatureValueSeries) GetBaseWindowFunction 

func (x *FeatureValueSeries) GetBaseWindowFunction() FeatureValueBaseWindowFunction

func (*FeatureValueSeries) GetFeatureFqn 

func (x *FeatureValueSeries) GetFeatureFqn() string

func (*FeatureValueSeries) GetPercentileWindowFunction 

func (x *FeatureValueSeries) GetPercentileWindowFunction() *FeatureValuePercentileWindowFunction

func (*FeatureValueSeries) GetSeriesTitle 

func (x *FeatureValueSeries) GetSeriesTitle() string

func (*FeatureValueSeries) GetWindowFunction 

func (m *FeatureValueSeries) GetWindowFunction() isFeatureValueSeries_WindowFunction

func (*FeatureValueSeries) ProtoMessage 

func (*FeatureValueSeries) ProtoMessage()

func (*FeatureValueSeries) ProtoReflect 

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

func (*FeatureValueSeries) Reset 

func (x *FeatureValueSeries) Reset()

func (*FeatureValueSeries) String 

func (x *FeatureValueSeries) String() string

type FeatureValueSeries_BaseWindowFunction 

type FeatureValueSeries_BaseWindowFunction struct {
	BaseWindowFunction FeatureValueBaseWindowFunction `` /* 138-byte string literal not displayed */
}

type FeatureValueSeries_PercentileWindowFunction 

type FeatureValueSeries_PercentileWindowFunction struct {
	PercentileWindowFunction *FeatureValuePercentileWindowFunction `protobuf:"bytes,4,opt,name=percentile_window_function,json=percentileWindowFunction,proto3,oneof"`
}

type FeatureValueTimeSeries added in v0.17.24 

type FeatureValueTimeSeries int32
const (
	FeatureValueTimeSeries_FEATURE_VALUE_TIME_SERIES_UNSPECIFIED FeatureValueTimeSeries = 0
	FeatureValueTimeSeries_FEATURE_VALUE_TIME_SERIES_INSERTED_AT FeatureValueTimeSeries = 1
	FeatureValueTimeSeries_FEATURE_VALUE_TIME_SERIES_OBSERVED_AT FeatureValueTimeSeries = 2
)

func (FeatureValueTimeSeries) Descriptor added in v0.17.24 

func (FeatureValueTimeSeries) Descriptor() protoreflect.EnumDescriptor

func (FeatureValueTimeSeries) Enum added in v0.17.24 

func (x FeatureValueTimeSeries) Enum() *FeatureValueTimeSeries

func (FeatureValueTimeSeries) EnumDescriptor deprecated added in v0.17.24 

func (FeatureValueTimeSeries) EnumDescriptor() ([]byte, []int)

Deprecated: Use FeatureValueTimeSeries.Descriptor instead.

func (FeatureValueTimeSeries) Number added in v0.17.24 

func (x FeatureValueTimeSeries) Number() protoreflect.EnumNumber

func (FeatureValueTimeSeries) String added in v0.17.24 

func (x FeatureValueTimeSeries) String() string

func (FeatureValueTimeSeries) Type added in v0.17.24 

func (FeatureValueTimeSeries) Type() protoreflect.EnumType

type FeatureValuesTimestampType 

type FeatureValuesTimestampType int32
const (
	FeatureValuesTimestampType_FEATURE_VALUES_TIMESTAMP_TYPE_UNSPECIFIED FeatureValuesTimestampType = 0
	FeatureValuesTimestampType_FEATURE_VALUES_TIMESTAMP_TYPE_INSERTED_AT FeatureValuesTimestampType = 1
	FeatureValuesTimestampType_FEATURE_VALUES_TIMESTAMP_TYPE_OBSERVED_AT FeatureValuesTimestampType = 2
)

func (FeatureValuesTimestampType) Descriptor 

func (FeatureValuesTimestampType) Descriptor() protoreflect.EnumDescriptor

func (FeatureValuesTimestampType) Enum 

func (x FeatureValuesTimestampType) Enum() *FeatureValuesTimestampType

func (FeatureValuesTimestampType) EnumDescriptor deprecated 

func (FeatureValuesTimestampType) EnumDescriptor() ([]byte, []int)

Deprecated: Use FeatureValuesTimestampType.Descriptor instead.

func (FeatureValuesTimestampType) Number 

func (x FeatureValuesTimestampType) Number() protoreflect.EnumNumber

func (FeatureValuesTimestampType) String 

func (x FeatureValuesTimestampType) String() string

func (FeatureValuesTimestampType) Type 

func (FeatureValuesTimestampType) Type() protoreflect.EnumType

type GetFeatureValuesPageToken 

type GetFeatureValuesPageToken struct {
	TimestampHwm     *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp_hwm,json=timestampHwm,proto3" json:"timestamp_hwm,omitempty"`
	OperationIdHwm   string                 `protobuf:"bytes,2,opt,name=operation_id_hwm,json=operationIdHwm,proto3" json:"operation_id_hwm,omitempty"`
	ObservationIdHwm string                 `protobuf:"bytes,3,opt,name=observation_id_hwm,json=observationIdHwm,proto3" json:"observation_id_hwm,omitempty"`
	// contains filtered or unexported fields
}

Internal protobuf representing a next page token. Contains the operation id and the query timestamp for the last row in the previous batch. Results are sorted query timestamp, then by operation id, then observation id lexicographically, so this is all we need to know where the next page begins

func (*GetFeatureValuesPageToken) Descriptor deprecated 

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

Deprecated: Use GetFeatureValuesPageToken.ProtoReflect.Descriptor instead.

func (*GetFeatureValuesPageToken) GetObservationIdHwm 

func (x *GetFeatureValuesPageToken) GetObservationIdHwm() string

func (*GetFeatureValuesPageToken) GetOperationIdHwm 

func (x *GetFeatureValuesPageToken) GetOperationIdHwm() string

func (*GetFeatureValuesPageToken) GetTimestampHwm 

func (x *GetFeatureValuesPageToken) GetTimestampHwm() *timestamppb.Timestamp

func (*GetFeatureValuesPageToken) ProtoMessage 

func (*GetFeatureValuesPageToken) ProtoMessage()

func (*GetFeatureValuesPageToken) ProtoReflect 

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

func (*GetFeatureValuesPageToken) Reset 

func (x *GetFeatureValuesPageToken) Reset()

func (*GetFeatureValuesPageToken) String 

func (x *GetFeatureValuesPageToken) String() string

type GetFeatureValuesRequest 

type GetFeatureValuesRequest struct {
	FeatureFqn string `protobuf:"bytes,1,opt,name=feature_fqn,json=featureFqn,proto3" json:"feature_fqn,omitempty"`
	// Along which time dimension to query features by.
	// Time ranges can either be specified along inserted_at or observed_at
	// Optional. If unspecified, default to inserted_at
	TimestampType       FeatureValuesTimestampType `` /* 149-byte string literal not displayed */
	LowerBoundInclusive *timestamppb.Timestamp     `protobuf:"bytes,3,opt,name=lower_bound_inclusive,json=lowerBoundInclusive,proto3" json:"lower_bound_inclusive,omitempty"`
	UpperBoundExclusive *timestamppb.Timestamp     `protobuf:"bytes,4,opt,name=upper_bound_exclusive,json=upperBoundExclusive,proto3" json:"upper_bound_exclusive,omitempty"`
	// optional filters that can be specified to filter down feature rows returned
	Filters *FeatureValueFilters `protobuf:"bytes,5,opt,name=filters,proto3" json:"filters,omitempty"`
	// The (maximum) page size for results. If zero, then the server picks.
	PageSize int32 `protobuf:"varint,6,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// When dealing with paginated responses, the next token can be provided to get the next page of responses
	// The query parameters above must be exactly the same when using a next token
	// This is opaque to the clients, but in practice, it is an encoding of the GetFeatureValuesPageToken
	// if unspecified, retrieve the zeroth page.
	PageToken string `protobuf:"bytes,7,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFeatureValuesRequest) Descriptor deprecated 

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

Deprecated: Use GetFeatureValuesRequest.ProtoReflect.Descriptor instead.

func (*GetFeatureValuesRequest) GetFeatureFqn 

func (x *GetFeatureValuesRequest) GetFeatureFqn() string

func (*GetFeatureValuesRequest) GetFilters 

func (x *GetFeatureValuesRequest) GetFilters() *FeatureValueFilters

func (*GetFeatureValuesRequest) GetLowerBoundInclusive 

func (x *GetFeatureValuesRequest) GetLowerBoundInclusive() *timestamppb.Timestamp

func (*GetFeatureValuesRequest) GetPageSize 

func (x *GetFeatureValuesRequest) GetPageSize() int32

func (*GetFeatureValuesRequest) GetPageToken 

func (x *GetFeatureValuesRequest) GetPageToken() string

func (*GetFeatureValuesRequest) GetTimestampType 

func (x *GetFeatureValuesRequest) GetTimestampType() FeatureValuesTimestampType

func (*GetFeatureValuesRequest) GetUpperBoundExclusive 

func (x *GetFeatureValuesRequest) GetUpperBoundExclusive() *timestamppb.Timestamp

func (*GetFeatureValuesRequest) ProtoMessage 

func (*GetFeatureValuesRequest) ProtoMessage()

func (*GetFeatureValuesRequest) ProtoReflect 

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

func (*GetFeatureValuesRequest) Reset 

func (x *GetFeatureValuesRequest) Reset()

func (*GetFeatureValuesRequest) String 

func (x *GetFeatureValuesRequest) String() string

type GetFeatureValuesResponse 

type GetFeatureValuesResponse struct {

	// If non-empty, call this endpoint again, with this next token to get the next page of responses.
	NextPageToken string `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// The number of results returned
	TotalSize int32 `protobuf:"varint,2,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// The response payload. Defining as a one-of to future-proof it should we decide to support multiple encodings (parquet, feather, ...)
	//
	// Types that are assignable to Payload:
	//
	//	*GetFeatureValuesResponse_Parquet
	Payload isGetFeatureValuesResponse_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*GetFeatureValuesResponse) Descriptor deprecated 

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

Deprecated: Use GetFeatureValuesResponse.ProtoReflect.Descriptor instead.

func (*GetFeatureValuesResponse) GetNextPageToken 

func (x *GetFeatureValuesResponse) GetNextPageToken() string

func (*GetFeatureValuesResponse) GetParquet 

func (x *GetFeatureValuesResponse) GetParquet() []byte

func (*GetFeatureValuesResponse) GetPayload 

func (m *GetFeatureValuesResponse) GetPayload() isGetFeatureValuesResponse_Payload

func (*GetFeatureValuesResponse) GetTotalSize 

func (x *GetFeatureValuesResponse) GetTotalSize() int32

func (*GetFeatureValuesResponse) ProtoMessage 

func (*GetFeatureValuesResponse) ProtoMessage()

func (*GetFeatureValuesResponse) ProtoReflect 

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

func (*GetFeatureValuesResponse) Reset 

func (x *GetFeatureValuesResponse) Reset()

func (*GetFeatureValuesResponse) String 

func (x *GetFeatureValuesResponse) String() string

type GetFeatureValuesResponse_Parquet 

type GetFeatureValuesResponse_Parquet struct {
	Parquet []byte `protobuf:"bytes,3,opt,name=parquet,proto3,oneof"`
}

type GetFeatureValuesTimeSeriesChartRequest 

type GetFeatureValuesTimeSeriesChartRequest struct {
	Title  *string               `protobuf:"bytes,1,opt,name=title,proto3,oneof" json:"title,omitempty"`
	Series []*FeatureValueSeries `protobuf:"bytes,2,rep,name=series,proto3" json:"series,omitempty"`
	// The size of each time bucket + how far apart time points are in the chart
	// Ideally a divisor of the total window between end and start ms
	// If not, the bucket aligned with end_timestamp_exclusive will be of size total_window % window_period
	// For JSON format, this is a string `${duration_in_seconds}s`
	WindowPeriod            *durationpb.Duration   `protobuf:"bytes,3,opt,name=window_period,json=windowPeriod,proto3" json:"window_period,omitempty"`
	StartTimestampInclusive *timestamppb.Timestamp `` /* 132-byte string literal not displayed */
	// If not provided, will assume current time is the ending time
	EndTimestampExclusive *timestamppb.Timestamp `` /* 132-byte string literal not displayed */
	// The dimension to use as the time series axis. Defaults to inserted_at if not specified
	TimeSeries *FeatureValueTimeSeries `` /* 142-byte string literal not displayed */
	// The group bys to apply to this chart. Multiple group bys may produce high #'s of axes.
	GroupBy []FeatureValueGroupBy `` /* 131-byte string literal not displayed */
	// The maximum number of series produced by the group by.
	// Important because some group bys are high cardinality (ex. value)
	GroupBySeriesLimit *int32 `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetFeatureValuesTimeSeriesChartRequest) Descriptor deprecated 

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

Deprecated: Use GetFeatureValuesTimeSeriesChartRequest.ProtoReflect.Descriptor instead.

func (*GetFeatureValuesTimeSeriesChartRequest) GetEndTimestampExclusive 

func (x *GetFeatureValuesTimeSeriesChartRequest) GetEndTimestampExclusive() *timestamppb.Timestamp

func (*GetFeatureValuesTimeSeriesChartRequest) GetGroupBy added in v0.17.24 

func (x *GetFeatureValuesTimeSeriesChartRequest) GetGroupBy() []FeatureValueGroupBy

func (*GetFeatureValuesTimeSeriesChartRequest) GetGroupBySeriesLimit added in v0.17.24 

func (x *GetFeatureValuesTimeSeriesChartRequest) GetGroupBySeriesLimit() int32

func (*GetFeatureValuesTimeSeriesChartRequest) GetSeries 

func (x *GetFeatureValuesTimeSeriesChartRequest) GetSeries() []*FeatureValueSeries

func (*GetFeatureValuesTimeSeriesChartRequest) GetStartTimestampInclusive 

func (x *GetFeatureValuesTimeSeriesChartRequest) GetStartTimestampInclusive() *timestamppb.Timestamp

func (*GetFeatureValuesTimeSeriesChartRequest) GetTimeSeries added in v0.17.24 

func (x *GetFeatureValuesTimeSeriesChartRequest) GetTimeSeries() FeatureValueTimeSeries

func (*GetFeatureValuesTimeSeriesChartRequest) GetTitle 

func (x *GetFeatureValuesTimeSeriesChartRequest) GetTitle() string

func (*GetFeatureValuesTimeSeriesChartRequest) GetWindowPeriod 

func (x *GetFeatureValuesTimeSeriesChartRequest) GetWindowPeriod() *durationpb.Duration

func (*GetFeatureValuesTimeSeriesChartRequest) ProtoMessage 

func (*GetFeatureValuesTimeSeriesChartRequest) ProtoMessage()

func (*GetFeatureValuesTimeSeriesChartRequest) ProtoReflect 

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

func (*GetFeatureValuesTimeSeriesChartRequest) Reset 

func (x *GetFeatureValuesTimeSeriesChartRequest) Reset()

func (*GetFeatureValuesTimeSeriesChartRequest) String 

func (x *GetFeatureValuesTimeSeriesChartRequest) String() string

type GetFeatureValuesTimeSeriesChartResponse 

type GetFeatureValuesTimeSeriesChartResponse struct {
	Chart *v1.DenseTimeSeriesChart `protobuf:"bytes,1,opt,name=chart,proto3" json:"chart,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFeatureValuesTimeSeriesChartResponse) Descriptor deprecated 

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

Deprecated: Use GetFeatureValuesTimeSeriesChartResponse.ProtoReflect.Descriptor instead.

func (*GetFeatureValuesTimeSeriesChartResponse) GetChart 

func (x *GetFeatureValuesTimeSeriesChartResponse) GetChart() *v1.DenseTimeSeriesChart

func (*GetFeatureValuesTimeSeriesChartResponse) ProtoMessage 

func (*GetFeatureValuesTimeSeriesChartResponse) ProtoMessage()

func (*GetFeatureValuesTimeSeriesChartResponse) ProtoReflect 

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

func (*GetFeatureValuesTimeSeriesChartResponse) Reset 

func (x *GetFeatureValuesTimeSeriesChartResponse) Reset()

func (*GetFeatureValuesTimeSeriesChartResponse) String 

func (x *GetFeatureValuesTimeSeriesChartResponse) String() string

type GetQueryLogEntriesPageToken 

type GetQueryLogEntriesPageToken struct {
	OperationIdHwm    string                 `protobuf:"bytes,1,opt,name=operation_id_hwm,json=operationIdHwm,proto3" json:"operation_id_hwm,omitempty"`
	QueryTimestampHwm *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=query_timestamp_hwm,json=queryTimestampHwm,proto3" json:"query_timestamp_hwm,omitempty"`
	// contains filtered or unexported fields
}

Internal protobuf representing a next page token. Contains the operation id and the query timestamp for the last row in the previous batch. Results are sorted query timestamp then by operation id lexicographically, so this is all we need to know where the next page begins

func (*GetQueryLogEntriesPageToken) Descriptor deprecated 

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

Deprecated: Use GetQueryLogEntriesPageToken.ProtoReflect.Descriptor instead.

func (*GetQueryLogEntriesPageToken) GetOperationIdHwm 

func (x *GetQueryLogEntriesPageToken) GetOperationIdHwm() string

func (*GetQueryLogEntriesPageToken) GetQueryTimestampHwm 

func (x *GetQueryLogEntriesPageToken) GetQueryTimestampHwm() *timestamppb.Timestamp

func (*GetQueryLogEntriesPageToken) ProtoMessage 

func (*GetQueryLogEntriesPageToken) ProtoMessage()

func (*GetQueryLogEntriesPageToken) ProtoReflect 

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

func (*GetQueryLogEntriesPageToken) Reset 

func (x *GetQueryLogEntriesPageToken) Reset()

func (*GetQueryLogEntriesPageToken) String 

func (x *GetQueryLogEntriesPageToken) String() string

type GetQueryLogEntriesRequest 

type GetQueryLogEntriesRequest struct {

	// The query log table is partitioned / sorted by timestamp, so we must provide these
	// for the queries to be efficient, even if we are querying for a single operation id
	QueryTimestampLowerBoundInclusive *timestamppb.Timestamp `` /* 166-byte string literal not displayed */
	// If the upper bound is omitted, then the lower bound will be used as an "equality" filter
	QueryTimestampUpperBoundExclusive *timestamppb.Timestamp `` /* 172-byte string literal not displayed */
	// Any filters for searching the query log. See the QueryLogFilters message above
	Filters *QueryLogFilters `protobuf:"bytes,3,opt,name=filters,proto3" json:"filters,omitempty"`
	// The (maximum) page size. If zero, the server gets to choose.
	PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// When dealing with paginated responses, the next token can be provided to get the next page of responses
	// The query parameters above must be exactly the same when using a next token
	// This is opaque to the clients, but in practice, it is an encoding of the GetQueryLogEntriesPageToken
	PageToken string `protobuf:"bytes,5,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetQueryLogEntriesRequest) Descriptor deprecated 

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

Deprecated: Use GetQueryLogEntriesRequest.ProtoReflect.Descriptor instead.

func (*GetQueryLogEntriesRequest) GetFilters 

func (x *GetQueryLogEntriesRequest) GetFilters() *QueryLogFilters

func (*GetQueryLogEntriesRequest) GetPageSize 

func (x *GetQueryLogEntriesRequest) GetPageSize() int32

func (*GetQueryLogEntriesRequest) GetPageToken 

func (x *GetQueryLogEntriesRequest) GetPageToken() string

func (*GetQueryLogEntriesRequest) GetQueryTimestampLowerBoundInclusive 

func (x *GetQueryLogEntriesRequest) GetQueryTimestampLowerBoundInclusive() *timestamppb.Timestamp

func (*GetQueryLogEntriesRequest) GetQueryTimestampUpperBoundExclusive 

func (x *GetQueryLogEntriesRequest) GetQueryTimestampUpperBoundExclusive() *timestamppb.Timestamp

func (*GetQueryLogEntriesRequest) ProtoMessage 

func (*GetQueryLogEntriesRequest) ProtoMessage()

func (*GetQueryLogEntriesRequest) ProtoReflect 

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

func (*GetQueryLogEntriesRequest) Reset 

func (x *GetQueryLogEntriesRequest) Reset()

func (*GetQueryLogEntriesRequest) String 

func (x *GetQueryLogEntriesRequest) String() string

type GetQueryLogEntriesResponse 

type GetQueryLogEntriesResponse struct {
	Entries []*QueryLogEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// If the next_page_token is non-empty, then there may be more rows, even if the entries are empty.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetQueryLogEntriesResponse) Descriptor deprecated 

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

Deprecated: Use GetQueryLogEntriesResponse.ProtoReflect.Descriptor instead.

func (*GetQueryLogEntriesResponse) GetEntries 

func (x *GetQueryLogEntriesResponse) GetEntries() []*QueryLogEntry

func (*GetQueryLogEntriesResponse) GetNextPageToken 

func (x *GetQueryLogEntriesResponse) GetNextPageToken() string

func (*GetQueryLogEntriesResponse) ProtoMessage 

func (*GetQueryLogEntriesResponse) ProtoMessage()

func (*GetQueryLogEntriesResponse) ProtoReflect 

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

func (*GetQueryLogEntriesResponse) Reset 

func (x *GetQueryLogEntriesResponse) Reset()

func (*GetQueryLogEntriesResponse) String 

func (x *GetQueryLogEntriesResponse) String() string

type GetQueryValuesPageToken 

type GetQueryValuesPageToken struct {
	QueryTimestampHwm *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=query_timestamp_hwm,json=queryTimestampHwm,proto3" json:"query_timestamp_hwm,omitempty"`
	OperationIdHwm    string                 `protobuf:"bytes,2,opt,name=operation_id_hwm,json=operationIdHwm,proto3" json:"operation_id_hwm,omitempty"`
	RowIdHwm          int64                  `protobuf:"varint,3,opt,name=row_id_hwm,json=rowIdHwm,proto3" json:"row_id_hwm,omitempty"`
	// contains filtered or unexported fields
}

Internal protobuf representing a next page token. Contains the operation id and the query timestamp for the last row in the pervious batch. Results are sorted query timestamp then by operation id lexagraphically then by row id, so this is all we need to know where the next page begins

func (*GetQueryValuesPageToken) Descriptor deprecated 

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

Deprecated: Use GetQueryValuesPageToken.ProtoReflect.Descriptor instead.

func (*GetQueryValuesPageToken) GetOperationIdHwm 

func (x *GetQueryValuesPageToken) GetOperationIdHwm() string

func (*GetQueryValuesPageToken) GetQueryTimestampHwm 

func (x *GetQueryValuesPageToken) GetQueryTimestampHwm() *timestamppb.Timestamp

func (*GetQueryValuesPageToken) GetRowIdHwm 

func (x *GetQueryValuesPageToken) GetRowIdHwm() int64

func (*GetQueryValuesPageToken) ProtoMessage 

func (*GetQueryValuesPageToken) ProtoMessage()

func (*GetQueryValuesPageToken) ProtoReflect 

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

func (*GetQueryValuesPageToken) Reset 

func (x *GetQueryValuesPageToken) Reset()

func (*GetQueryValuesPageToken) String 

func (x *GetQueryValuesPageToken) String() string

type GetQueryValuesRequest 

type GetQueryValuesRequest struct {

	// Types that are assignable to TableIdentifier:
	//
	//	*GetQueryValuesRequest_OperationIdIdentifier
	//	*GetQueryValuesRequest_TableNameIdentifier
	TableIdentifier isGetQueryValuesRequest_TableIdentifier `protobuf_oneof:"table_identifier"`
	// The query log table is partitioned / sorted by timestamp, so we must provide these
	// for the queries to be efficient, even if we are querying for a single operation id
	// This is always required.
	// If you know the operation id, then its feasible that you know the exact query timestamp, too.
	QueryTimestampLowerBoundInclusive *timestamppb.Timestamp `` /* 166-byte string literal not displayed */
	// If the upper bound is ommitted, then the lower bound will be used as an exact (equality) filter
	QueryTimestampUpperBoundExclusive *timestamppb.Timestamp `` /* 172-byte string literal not displayed */
	// If you're insterested in a subset of features, specify those here. Other columns won't be selected from the database, which will help reduce query costs.
	// If empty, all features will be returned
	Features []string `protobuf:"bytes,5,rep,name=features,proto3" json:"features,omitempty"`
	// The (maximum) page size for results. If zero, then the server picks.
	PageSize int32 `protobuf:"varint,7,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// When dealing with paginated responses, specify the next token to resume where you left off. The subsequent request must be identicial to the original (except for the value of the next_token)
	// Leave empty if querying for the zeroth page.
	PageToken string `protobuf:"bytes,8,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetQueryValuesRequest) Descriptor deprecated 

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

Deprecated: Use GetQueryValuesRequest.ProtoReflect.Descriptor instead.

func (*GetQueryValuesRequest) GetFeatures 

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

func (*GetQueryValuesRequest) GetOperationIdIdentifier 

func (x *GetQueryValuesRequest) GetOperationIdIdentifier() *OperationIdTableIdentifier

func (*GetQueryValuesRequest) GetPageSize 

func (x *GetQueryValuesRequest) GetPageSize() int32

func (*GetQueryValuesRequest) GetPageToken 

func (x *GetQueryValuesRequest) GetPageToken() string

func (*GetQueryValuesRequest) GetQueryTimestampLowerBoundInclusive 

func (x *GetQueryValuesRequest) GetQueryTimestampLowerBoundInclusive() *timestamppb.Timestamp

func (*GetQueryValuesRequest) GetQueryTimestampUpperBoundExclusive 

func (x *GetQueryValuesRequest) GetQueryTimestampUpperBoundExclusive() *timestamppb.Timestamp

func (*GetQueryValuesRequest) GetTableIdentifier 

func (m *GetQueryValuesRequest) GetTableIdentifier() isGetQueryValuesRequest_TableIdentifier

func (*GetQueryValuesRequest) GetTableNameIdentifier 

func (x *GetQueryValuesRequest) GetTableNameIdentifier() *TableNameTableIdentifier

func (*GetQueryValuesRequest) ProtoMessage 

func (*GetQueryValuesRequest) ProtoMessage()

func (*GetQueryValuesRequest) ProtoReflect 

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

func (*GetQueryValuesRequest) Reset 

func (x *GetQueryValuesRequest) Reset()

func (*GetQueryValuesRequest) String 

func (x *GetQueryValuesRequest) String() string

type GetQueryValuesRequest_OperationIdIdentifier 

type GetQueryValuesRequest_OperationIdIdentifier struct {
	// Forcing the client to specify the table name can be a bit narly. Instead, for use case 1), it can be easier to allow the client to specify the operation id,
	// and the engine can figure out what table to query.
	OperationIdIdentifier *OperationIdTableIdentifier `protobuf:"bytes,1,opt,name=operation_id_identifier,json=operationIdIdentifier,proto3,oneof"`
}

type GetQueryValuesRequest_TableNameIdentifier 

type GetQueryValuesRequest_TableNameIdentifier struct {
	// For use case 2, you have to specify which table name to look up, if you want to query across multiple queries
	TableNameIdentifier *TableNameTableIdentifier `protobuf:"bytes,2,opt,name=table_name_identifier,json=tableNameIdentifier,proto3,oneof"`
}

type GetQueryValuesResponse 

type GetQueryValuesResponse struct {

	// If non-empty, call this endpoint again, with this next token to get the next page of responses.
	NextPageToken string `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// The response payload. Defining as a one-of to future-proof it should we decide to support multiple encodings (parquet, feather, ...)
	//
	// Types that are assignable to Payload:
	//
	//	*GetQueryValuesResponse_Parquet
	Payload isGetQueryValuesResponse_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*GetQueryValuesResponse) Descriptor deprecated 

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

Deprecated: Use GetQueryValuesResponse.ProtoReflect.Descriptor instead.

func (*GetQueryValuesResponse) GetNextPageToken 

func (x *GetQueryValuesResponse) GetNextPageToken() string

func (*GetQueryValuesResponse) GetParquet 

func (x *GetQueryValuesResponse) GetParquet() []byte

func (*GetQueryValuesResponse) GetPayload 

func (m *GetQueryValuesResponse) GetPayload() isGetQueryValuesResponse_Payload

func (*GetQueryValuesResponse) ProtoMessage 

func (*GetQueryValuesResponse) ProtoMessage()

func (*GetQueryValuesResponse) ProtoReflect 

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

func (*GetQueryValuesResponse) Reset 

func (x *GetQueryValuesResponse) Reset()

func (*GetQueryValuesResponse) String 

func (x *GetQueryValuesResponse) String() string

type GetQueryValuesResponse_Parquet 

type GetQueryValuesResponse_Parquet struct {
	Parquet []byte `protobuf:"bytes,2,opt,name=parquet,proto3,oneof"`
}

type OfflineStoreServiceDummy 

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

func (*OfflineStoreServiceDummy) Descriptor deprecated 

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

Deprecated: Use OfflineStoreServiceDummy.ProtoReflect.Descriptor instead.

func (*OfflineStoreServiceDummy) ProtoMessage 

func (*OfflineStoreServiceDummy) ProtoMessage()

func (*OfflineStoreServiceDummy) ProtoReflect 

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

func (*OfflineStoreServiceDummy) Reset 

func (x *OfflineStoreServiceDummy) Reset()

func (*OfflineStoreServiceDummy) String 

func (x *OfflineStoreServiceDummy) String() string

type OperationIdTableIdentifier 

type OperationIdTableIdentifier struct {

	// If you want the results for a particular operation id, no need to look up the value tables separately.
	// The engine will do that for you
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// contains filtered or unexported fields
}

func (*OperationIdTableIdentifier) Descriptor deprecated 

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

Deprecated: Use OperationIdTableIdentifier.ProtoReflect.Descriptor instead.

func (*OperationIdTableIdentifier) GetOperationId 

func (x *OperationIdTableIdentifier) GetOperationId() string

func (*OperationIdTableIdentifier) ProtoMessage 

func (*OperationIdTableIdentifier) ProtoMessage()

func (*OperationIdTableIdentifier) ProtoReflect 

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

func (*OperationIdTableIdentifier) Reset 

func (x *OperationIdTableIdentifier) Reset()

func (*OperationIdTableIdentifier) String 

func (x *OperationIdTableIdentifier) String() string

type QueryLogEntry 

type QueryLogEntry struct {
	OperationId         string                 `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_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"`
	OperationKind       v1.OperationKind       `` /* 136-byte string literal not displayed */
	QueryTimestamp      *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=query_timestamp,json=queryTimestamp,proto3" json:"query_timestamp,omitempty"`
	ExecutionStartedAt  *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=execution_started_at,json=executionStartedAt,proto3" json:"execution_started_at,omitempty"`
	ExecutionFinishedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=execution_finished_at,json=executionFinishedAt,proto3" json:"execution_finished_at,omitempty"`
	QueryStatus         v1.QueryStatus         `` /* 128-byte string literal not displayed */
	QueryName           string                 `protobuf:"bytes,9,opt,name=query_name,json=queryName,proto3" json:"query_name,omitempty"`
	QueryNameVersion    string                 `protobuf:"bytes,10,opt,name=query_name_version,json=queryNameVersion,proto3" json:"query_name_version,omitempty"`
	AgentId             string                 `protobuf:"bytes,11,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	BranchName          string                 `protobuf:"bytes,12,opt,name=branch_name,json=branchName,proto3" json:"branch_name,omitempty"`
	CorrelationId       string                 `protobuf:"bytes,13,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	TraceId             string                 `protobuf:"bytes,14,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	QueryPlanId         string                 `protobuf:"bytes,15,opt,name=query_plan_id,json=queryPlanId,proto3" json:"query_plan_id,omitempty"`
	ValueTables         []string               `protobuf:"bytes,16,rep,name=value_tables,json=valueTables,proto3" json:"value_tables,omitempty"`
	MetaQueryHash       string                 `protobuf:"bytes,17,opt,name=meta_query_hash,json=metaQueryHash,proto3" json:"meta_query_hash,omitempty"`
	// contains filtered or unexported fields
}

This is a proto representation of the SQL QueryLogModel.

func (*QueryLogEntry) Descriptor deprecated 

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

Deprecated: Use QueryLogEntry.ProtoReflect.Descriptor instead.

func (*QueryLogEntry) GetAgentId 

func (x *QueryLogEntry) GetAgentId() string

func (*QueryLogEntry) GetBranchName 

func (x *QueryLogEntry) GetBranchName() string

func (*QueryLogEntry) GetCorrelationId 

func (x *QueryLogEntry) GetCorrelationId() string

func (*QueryLogEntry) GetDeploymentId 

func (x *QueryLogEntry) GetDeploymentId() string

func (*QueryLogEntry) GetEnvironmentId 

func (x *QueryLogEntry) GetEnvironmentId() string

func (*QueryLogEntry) GetExecutionFinishedAt 

func (x *QueryLogEntry) GetExecutionFinishedAt() *timestamppb.Timestamp

func (*QueryLogEntry) GetExecutionStartedAt 

func (x *QueryLogEntry) GetExecutionStartedAt() *timestamppb.Timestamp

func (*QueryLogEntry) GetMetaQueryHash 

func (x *QueryLogEntry) GetMetaQueryHash() string

func (*QueryLogEntry) GetOperationId 

func (x *QueryLogEntry) GetOperationId() string

func (*QueryLogEntry) GetOperationKind 

func (x *QueryLogEntry) GetOperationKind() v1.OperationKind

func (*QueryLogEntry) GetQueryName 

func (x *QueryLogEntry) GetQueryName() string

func (*QueryLogEntry) GetQueryNameVersion 

func (x *QueryLogEntry) GetQueryNameVersion() string

func (*QueryLogEntry) GetQueryPlanId 

func (x *QueryLogEntry) GetQueryPlanId() string

func (*QueryLogEntry) GetQueryStatus 

func (x *QueryLogEntry) GetQueryStatus() v1.QueryStatus

func (*QueryLogEntry) GetQueryTimestamp 

func (x *QueryLogEntry) GetQueryTimestamp() *timestamppb.Timestamp

func (*QueryLogEntry) GetTraceId 

func (x *QueryLogEntry) GetTraceId() string

func (*QueryLogEntry) GetValueTables 

func (x *QueryLogEntry) GetValueTables() []string

func (*QueryLogEntry) ProtoMessage 

func (*QueryLogEntry) ProtoMessage()

func (*QueryLogEntry) ProtoReflect 

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

func (*QueryLogEntry) Reset 

func (x *QueryLogEntry) Reset()

func (*QueryLogEntry) String 

func (x *QueryLogEntry) String() string

type QueryLogFilters 

type QueryLogFilters struct {

	// All of these fields are optional. If any are specified, they will be AND'd together in a where clause
	// Any len-zero options will be ignored. If multiple options are specified for a given key, they will be OR'd together
	// i.e. works similarly to how you filter products on Amazon -- (size 8 or size 9) AND (color == blue OR color == "red")
	OperationId   []string              `protobuf:"bytes,1,rep,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	OperationKind []v1.OperationKind    `` /* 143-byte string literal not displayed */
	QueryName     []*VersionedQueryName `protobuf:"bytes,3,rep,name=query_name,json=queryName,proto3" json:"query_name,omitempty"`
	AgentId       []string              `protobuf:"bytes,5,rep,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	BranchName    []string              `protobuf:"bytes,6,rep,name=branch_name,json=branchName,proto3" json:"branch_name,omitempty"`
	CorrelationId []string              `protobuf:"bytes,7,rep,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	TraceId       []string              `protobuf:"bytes,8,rep,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	QueryPlanId   []string              `protobuf:"bytes,9,rep,name=query_plan_id,json=queryPlanId,proto3" json:"query_plan_id,omitempty"`
	DeploymentId  []string              `protobuf:"bytes,10,rep,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	QueryStatus   []v1.QueryStatus      `` /* 136-byte string literal not displayed */
	MetaQueryHash []string              `protobuf:"bytes,12,rep,name=meta_query_hash,json=metaQueryHash,proto3" json:"meta_query_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryLogFilters) Descriptor deprecated 

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

Deprecated: Use QueryLogFilters.ProtoReflect.Descriptor instead.

func (*QueryLogFilters) GetAgentId 

func (x *QueryLogFilters) GetAgentId() []string

func (*QueryLogFilters) GetBranchName 

func (x *QueryLogFilters) GetBranchName() []string

func (*QueryLogFilters) GetCorrelationId 

func (x *QueryLogFilters) GetCorrelationId() []string

func (*QueryLogFilters) GetDeploymentId 

func (x *QueryLogFilters) GetDeploymentId() []string

func (*QueryLogFilters) GetMetaQueryHash 

func (x *QueryLogFilters) GetMetaQueryHash() []string

func (*QueryLogFilters) GetOperationId 

func (x *QueryLogFilters) GetOperationId() []string

func (*QueryLogFilters) GetOperationKind 

func (x *QueryLogFilters) GetOperationKind() []v1.OperationKind

func (*QueryLogFilters) GetQueryName 

func (x *QueryLogFilters) GetQueryName() []*VersionedQueryName

func (*QueryLogFilters) GetQueryPlanId 

func (x *QueryLogFilters) GetQueryPlanId() []string

func (*QueryLogFilters) GetQueryStatus 

func (x *QueryLogFilters) GetQueryStatus() []v1.QueryStatus

func (*QueryLogFilters) GetTraceId 

func (x *QueryLogFilters) GetTraceId() []string

func (*QueryLogFilters) ProtoMessage 

func (*QueryLogFilters) ProtoMessage()

func (*QueryLogFilters) ProtoReflect 

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

func (*QueryLogFilters) Reset 

func (x *QueryLogFilters) Reset()

func (*QueryLogFilters) String 

func (x *QueryLogFilters) String() string

type TableNameTableIdentifier 

type TableNameTableIdentifier struct {
	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// Optionally, you can filter. Specifying any filters will result in a join against the query log table.
	Filters *v1.QueryLogFilters `protobuf:"bytes,2,opt,name=filters,proto3" json:"filters,omitempty"`
	// contains filtered or unexported fields
}

func (*TableNameTableIdentifier) Descriptor deprecated 

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

Deprecated: Use TableNameTableIdentifier.ProtoReflect.Descriptor instead.

func (*TableNameTableIdentifier) GetFilters 

func (x *TableNameTableIdentifier) GetFilters() *v1.QueryLogFilters

func (*TableNameTableIdentifier) GetTableName 

func (x *TableNameTableIdentifier) GetTableName() string

func (*TableNameTableIdentifier) ProtoMessage 

func (*TableNameTableIdentifier) ProtoMessage()

func (*TableNameTableIdentifier) ProtoReflect 

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

func (*TableNameTableIdentifier) Reset 

func (x *TableNameTableIdentifier) Reset()

func (*TableNameTableIdentifier) String 

func (x *TableNameTableIdentifier) String() string

type VersionedQueryName 

type VersionedQueryName struct {
	QueryName        string  `protobuf:"bytes,1,opt,name=query_name,json=queryName,proto3" json:"query_name,omitempty"`
	QueryNameVersion *string `protobuf:"bytes,2,opt,name=query_name_version,json=queryNameVersion,proto3,oneof" json:"query_name_version,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionedQueryName) Descriptor deprecated 

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

Deprecated: Use VersionedQueryName.ProtoReflect.Descriptor instead.

func (*VersionedQueryName) GetQueryName 

func (x *VersionedQueryName) GetQueryName() string

func (*VersionedQueryName) GetQueryNameVersion 

func (x *VersionedQueryName) GetQueryNameVersion() string

func (*VersionedQueryName) ProtoMessage 

func (*VersionedQueryName) ProtoMessage()

func (*VersionedQueryName) ProtoReflect 

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

func (*VersionedQueryName) Reset 

func (x *VersionedQueryName) Reset()

func (*VersionedQueryName) String 

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