commonv1

package
v0.18.11 Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2024 License: Apache-2.0 Imports: 9 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrorCode_name = map[int32]string{
		0:  "ERROR_CODE_INTERNAL_SERVER_ERROR_UNSPECIFIED",
		1:  "ERROR_CODE_PARSE_FAILED",
		2:  "ERROR_CODE_RESOLVER_NOT_FOUND",
		3:  "ERROR_CODE_INVALID_QUERY",
		4:  "ERROR_CODE_VALIDATION_FAILED",
		5:  "ERROR_CODE_RESOLVER_FAILED",
		6:  "ERROR_CODE_RESOLVER_TIMED_OUT",
		7:  "ERROR_CODE_UPSTREAM_FAILED",
		8:  "ERROR_CODE_UNAUTHENTICATED",
		9:  "ERROR_CODE_UNAUTHORIZED",
		10: "ERROR_CODE_CANCELLED",
		11: "ERROR_CODE_DEADLINE_EXCEEDED",
	}
	ErrorCode_value = map[string]int32{
		"ERROR_CODE_INTERNAL_SERVER_ERROR_UNSPECIFIED": 0,
		"ERROR_CODE_PARSE_FAILED":                      1,
		"ERROR_CODE_RESOLVER_NOT_FOUND":                2,
		"ERROR_CODE_INVALID_QUERY":                     3,
		"ERROR_CODE_VALIDATION_FAILED":                 4,
		"ERROR_CODE_RESOLVER_FAILED":                   5,
		"ERROR_CODE_RESOLVER_TIMED_OUT":                6,
		"ERROR_CODE_UPSTREAM_FAILED":                   7,
		"ERROR_CODE_UNAUTHENTICATED":                   8,
		"ERROR_CODE_UNAUTHORIZED":                      9,
		"ERROR_CODE_CANCELLED":                         10,
		"ERROR_CODE_DEADLINE_EXCEEDED":                 11,
	}
)

Enum value maps for ErrorCode.

View Source 
var (
	ErrorCodeCategory_name = map[int32]string{
		0: "ERROR_CODE_CATEGORY_NETWORK_UNSPECIFIED",
		1: "ERROR_CODE_CATEGORY_REQUEST",
		2: "ERROR_CODE_CATEGORY_FIELD",
	}
	ErrorCodeCategory_value = map[string]int32{
		"ERROR_CODE_CATEGORY_NETWORK_UNSPECIFIED": 0,
		"ERROR_CODE_CATEGORY_REQUEST":             1,
		"ERROR_CODE_CATEGORY_FIELD":               2,
	}
)

Enum value maps for ErrorCodeCategory.

View Source 
var (
	FeatureValueAggregation_name = map[int32]string{
		0:  "FEATURE_VALUE_AGGREGATION_UNSPECIFIED",
		1:  "FEATURE_VALUE_AGGREGATION_UNIQUE_VALUES",
		2:  "FEATURE_VALUE_AGGREGATION_TOTAL_OBSERVATIONS",
		3:  "FEATURE_VALUE_AGGREGATION_NULL_PERCENTAGE",
		4:  "FEATURE_VALUE_AGGREGATION_MAX_VALUE",
		5:  "FEATURE_VALUE_AGGREGATION_MIN_VALUE",
		6:  "FEATURE_VALUE_AGGREGATION_AVERAGE",
		7:  "FEATURE_VALUE_AGGREGATION_UNIQUE_PKEYS",
		8:  "FEATURE_VALUE_AGGREGATION_P95",
		9:  "FEATURE_VALUE_AGGREGATION_P75",
		10: "FEATURE_VALUE_AGGREGATION_P50",
		11: "FEATURE_VALUE_AGGREGATION_P25",
		12: "FEATURE_VALUE_AGGREGATION_P05",
	}
	FeatureValueAggregation_value = map[string]int32{
		"FEATURE_VALUE_AGGREGATION_UNSPECIFIED":        0,
		"FEATURE_VALUE_AGGREGATION_UNIQUE_VALUES":      1,
		"FEATURE_VALUE_AGGREGATION_TOTAL_OBSERVATIONS": 2,
		"FEATURE_VALUE_AGGREGATION_NULL_PERCENTAGE":    3,
		"FEATURE_VALUE_AGGREGATION_MAX_VALUE":          4,
		"FEATURE_VALUE_AGGREGATION_MIN_VALUE":          5,
		"FEATURE_VALUE_AGGREGATION_AVERAGE":            6,
		"FEATURE_VALUE_AGGREGATION_UNIQUE_PKEYS":       7,
		"FEATURE_VALUE_AGGREGATION_P95":                8,
		"FEATURE_VALUE_AGGREGATION_P75":                9,
		"FEATURE_VALUE_AGGREGATION_P50":                10,
		"FEATURE_VALUE_AGGREGATION_P25":                11,
		"FEATURE_VALUE_AGGREGATION_P05":                12,
	}
)

Enum value maps for FeatureValueAggregation.

View Source 
var (
	FeatherBodyType_name = map[int32]string{
		0: "FEATHER_BODY_TYPE_UNSPECIFIED",
		1: "FEATHER_BODY_TYPE_TABLE",
		2: "FEATHER_BODY_TYPE_RECORD_BATCHES",
	}
	FeatherBodyType_value = map[string]int32{
		"FEATHER_BODY_TYPE_UNSPECIFIED":    0,
		"FEATHER_BODY_TYPE_TABLE":          1,
		"FEATHER_BODY_TYPE_RECORD_BATCHES": 2,
	}
)

Enum value maps for FeatherBodyType.

View Source 
var (
	OperationKind_name = map[int32]string{
		0: "OPERATION_KIND_UNSPECIFIED",
		1: "OPERATION_KIND_ONLINE_QUERY",
		2: "OPERATION_KIND_MIGRATION",
		3: "OPERATION_KIND_CRON",
		4: "OPERATION_KIND_STREAMING",
		5: "OPERATION_KIND_MIGRATION_SAMPLER",
		6: "OPERATION_KIND_WINDOWED_STREAMING",
		7: "OPERATION_KIND_OFFLINE_QUERY",
	}
	OperationKind_value = map[string]int32{
		"OPERATION_KIND_UNSPECIFIED":        0,
		"OPERATION_KIND_ONLINE_QUERY":       1,
		"OPERATION_KIND_MIGRATION":          2,
		"OPERATION_KIND_CRON":               3,
		"OPERATION_KIND_STREAMING":          4,
		"OPERATION_KIND_MIGRATION_SAMPLER":  5,
		"OPERATION_KIND_WINDOWED_STREAMING": 6,
		"OPERATION_KIND_OFFLINE_QUERY":      7,
	}
)

Enum value maps for OperationKind.

View Source 
var (
	QueryStatus_name = map[int32]string{
		0: "QUERY_STATUS_UNSPECIFIED",
		1: "QUERY_STATUS_PENDING_SUBMISSION",
		2: "QUERY_STATUS_SUBMITTED",
		3: "QUERY_STATUS_RUNNING",
		4: "QUERY_STATUS_ERROR",
		5: "QUERY_STATUS_EXPIRED",
		6: "QUERY_STATUS_CANCELLED",
		7: "QUERY_STATUS_SUCCESSFUL",
		8: "QUERY_STATUS_SUCCESSFUL_WITH_NONFATAL_ERRORS",
	}
	QueryStatus_value = map[string]int32{
		"QUERY_STATUS_UNSPECIFIED":                     0,
		"QUERY_STATUS_PENDING_SUBMISSION":              1,
		"QUERY_STATUS_SUBMITTED":                       2,
		"QUERY_STATUS_RUNNING":                         3,
		"QUERY_STATUS_ERROR":                           4,
		"QUERY_STATUS_EXPIRED":                         5,
		"QUERY_STATUS_CANCELLED":                       6,
		"QUERY_STATUS_SUCCESSFUL":                      7,
		"QUERY_STATUS_SUCCESSFUL_WITH_NONFATAL_ERRORS": 8,
	}
)

Enum value maps for QueryStatus.

View Source 
var File_chalk_common_v1_chalk_error_proto protoreflect.FileDescriptor
View Source 
var File_chalk_common_v1_chart_proto protoreflect.FileDescriptor
View Source 
var File_chalk_common_v1_dataset_response_proto protoreflect.FileDescriptor
View Source 
var File_chalk_common_v1_feature_values_proto protoreflect.FileDescriptor
View Source 
var File_chalk_common_v1_offline_query_proto protoreflect.FileDescriptor
View Source 
var File_chalk_common_v1_online_query_proto protoreflect.FileDescriptor
View Source 
var File_chalk_common_v1_operation_kind_proto protoreflect.FileDescriptor
View Source 
var File_chalk_common_v1_query_log_proto protoreflect.FileDescriptor
View Source 
var File_chalk_common_v1_query_status_proto protoreflect.FileDescriptor
View Source 
var File_chalk_common_v1_query_values_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ChalkError 

type ChalkError struct {
	Code     ErrorCode         `protobuf:"varint,1,opt,name=code,proto3,enum=chalk.common.v1.ErrorCode" json:"code,omitempty"`
	Category ErrorCodeCategory `protobuf:"varint,2,opt,name=category,proto3,enum=chalk.common.v1.ErrorCodeCategory" json:"category,omitempty"`
	// A readable description of the error message.
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// A human-readable hint that can be used to identify the entity that this error is associated with.
	DisplayPrimaryKey *string `protobuf:"bytes,101,opt,name=display_primary_key,json=displayPrimaryKey,proto3,oneof" json:"display_primary_key,omitempty"`
	// If provided, can be used to add additional context to 'display_primary_key'.
	DisplayPrimaryKeyFqn *string `` /* 133-byte string literal not displayed */
	// The exception that caused the failure, if applicable.
	Exception *ChalkException `protobuf:"bytes,103,opt,name=exception,proto3,oneof" json:"exception,omitempty"`
	// The fully qualified name of the failing feature, e.g. `user.identity.has_voip_phone`.
	Feature *string `protobuf:"bytes,104,opt,name=feature,proto3,oneof" json:"feature,omitempty"`
	// The fully qualified name of the failing resolver, e.g. `my.project.get_fraud_score`.
	Resolver *string `protobuf:"bytes,105,opt,name=resolver,proto3,oneof" json:"resolver,omitempty"`
	// contains filtered or unexported fields
}

func (*ChalkError) Descriptor deprecated 

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

Deprecated: Use ChalkError.ProtoReflect.Descriptor instead.

func (*ChalkError) GetCategory 

func (x *ChalkError) GetCategory() ErrorCodeCategory

func (*ChalkError) GetCode 

func (x *ChalkError) GetCode() ErrorCode

func (*ChalkError) GetDisplayPrimaryKey 

func (x *ChalkError) GetDisplayPrimaryKey() string

func (*ChalkError) GetDisplayPrimaryKeyFqn 

func (x *ChalkError) GetDisplayPrimaryKeyFqn() string

func (*ChalkError) GetException 

func (x *ChalkError) GetException() *ChalkException

func (*ChalkError) GetFeature 

func (x *ChalkError) GetFeature() string

func (*ChalkError) GetMessage 

func (x *ChalkError) GetMessage() string

func (*ChalkError) GetResolver 

func (x *ChalkError) GetResolver() string

func (*ChalkError) ProtoMessage 

func (*ChalkError) ProtoMessage()

func (*ChalkError) ProtoReflect 

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

func (*ChalkError) Reset 

func (x *ChalkError) Reset()

func (*ChalkError) String 

func (x *ChalkError) String() string

type ChalkException 

type ChalkException struct {

	// The name of the class of the exception.
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	// The message taken from the exception.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// The stacktrace produced by the code.
	Stacktrace string `protobuf:"bytes,3,opt,name=stacktrace,proto3" json:"stacktrace,omitempty"`
	// The stacktrace produced by the code, full detail.
	InternalStacktrace string `protobuf:"bytes,4,opt,name=internal_stacktrace,json=internalStacktrace,proto3" json:"internal_stacktrace,omitempty"`
	// contains filtered or unexported fields
}

func (*ChalkException) Descriptor deprecated 

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

Deprecated: Use ChalkException.ProtoReflect.Descriptor instead.

func (*ChalkException) GetInternalStacktrace 

func (x *ChalkException) GetInternalStacktrace() string

func (*ChalkException) GetKind 

func (x *ChalkException) GetKind() string

func (*ChalkException) GetMessage 

func (x *ChalkException) GetMessage() string

func (*ChalkException) GetStacktrace 

func (x *ChalkException) GetStacktrace() string

func (*ChalkException) ProtoMessage 

func (*ChalkException) ProtoMessage()

func (*ChalkException) ProtoReflect 

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

func (*ChalkException) Reset 

func (x *ChalkException) Reset()

func (*ChalkException) String 

func (x *ChalkException) String() string

type Chart deprecated added in v0.16.22 

type Chart struct {
	Title        string    `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Series       []*Series `protobuf:"bytes,2,rep,name=series,proto3" json:"series,omitempty"`
	XTimestampMs []int64   `protobuf:"varint,4,rep,packed,name=x_timestamp_ms,json=xTimestampMs,proto3" json:"x_timestamp_ms,omitempty"`
	// contains filtered or unexported fields
}

Deprecated: Marked as deprecated in chalk/common/v1/chart.proto.

func (*Chart) Descriptor deprecated added in v0.16.22 

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

Deprecated: Use Chart.ProtoReflect.Descriptor instead.

func (*Chart) GetSeries added in v0.16.22 

func (x *Chart) GetSeries() []*Series

func (*Chart) GetTitle added in v0.16.22 

func (x *Chart) GetTitle() string

func (*Chart) GetXTimestampMs added in v0.16.22 

func (x *Chart) GetXTimestampMs() []int64

func (*Chart) ProtoMessage added in v0.16.22 

func (*Chart) ProtoMessage()

func (*Chart) ProtoReflect added in v0.16.22 

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

func (*Chart) Reset added in v0.16.22 

func (x *Chart) Reset()

func (*Chart) String added in v0.16.22 

func (x *Chart) String() string

type ColumnMetadataList 

type ColumnMetadataList struct {
	Metadata []*ColumnMetadataList_ColumnMetadata `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnMetadataList) Descriptor deprecated 

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

Deprecated: Use ColumnMetadataList.ProtoReflect.Descriptor instead.

func (*ColumnMetadataList) GetMetadata 

func (x *ColumnMetadataList) GetMetadata() []*ColumnMetadataList_ColumnMetadata

func (*ColumnMetadataList) ProtoMessage 

func (*ColumnMetadataList) ProtoMessage()

func (*ColumnMetadataList) ProtoReflect 

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

func (*ColumnMetadataList) Reset 

func (x *ColumnMetadataList) Reset()

func (*ColumnMetadataList) String 

func (x *ColumnMetadataList) String() string

type ColumnMetadataList_ColumnMetadata 

type ColumnMetadataList_ColumnMetadata struct {

	// The root FQN of the feature for a column
	FeatureFqn string `protobuf:"bytes,1,opt,name=feature_fqn,json=featureFqn,proto3" json:"feature_fqn,omitempty"`
	// The name of the column that corresponds to this feature
	ColumnName string `protobuf:"bytes,2,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	// The data type for this feature
	Dtype string `protobuf:"bytes,3,opt,name=dtype,proto3" json:"dtype,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnMetadataList_ColumnMetadata) Descriptor deprecated 

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

Deprecated: Use ColumnMetadataList_ColumnMetadata.ProtoReflect.Descriptor instead.

func (*ColumnMetadataList_ColumnMetadata) GetColumnName 

func (x *ColumnMetadataList_ColumnMetadata) GetColumnName() string

func (*ColumnMetadataList_ColumnMetadata) GetDtype 

func (x *ColumnMetadataList_ColumnMetadata) GetDtype() string

func (*ColumnMetadataList_ColumnMetadata) GetFeatureFqn 

func (x *ColumnMetadataList_ColumnMetadata) GetFeatureFqn() string

func (*ColumnMetadataList_ColumnMetadata) ProtoMessage 

func (*ColumnMetadataList_ColumnMetadata) ProtoMessage()

func (*ColumnMetadataList_ColumnMetadata) ProtoReflect 

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

func (*ColumnMetadataList_ColumnMetadata) Reset 

func (x *ColumnMetadataList_ColumnMetadata) Reset()

func (*ColumnMetadataList_ColumnMetadata) String 

func (x *ColumnMetadataList_ColumnMetadata) String() string

type DatasetFilter 

type DatasetFilter struct {
	SampleFilters   *DatasetSampleFilter `protobuf:"bytes,1,opt,name=sample_filters,json=sampleFilters,proto3" json:"sample_filters,omitempty"`
	MaxCacheAgeSecs *float32             `protobuf:"fixed32,2,opt,name=max_cache_age_secs,json=maxCacheAgeSecs,proto3,oneof" json:"max_cache_age_secs,omitempty"`
	// contains filtered or unexported fields
}

func (*DatasetFilter) Descriptor deprecated 

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

Deprecated: Use DatasetFilter.ProtoReflect.Descriptor instead.

func (*DatasetFilter) GetMaxCacheAgeSecs 

func (x *DatasetFilter) GetMaxCacheAgeSecs() float32

func (*DatasetFilter) GetSampleFilters 

func (x *DatasetFilter) GetSampleFilters() *DatasetSampleFilter

func (*DatasetFilter) ProtoMessage 

func (*DatasetFilter) ProtoMessage()

func (*DatasetFilter) ProtoReflect 

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

func (*DatasetFilter) Reset 

func (x *DatasetFilter) Reset()

func (*DatasetFilter) String 

func (x *DatasetFilter) String() string

type DatasetResponse 

type DatasetResponse struct {

	// Whether the export job is finished (it runs asynchronously)
	IsFinished bool `protobuf:"varint,1,opt,name=is_finished,json=isFinished,proto3" json:"is_finished,omitempty"`
	// Version number representing the format of the data. The client uses this version number
	// to properly decode and load the query results into DataFrames.
	Version       int32                      `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	EnvironmentId string                     `protobuf:"bytes,3,opt,name=environment_id,json=environmentId,proto3" json:"environment_id,omitempty"`
	DatasetId     string                     `protobuf:"bytes,4,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	DatasetName   string                     `protobuf:"bytes,5,opt,name=dataset_name,json=datasetName,proto3" json:"dataset_name,omitempty"`
	Errors        []*ChalkError              `protobuf:"bytes,101,rep,name=errors,proto3" json:"errors,omitempty"`
	Revisions     []*DatasetRevisionResponse `protobuf:"bytes,102,rep,name=revisions,proto3" json:"revisions,omitempty"`
	// contains filtered or unexported fields
}

func (*DatasetResponse) Descriptor deprecated 

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

Deprecated: Use DatasetResponse.ProtoReflect.Descriptor instead.

func (*DatasetResponse) GetDatasetId 

func (x *DatasetResponse) GetDatasetId() string

func (*DatasetResponse) GetDatasetName 

func (x *DatasetResponse) GetDatasetName() string

func (*DatasetResponse) GetEnvironmentId 

func (x *DatasetResponse) GetEnvironmentId() string

func (*DatasetResponse) GetErrors 

func (x *DatasetResponse) GetErrors() []*ChalkError

func (*DatasetResponse) GetIsFinished 

func (x *DatasetResponse) GetIsFinished() bool

func (*DatasetResponse) GetRevisions 

func (x *DatasetResponse) GetRevisions() []*DatasetRevisionResponse

func (*DatasetResponse) GetVersion 

func (x *DatasetResponse) GetVersion() int32

func (*DatasetResponse) ProtoMessage 

func (*DatasetResponse) ProtoMessage()

func (*DatasetResponse) ProtoReflect 

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

func (*DatasetResponse) Reset 

func (x *DatasetResponse) Reset()

func (*DatasetResponse) String 

func (x *DatasetResponse) String() string

type DatasetRevisionResponse 

type DatasetRevisionResponse struct {
	DatasetName   *string                `protobuf:"bytes,1,opt,name=dataset_name,json=datasetName,proto3,oneof" json:"dataset_name,omitempty"`
	DatasetId     *string                `protobuf:"bytes,2,opt,name=dataset_id,json=datasetId,proto3,oneof" json:"dataset_id,omitempty"`
	EnvironmentId *string                `protobuf:"bytes,3,opt,name=environment_id,json=environmentId,proto3,oneof" json:"environment_id,omitempty"`
	RevisionId    *string                `protobuf:"bytes,4,opt,name=revision_id,json=revisionId,proto3,oneof" json:"revision_id,omitempty"`
	CreatorId     string                 `protobuf:"bytes,5,opt,name=creator_id,json=creatorId,proto3" json:"creator_id,omitempty"`
	Outputs       []string               `protobuf:"bytes,6,rep,name=outputs,proto3" json:"outputs,omitempty"`
	GivensUri     *string                `protobuf:"bytes,7,opt,name=givens_uri,json=givensUri,proto3,oneof" json:"givens_uri,omitempty"`
	Status        QueryStatus            `protobuf:"varint,8,opt,name=status,proto3,enum=chalk.common.v1.QueryStatus" json:"status,omitempty"`
	Filters       *DatasetFilter         `protobuf:"bytes,9,opt,name=filters,proto3" json:"filters,omitempty"`
	NumPartitions int32                  `protobuf:"varint,10,opt,name=num_partitions,json=numPartitions,proto3" json:"num_partitions,omitempty"`
	NumBytes      *int32                 `protobuf:"varint,11,opt,name=num_bytes,json=numBytes,proto3,oneof" json:"num_bytes,omitempty"`
	OutputUris    string                 `protobuf:"bytes,12,opt,name=output_uris,json=outputUris,proto3" json:"output_uris,omitempty"`
	OutputVersion int32                  `protobuf:"varint,13,opt,name=output_version,json=outputVersion,proto3" json:"output_version,omitempty"`
	Branch        *string                `protobuf:"bytes,14,opt,name=branch,proto3,oneof" json:"branch,omitempty"`
	DashboardUrl  *string                `protobuf:"bytes,15,opt,name=dashboard_url,json=dashboardUrl,proto3,oneof" json:"dashboard_url,omitempty"`
	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=created_at,json=createdAt,proto3,oneof" json:"created_at,omitempty"`
	StartedAt     *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=started_at,json=startedAt,proto3,oneof" json:"started_at,omitempty"`
	TerminatedAt  *timestamppb.Timestamp `protobuf:"bytes,103,opt,name=terminated_at,json=terminatedAt,proto3,oneof" json:"terminated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*DatasetRevisionResponse) Descriptor deprecated 

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

Deprecated: Use DatasetRevisionResponse.ProtoReflect.Descriptor instead.

func (*DatasetRevisionResponse) GetBranch 

func (x *DatasetRevisionResponse) GetBranch() string

func (*DatasetRevisionResponse) GetCreatedAt 

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

func (*DatasetRevisionResponse) GetCreatorId 

func (x *DatasetRevisionResponse) GetCreatorId() string

func (*DatasetRevisionResponse) GetDashboardUrl 

func (x *DatasetRevisionResponse) GetDashboardUrl() string

func (*DatasetRevisionResponse) GetDatasetId 

func (x *DatasetRevisionResponse) GetDatasetId() string

func (*DatasetRevisionResponse) GetDatasetName 

func (x *DatasetRevisionResponse) GetDatasetName() string

func (*DatasetRevisionResponse) GetEnvironmentId 

func (x *DatasetRevisionResponse) GetEnvironmentId() string

func (*DatasetRevisionResponse) GetFilters 

func (x *DatasetRevisionResponse) GetFilters() *DatasetFilter

func (*DatasetRevisionResponse) GetGivensUri 

func (x *DatasetRevisionResponse) GetGivensUri() string

func (*DatasetRevisionResponse) GetNumBytes 

func (x *DatasetRevisionResponse) GetNumBytes() int32

func (*DatasetRevisionResponse) GetNumPartitions 

func (x *DatasetRevisionResponse) GetNumPartitions() int32

func (*DatasetRevisionResponse) GetOutputUris 

func (x *DatasetRevisionResponse) GetOutputUris() string

func (*DatasetRevisionResponse) GetOutputVersion 

func (x *DatasetRevisionResponse) GetOutputVersion() int32

func (*DatasetRevisionResponse) GetOutputs 

func (x *DatasetRevisionResponse) GetOutputs() []string

func (*DatasetRevisionResponse) GetRevisionId 

func (x *DatasetRevisionResponse) GetRevisionId() string

func (*DatasetRevisionResponse) GetStartedAt 

func (x *DatasetRevisionResponse) GetStartedAt() *timestamppb.Timestamp

func (*DatasetRevisionResponse) GetStatus 

func (x *DatasetRevisionResponse) GetStatus() QueryStatus

func (*DatasetRevisionResponse) GetTerminatedAt 

func (x *DatasetRevisionResponse) GetTerminatedAt() *timestamppb.Timestamp

func (*DatasetRevisionResponse) ProtoMessage 

func (*DatasetRevisionResponse) ProtoMessage()

func (*DatasetRevisionResponse) ProtoReflect 

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

func (*DatasetRevisionResponse) Reset 

func (x *DatasetRevisionResponse) Reset()

func (*DatasetRevisionResponse) String 

func (x *DatasetRevisionResponse) String() string

type DatasetSampleFilter 

type DatasetSampleFilter struct {
	LowerBound *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=lower_bound,json=lowerBound,proto3,oneof" json:"lower_bound,omitempty"`
	UpperBound *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=upper_bound,json=upperBound,proto3,oneof" json:"upper_bound,omitempty"`
	MaxSamples *int32                 `protobuf:"varint,3,opt,name=max_samples,json=maxSamples,proto3,oneof" json:"max_samples,omitempty"`
	// contains filtered or unexported fields
}

func (*DatasetSampleFilter) Descriptor deprecated 

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

Deprecated: Use DatasetSampleFilter.ProtoReflect.Descriptor instead.

func (*DatasetSampleFilter) GetLowerBound 

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

func (*DatasetSampleFilter) GetMaxSamples 

func (x *DatasetSampleFilter) GetMaxSamples() int32

func (*DatasetSampleFilter) GetUpperBound 

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

func (*DatasetSampleFilter) ProtoMessage 

func (*DatasetSampleFilter) ProtoMessage()

func (*DatasetSampleFilter) ProtoReflect 

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

func (*DatasetSampleFilter) Reset 

func (x *DatasetSampleFilter) Reset()

func (*DatasetSampleFilter) String 

func (x *DatasetSampleFilter) String() string

type ErrorCode 

type ErrorCode int32
const (
	// An unspecified error occurred.
	ErrorCode_ERROR_CODE_INTERNAL_SERVER_ERROR_UNSPECIFIED ErrorCode = 0
	// The query contained features that do not exist
	ErrorCode_ERROR_CODE_PARSE_FAILED ErrorCode = 1
	// A resolver was required as part of running the dependency
	// graph that could not be found.
	ErrorCode_ERROR_CODE_RESOLVER_NOT_FOUND ErrorCode = 2
	// The query is invalid. All supplied features need to be
	// rooted in the same top-level entity.
	ErrorCode_ERROR_CODE_INVALID_QUERY ErrorCode = 3
	// A feature value did not match the expected schema
	// (e.g. `incompatible type "int"; expected "str"`)
	ErrorCode_ERROR_CODE_VALIDATION_FAILED ErrorCode = 4
	// The resolver for a feature errored.
	ErrorCode_ERROR_CODE_RESOLVER_FAILED ErrorCode = 5
	// The resolver for a feature timed out.
	ErrorCode_ERROR_CODE_RESOLVER_TIMED_OUT ErrorCode = 6
	// A crash in a resolver that was to produce an input for
	// the resolver crashed, and so the resolver could not run
	// crashed, and so the resolver could not run.
	ErrorCode_ERROR_CODE_UPSTREAM_FAILED ErrorCode = 7
	// The request was submitted with an invalid authentication header.
	ErrorCode_ERROR_CODE_UNAUTHENTICATED ErrorCode = 8
	// The supplied credentials do not provide the right authorization to execute the request.
	ErrorCode_ERROR_CODE_UNAUTHORIZED ErrorCode = 9
	// The operation was cancelled, typically by the caller.
	ErrorCode_ERROR_CODE_CANCELLED ErrorCode = 10
	// The deadline expired before the operation could complete.
	ErrorCode_ERROR_CODE_DEADLINE_EXCEEDED ErrorCode = 11
)

func (ErrorCode) Descriptor 

func (ErrorCode) Descriptor() protoreflect.EnumDescriptor

func (ErrorCode) Enum 

func (x ErrorCode) Enum() *ErrorCode

func (ErrorCode) EnumDescriptor deprecated 

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

Deprecated: Use ErrorCode.Descriptor instead.

func (ErrorCode) Number 

func (x ErrorCode) Number() protoreflect.EnumNumber

func (ErrorCode) String 

func (x ErrorCode) String() string

func (ErrorCode) Type 

func (ErrorCode) Type() protoreflect.EnumType

type ErrorCodeCategory 

type ErrorCodeCategory int32
const (
	// -- DEFAULT VALUE --
	ErrorCodeCategory_ERROR_CODE_CATEGORY_NETWORK_UNSPECIFIED ErrorCodeCategory = 0
	// Request errors are raised before execution of your
	// resolver code. They may occur due to invalid feature
	// names in the input or a request that cannot be satisfied
	// by the resolvers you have defined.
	ErrorCodeCategory_ERROR_CODE_CATEGORY_REQUEST ErrorCodeCategory = 1
	// Field errors are raised while running a feature resolver
	// for a particular field. For this type of error, you'll
	// find a feature and resolver attribute in the error type.
	// When a feature resolver crashes, you will receive null
	// value in the response. To differentiate from a resolver
	// returning a null value and a failure in the resolver,
	// you need to check the error schema.
	ErrorCodeCategory_ERROR_CODE_CATEGORY_FIELD ErrorCodeCategory = 2
)

func (ErrorCodeCategory) Descriptor 

func (ErrorCodeCategory) Descriptor() protoreflect.EnumDescriptor

func (ErrorCodeCategory) Enum 

func (x ErrorCodeCategory) Enum() *ErrorCodeCategory

func (ErrorCodeCategory) EnumDescriptor deprecated 

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

Deprecated: Use ErrorCodeCategory.Descriptor instead.

func (ErrorCodeCategory) Number 

func (x ErrorCodeCategory) Number() protoreflect.EnumNumber

func (ErrorCodeCategory) String 

func (x ErrorCodeCategory) String() string

func (ErrorCodeCategory) Type 

func (ErrorCodeCategory) Type() protoreflect.EnumType

type ExplainOptions added in v0.4.7 

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

func (*ExplainOptions) Descriptor deprecated added in v0.4.7 

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

Deprecated: Use ExplainOptions.ProtoReflect.Descriptor instead.

func (*ExplainOptions) ProtoMessage added in v0.4.7 

func (*ExplainOptions) ProtoMessage()

func (*ExplainOptions) ProtoReflect added in v0.4.7 

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

func (*ExplainOptions) Reset added in v0.4.7 

func (x *ExplainOptions) Reset()

func (*ExplainOptions) String added in v0.4.7 

func (x *ExplainOptions) String() string

type FeatherBodyType added in v0.4.7 

type FeatherBodyType int32
const (
	FeatherBodyType_FEATHER_BODY_TYPE_UNSPECIFIED    FeatherBodyType = 0
	FeatherBodyType_FEATHER_BODY_TYPE_TABLE          FeatherBodyType = 1
	FeatherBodyType_FEATHER_BODY_TYPE_RECORD_BATCHES FeatherBodyType = 2
)

func (FeatherBodyType) Descriptor added in v0.4.7 

func (FeatherBodyType) Descriptor() protoreflect.EnumDescriptor

func (FeatherBodyType) Enum added in v0.4.7 

func (x FeatherBodyType) Enum() *FeatherBodyType

func (FeatherBodyType) EnumDescriptor deprecated added in v0.4.7 

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

Deprecated: Use FeatherBodyType.Descriptor instead.

func (FeatherBodyType) Number added in v0.4.7 

func (x FeatherBodyType) Number() protoreflect.EnumNumber

func (FeatherBodyType) String added in v0.4.7 

func (x FeatherBodyType) String() string

func (FeatherBodyType) Type added in v0.4.7 

func (FeatherBodyType) Type() protoreflect.EnumType

type FeatureEncodingOptions added in v0.4.7 

type FeatureEncodingOptions struct {
	EncodeStructsAsObjects bool `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FeatureEncodingOptions) Descriptor deprecated added in v0.4.7 

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

Deprecated: Use FeatureEncodingOptions.ProtoReflect.Descriptor instead.

func (*FeatureEncodingOptions) GetEncodeStructsAsObjects added in v0.4.7 

func (x *FeatureEncodingOptions) GetEncodeStructsAsObjects() bool

func (*FeatureEncodingOptions) ProtoMessage added in v0.4.7 

func (*FeatureEncodingOptions) ProtoMessage()

func (*FeatureEncodingOptions) ProtoReflect added in v0.4.7 

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

func (*FeatureEncodingOptions) Reset added in v0.4.7 

func (x *FeatureEncodingOptions) Reset()

func (*FeatureEncodingOptions) String added in v0.4.7 

func (x *FeatureEncodingOptions) String() string

type FeatureMeta 

type FeatureMeta struct {
	ChosenResolverFqn string `protobuf:"bytes,1,opt,name=chosen_resolver_fqn,json=chosenResolverFqn,proto3" json:"chosen_resolver_fqn,omitempty"`
	CacheHit          bool   `protobuf:"varint,2,opt,name=cache_hit,json=cacheHit,proto3" json:"cache_hit,omitempty"`
	PrimitiveType     string `protobuf:"bytes,3,opt,name=primitive_type,json=primitiveType,proto3" json:"primitive_type,omitempty"`
	Version           int64  `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureMeta) Descriptor deprecated 

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

Deprecated: Use FeatureMeta.ProtoReflect.Descriptor instead.

func (*FeatureMeta) GetCacheHit 

func (x *FeatureMeta) GetCacheHit() bool

func (*FeatureMeta) GetChosenResolverFqn 

func (x *FeatureMeta) GetChosenResolverFqn() string

func (*FeatureMeta) GetPrimitiveType 

func (x *FeatureMeta) GetPrimitiveType() string

func (*FeatureMeta) GetVersion 

func (x *FeatureMeta) GetVersion() int64

func (*FeatureMeta) ProtoMessage 

func (*FeatureMeta) ProtoMessage()

func (*FeatureMeta) ProtoReflect 

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

func (*FeatureMeta) Reset 

func (x *FeatureMeta) Reset()

func (*FeatureMeta) String 

func (x *FeatureMeta) String() string

type FeatureResult 

type FeatureResult struct {
	Field string                 `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Pkey  *structpb.Value        `protobuf:"bytes,6,opt,name=pkey,proto3" json:"pkey,omitempty"`
	Value *structpb.Value        `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Error *ChalkError            `protobuf:"bytes,3,opt,name=error,proto3,oneof" json:"error,omitempty"`
	Ts    *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=ts,proto3,oneof" json:"ts,omitempty"`
	Meta  *FeatureMeta           `protobuf:"bytes,5,opt,name=meta,proto3,oneof" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureResult) Descriptor deprecated 

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

Deprecated: Use FeatureResult.ProtoReflect.Descriptor instead.

func (*FeatureResult) GetError 

func (x *FeatureResult) GetError() *ChalkError

func (*FeatureResult) GetField 

func (x *FeatureResult) GetField() string

func (*FeatureResult) GetMeta 

func (x *FeatureResult) GetMeta() *FeatureMeta

func (*FeatureResult) GetPkey added in v0.4.14 

func (x *FeatureResult) GetPkey() *structpb.Value

func (*FeatureResult) GetTs 

func (x *FeatureResult) GetTs() *timestamppb.Timestamp

func (*FeatureResult) GetValue 

func (x *FeatureResult) GetValue() *structpb.Value

func (*FeatureResult) ProtoMessage 

func (*FeatureResult) ProtoMessage()

func (*FeatureResult) ProtoReflect 

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

func (*FeatureResult) Reset 

func (x *FeatureResult) Reset()

func (*FeatureResult) String 

func (x *FeatureResult) String() string

type FeatureValueAggregation deprecated added in v0.16.22 

type FeatureValueAggregation int32

Deprecated: Marked as deprecated in chalk/common/v1/feature_values.proto. 

const (
	FeatureValueAggregation_FEATURE_VALUE_AGGREGATION_UNSPECIFIED        FeatureValueAggregation = 0
	FeatureValueAggregation_FEATURE_VALUE_AGGREGATION_UNIQUE_VALUES      FeatureValueAggregation = 1
	FeatureValueAggregation_FEATURE_VALUE_AGGREGATION_TOTAL_OBSERVATIONS FeatureValueAggregation = 2
	FeatureValueAggregation_FEATURE_VALUE_AGGREGATION_NULL_PERCENTAGE    FeatureValueAggregation = 3
	FeatureValueAggregation_FEATURE_VALUE_AGGREGATION_MAX_VALUE          FeatureValueAggregation = 4
	FeatureValueAggregation_FEATURE_VALUE_AGGREGATION_MIN_VALUE          FeatureValueAggregation = 5
	FeatureValueAggregation_FEATURE_VALUE_AGGREGATION_AVERAGE            FeatureValueAggregation = 6
	FeatureValueAggregation_FEATURE_VALUE_AGGREGATION_UNIQUE_PKEYS       FeatureValueAggregation = 7
	FeatureValueAggregation_FEATURE_VALUE_AGGREGATION_P95                FeatureValueAggregation = 8
	FeatureValueAggregation_FEATURE_VALUE_AGGREGATION_P75                FeatureValueAggregation = 9
	FeatureValueAggregation_FEATURE_VALUE_AGGREGATION_P50                FeatureValueAggregation = 10
	FeatureValueAggregation_FEATURE_VALUE_AGGREGATION_P25                FeatureValueAggregation = 11
	FeatureValueAggregation_FEATURE_VALUE_AGGREGATION_P05                FeatureValueAggregation = 12
)

func (FeatureValueAggregation) Descriptor added in v0.16.22 

func (FeatureValueAggregation) Descriptor() protoreflect.EnumDescriptor

func (FeatureValueAggregation) Enum added in v0.16.22 

func (x FeatureValueAggregation) Enum() *FeatureValueAggregation

func (FeatureValueAggregation) EnumDescriptor deprecated added in v0.16.22 

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

Deprecated: Use FeatureValueAggregation.Descriptor instead.

func (FeatureValueAggregation) Number added in v0.16.22 

func (x FeatureValueAggregation) Number() protoreflect.EnumNumber

func (FeatureValueAggregation) String added in v0.16.22 

func (x FeatureValueAggregation) String() string

func (FeatureValueAggregation) Type added in v0.16.22 

func (FeatureValueAggregation) Type() protoreflect.EnumType

type GenericSingleQuery added in v0.7.7 

type GenericSingleQuery struct {

	// Types that are assignable to Query:
	//
	//	*GenericSingleQuery_SingleRequest
	//	*GenericSingleQuery_BulkRequest
	Query isGenericSingleQuery_Query `protobuf_oneof:"query"`
	// contains filtered or unexported fields
}

func (*GenericSingleQuery) Descriptor deprecated added in v0.7.7 

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

Deprecated: Use GenericSingleQuery.ProtoReflect.Descriptor instead.

func (*GenericSingleQuery) GetBulkRequest added in v0.7.7 

func (x *GenericSingleQuery) GetBulkRequest() *OnlineQueryBulkRequest

func (*GenericSingleQuery) GetQuery added in v0.7.7 

func (m *GenericSingleQuery) GetQuery() isGenericSingleQuery_Query

func (*GenericSingleQuery) GetSingleRequest added in v0.7.7 

func (x *GenericSingleQuery) GetSingleRequest() *OnlineQueryRequest

func (*GenericSingleQuery) ProtoMessage added in v0.7.7 

func (*GenericSingleQuery) ProtoMessage()

func (*GenericSingleQuery) ProtoReflect added in v0.7.7 

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

func (*GenericSingleQuery) Reset added in v0.7.7 

func (x *GenericSingleQuery) Reset()

func (*GenericSingleQuery) String added in v0.7.7 

func (x *GenericSingleQuery) String() string

type GenericSingleQuery_BulkRequest added in v0.7.7 

type GenericSingleQuery_BulkRequest struct {
	BulkRequest *OnlineQueryBulkRequest `protobuf:"bytes,2,opt,name=bulk_request,json=bulkRequest,proto3,oneof"`
}

type GenericSingleQuery_SingleRequest added in v0.7.7 

type GenericSingleQuery_SingleRequest struct {
	SingleRequest *OnlineQueryRequest `protobuf:"bytes,1,opt,name=single_request,json=singleRequest,proto3,oneof"`
}

type GenericSingleResponse added in v0.7.7 

type GenericSingleResponse struct {

	// Types that are assignable to Query:
	//
	//	*GenericSingleResponse_SingleResponse
	//	*GenericSingleResponse_BulkResponse
	Query isGenericSingleResponse_Query `protobuf_oneof:"query"`
	// contains filtered or unexported fields
}

func (*GenericSingleResponse) Descriptor deprecated added in v0.7.7 

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

Deprecated: Use GenericSingleResponse.ProtoReflect.Descriptor instead.

func (*GenericSingleResponse) GetBulkResponse added in v0.7.7 

func (x *GenericSingleResponse) GetBulkResponse() *OnlineQueryBulkResponse

func (*GenericSingleResponse) GetQuery added in v0.7.7 

func (m *GenericSingleResponse) GetQuery() isGenericSingleResponse_Query

func (*GenericSingleResponse) GetSingleResponse added in v0.7.7 

func (x *GenericSingleResponse) GetSingleResponse() *OnlineQueryResponse

func (*GenericSingleResponse) ProtoMessage added in v0.7.7 

func (*GenericSingleResponse) ProtoMessage()

func (*GenericSingleResponse) ProtoReflect added in v0.7.7 

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

func (*GenericSingleResponse) Reset added in v0.7.7 

func (x *GenericSingleResponse) Reset()

func (*GenericSingleResponse) String added in v0.7.7 

func (x *GenericSingleResponse) String() string

type GenericSingleResponse_BulkResponse added in v0.7.7 

type GenericSingleResponse_BulkResponse struct {
	BulkResponse *OnlineQueryBulkResponse `protobuf:"bytes,2,opt,name=bulk_response,json=bulkResponse,proto3,oneof"`
}

type GenericSingleResponse_SingleResponse added in v0.7.7 

type GenericSingleResponse_SingleResponse struct {
	SingleResponse *OnlineQueryResponse `protobuf:"bytes,1,opt,name=single_response,json=singleResponse,proto3,oneof"`
}

type GetFeatureValuesChartRequest deprecated added in v0.16.22 

type GetFeatureValuesChartRequest struct {
	Fqn         string                    `protobuf:"bytes,1,opt,name=fqn,proto3" json:"fqn,omitempty"`
	AggregateBy []FeatureValueAggregation `` /* 147-byte string literal not displayed */
	// 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_ms will be of size total_window % window_period
	WindowPeriod *string `protobuf:"bytes,3,opt,name=window_period,json=windowPeriod,proto3,oneof" json:"window_period,omitempty"`
	StartMs      int64   `protobuf:"varint,4,opt,name=start_ms,json=startMs,proto3" json:"start_ms,omitempty"`
	// If not provided, will assume current time is the ending time
	EndMs *int64 `protobuf:"varint,5,opt,name=end_ms,json=endMs,proto3,oneof" json:"end_ms,omitempty"`
	// contains filtered or unexported fields
}

Deprecated: Marked as deprecated in chalk/common/v1/feature_values.proto.

func (*GetFeatureValuesChartRequest) Descriptor deprecated added in v0.16.22 

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

Deprecated: Use GetFeatureValuesChartRequest.ProtoReflect.Descriptor instead.

func (*GetFeatureValuesChartRequest) GetAggregateBy added in v0.16.22 

func (x *GetFeatureValuesChartRequest) GetAggregateBy() []FeatureValueAggregation

func (*GetFeatureValuesChartRequest) GetEndMs added in v0.16.22 

func (x *GetFeatureValuesChartRequest) GetEndMs() int64

func (*GetFeatureValuesChartRequest) GetFqn added in v0.16.22 

func (x *GetFeatureValuesChartRequest) GetFqn() string

func (*GetFeatureValuesChartRequest) GetStartMs added in v0.16.22 

func (x *GetFeatureValuesChartRequest) GetStartMs() int64

func (*GetFeatureValuesChartRequest) GetWindowPeriod added in v0.16.22 

func (x *GetFeatureValuesChartRequest) GetWindowPeriod() string

func (*GetFeatureValuesChartRequest) ProtoMessage added in v0.16.22 

func (*GetFeatureValuesChartRequest) ProtoMessage()

func (*GetFeatureValuesChartRequest) ProtoReflect added in v0.16.22 

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

func (*GetFeatureValuesChartRequest) Reset added in v0.16.22 

func (x *GetFeatureValuesChartRequest) Reset()

func (*GetFeatureValuesChartRequest) String added in v0.16.22 

func (x *GetFeatureValuesChartRequest) String() string

type GetFeatureValuesChartResponse deprecated added in v0.16.22 

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

Deprecated: Marked as deprecated in chalk/common/v1/feature_values.proto.

func (*GetFeatureValuesChartResponse) Descriptor deprecated added in v0.16.22 

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

Deprecated: Use GetFeatureValuesChartResponse.ProtoReflect.Descriptor instead.

func (*GetFeatureValuesChartResponse) GetChart added in v0.16.22 

func (x *GetFeatureValuesChartResponse) GetChart() *Chart

func (*GetFeatureValuesChartResponse) ProtoMessage added in v0.16.22 

func (*GetFeatureValuesChartResponse) ProtoMessage()

func (*GetFeatureValuesChartResponse) ProtoReflect added in v0.16.22 

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

func (*GetFeatureValuesChartResponse) Reset added in v0.16.22 

func (x *GetFeatureValuesChartResponse) Reset()

func (*GetFeatureValuesChartResponse) String added in v0.16.22 

func (x *GetFeatureValuesChartResponse) String() string

type GetFeatureValuesTimeSeriesChartRequest deprecated added in v0.17.2 

type GetFeatureValuesTimeSeriesChartRequest struct {
	Fqn         string                    `protobuf:"bytes,1,opt,name=fqn,proto3" json:"fqn,omitempty"`
	AggregateBy []FeatureValueAggregation `` /* 147-byte string literal not displayed */
	// 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,oneof" 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 */
	// contains filtered or unexported fields
}

Deprecated: Marked as deprecated in chalk/common/v1/feature_values.proto.

func (*GetFeatureValuesTimeSeriesChartRequest) Descriptor deprecated added in v0.17.2 

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

Deprecated: Use GetFeatureValuesTimeSeriesChartRequest.ProtoReflect.Descriptor instead.

func (*GetFeatureValuesTimeSeriesChartRequest) GetAggregateBy added in v0.17.2 

func (x *GetFeatureValuesTimeSeriesChartRequest) GetAggregateBy() []FeatureValueAggregation

func (*GetFeatureValuesTimeSeriesChartRequest) GetEndTimestampExclusive added in v0.17.2 

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

func (*GetFeatureValuesTimeSeriesChartRequest) GetFqn added in v0.17.2 

func (x *GetFeatureValuesTimeSeriesChartRequest) GetFqn() string

func (*GetFeatureValuesTimeSeriesChartRequest) GetStartTimestampInclusive added in v0.17.2 

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

func (*GetFeatureValuesTimeSeriesChartRequest) GetWindowPeriod added in v0.17.2 

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

func (*GetFeatureValuesTimeSeriesChartRequest) ProtoMessage added in v0.17.2 

func (*GetFeatureValuesTimeSeriesChartRequest) ProtoMessage()

func (*GetFeatureValuesTimeSeriesChartRequest) ProtoReflect added in v0.17.2 

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

func (*GetFeatureValuesTimeSeriesChartRequest) Reset added in v0.17.2 

func (x *GetFeatureValuesTimeSeriesChartRequest) Reset()

func (*GetFeatureValuesTimeSeriesChartRequest) String added in v0.17.2 

func (x *GetFeatureValuesTimeSeriesChartRequest) String() string

type GetFeatureValuesTimeSeriesChartResponse deprecated added in v0.17.2 

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

Deprecated: Marked as deprecated in chalk/common/v1/feature_values.proto.

func (*GetFeatureValuesTimeSeriesChartResponse) Descriptor deprecated added in v0.17.2 

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

Deprecated: Use GetFeatureValuesTimeSeriesChartResponse.ProtoReflect.Descriptor instead.

func (*GetFeatureValuesTimeSeriesChartResponse) GetChart added in v0.17.2 

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

func (*GetFeatureValuesTimeSeriesChartResponse) ProtoMessage added in v0.17.2 

func (*GetFeatureValuesTimeSeriesChartResponse) ProtoMessage()

func (*GetFeatureValuesTimeSeriesChartResponse) ProtoReflect added in v0.17.2 

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

func (*GetFeatureValuesTimeSeriesChartResponse) Reset added in v0.17.2 

func (x *GetFeatureValuesTimeSeriesChartResponse) Reset()

func (*GetFeatureValuesTimeSeriesChartResponse) String added in v0.17.2 

func (x *GetFeatureValuesTimeSeriesChartResponse) String() string

type GetFeatureValuesTimeSeriesChartV2Request deprecated added in v0.17.3 

type GetFeatureValuesTimeSeriesChartV2Request struct {
	Fqn         string                    `protobuf:"bytes,1,opt,name=fqn,proto3" json:"fqn,omitempty"`
	AggregateBy []FeatureValueAggregation `` /* 147-byte string literal not displayed */
	// 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,oneof" 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 */
	// contains filtered or unexported fields
}

Deprecated: Marked as deprecated in chalk/common/v1/feature_values.proto.

func (*GetFeatureValuesTimeSeriesChartV2Request) Descriptor deprecated added in v0.17.3 

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

Deprecated: Use GetFeatureValuesTimeSeriesChartV2Request.ProtoReflect.Descriptor instead.

func (*GetFeatureValuesTimeSeriesChartV2Request) GetAggregateBy added in v0.17.3 

func (x *GetFeatureValuesTimeSeriesChartV2Request) GetAggregateBy() []FeatureValueAggregation

func (*GetFeatureValuesTimeSeriesChartV2Request) GetEndTimestampExclusive added in v0.17.3 

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

func (*GetFeatureValuesTimeSeriesChartV2Request) GetFqn added in v0.17.3 

func (x *GetFeatureValuesTimeSeriesChartV2Request) GetFqn() string

func (*GetFeatureValuesTimeSeriesChartV2Request) GetStartTimestampInclusive added in v0.17.3 

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

func (*GetFeatureValuesTimeSeriesChartV2Request) GetWindowPeriod added in v0.17.3 

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

func (*GetFeatureValuesTimeSeriesChartV2Request) ProtoMessage added in v0.17.3 

func (*GetFeatureValuesTimeSeriesChartV2Request) ProtoMessage()

func (*GetFeatureValuesTimeSeriesChartV2Request) ProtoReflect added in v0.17.3 

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

func (*GetFeatureValuesTimeSeriesChartV2Request) Reset added in v0.17.3 

func (x *GetFeatureValuesTimeSeriesChartV2Request) Reset()

func (*GetFeatureValuesTimeSeriesChartV2Request) String added in v0.17.3 

func (x *GetFeatureValuesTimeSeriesChartV2Request) String() string

type GetFeatureValuesTimeSeriesChartV2Response deprecated added in v0.17.3 

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

Deprecated: Marked as deprecated in chalk/common/v1/feature_values.proto.

func (*GetFeatureValuesTimeSeriesChartV2Response) Descriptor deprecated added in v0.17.3 

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

Deprecated: Use GetFeatureValuesTimeSeriesChartV2Response.ProtoReflect.Descriptor instead.

func (*GetFeatureValuesTimeSeriesChartV2Response) GetChart added in v0.17.3 

func (x *GetFeatureValuesTimeSeriesChartV2Response) GetChart() *v1.TimeSeriesChartV2

func (*GetFeatureValuesTimeSeriesChartV2Response) ProtoMessage added in v0.17.3 

func (*GetFeatureValuesTimeSeriesChartV2Response) ProtoMessage()

func (*GetFeatureValuesTimeSeriesChartV2Response) ProtoReflect added in v0.17.3 

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

func (*GetFeatureValuesTimeSeriesChartV2Response) Reset added in v0.17.3 

func (x *GetFeatureValuesTimeSeriesChartV2Response) Reset()

func (*GetFeatureValuesTimeSeriesChartV2Response) String added in v0.17.3 

func (x *GetFeatureValuesTimeSeriesChartV2Response) String() string

type GetOfflineQueryJobResponse 

type GetOfflineQueryJobResponse struct {
	IsFinished bool                `protobuf:"varint,1,opt,name=is_finished,json=isFinished,proto3" json:"is_finished,omitempty"`
	Version    int32               `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Urls       []string            `protobuf:"bytes,3,rep,name=urls,proto3" json:"urls,omitempty"`
	Errors     []*ChalkError       `protobuf:"bytes,4,rep,name=errors,proto3" json:"errors,omitempty"`
	Columns    *ColumnMetadataList `protobuf:"bytes,5,opt,name=columns,proto3,oneof" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOfflineQueryJobResponse) Descriptor deprecated 

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

Deprecated: Use GetOfflineQueryJobResponse.ProtoReflect.Descriptor instead.

func (*GetOfflineQueryJobResponse) GetColumns 

func (x *GetOfflineQueryJobResponse) GetColumns() *ColumnMetadataList

func (*GetOfflineQueryJobResponse) GetErrors 

func (x *GetOfflineQueryJobResponse) GetErrors() []*ChalkError

func (*GetOfflineQueryJobResponse) GetIsFinished 

func (x *GetOfflineQueryJobResponse) GetIsFinished() bool

func (*GetOfflineQueryJobResponse) GetUrls 

func (x *GetOfflineQueryJobResponse) GetUrls() []string

func (*GetOfflineQueryJobResponse) GetVersion 

func (x *GetOfflineQueryJobResponse) GetVersion() int32

func (*GetOfflineQueryJobResponse) ProtoMessage 

func (*GetOfflineQueryJobResponse) ProtoMessage()

func (*GetOfflineQueryJobResponse) ProtoReflect 

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

func (*GetOfflineQueryJobResponse) Reset 

func (x *GetOfflineQueryJobResponse) Reset()

func (*GetOfflineQueryJobResponse) String 

func (x *GetOfflineQueryJobResponse) String() string

type GetQueryLogEntriesPageToken deprecated added in v0.10.0 

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

Deprecated: Marked as deprecated in chalk/common/v1/query_log.proto.

func (*GetQueryLogEntriesPageToken) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetQueryLogEntriesPageToken.ProtoReflect.Descriptor instead.

func (*GetQueryLogEntriesPageToken) GetOperationIdHwm added in v0.10.0 

func (x *GetQueryLogEntriesPageToken) GetOperationIdHwm() string

func (*GetQueryLogEntriesPageToken) GetQueryTimestampHwm added in v0.10.0 

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

func (*GetQueryLogEntriesPageToken) ProtoMessage added in v0.10.0 

func (*GetQueryLogEntriesPageToken) ProtoMessage()

func (*GetQueryLogEntriesPageToken) ProtoReflect added in v0.10.0 

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

func (*GetQueryLogEntriesPageToken) Reset added in v0.10.0 

func (x *GetQueryLogEntriesPageToken) Reset()

func (*GetQueryLogEntriesPageToken) String added in v0.10.0 

func (x *GetQueryLogEntriesPageToken) String() string

type GetQueryLogEntriesRequest deprecated added in v0.10.0 

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
}

Deprecated: Marked as deprecated in chalk/common/v1/query_log.proto.

func (*GetQueryLogEntriesRequest) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetQueryLogEntriesRequest.ProtoReflect.Descriptor instead.

func (*GetQueryLogEntriesRequest) GetFilters added in v0.10.0 

func (x *GetQueryLogEntriesRequest) GetFilters() *QueryLogFilters

func (*GetQueryLogEntriesRequest) GetPageSize added in v0.10.0 

func (x *GetQueryLogEntriesRequest) GetPageSize() int32

func (*GetQueryLogEntriesRequest) GetPageToken added in v0.10.0 

func (x *GetQueryLogEntriesRequest) GetPageToken() string

func (*GetQueryLogEntriesRequest) GetQueryTimestampLowerBoundInclusive added in v0.10.0 

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

func (*GetQueryLogEntriesRequest) GetQueryTimestampUpperBoundExclusive added in v0.10.0 

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

func (*GetQueryLogEntriesRequest) ProtoMessage added in v0.10.0 

func (*GetQueryLogEntriesRequest) ProtoMessage()

func (*GetQueryLogEntriesRequest) ProtoReflect added in v0.10.0 

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

func (*GetQueryLogEntriesRequest) Reset added in v0.10.0 

func (x *GetQueryLogEntriesRequest) Reset()

func (*GetQueryLogEntriesRequest) String added in v0.10.0 

func (x *GetQueryLogEntriesRequest) String() string

type GetQueryLogEntriesResponse deprecated added in v0.10.0 

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 entires is empty.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Deprecated: Marked as deprecated in chalk/common/v1/query_log.proto.

func (*GetQueryLogEntriesResponse) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetQueryLogEntriesResponse.ProtoReflect.Descriptor instead.

func (*GetQueryLogEntriesResponse) GetEntries added in v0.10.0 

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

func (*GetQueryLogEntriesResponse) GetNextPageToken added in v0.10.0 

func (x *GetQueryLogEntriesResponse) GetNextPageToken() string

func (*GetQueryLogEntriesResponse) ProtoMessage added in v0.10.0 

func (*GetQueryLogEntriesResponse) ProtoMessage()

func (*GetQueryLogEntriesResponse) ProtoReflect added in v0.10.0 

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

func (*GetQueryLogEntriesResponse) Reset added in v0.10.0 

func (x *GetQueryLogEntriesResponse) Reset()

func (*GetQueryLogEntriesResponse) String added in v0.10.0 

func (x *GetQueryLogEntriesResponse) String() string

type GetQueryValuesPageToken deprecated added in v0.10.0 

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

Deprecated: Marked as deprecated in chalk/common/v1/query_values.proto.

func (*GetQueryValuesPageToken) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetQueryValuesPageToken.ProtoReflect.Descriptor instead.

func (*GetQueryValuesPageToken) GetOperationIdHwm added in v0.10.0 

func (x *GetQueryValuesPageToken) GetOperationIdHwm() string

func (*GetQueryValuesPageToken) GetQueryTimestampHwm added in v0.10.0 

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

func (*GetQueryValuesPageToken) GetRowIdHwm added in v0.10.0 

func (x *GetQueryValuesPageToken) GetRowIdHwm() int64

func (*GetQueryValuesPageToken) ProtoMessage added in v0.10.0 

func (*GetQueryValuesPageToken) ProtoMessage()

func (*GetQueryValuesPageToken) ProtoReflect added in v0.10.0 

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

func (*GetQueryValuesPageToken) Reset added in v0.10.0 

func (x *GetQueryValuesPageToken) Reset()

func (*GetQueryValuesPageToken) String added in v0.10.0 

func (x *GetQueryValuesPageToken) String() string

type GetQueryValuesRequest deprecated added in v0.10.0 

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
}

Deprecated: Marked as deprecated in chalk/common/v1/query_values.proto.

func (*GetQueryValuesRequest) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetQueryValuesRequest.ProtoReflect.Descriptor instead.

func (*GetQueryValuesRequest) GetFeatures added in v0.10.0 

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

func (*GetQueryValuesRequest) GetOperationIdIdentifier added in v0.10.0 

func (x *GetQueryValuesRequest) GetOperationIdIdentifier() *OperationIdTableIdentifier

func (*GetQueryValuesRequest) GetPageSize added in v0.10.0 

func (x *GetQueryValuesRequest) GetPageSize() int32

func (*GetQueryValuesRequest) GetPageToken added in v0.10.0 

func (x *GetQueryValuesRequest) GetPageToken() string

func (*GetQueryValuesRequest) GetQueryTimestampLowerBoundInclusive added in v0.10.0 

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

func (*GetQueryValuesRequest) GetQueryTimestampUpperBoundExclusive added in v0.10.0 

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

func (*GetQueryValuesRequest) GetTableIdentifier added in v0.10.0 

func (m *GetQueryValuesRequest) GetTableIdentifier() isGetQueryValuesRequest_TableIdentifier

func (*GetQueryValuesRequest) GetTableNameIdentifier added in v0.10.0 

func (x *GetQueryValuesRequest) GetTableNameIdentifier() *TableNameTableIdentifier

func (*GetQueryValuesRequest) ProtoMessage added in v0.10.0 

func (*GetQueryValuesRequest) ProtoMessage()

func (*GetQueryValuesRequest) ProtoReflect added in v0.10.0 

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

func (*GetQueryValuesRequest) Reset added in v0.10.0 

func (x *GetQueryValuesRequest) Reset()

func (*GetQueryValuesRequest) String added in v0.10.0 

func (x *GetQueryValuesRequest) String() string

type GetQueryValuesRequest_OperationIdIdentifier added in v0.10.0 

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

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 deprecated added in v0.10.0 

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
}

Deprecated: Marked as deprecated in chalk/common/v1/query_values.proto.

func (*GetQueryValuesResponse) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use GetQueryValuesResponse.ProtoReflect.Descriptor instead.

func (*GetQueryValuesResponse) GetNextPageToken added in v0.10.0 

func (x *GetQueryValuesResponse) GetNextPageToken() string

func (*GetQueryValuesResponse) GetParquet added in v0.10.0 

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

func (*GetQueryValuesResponse) GetPayload added in v0.10.0 

func (m *GetQueryValuesResponse) GetPayload() isGetQueryValuesResponse_Payload

func (*GetQueryValuesResponse) ProtoMessage added in v0.10.0 

func (*GetQueryValuesResponse) ProtoMessage()

func (*GetQueryValuesResponse) ProtoReflect added in v0.10.0 

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

func (*GetQueryValuesResponse) Reset added in v0.10.0 

func (x *GetQueryValuesResponse) Reset()

func (*GetQueryValuesResponse) String added in v0.10.0 

func (x *GetQueryValuesResponse) String() string

type GetQueryValuesResponse_Parquet added in v0.10.0 

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

type OfflineQueryExplain 

type OfflineQueryExplain struct {

	// Types that are assignable to Impl:
	//
	//	*OfflineQueryExplain_Truthy
	//	*OfflineQueryExplain_Only_
	Impl isOfflineQueryExplain_Impl `protobuf_oneof:"impl"`
	// contains filtered or unexported fields
}

OfflineQueryExplain is DEPRECATED. DO NOT USE IT!!

func (*OfflineQueryExplain) Descriptor deprecated 

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

Deprecated: Use OfflineQueryExplain.ProtoReflect.Descriptor instead.

func (*OfflineQueryExplain) GetImpl 

func (m *OfflineQueryExplain) GetImpl() isOfflineQueryExplain_Impl

func (*OfflineQueryExplain) GetOnly 

func (x *OfflineQueryExplain) GetOnly() *OfflineQueryExplain_Only

func (*OfflineQueryExplain) GetTruthy 

func (x *OfflineQueryExplain) GetTruthy() bool

func (*OfflineQueryExplain) ProtoMessage 

func (*OfflineQueryExplain) ProtoMessage()

func (*OfflineQueryExplain) ProtoReflect 

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

func (*OfflineQueryExplain) Reset 

func (x *OfflineQueryExplain) Reset()

func (*OfflineQueryExplain) String 

func (x *OfflineQueryExplain) String() string

type OfflineQueryExplain_Only 

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

func (*OfflineQueryExplain_Only) Descriptor deprecated 

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

Deprecated: Use OfflineQueryExplain_Only.ProtoReflect.Descriptor instead.

func (*OfflineQueryExplain_Only) ProtoMessage 

func (*OfflineQueryExplain_Only) ProtoMessage()

func (*OfflineQueryExplain_Only) ProtoReflect 

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

func (*OfflineQueryExplain_Only) Reset 

func (x *OfflineQueryExplain_Only) Reset()

func (*OfflineQueryExplain_Only) String 

func (x *OfflineQueryExplain_Only) String() string

type OfflineQueryExplain_Only_ 

type OfflineQueryExplain_Only_ struct {
	Only *OfflineQueryExplain_Only `protobuf:"bytes,2,opt,name=only,proto3,oneof"`
}

type OfflineQueryExplain_Truthy 

type OfflineQueryExplain_Truthy struct {
	Truthy bool `protobuf:"varint,1,opt,name=truthy,proto3,oneof"`
}

type OfflineQueryInputs 

type OfflineQueryInputs struct {

	// Types that are assignable to Impl:
	//
	//	*OfflineQueryInputs_FeatherInputs
	//	*OfflineQueryInputs_NoInputs_
	Impl isOfflineQueryInputs_Impl `protobuf_oneof:"impl"`
	// contains filtered or unexported fields
}

func (*OfflineQueryInputs) Descriptor deprecated 

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

Deprecated: Use OfflineQueryInputs.ProtoReflect.Descriptor instead.

func (*OfflineQueryInputs) GetFeatherInputs 

func (x *OfflineQueryInputs) GetFeatherInputs() []byte

func (*OfflineQueryInputs) GetImpl 

func (m *OfflineQueryInputs) GetImpl() isOfflineQueryInputs_Impl

func (*OfflineQueryInputs) GetNoInputs 

func (x *OfflineQueryInputs) GetNoInputs() *OfflineQueryInputs_NoInputs

func (*OfflineQueryInputs) ProtoMessage 

func (*OfflineQueryInputs) ProtoMessage()

func (*OfflineQueryInputs) ProtoReflect 

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

func (*OfflineQueryInputs) Reset 

func (x *OfflineQueryInputs) Reset()

func (*OfflineQueryInputs) String 

func (x *OfflineQueryInputs) String() string

type OfflineQueryInputs_FeatherInputs 

type OfflineQueryInputs_FeatherInputs struct {
	// *
	// Should be a feather-compressed table, complete with schema
	FeatherInputs []byte `protobuf:"bytes,1,opt,name=feather_inputs,json=featherInputs,proto3,oneof"`
}

type OfflineQueryInputs_NoInputs 

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

func (*OfflineQueryInputs_NoInputs) Descriptor deprecated 

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

Deprecated: Use OfflineQueryInputs_NoInputs.ProtoReflect.Descriptor instead.

func (*OfflineQueryInputs_NoInputs) ProtoMessage 

func (*OfflineQueryInputs_NoInputs) ProtoMessage()

func (*OfflineQueryInputs_NoInputs) ProtoReflect 

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

func (*OfflineQueryInputs_NoInputs) Reset 

func (x *OfflineQueryInputs_NoInputs) Reset()

func (*OfflineQueryInputs_NoInputs) String 

func (x *OfflineQueryInputs_NoInputs) String() string

type OfflineQueryInputs_NoInputs_ 

type OfflineQueryInputs_NoInputs_ struct {
	NoInputs *OfflineQueryInputs_NoInputs `protobuf:"bytes,2,opt,name=no_inputs,json=noInputs,proto3,oneof"`
}

type OfflineQueryRecomputeFeatures 

type OfflineQueryRecomputeFeatures struct {

	// Types that are assignable to Impl:
	//
	//	*OfflineQueryRecomputeFeatures_AllOrNone
	//	*OfflineQueryRecomputeFeatures_FeatureList_
	Impl isOfflineQueryRecomputeFeatures_Impl `protobuf_oneof:"impl"`
	// contains filtered or unexported fields
}

func (*OfflineQueryRecomputeFeatures) Descriptor deprecated 

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

Deprecated: Use OfflineQueryRecomputeFeatures.ProtoReflect.Descriptor instead.

func (*OfflineQueryRecomputeFeatures) GetAllOrNone 

func (x *OfflineQueryRecomputeFeatures) GetAllOrNone() bool

func (*OfflineQueryRecomputeFeatures) GetFeatureList 

func (x *OfflineQueryRecomputeFeatures) GetFeatureList() *OfflineQueryRecomputeFeatures_FeatureList

func (*OfflineQueryRecomputeFeatures) GetImpl 

func (m *OfflineQueryRecomputeFeatures) GetImpl() isOfflineQueryRecomputeFeatures_Impl

func (*OfflineQueryRecomputeFeatures) ProtoMessage 

func (*OfflineQueryRecomputeFeatures) ProtoMessage()

func (*OfflineQueryRecomputeFeatures) ProtoReflect 

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

func (*OfflineQueryRecomputeFeatures) Reset 

func (x *OfflineQueryRecomputeFeatures) Reset()

func (*OfflineQueryRecomputeFeatures) String 

func (x *OfflineQueryRecomputeFeatures) String() string

type OfflineQueryRecomputeFeatures_AllOrNone 

type OfflineQueryRecomputeFeatures_AllOrNone struct {
	AllOrNone bool `protobuf:"varint,1,opt,name=all_or_none,json=allOrNone,proto3,oneof"`
}

type OfflineQueryRecomputeFeatures_FeatureList 

type OfflineQueryRecomputeFeatures_FeatureList struct {
	FeatureList []string `protobuf:"bytes,1,rep,name=feature_list,json=featureList,proto3" json:"feature_list,omitempty"`
	// contains filtered or unexported fields
}

func (*OfflineQueryRecomputeFeatures_FeatureList) Descriptor deprecated 

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

Deprecated: Use OfflineQueryRecomputeFeatures_FeatureList.ProtoReflect.Descriptor instead.

func (*OfflineQueryRecomputeFeatures_FeatureList) GetFeatureList 

func (x *OfflineQueryRecomputeFeatures_FeatureList) GetFeatureList() []string

func (*OfflineQueryRecomputeFeatures_FeatureList) ProtoMessage 

func (*OfflineQueryRecomputeFeatures_FeatureList) ProtoMessage()

func (*OfflineQueryRecomputeFeatures_FeatureList) ProtoReflect 

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

func (*OfflineQueryRecomputeFeatures_FeatureList) Reset 

func (x *OfflineQueryRecomputeFeatures_FeatureList) Reset()

func (*OfflineQueryRecomputeFeatures_FeatureList) String 

func (x *OfflineQueryRecomputeFeatures_FeatureList) String() string

type OfflineQueryRecomputeFeatures_FeatureList_ 

type OfflineQueryRecomputeFeatures_FeatureList_ struct {
	FeatureList *OfflineQueryRecomputeFeatures_FeatureList `protobuf:"bytes,2,opt,name=feature_list,json=featureList,proto3,oneof"`
}

type OfflineQueryRequest 

type OfflineQueryRequest struct {
	Inputs *OfflineQueryInputs `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// A list of output feature root fqns to query
	Outputs []string `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// A list of required output feature root fqns
	RequiredOutputs []string `protobuf:"bytes,3,rep,name=required_outputs,json=requiredOutputs,proto3" json:"required_outputs,omitempty"`
	// The desired output format. Should be 'CSV' or 'PARQUET
	DestinationFormat string                         `protobuf:"bytes,4,opt,name=destination_format,json=destinationFormat,proto3" json:"destination_format,omitempty"`
	Branch            *string                        `protobuf:"bytes,5,opt,name=branch,proto3,oneof" json:"branch,omitempty"`
	DatasetName       *string                        `protobuf:"bytes,6,opt,name=dataset_name,json=datasetName,proto3,oneof" json:"dataset_name,omitempty"`
	RecomputeFeatures *OfflineQueryRecomputeFeatures `protobuf:"bytes,7,opt,name=recompute_features,json=recomputeFeatures,proto3" json:"recompute_features,omitempty"`
	StorePlanStages   bool                           `protobuf:"varint,8,opt,name=store_plan_stages,json=storePlanStages,proto3" json:"store_plan_stages,omitempty"`
	// "Where" clause
	Filters []*v1.LogicalExprNode `protobuf:"bytes,11,rep,name=filters,proto3" json:"filters,omitempty"`
	// The maximum number of samples. If None, no limit
	MaxSamples *int32 `protobuf:"varint,101,opt,name=max_samples,json=maxSamples,proto3,oneof" json:"max_samples,omitempty"`
	// The maximum staleness, in seconds, for how old the view on the offline store can be. That is,
	// data ingested within this interval will not be reflected in this offline query.
	// Set to “0“ to ignore the cache. If not specified, it defaults to OFFLINE_QUERY_MAX_CACHE_AGE_SECS
	// in chalk engine config.
	MaxCacheAgeSecs *int32 `protobuf:"varint,102,opt,name=max_cache_age_secs,json=maxCacheAgeSecs,proto3,oneof" json:"max_cache_age_secs,omitempty"`
	// Field is deprecated because we shouldn't have OnlineExplain that differs from OfflineExplain
	// Use explain2
	//
	// Deprecated: Marked as deprecated in chalk/common/v1/offline_query.proto.
	Explain       *OfflineQueryExplain `protobuf:"bytes,103,opt,name=explain,proto3" json:"explain,omitempty"`
	Explain2      *ExplainOptions      `protobuf:"bytes,106,opt,name=explain2,proto3" json:"explain2,omitempty"`
	Tags          []string             `protobuf:"bytes,104,rep,name=tags,proto3" json:"tags,omitempty"`
	CorrelationId *string              `protobuf:"bytes,105,opt,name=correlation_id,json=correlationId,proto3,oneof" json:"correlation_id,omitempty"`
	// The lower bound for the observed at timestamp (inclusive). If not specified, defaults to the beginning of time
	ObservedAtLowerBound *string `` /* 133-byte string literal not displayed */
	// The upper bound for the observed at timestamp (inclusive). If not specified, defaults to the end of time
	ObservedAtUpperBound *string `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*OfflineQueryRequest) Descriptor deprecated 

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

Deprecated: Use OfflineQueryRequest.ProtoReflect.Descriptor instead.

func (*OfflineQueryRequest) GetBranch 

func (x *OfflineQueryRequest) GetBranch() string

func (*OfflineQueryRequest) GetCorrelationId 

func (x *OfflineQueryRequest) GetCorrelationId() string

func (*OfflineQueryRequest) GetDatasetName 

func (x *OfflineQueryRequest) GetDatasetName() string

func (*OfflineQueryRequest) GetDestinationFormat 

func (x *OfflineQueryRequest) GetDestinationFormat() string

func (*OfflineQueryRequest) GetExplain deprecated 

func (x *OfflineQueryRequest) GetExplain() *OfflineQueryExplain

Deprecated: Marked as deprecated in chalk/common/v1/offline_query.proto.

func (*OfflineQueryRequest) GetExplain2 added in v0.16.17 

func (x *OfflineQueryRequest) GetExplain2() *ExplainOptions

func (*OfflineQueryRequest) GetFilters added in v0.4.7 

func (x *OfflineQueryRequest) GetFilters() []*v1.LogicalExprNode

func (*OfflineQueryRequest) GetInputs 

func (x *OfflineQueryRequest) GetInputs() *OfflineQueryInputs

func (*OfflineQueryRequest) GetMaxCacheAgeSecs 

func (x *OfflineQueryRequest) GetMaxCacheAgeSecs() int32

func (*OfflineQueryRequest) GetMaxSamples 

func (x *OfflineQueryRequest) GetMaxSamples() int32

func (*OfflineQueryRequest) GetObservedAtLowerBound 

func (x *OfflineQueryRequest) GetObservedAtLowerBound() string

func (*OfflineQueryRequest) GetObservedAtUpperBound 

func (x *OfflineQueryRequest) GetObservedAtUpperBound() string

func (*OfflineQueryRequest) GetOutputs 

func (x *OfflineQueryRequest) GetOutputs() []string

func (*OfflineQueryRequest) GetRecomputeFeatures 

func (x *OfflineQueryRequest) GetRecomputeFeatures() *OfflineQueryRecomputeFeatures

func (*OfflineQueryRequest) GetRequiredOutputs 

func (x *OfflineQueryRequest) GetRequiredOutputs() []string

func (*OfflineQueryRequest) GetStorePlanStages 

func (x *OfflineQueryRequest) GetStorePlanStages() bool

func (*OfflineQueryRequest) GetTags 

func (x *OfflineQueryRequest) GetTags() []string

func (*OfflineQueryRequest) ProtoMessage 

func (*OfflineQueryRequest) ProtoMessage()

func (*OfflineQueryRequest) ProtoReflect 

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

func (*OfflineQueryRequest) Reset 

func (x *OfflineQueryRequest) Reset()

func (*OfflineQueryRequest) String 

func (x *OfflineQueryRequest) String() string

type OnlineQueryBulkRequest added in v0.5.0 

type OnlineQueryBulkRequest struct {
	InputsFeather   []byte                      `protobuf:"bytes,1,opt,name=inputs_feather,json=inputsFeather,proto3" json:"inputs_feather,omitempty"`
	Outputs         []*OutputExpr               `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty"`
	Now             []*timestamppb.Timestamp    `protobuf:"bytes,3,rep,name=now,proto3" json:"now,omitempty"`
	Staleness       map[string]string           `` /* 159-byte string literal not displayed */
	Context         *OnlineQueryContext         `protobuf:"bytes,5,opt,name=context,proto3" json:"context,omitempty"`
	ResponseOptions *OnlineQueryResponseOptions `protobuf:"bytes,6,opt,name=response_options,json=responseOptions,proto3" json:"response_options,omitempty"`
	BodyType        FeatherBodyType             `protobuf:"varint,7,opt,name=body_type,json=bodyType,proto3,enum=chalk.common.v1.FeatherBodyType" json:"body_type,omitempty"`
	// contains filtered or unexported fields
}

func (*OnlineQueryBulkRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use OnlineQueryBulkRequest.ProtoReflect.Descriptor instead.

func (*OnlineQueryBulkRequest) GetBodyType added in v0.5.0 

func (x *OnlineQueryBulkRequest) GetBodyType() FeatherBodyType

func (*OnlineQueryBulkRequest) GetContext added in v0.5.0 

func (x *OnlineQueryBulkRequest) GetContext() *OnlineQueryContext

func (*OnlineQueryBulkRequest) GetInputsFeather added in v0.5.0 

func (x *OnlineQueryBulkRequest) GetInputsFeather() []byte

func (*OnlineQueryBulkRequest) GetNow added in v0.5.0 

func (x *OnlineQueryBulkRequest) GetNow() []*timestamppb.Timestamp

func (*OnlineQueryBulkRequest) GetOutputs added in v0.5.0 

func (x *OnlineQueryBulkRequest) GetOutputs() []*OutputExpr

func (*OnlineQueryBulkRequest) GetResponseOptions added in v0.5.0 

func (x *OnlineQueryBulkRequest) GetResponseOptions() *OnlineQueryResponseOptions

func (*OnlineQueryBulkRequest) GetStaleness added in v0.5.0 

func (x *OnlineQueryBulkRequest) GetStaleness() map[string]string

func (*OnlineQueryBulkRequest) ProtoMessage added in v0.5.0 

func (*OnlineQueryBulkRequest) ProtoMessage()

func (*OnlineQueryBulkRequest) ProtoReflect added in v0.5.0 

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

func (*OnlineQueryBulkRequest) Reset added in v0.5.0 

func (x *OnlineQueryBulkRequest) Reset()

func (*OnlineQueryBulkRequest) String added in v0.5.0 

func (x *OnlineQueryBulkRequest) String() string

type OnlineQueryBulkResponse added in v0.5.0 

type OnlineQueryBulkResponse struct {
	ScalarsData  []byte               `protobuf:"bytes,1,opt,name=scalars_data,json=scalarsData,proto3" json:"scalars_data,omitempty"`
	GroupsData   map[string][]byte    `` /* 179-byte string literal not displayed */
	Errors       []*ChalkError        `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"`
	ResponseMeta *OnlineQueryMetadata `protobuf:"bytes,4,opt,name=response_meta,json=responseMeta,proto3" json:"response_meta,omitempty"`
	// contains filtered or unexported fields
}

func (*OnlineQueryBulkResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use OnlineQueryBulkResponse.ProtoReflect.Descriptor instead.

func (*OnlineQueryBulkResponse) GetErrors added in v0.5.0 

func (x *OnlineQueryBulkResponse) GetErrors() []*ChalkError

func (*OnlineQueryBulkResponse) GetGroupsData added in v0.5.0 

func (x *OnlineQueryBulkResponse) GetGroupsData() map[string][]byte

func (*OnlineQueryBulkResponse) GetResponseMeta added in v0.5.0 

func (x *OnlineQueryBulkResponse) GetResponseMeta() *OnlineQueryMetadata

func (*OnlineQueryBulkResponse) GetScalarsData added in v0.5.0 

func (x *OnlineQueryBulkResponse) GetScalarsData() []byte

func (*OnlineQueryBulkResponse) ProtoMessage added in v0.5.0 

func (*OnlineQueryBulkResponse) ProtoMessage()

func (*OnlineQueryBulkResponse) ProtoReflect added in v0.5.0 

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

func (*OnlineQueryBulkResponse) Reset added in v0.5.0 

func (x *OnlineQueryBulkResponse) Reset()

func (*OnlineQueryBulkResponse) String added in v0.5.0 

func (x *OnlineQueryBulkResponse) String() string

type OnlineQueryContext 

type OnlineQueryContext struct {

	// Deprecated: Marked as deprecated in chalk/common/v1/online_query.proto.
	Environment          string   `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"` // environment id is set in the header. This field is not set anymore
	Tags                 []string `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	RequiredResolverTags []string `protobuf:"bytes,3,rep,name=required_resolver_tags,json=requiredResolverTags,proto3" json:"required_resolver_tags,omitempty"`
	// Deprecated: Marked as deprecated in chalk/common/v1/online_query.proto.
	DeploymentId *string `protobuf:"bytes,4,opt,name=deployment_id,json=deploymentId,proto3,oneof" json:"deployment_id,omitempty"` // deployment id is set in the header. This field is not set anymore
	// Deprecated: Marked as deprecated in chalk/common/v1/online_query.proto.
	BranchId         *string `protobuf:"bytes,5,opt,name=branch_id,json=branchId,proto3,oneof" json:"branch_id,omitempty"` // branch_id is set in the header. This field is not set anymore
	CorrelationId    *string `protobuf:"bytes,6,opt,name=correlation_id,json=correlationId,proto3,oneof" json:"correlation_id,omitempty"`
	QueryName        *string `protobuf:"bytes,7,opt,name=query_name,json=queryName,proto3,oneof" json:"query_name,omitempty"`
	QueryNameVersion *string `protobuf:"bytes,8,opt,name=query_name_version,json=queryNameVersion,proto3,oneof" json:"query_name_version,omitempty"`
	// Arbitrary flags for the query such as store_plan_stages
	// If a flag because consistently used it should be moved into an actual field.
	Options map[string]*structpb.Value `` /* 155-byte string literal not displayed */
	// Value metrics will be tagged by the output of the given features
	ValueMetricsTagByFeatures []*OutputExpr `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

Roughly speaking data in here should affect the query hash key / the query plan

func (*OnlineQueryContext) Descriptor deprecated 

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

Deprecated: Use OnlineQueryContext.ProtoReflect.Descriptor instead.

func (*OnlineQueryContext) GetBranchId deprecated 

func (x *OnlineQueryContext) GetBranchId() string

Deprecated: Marked as deprecated in chalk/common/v1/online_query.proto.

func (*OnlineQueryContext) GetCorrelationId 

func (x *OnlineQueryContext) GetCorrelationId() string

func (*OnlineQueryContext) GetDeploymentId deprecated 

func (x *OnlineQueryContext) GetDeploymentId() string

Deprecated: Marked as deprecated in chalk/common/v1/online_query.proto.

func (*OnlineQueryContext) GetEnvironment deprecated 

func (x *OnlineQueryContext) GetEnvironment() string

Deprecated: Marked as deprecated in chalk/common/v1/online_query.proto.

func (*OnlineQueryContext) GetOptions added in v0.4.7 

func (x *OnlineQueryContext) GetOptions() map[string]*structpb.Value

func (*OnlineQueryContext) GetQueryName 

func (x *OnlineQueryContext) GetQueryName() string

func (*OnlineQueryContext) GetQueryNameVersion added in v0.4.7 

func (x *OnlineQueryContext) GetQueryNameVersion() string

func (*OnlineQueryContext) GetRequiredResolverTags added in v0.4.7 

func (x *OnlineQueryContext) GetRequiredResolverTags() []string

func (*OnlineQueryContext) GetTags 

func (x *OnlineQueryContext) GetTags() []string

func (*OnlineQueryContext) GetValueMetricsTagByFeatures added in v0.17.12 

func (x *OnlineQueryContext) GetValueMetricsTagByFeatures() []*OutputExpr

func (*OnlineQueryContext) ProtoMessage 

func (*OnlineQueryContext) ProtoMessage()

func (*OnlineQueryContext) ProtoReflect 

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

func (*OnlineQueryContext) Reset 

func (x *OnlineQueryContext) Reset()

func (*OnlineQueryContext) String 

func (x *OnlineQueryContext) String() string

type OnlineQueryMetadata 

type OnlineQueryMetadata struct {
	ExecutionDuration *durationpb.Duration   `protobuf:"bytes,1,opt,name=execution_duration,json=executionDuration,proto3" json:"execution_duration,omitempty"`
	DeploymentId      string                 `protobuf:"bytes,2,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	EnvironmentId     string                 `protobuf:"bytes,3,opt,name=environment_id,json=environmentId,proto3" json:"environment_id,omitempty"`
	EnvironmentName   string                 `protobuf:"bytes,4,opt,name=environment_name,json=environmentName,proto3" json:"environment_name,omitempty"`
	QueryId           string                 `protobuf:"bytes,5,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	QueryTimestamp    *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=query_timestamp,json=queryTimestamp,proto3" json:"query_timestamp,omitempty"`
	QueryHash         string                 `protobuf:"bytes,7,opt,name=query_hash,json=queryHash,proto3" json:"query_hash,omitempty"`
	ExplainOutput     *QueryExplainInfo      `protobuf:"bytes,8,opt,name=explain_output,json=explainOutput,proto3" json:"explain_output,omitempty"`
	// Same customer-provided metadata that was provided in the request.
	Metadata           map[string]string          `` /* 157-byte string literal not displayed */
	AdditionalMetadata map[string]*structpb.Value `` /* 204-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*OnlineQueryMetadata) Descriptor deprecated 

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

Deprecated: Use OnlineQueryMetadata.ProtoReflect.Descriptor instead.

func (*OnlineQueryMetadata) GetAdditionalMetadata added in v0.17.10 

func (x *OnlineQueryMetadata) GetAdditionalMetadata() map[string]*structpb.Value

func (*OnlineQueryMetadata) GetDeploymentId 

func (x *OnlineQueryMetadata) GetDeploymentId() string

func (*OnlineQueryMetadata) GetEnvironmentId 

func (x *OnlineQueryMetadata) GetEnvironmentId() string

func (*OnlineQueryMetadata) GetEnvironmentName 

func (x *OnlineQueryMetadata) GetEnvironmentName() string

func (*OnlineQueryMetadata) GetExecutionDuration 

func (x *OnlineQueryMetadata) GetExecutionDuration() *durationpb.Duration

func (*OnlineQueryMetadata) GetExplainOutput 

func (x *OnlineQueryMetadata) GetExplainOutput() *QueryExplainInfo

func (*OnlineQueryMetadata) GetMetadata added in v0.4.7 

func (x *OnlineQueryMetadata) GetMetadata() map[string]string

func (*OnlineQueryMetadata) GetQueryHash 

func (x *OnlineQueryMetadata) GetQueryHash() string

func (*OnlineQueryMetadata) GetQueryId 

func (x *OnlineQueryMetadata) GetQueryId() string

func (*OnlineQueryMetadata) GetQueryTimestamp 

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

func (*OnlineQueryMetadata) ProtoMessage 

func (*OnlineQueryMetadata) ProtoMessage()

func (*OnlineQueryMetadata) ProtoReflect 

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

func (*OnlineQueryMetadata) Reset 

func (x *OnlineQueryMetadata) Reset()

func (*OnlineQueryMetadata) String 

func (x *OnlineQueryMetadata) String() string

type OnlineQueryMultiRequest added in v0.7.7 

type OnlineQueryMultiRequest struct {
	Queries []*GenericSingleQuery `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
	// contains filtered or unexported fields
}

func (*OnlineQueryMultiRequest) Descriptor deprecated added in v0.7.7 

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

Deprecated: Use OnlineQueryMultiRequest.ProtoReflect.Descriptor instead.

func (*OnlineQueryMultiRequest) GetQueries added in v0.7.7 

func (x *OnlineQueryMultiRequest) GetQueries() []*GenericSingleQuery

func (*OnlineQueryMultiRequest) ProtoMessage added in v0.7.7 

func (*OnlineQueryMultiRequest) ProtoMessage()

func (*OnlineQueryMultiRequest) ProtoReflect added in v0.7.7 

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

func (*OnlineQueryMultiRequest) Reset added in v0.7.7 

func (x *OnlineQueryMultiRequest) Reset()

func (*OnlineQueryMultiRequest) String added in v0.7.7 

func (x *OnlineQueryMultiRequest) String() string

type OnlineQueryMultiResponse added in v0.7.7 

type OnlineQueryMultiResponse struct {
	Responses []*GenericSingleResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// Internal errors not tied to a specific request. Most errors should be stored in the individual response objects.
	Errors []*ChalkError `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*OnlineQueryMultiResponse) Descriptor deprecated added in v0.7.7 

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

Deprecated: Use OnlineQueryMultiResponse.ProtoReflect.Descriptor instead.

func (*OnlineQueryMultiResponse) GetErrors added in v0.7.7 

func (x *OnlineQueryMultiResponse) GetErrors() []*ChalkError

func (*OnlineQueryMultiResponse) GetResponses added in v0.7.7 

func (x *OnlineQueryMultiResponse) GetResponses() []*GenericSingleResponse

func (*OnlineQueryMultiResponse) ProtoMessage added in v0.7.7 

func (*OnlineQueryMultiResponse) ProtoMessage()

func (*OnlineQueryMultiResponse) ProtoReflect added in v0.7.7 

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

func (*OnlineQueryMultiResponse) Reset added in v0.7.7 

func (x *OnlineQueryMultiResponse) Reset()

func (*OnlineQueryMultiResponse) String added in v0.7.7 

func (x *OnlineQueryMultiResponse) String() string

type OnlineQueryRequest 

type OnlineQueryRequest struct {
	Inputs          map[string]*structpb.Value  `` /* 153-byte string literal not displayed */
	Outputs         []*OutputExpr               `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty"`
	Now             *timestamppb.Timestamp      `protobuf:"bytes,3,opt,name=now,proto3,oneof" json:"now,omitempty"`
	Staleness       map[string]string           `` /* 159-byte string literal not displayed */
	Context         *OnlineQueryContext         `protobuf:"bytes,5,opt,name=context,proto3" json:"context,omitempty"`
	ResponseOptions *OnlineQueryResponseOptions `protobuf:"bytes,6,opt,name=response_options,json=responseOptions,proto3" json:"response_options,omitempty"`
	// contains filtered or unexported fields
}

func (*OnlineQueryRequest) Descriptor deprecated 

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

Deprecated: Use OnlineQueryRequest.ProtoReflect.Descriptor instead.

func (*OnlineQueryRequest) GetContext 

func (x *OnlineQueryRequest) GetContext() *OnlineQueryContext

func (*OnlineQueryRequest) GetInputs 

func (x *OnlineQueryRequest) GetInputs() map[string]*structpb.Value

func (*OnlineQueryRequest) GetNow 

func (x *OnlineQueryRequest) GetNow() *timestamppb.Timestamp

func (*OnlineQueryRequest) GetOutputs 

func (x *OnlineQueryRequest) GetOutputs() []*OutputExpr

func (*OnlineQueryRequest) GetResponseOptions 

func (x *OnlineQueryRequest) GetResponseOptions() *OnlineQueryResponseOptions

func (*OnlineQueryRequest) GetStaleness 

func (x *OnlineQueryRequest) GetStaleness() map[string]string

func (*OnlineQueryRequest) ProtoMessage 

func (*OnlineQueryRequest) ProtoMessage()

func (*OnlineQueryRequest) ProtoReflect 

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

func (*OnlineQueryRequest) Reset 

func (x *OnlineQueryRequest) Reset()

func (*OnlineQueryRequest) String 

func (x *OnlineQueryRequest) String() string

type OnlineQueryResponse 

type OnlineQueryResponse struct {
	Data         *OnlineQueryResult   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Errors       []*ChalkError        `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	ResponseMeta *OnlineQueryMetadata `protobuf:"bytes,3,opt,name=response_meta,json=responseMeta,proto3" json:"response_meta,omitempty"`
	// contains filtered or unexported fields
}

func (*OnlineQueryResponse) Descriptor deprecated 

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

Deprecated: Use OnlineQueryResponse.ProtoReflect.Descriptor instead.

func (*OnlineQueryResponse) GetData 

func (x *OnlineQueryResponse) GetData() *OnlineQueryResult

func (*OnlineQueryResponse) GetErrors 

func (x *OnlineQueryResponse) GetErrors() []*ChalkError

func (*OnlineQueryResponse) GetResponseMeta 

func (x *OnlineQueryResponse) GetResponseMeta() *OnlineQueryMetadata

func (*OnlineQueryResponse) ProtoMessage 

func (*OnlineQueryResponse) ProtoMessage()

func (*OnlineQueryResponse) ProtoReflect 

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

func (*OnlineQueryResponse) Reset 

func (x *OnlineQueryResponse) Reset()

func (*OnlineQueryResponse) String 

func (x *OnlineQueryResponse) String() string

type OnlineQueryResponseOptions 

type OnlineQueryResponseOptions struct {
	IncludeMeta     bool                    `protobuf:"varint,1,opt,name=include_meta,json=includeMeta,proto3" json:"include_meta,omitempty"`
	Explain         *ExplainOptions         `protobuf:"bytes,2,opt,name=explain,proto3" json:"explain,omitempty"`
	EncodingOptions *FeatureEncodingOptions `protobuf:"bytes,3,opt,name=encoding_options,json=encodingOptions,proto3" json:"encoding_options,omitempty"`
	// Customer-provided metadata that gets returned in the response
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

Options re: how we construct the response, shouldn't affect the query hash

func (*OnlineQueryResponseOptions) Descriptor deprecated 

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

Deprecated: Use OnlineQueryResponseOptions.ProtoReflect.Descriptor instead.

func (*OnlineQueryResponseOptions) GetEncodingOptions added in v0.4.7 

func (x *OnlineQueryResponseOptions) GetEncodingOptions() *FeatureEncodingOptions

func (*OnlineQueryResponseOptions) GetExplain 

func (x *OnlineQueryResponseOptions) GetExplain() *ExplainOptions

func (*OnlineQueryResponseOptions) GetIncludeMeta 

func (x *OnlineQueryResponseOptions) GetIncludeMeta() bool

func (*OnlineQueryResponseOptions) GetMetadata added in v0.4.7 

func (x *OnlineQueryResponseOptions) GetMetadata() map[string]string

func (*OnlineQueryResponseOptions) ProtoMessage 

func (*OnlineQueryResponseOptions) ProtoMessage()

func (*OnlineQueryResponseOptions) ProtoReflect 

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

func (*OnlineQueryResponseOptions) Reset 

func (x *OnlineQueryResponseOptions) Reset()

func (*OnlineQueryResponseOptions) String 

func (x *OnlineQueryResponseOptions) String() string

type OnlineQueryResult 

type OnlineQueryResult struct {
	Results []*FeatureResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*OnlineQueryResult) Descriptor deprecated 

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

Deprecated: Use OnlineQueryResult.ProtoReflect.Descriptor instead.

func (*OnlineQueryResult) GetResults added in v0.4.7 

func (x *OnlineQueryResult) GetResults() []*FeatureResult

func (*OnlineQueryResult) ProtoMessage 

func (*OnlineQueryResult) ProtoMessage()

func (*OnlineQueryResult) ProtoReflect 

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

func (*OnlineQueryResult) Reset 

func (x *OnlineQueryResult) Reset()

func (*OnlineQueryResult) String 

func (x *OnlineQueryResult) String() string

type OperationIdTableIdentifier deprecated added in v0.10.0 

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
}

Deprecated: Marked as deprecated in chalk/common/v1/query_values.proto.

func (*OperationIdTableIdentifier) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use OperationIdTableIdentifier.ProtoReflect.Descriptor instead.

func (*OperationIdTableIdentifier) GetOperationId added in v0.10.0 

func (x *OperationIdTableIdentifier) GetOperationId() string

func (*OperationIdTableIdentifier) ProtoMessage added in v0.10.0 

func (*OperationIdTableIdentifier) ProtoMessage()

func (*OperationIdTableIdentifier) ProtoReflect added in v0.10.0 

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

func (*OperationIdTableIdentifier) Reset added in v0.10.0 

func (x *OperationIdTableIdentifier) Reset()

func (*OperationIdTableIdentifier) String added in v0.10.0 

func (x *OperationIdTableIdentifier) String() string

type OperationKind added in v0.10.0 

type OperationKind int32
const (
	OperationKind_OPERATION_KIND_UNSPECIFIED        OperationKind = 0
	OperationKind_OPERATION_KIND_ONLINE_QUERY       OperationKind = 1 // also known as inference
	OperationKind_OPERATION_KIND_MIGRATION          OperationKind = 2
	OperationKind_OPERATION_KIND_CRON               OperationKind = 3
	OperationKind_OPERATION_KIND_STREAMING          OperationKind = 4
	OperationKind_OPERATION_KIND_MIGRATION_SAMPLER  OperationKind = 5
	OperationKind_OPERATION_KIND_WINDOWED_STREAMING OperationKind = 6
	OperationKind_OPERATION_KIND_OFFLINE_QUERY      OperationKind = 7
)

func (OperationKind) Descriptor added in v0.10.0 

func (OperationKind) Descriptor() protoreflect.EnumDescriptor

func (OperationKind) Enum added in v0.10.0 

func (x OperationKind) Enum() *OperationKind

func (OperationKind) EnumDescriptor deprecated added in v0.10.0 

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

Deprecated: Use OperationKind.Descriptor instead.

func (OperationKind) Number added in v0.10.0 

func (x OperationKind) Number() protoreflect.EnumNumber

func (OperationKind) String added in v0.10.0 

func (x OperationKind) String() string

func (OperationKind) Type added in v0.10.0 

func (OperationKind) Type() protoreflect.EnumType

type OutputExpr added in v0.4.7 

type OutputExpr struct {

	// Types that are assignable to Expr:
	//
	//	*OutputExpr_FeatureFqn
	Expr isOutputExpr_Expr `protobuf_oneof:"expr"`
	// contains filtered or unexported fields
}

Represent an online query output. Currently these are just single feature FQNs. In the future these could be expressions like `User.card.transactions[_.amount < 100]`

func (*OutputExpr) Descriptor deprecated added in v0.4.7 

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

Deprecated: Use OutputExpr.ProtoReflect.Descriptor instead.

func (*OutputExpr) GetExpr added in v0.4.7 

func (m *OutputExpr) GetExpr() isOutputExpr_Expr

func (*OutputExpr) GetFeatureFqn added in v0.4.7 

func (x *OutputExpr) GetFeatureFqn() string

func (*OutputExpr) ProtoMessage added in v0.4.7 

func (*OutputExpr) ProtoMessage()

func (*OutputExpr) ProtoReflect added in v0.4.7 

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

func (*OutputExpr) Reset added in v0.4.7 

func (x *OutputExpr) Reset()

func (*OutputExpr) String added in v0.4.7 

func (x *OutputExpr) String() string

type OutputExpr_FeatureFqn added in v0.4.7 

type OutputExpr_FeatureFqn struct {
	FeatureFqn string `protobuf:"bytes,1,opt,name=feature_fqn,json=featureFqn,proto3,oneof"`
}

type QueryExplainInfo added in v0.4.7 

type QueryExplainInfo struct {

	// Unstructured string representation of the plan
	PlanString *string `protobuf:"bytes,1,opt,name=plan_string,json=planString,proto3,oneof" json:"plan_string,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryExplainInfo) Descriptor deprecated added in v0.4.7 

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

Deprecated: Use QueryExplainInfo.ProtoReflect.Descriptor instead.

func (*QueryExplainInfo) GetPlanString added in v0.4.7 

func (x *QueryExplainInfo) GetPlanString() string

func (*QueryExplainInfo) ProtoMessage added in v0.4.7 

func (*QueryExplainInfo) ProtoMessage()

func (*QueryExplainInfo) ProtoReflect added in v0.4.7 

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

func (*QueryExplainInfo) Reset added in v0.4.7 

func (x *QueryExplainInfo) Reset()

func (*QueryExplainInfo) String added in v0.4.7 

func (x *QueryExplainInfo) String() string

type QueryLogEntry deprecated added in v0.10.0 

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       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         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.

Deprecated: Marked as deprecated in chalk/common/v1/query_log.proto.

func (*QueryLogEntry) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use QueryLogEntry.ProtoReflect.Descriptor instead.

func (*QueryLogEntry) GetAgentId added in v0.10.0 

func (x *QueryLogEntry) GetAgentId() string

func (*QueryLogEntry) GetBranchName added in v0.10.0 

func (x *QueryLogEntry) GetBranchName() string

func (*QueryLogEntry) GetCorrelationId added in v0.10.0 

func (x *QueryLogEntry) GetCorrelationId() string

func (*QueryLogEntry) GetDeploymentId added in v0.10.0 

func (x *QueryLogEntry) GetDeploymentId() string

func (*QueryLogEntry) GetEnvironmentId added in v0.10.0 

func (x *QueryLogEntry) GetEnvironmentId() string

func (*QueryLogEntry) GetExecutionFinishedAt added in v0.10.0 

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

func (*QueryLogEntry) GetExecutionStartedAt added in v0.10.0 

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

func (*QueryLogEntry) GetMetaQueryHash added in v0.13.8 

func (x *QueryLogEntry) GetMetaQueryHash() string

func (*QueryLogEntry) GetOperationId added in v0.10.0 

func (x *QueryLogEntry) GetOperationId() string

func (*QueryLogEntry) GetOperationKind added in v0.10.0 

func (x *QueryLogEntry) GetOperationKind() OperationKind

func (*QueryLogEntry) GetQueryName added in v0.10.0 

func (x *QueryLogEntry) GetQueryName() string

func (*QueryLogEntry) GetQueryNameVersion added in v0.10.0 

func (x *QueryLogEntry) GetQueryNameVersion() string

func (*QueryLogEntry) GetQueryPlanId added in v0.10.0 

func (x *QueryLogEntry) GetQueryPlanId() string

func (*QueryLogEntry) GetQueryStatus added in v0.10.0 

func (x *QueryLogEntry) GetQueryStatus() QueryStatus

func (*QueryLogEntry) GetQueryTimestamp added in v0.10.0 

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

func (*QueryLogEntry) GetTraceId added in v0.10.0 

func (x *QueryLogEntry) GetTraceId() string

func (*QueryLogEntry) GetValueTables added in v0.10.0 

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

func (*QueryLogEntry) ProtoMessage added in v0.10.0 

func (*QueryLogEntry) ProtoMessage()

func (*QueryLogEntry) ProtoReflect added in v0.10.0 

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

func (*QueryLogEntry) Reset added in v0.10.0 

func (x *QueryLogEntry) Reset()

func (*QueryLogEntry) String added in v0.10.0 

func (x *QueryLogEntry) String() string

type QueryLogFilters deprecated added in v0.10.0 

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 []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   []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
}

Deprecated: Marked as deprecated in chalk/common/v1/query_log.proto.

func (*QueryLogFilters) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use QueryLogFilters.ProtoReflect.Descriptor instead.

func (*QueryLogFilters) GetAgentId added in v0.10.0 

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

func (*QueryLogFilters) GetBranchName added in v0.10.0 

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

func (*QueryLogFilters) GetCorrelationId added in v0.10.0 

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

func (*QueryLogFilters) GetDeploymentId added in v0.10.0 

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

func (*QueryLogFilters) GetMetaQueryHash added in v0.13.8 

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

func (*QueryLogFilters) GetOperationId added in v0.10.0 

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

func (*QueryLogFilters) GetOperationKind added in v0.10.0 

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

func (*QueryLogFilters) GetQueryName added in v0.10.0 

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

func (*QueryLogFilters) GetQueryPlanId added in v0.10.0 

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

func (*QueryLogFilters) GetQueryStatus added in v0.10.0 

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

func (*QueryLogFilters) GetTraceId added in v0.10.0 

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

func (*QueryLogFilters) ProtoMessage added in v0.10.0 

func (*QueryLogFilters) ProtoMessage()

func (*QueryLogFilters) ProtoReflect added in v0.10.0 

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

func (*QueryLogFilters) Reset added in v0.10.0 

func (x *QueryLogFilters) Reset()

func (*QueryLogFilters) String added in v0.10.0 

func (x *QueryLogFilters) String() string

type QueryStatus 

type QueryStatus int32
const (
	// Default value, should not be used
	QueryStatus_QUERY_STATUS_UNSPECIFIED QueryStatus = 0
	// Pending submission to the database.
	QueryStatus_QUERY_STATUS_PENDING_SUBMISSION QueryStatus = 1
	// Submitted to the database, but not yet running
	QueryStatus_QUERY_STATUS_SUBMITTED QueryStatus = 2
	// Running in the database.
	QueryStatus_QUERY_STATUS_RUNNING QueryStatus = 3
	// Error with either submitting or running the job.
	QueryStatus_QUERY_STATUS_ERROR QueryStatus = 4
	// The job did not complete before an expiration deadline, so there are no results.
	QueryStatus_QUERY_STATUS_EXPIRED QueryStatus = 5
	// Manually cancelled before it errored or finished successfully.
	QueryStatus_QUERY_STATUS_CANCELLED QueryStatus = 6
	// Successfully ran the job.
	QueryStatus_QUERY_STATUS_SUCCESSFUL QueryStatus = 7
	// Succesfully ran the job, but encountered nonfatal errors (e.g. failed to run resolver on some rows)
	QueryStatus_QUERY_STATUS_SUCCESSFUL_WITH_NONFATAL_ERRORS QueryStatus = 8
)

func (QueryStatus) Descriptor 

func (QueryStatus) Descriptor() protoreflect.EnumDescriptor

func (QueryStatus) Enum 

func (x QueryStatus) Enum() *QueryStatus

func (QueryStatus) EnumDescriptor deprecated 

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

Deprecated: Use QueryStatus.Descriptor instead.

func (QueryStatus) Number 

func (x QueryStatus) Number() protoreflect.EnumNumber

func (QueryStatus) String 

func (x QueryStatus) String() string

func (QueryStatus) Type 

func (QueryStatus) Type() protoreflect.EnumType

type Series deprecated added in v0.16.22 

type Series struct {
	Points []float64 `protobuf:"fixed64,1,rep,packed,name=points,proto3" json:"points,omitempty"`
	Label  string    `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Units  string    `protobuf:"bytes,3,opt,name=units,proto3" json:"units,omitempty"`
	// contains filtered or unexported fields
}

Deprecated: Marked as deprecated in chalk/common/v1/chart.proto.

func (*Series) Descriptor deprecated added in v0.16.22 

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

Deprecated: Use Series.ProtoReflect.Descriptor instead.

func (*Series) GetLabel added in v0.16.22 

func (x *Series) GetLabel() string

func (*Series) GetPoints added in v0.16.22 

func (x *Series) GetPoints() []float64

func (*Series) GetUnits added in v0.16.22 

func (x *Series) GetUnits() string

func (*Series) ProtoMessage added in v0.16.22 

func (*Series) ProtoMessage()

func (*Series) ProtoReflect added in v0.16.22 

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

func (*Series) Reset added in v0.16.22 

func (x *Series) Reset()

func (*Series) String added in v0.16.22 

func (x *Series) String() string

type TableNameTableIdentifier deprecated added in v0.10.0 

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 *QueryLogFilters `protobuf:"bytes,2,opt,name=filters,proto3" json:"filters,omitempty"`
	// contains filtered or unexported fields
}

Deprecated: Marked as deprecated in chalk/common/v1/query_values.proto.

func (*TableNameTableIdentifier) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use TableNameTableIdentifier.ProtoReflect.Descriptor instead.

func (*TableNameTableIdentifier) GetFilters added in v0.10.0 

func (x *TableNameTableIdentifier) GetFilters() *QueryLogFilters

func (*TableNameTableIdentifier) GetTableName added in v0.10.0 

func (x *TableNameTableIdentifier) GetTableName() string

func (*TableNameTableIdentifier) ProtoMessage added in v0.10.0 

func (*TableNameTableIdentifier) ProtoMessage()

func (*TableNameTableIdentifier) ProtoReflect added in v0.10.0 

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

func (*TableNameTableIdentifier) Reset added in v0.10.0 

func (x *TableNameTableIdentifier) Reset()

func (*TableNameTableIdentifier) String added in v0.10.0 

func (x *TableNameTableIdentifier) String() string

type UploadFeaturesBulkRequest added in v0.13.2 

type UploadFeaturesBulkRequest struct {
	InputsFeather []byte          `protobuf:"bytes,1,opt,name=inputs_feather,json=inputsFeather,proto3" json:"inputs_feather,omitempty"`
	BodyType      FeatherBodyType `protobuf:"varint,7,opt,name=body_type,json=bodyType,proto3,enum=chalk.common.v1.FeatherBodyType" json:"body_type,omitempty"`
	// contains filtered or unexported fields
}

UPLOAD FEATURES

func (*UploadFeaturesBulkRequest) Descriptor deprecated added in v0.13.2 

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

Deprecated: Use UploadFeaturesBulkRequest.ProtoReflect.Descriptor instead.

func (*UploadFeaturesBulkRequest) GetBodyType added in v0.13.2 

func (x *UploadFeaturesBulkRequest) GetBodyType() FeatherBodyType

func (*UploadFeaturesBulkRequest) GetInputsFeather added in v0.13.2 

func (x *UploadFeaturesBulkRequest) GetInputsFeather() []byte

func (*UploadFeaturesBulkRequest) ProtoMessage added in v0.13.2 

func (*UploadFeaturesBulkRequest) ProtoMessage()

func (*UploadFeaturesBulkRequest) ProtoReflect added in v0.13.2 

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

func (*UploadFeaturesBulkRequest) Reset added in v0.13.2 

func (x *UploadFeaturesBulkRequest) Reset()

func (*UploadFeaturesBulkRequest) String added in v0.13.2 

func (x *UploadFeaturesBulkRequest) String() string

type UploadFeaturesBulkResponse added in v0.13.2 

type UploadFeaturesBulkResponse struct {
	Errors []*ChalkError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadFeaturesBulkResponse) Descriptor deprecated added in v0.13.2 

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

Deprecated: Use UploadFeaturesBulkResponse.ProtoReflect.Descriptor instead.

func (*UploadFeaturesBulkResponse) GetErrors added in v0.13.2 

func (x *UploadFeaturesBulkResponse) GetErrors() []*ChalkError

func (*UploadFeaturesBulkResponse) ProtoMessage added in v0.13.2 

func (*UploadFeaturesBulkResponse) ProtoMessage()

func (*UploadFeaturesBulkResponse) ProtoReflect added in v0.13.2 

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

func (*UploadFeaturesBulkResponse) Reset added in v0.13.2 

func (x *UploadFeaturesBulkResponse) Reset()

func (*UploadFeaturesBulkResponse) String added in v0.13.2 

func (x *UploadFeaturesBulkResponse) String() string

type VersionedQueryName deprecated added in v0.10.0 

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
}

Deprecated: Marked as deprecated in chalk/common/v1/query_log.proto.

func (*VersionedQueryName) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use VersionedQueryName.ProtoReflect.Descriptor instead.

func (*VersionedQueryName) GetQueryName added in v0.10.0 

func (x *VersionedQueryName) GetQueryName() string

func (*VersionedQueryName) GetQueryNameVersion added in v0.10.0 

func (x *VersionedQueryName) GetQueryNameVersion() string

func (*VersionedQueryName) ProtoMessage added in v0.10.0 

func (*VersionedQueryName) ProtoMessage()

func (*VersionedQueryName) ProtoReflect added in v0.10.0 

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

func (*VersionedQueryName) Reset added in v0.10.0 

func (x *VersionedQueryName) Reset()

func (*VersionedQueryName) String added in v0.10.0 

func (x *VersionedQueryName) String() string

Source Files

View all Source files

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.