Documentation ¶
Index ¶
- Variables
- type ChalkError
- func (*ChalkError) Descriptor() ([]byte, []int)deprecated
- func (x *ChalkError) GetCategory() ErrorCodeCategory
- func (x *ChalkError) GetCode() ErrorCode
- func (x *ChalkError) GetDisplayPrimaryKey() string
- func (x *ChalkError) GetDisplayPrimaryKeyFqn() string
- func (x *ChalkError) GetException() *ChalkException
- func (x *ChalkError) GetFeature() string
- func (x *ChalkError) GetMessage() string
- func (x *ChalkError) GetResolver() string
- func (*ChalkError) ProtoMessage()
- func (x *ChalkError) ProtoReflect() protoreflect.Message
- func (x *ChalkError) Reset()
- func (x *ChalkError) String() string
- type ChalkException
- func (*ChalkException) Descriptor() ([]byte, []int)deprecated
- func (x *ChalkException) GetInternalStacktrace() string
- func (x *ChalkException) GetKind() string
- func (x *ChalkException) GetMessage() string
- func (x *ChalkException) GetStacktrace() string
- func (*ChalkException) ProtoMessage()
- func (x *ChalkException) ProtoReflect() protoreflect.Message
- func (x *ChalkException) Reset()
- func (x *ChalkException) String() string
- type ColumnMetadataList
- func (*ColumnMetadataList) Descriptor() ([]byte, []int)deprecated
- func (x *ColumnMetadataList) GetMetadata() []*ColumnMetadataList_ColumnMetadata
- func (*ColumnMetadataList) ProtoMessage()
- func (x *ColumnMetadataList) ProtoReflect() protoreflect.Message
- func (x *ColumnMetadataList) Reset()
- func (x *ColumnMetadataList) String() string
- type ColumnMetadataList_ColumnMetadata
- func (*ColumnMetadataList_ColumnMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *ColumnMetadataList_ColumnMetadata) GetColumnName() string
- func (x *ColumnMetadataList_ColumnMetadata) GetDtype() string
- func (x *ColumnMetadataList_ColumnMetadata) GetFeatureFqn() string
- func (*ColumnMetadataList_ColumnMetadata) ProtoMessage()
- func (x *ColumnMetadataList_ColumnMetadata) ProtoReflect() protoreflect.Message
- func (x *ColumnMetadataList_ColumnMetadata) Reset()
- func (x *ColumnMetadataList_ColumnMetadata) String() string
- type DatasetFilter
- func (*DatasetFilter) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetFilter) GetMaxCacheAgeSecs() float32
- func (x *DatasetFilter) GetSampleFilters() *DatasetSampleFilter
- func (*DatasetFilter) ProtoMessage()
- func (x *DatasetFilter) ProtoReflect() protoreflect.Message
- func (x *DatasetFilter) Reset()
- func (x *DatasetFilter) String() string
- type DatasetResponse
- func (*DatasetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetResponse) GetDatasetId() string
- func (x *DatasetResponse) GetDatasetName() string
- func (x *DatasetResponse) GetEnvironmentId() string
- func (x *DatasetResponse) GetErrors() []*ChalkError
- func (x *DatasetResponse) GetIsFinished() bool
- func (x *DatasetResponse) GetRevisions() []*DatasetRevisionResponse
- func (x *DatasetResponse) GetVersion() int32
- func (*DatasetResponse) ProtoMessage()
- func (x *DatasetResponse) ProtoReflect() protoreflect.Message
- func (x *DatasetResponse) Reset()
- func (x *DatasetResponse) String() string
- type DatasetRevisionResponse
- func (*DatasetRevisionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetRevisionResponse) GetBranch() string
- func (x *DatasetRevisionResponse) GetCreatedAt() *timestamppb.Timestamp
- func (x *DatasetRevisionResponse) GetCreatorId() string
- func (x *DatasetRevisionResponse) GetDashboardUrl() string
- func (x *DatasetRevisionResponse) GetDatasetId() string
- func (x *DatasetRevisionResponse) GetDatasetName() string
- func (x *DatasetRevisionResponse) GetEnvironmentId() string
- func (x *DatasetRevisionResponse) GetFilters() *DatasetFilter
- func (x *DatasetRevisionResponse) GetGivensUri() string
- func (x *DatasetRevisionResponse) GetNumBytes() int32
- func (x *DatasetRevisionResponse) GetNumPartitions() int32
- func (x *DatasetRevisionResponse) GetOutputUris() string
- func (x *DatasetRevisionResponse) GetOutputVersion() int32
- func (x *DatasetRevisionResponse) GetOutputs() []string
- func (x *DatasetRevisionResponse) GetRevisionId() string
- func (x *DatasetRevisionResponse) GetStartedAt() *timestamppb.Timestamp
- func (x *DatasetRevisionResponse) GetStatus() QueryStatus
- func (x *DatasetRevisionResponse) GetTerminatedAt() *timestamppb.Timestamp
- func (*DatasetRevisionResponse) ProtoMessage()
- func (x *DatasetRevisionResponse) ProtoReflect() protoreflect.Message
- func (x *DatasetRevisionResponse) Reset()
- func (x *DatasetRevisionResponse) String() string
- type DatasetSampleFilter
- func (*DatasetSampleFilter) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetSampleFilter) GetLowerBound() *timestamppb.Timestamp
- func (x *DatasetSampleFilter) GetMaxSamples() int32
- func (x *DatasetSampleFilter) GetUpperBound() *timestamppb.Timestamp
- func (*DatasetSampleFilter) ProtoMessage()
- func (x *DatasetSampleFilter) ProtoReflect() protoreflect.Message
- func (x *DatasetSampleFilter) Reset()
- func (x *DatasetSampleFilter) String() string
- type ErrorCode
- type ErrorCodeCategory
- func (ErrorCodeCategory) Descriptor() protoreflect.EnumDescriptor
- func (x ErrorCodeCategory) Enum() *ErrorCodeCategory
- func (ErrorCodeCategory) EnumDescriptor() ([]byte, []int)deprecated
- func (x ErrorCodeCategory) Number() protoreflect.EnumNumber
- func (x ErrorCodeCategory) String() string
- func (ErrorCodeCategory) Type() protoreflect.EnumType
- type ExplainOptions
- type FeatherBodyType
- func (FeatherBodyType) Descriptor() protoreflect.EnumDescriptor
- func (x FeatherBodyType) Enum() *FeatherBodyType
- func (FeatherBodyType) EnumDescriptor() ([]byte, []int)deprecated
- func (x FeatherBodyType) Number() protoreflect.EnumNumber
- func (x FeatherBodyType) String() string
- func (FeatherBodyType) Type() protoreflect.EnumType
- type FeatureEncodingOptions
- func (*FeatureEncodingOptions) Descriptor() ([]byte, []int)deprecated
- func (x *FeatureEncodingOptions) GetEncodeStructsAsObjects() bool
- func (*FeatureEncodingOptions) ProtoMessage()
- func (x *FeatureEncodingOptions) ProtoReflect() protoreflect.Message
- func (x *FeatureEncodingOptions) Reset()
- func (x *FeatureEncodingOptions) String() string
- type FeatureMeta
- func (*FeatureMeta) Descriptor() ([]byte, []int)deprecated
- func (x *FeatureMeta) GetCacheHit() bool
- func (x *FeatureMeta) GetChosenResolverFqn() string
- func (x *FeatureMeta) GetPrimitiveType() string
- func (x *FeatureMeta) GetVersion() int64
- func (*FeatureMeta) ProtoMessage()
- func (x *FeatureMeta) ProtoReflect() protoreflect.Message
- func (x *FeatureMeta) Reset()
- func (x *FeatureMeta) String() string
- type FeatureResult
- func (*FeatureResult) Descriptor() ([]byte, []int)deprecated
- func (x *FeatureResult) GetError() string
- func (x *FeatureResult) GetField() string
- func (x *FeatureResult) GetMeta() *FeatureMeta
- func (x *FeatureResult) GetTs() *timestamppb.Timestamp
- func (x *FeatureResult) GetValue() *structpb.Value
- func (*FeatureResult) ProtoMessage()
- func (x *FeatureResult) ProtoReflect() protoreflect.Message
- func (x *FeatureResult) Reset()
- func (x *FeatureResult) String() string
- type GetOfflineQueryJobResponse
- func (*GetOfflineQueryJobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetOfflineQueryJobResponse) GetColumns() *ColumnMetadataList
- func (x *GetOfflineQueryJobResponse) GetErrors() []*ChalkError
- func (x *GetOfflineQueryJobResponse) GetIsFinished() bool
- func (x *GetOfflineQueryJobResponse) GetUrls() []string
- func (x *GetOfflineQueryJobResponse) GetVersion() int32
- func (*GetOfflineQueryJobResponse) ProtoMessage()
- func (x *GetOfflineQueryJobResponse) ProtoReflect() protoreflect.Message
- func (x *GetOfflineQueryJobResponse) Reset()
- func (x *GetOfflineQueryJobResponse) String() string
- type OfflineQueryExplain
- func (*OfflineQueryExplain) Descriptor() ([]byte, []int)deprecated
- func (m *OfflineQueryExplain) GetImpl() isOfflineQueryExplain_Impl
- func (x *OfflineQueryExplain) GetOnly() *OfflineQueryExplain_Only
- func (x *OfflineQueryExplain) GetTruthy() bool
- func (*OfflineQueryExplain) ProtoMessage()
- func (x *OfflineQueryExplain) ProtoReflect() protoreflect.Message
- func (x *OfflineQueryExplain) Reset()
- func (x *OfflineQueryExplain) String() string
- type OfflineQueryExplain_Only
- type OfflineQueryExplain_Only_
- type OfflineQueryExplain_Truthy
- type OfflineQueryInputs
- func (*OfflineQueryInputs) Descriptor() ([]byte, []int)deprecated
- func (x *OfflineQueryInputs) GetFeatherInputs() []byte
- func (m *OfflineQueryInputs) GetImpl() isOfflineQueryInputs_Impl
- func (x *OfflineQueryInputs) GetNoInputs() *OfflineQueryInputs_NoInputs
- func (*OfflineQueryInputs) ProtoMessage()
- func (x *OfflineQueryInputs) ProtoReflect() protoreflect.Message
- func (x *OfflineQueryInputs) Reset()
- func (x *OfflineQueryInputs) String() string
- type OfflineQueryInputs_FeatherInputs
- type OfflineQueryInputs_NoInputs
- type OfflineQueryInputs_NoInputs_
- type OfflineQueryRecomputeFeatures
- func (*OfflineQueryRecomputeFeatures) Descriptor() ([]byte, []int)deprecated
- func (x *OfflineQueryRecomputeFeatures) GetAllOrNone() bool
- func (x *OfflineQueryRecomputeFeatures) GetFeatureList() *OfflineQueryRecomputeFeatures_FeatureList
- func (m *OfflineQueryRecomputeFeatures) GetImpl() isOfflineQueryRecomputeFeatures_Impl
- func (*OfflineQueryRecomputeFeatures) ProtoMessage()
- func (x *OfflineQueryRecomputeFeatures) ProtoReflect() protoreflect.Message
- func (x *OfflineQueryRecomputeFeatures) Reset()
- func (x *OfflineQueryRecomputeFeatures) String() string
- type OfflineQueryRecomputeFeatures_AllOrNone
- type OfflineQueryRecomputeFeatures_FeatureList
- func (*OfflineQueryRecomputeFeatures_FeatureList) Descriptor() ([]byte, []int)deprecated
- func (x *OfflineQueryRecomputeFeatures_FeatureList) GetFeatureList() []string
- func (*OfflineQueryRecomputeFeatures_FeatureList) ProtoMessage()
- func (x *OfflineQueryRecomputeFeatures_FeatureList) ProtoReflect() protoreflect.Message
- func (x *OfflineQueryRecomputeFeatures_FeatureList) Reset()
- func (x *OfflineQueryRecomputeFeatures_FeatureList) String() string
- type OfflineQueryRecomputeFeatures_FeatureList_
- type OfflineQueryRequest
- func (*OfflineQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OfflineQueryRequest) GetBranch() string
- func (x *OfflineQueryRequest) GetCorrelationId() string
- func (x *OfflineQueryRequest) GetDatasetName() string
- func (x *OfflineQueryRequest) GetDestinationFormat() string
- func (x *OfflineQueryRequest) GetExplain() *OfflineQueryExplain
- func (x *OfflineQueryRequest) GetFilters() []*v1.LogicalExprNode
- func (x *OfflineQueryRequest) GetInputs() *OfflineQueryInputs
- func (x *OfflineQueryRequest) GetMaxCacheAgeSecs() int32
- func (x *OfflineQueryRequest) GetMaxSamples() int32
- func (x *OfflineQueryRequest) GetObservedAtLowerBound() string
- func (x *OfflineQueryRequest) GetObservedAtUpperBound() string
- func (x *OfflineQueryRequest) GetOutputs() []string
- func (x *OfflineQueryRequest) GetRecomputeFeatures() *OfflineQueryRecomputeFeatures
- func (x *OfflineQueryRequest) GetRequiredOutputs() []string
- func (x *OfflineQueryRequest) GetStorePlanStages() bool
- func (x *OfflineQueryRequest) GetTags() []string
- func (*OfflineQueryRequest) ProtoMessage()
- func (x *OfflineQueryRequest) ProtoReflect() protoreflect.Message
- func (x *OfflineQueryRequest) Reset()
- func (x *OfflineQueryRequest) String() string
- type OnlineQueryContext
- func (*OnlineQueryContext) Descriptor() ([]byte, []int)deprecated
- func (x *OnlineQueryContext) GetBranchId() string
- func (x *OnlineQueryContext) GetCorrelationId() string
- func (x *OnlineQueryContext) GetDeploymentId() string
- func (x *OnlineQueryContext) GetEnvironment() string
- func (x *OnlineQueryContext) GetOptions() map[string]*structpb.Value
- func (x *OnlineQueryContext) GetQueryName() string
- func (x *OnlineQueryContext) GetQueryNameVersion() string
- func (x *OnlineQueryContext) GetRequiredResolverTags() []string
- func (x *OnlineQueryContext) GetTags() []string
- func (*OnlineQueryContext) ProtoMessage()
- func (x *OnlineQueryContext) ProtoReflect() protoreflect.Message
- func (x *OnlineQueryContext) Reset()
- func (x *OnlineQueryContext) String() string
- type OnlineQueryFeatherRequest
- func (*OnlineQueryFeatherRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OnlineQueryFeatherRequest) GetBodyType() FeatherBodyType
- func (x *OnlineQueryFeatherRequest) GetContext() *OnlineQueryContext
- func (x *OnlineQueryFeatherRequest) GetInputsFeather() []byte
- func (x *OnlineQueryFeatherRequest) GetNow() []*timestamppb.Timestamp
- func (x *OnlineQueryFeatherRequest) GetOutputs() []*OutputExpr
- func (x *OnlineQueryFeatherRequest) GetResponseOptions() *OnlineQueryResponseOptions
- func (x *OnlineQueryFeatherRequest) GetStaleness() map[string]string
- func (*OnlineQueryFeatherRequest) ProtoMessage()
- func (x *OnlineQueryFeatherRequest) ProtoReflect() protoreflect.Message
- func (x *OnlineQueryFeatherRequest) Reset()
- func (x *OnlineQueryFeatherRequest) String() string
- type OnlineQueryFeatherResponse
- func (*OnlineQueryFeatherResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OnlineQueryFeatherResponse) GetErrors() []*ChalkError
- func (x *OnlineQueryFeatherResponse) GetGroupsData() map[string][]byte
- func (x *OnlineQueryFeatherResponse) GetResponseMeta() *OnlineQueryMetadata
- func (x *OnlineQueryFeatherResponse) GetScalarsData() []byte
- func (*OnlineQueryFeatherResponse) ProtoMessage()
- func (x *OnlineQueryFeatherResponse) ProtoReflect() protoreflect.Message
- func (x *OnlineQueryFeatherResponse) Reset()
- func (x *OnlineQueryFeatherResponse) String() string
- type OnlineQueryMetadata
- func (*OnlineQueryMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *OnlineQueryMetadata) GetDeploymentId() string
- func (x *OnlineQueryMetadata) GetEnvironmentId() string
- func (x *OnlineQueryMetadata) GetEnvironmentName() string
- func (x *OnlineQueryMetadata) GetExecutionDuration() *durationpb.Duration
- func (x *OnlineQueryMetadata) GetExplainOutput() *QueryExplainInfo
- func (x *OnlineQueryMetadata) GetMetadata() map[string]string
- func (x *OnlineQueryMetadata) GetQueryHash() string
- func (x *OnlineQueryMetadata) GetQueryId() string
- func (x *OnlineQueryMetadata) GetQueryTimestamp() *timestamppb.Timestamp
- func (*OnlineQueryMetadata) ProtoMessage()
- func (x *OnlineQueryMetadata) ProtoReflect() protoreflect.Message
- func (x *OnlineQueryMetadata) Reset()
- func (x *OnlineQueryMetadata) String() string
- type OnlineQueryRequest
- func (*OnlineQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OnlineQueryRequest) GetContext() *OnlineQueryContext
- func (x *OnlineQueryRequest) GetInputs() map[string]*structpb.Value
- func (x *OnlineQueryRequest) GetNow() *timestamppb.Timestamp
- func (x *OnlineQueryRequest) GetOutputs() []*OutputExpr
- func (x *OnlineQueryRequest) GetResponseOptions() *OnlineQueryResponseOptions
- func (x *OnlineQueryRequest) GetStaleness() map[string]string
- func (*OnlineQueryRequest) ProtoMessage()
- func (x *OnlineQueryRequest) ProtoReflect() protoreflect.Message
- func (x *OnlineQueryRequest) Reset()
- func (x *OnlineQueryRequest) String() string
- type OnlineQueryResponse
- func (*OnlineQueryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OnlineQueryResponse) GetData() *OnlineQueryResult
- func (x *OnlineQueryResponse) GetErrors() []*ChalkError
- func (x *OnlineQueryResponse) GetResponseMeta() *OnlineQueryMetadata
- func (*OnlineQueryResponse) ProtoMessage()
- func (x *OnlineQueryResponse) ProtoReflect() protoreflect.Message
- func (x *OnlineQueryResponse) Reset()
- func (x *OnlineQueryResponse) String() string
- type OnlineQueryResponseOptions
- func (*OnlineQueryResponseOptions) Descriptor() ([]byte, []int)deprecated
- func (x *OnlineQueryResponseOptions) GetEncodingOptions() *FeatureEncodingOptions
- func (x *OnlineQueryResponseOptions) GetExplain() *ExplainOptions
- func (x *OnlineQueryResponseOptions) GetIncludeMeta() bool
- func (x *OnlineQueryResponseOptions) GetMetadata() map[string]string
- func (*OnlineQueryResponseOptions) ProtoMessage()
- func (x *OnlineQueryResponseOptions) ProtoReflect() protoreflect.Message
- func (x *OnlineQueryResponseOptions) Reset()
- func (x *OnlineQueryResponseOptions) String() string
- type OnlineQueryResult
- func (*OnlineQueryResult) Descriptor() ([]byte, []int)deprecated
- func (x *OnlineQueryResult) GetResults() []*FeatureResult
- func (*OnlineQueryResult) ProtoMessage()
- func (x *OnlineQueryResult) ProtoReflect() protoreflect.Message
- func (x *OnlineQueryResult) Reset()
- func (x *OnlineQueryResult) String() string
- type OutputExpr
- func (*OutputExpr) Descriptor() ([]byte, []int)deprecated
- func (m *OutputExpr) GetExpr() isOutputExpr_Expr
- func (x *OutputExpr) GetFeatureFqn() string
- func (*OutputExpr) ProtoMessage()
- func (x *OutputExpr) ProtoReflect() protoreflect.Message
- func (x *OutputExpr) Reset()
- func (x *OutputExpr) String() string
- type OutputExpr_FeatureFqn
- type QueryExplainInfo
- type QueryStatus
- func (QueryStatus) Descriptor() protoreflect.EnumDescriptor
- func (x QueryStatus) Enum() *QueryStatus
- func (QueryStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x QueryStatus) Number() protoreflect.EnumNumber
- func (x QueryStatus) String() string
- func (QueryStatus) Type() protoreflect.EnumType
Constants ¶
This section is empty.
Variables ¶
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.
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.
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_QUERY_STATUS_CANCELLED", 7: "QUERY_STATUS_SUCCESSFUL", } 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_QUERY_STATUS_CANCELLED": 6, "QUERY_STATUS_SUCCESSFUL": 7, } )
Enum value maps for QueryStatus.
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.
var File_chalk_common_v1_chalk_error_proto protoreflect.FileDescriptor
var File_chalk_common_v1_dataset_response_proto protoreflect.FileDescriptor
var File_chalk_common_v1_offline_query_proto protoreflect.FileDescriptor
var File_chalk_common_v1_online_query_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 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) EnumDescriptor
deprecated
func (ErrorCode) Number ¶
func (x ErrorCode) Number() protoreflect.EnumNumber
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"` Value *structpb.Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` Error *string `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() string
func (*FeatureResult) GetField ¶
func (x *FeatureResult) GetField() string
func (*FeatureResult) GetMeta ¶
func (x *FeatureResult) GetMeta() *FeatureMeta
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 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 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 }
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"` Explain *OfflineQueryExplain `protobuf:"bytes,103,opt,name=explain,proto3" json:"explain,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 ¶
func (x *OfflineQueryRequest) GetExplain() *OfflineQueryExplain
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 OnlineQueryContext ¶
type OnlineQueryContext struct { Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"` 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"` DeploymentId *string `protobuf:"bytes,4,opt,name=deployment_id,json=deploymentId,proto3,oneof" json:"deployment_id,omitempty"` BranchId *string `protobuf:"bytes,5,opt,name=branch_id,json=branchId,proto3,oneof" json:"branch_id,omitempty"` 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 */ // 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 ¶
func (x *OnlineQueryContext) GetBranchId() string
func (*OnlineQueryContext) GetCorrelationId ¶
func (x *OnlineQueryContext) GetCorrelationId() string
func (*OnlineQueryContext) GetDeploymentId ¶
func (x *OnlineQueryContext) GetDeploymentId() string
func (*OnlineQueryContext) GetEnvironment ¶
func (x *OnlineQueryContext) GetEnvironment() string
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) 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 OnlineQueryFeatherRequest ¶
type OnlineQueryFeatherRequest 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 (*OnlineQueryFeatherRequest) Descriptor
deprecated
func (*OnlineQueryFeatherRequest) Descriptor() ([]byte, []int)
Deprecated: Use OnlineQueryFeatherRequest.ProtoReflect.Descriptor instead.
func (*OnlineQueryFeatherRequest) GetBodyType ¶ added in v0.4.7
func (x *OnlineQueryFeatherRequest) GetBodyType() FeatherBodyType
func (*OnlineQueryFeatherRequest) GetContext ¶
func (x *OnlineQueryFeatherRequest) GetContext() *OnlineQueryContext
func (*OnlineQueryFeatherRequest) GetInputsFeather ¶
func (x *OnlineQueryFeatherRequest) GetInputsFeather() []byte
func (*OnlineQueryFeatherRequest) GetNow ¶
func (x *OnlineQueryFeatherRequest) GetNow() []*timestamppb.Timestamp
func (*OnlineQueryFeatherRequest) GetOutputs ¶
func (x *OnlineQueryFeatherRequest) GetOutputs() []*OutputExpr
func (*OnlineQueryFeatherRequest) GetResponseOptions ¶
func (x *OnlineQueryFeatherRequest) GetResponseOptions() *OnlineQueryResponseOptions
func (*OnlineQueryFeatherRequest) GetStaleness ¶
func (x *OnlineQueryFeatherRequest) GetStaleness() map[string]string
func (*OnlineQueryFeatherRequest) ProtoMessage ¶
func (*OnlineQueryFeatherRequest) ProtoMessage()
func (*OnlineQueryFeatherRequest) ProtoReflect ¶
func (x *OnlineQueryFeatherRequest) ProtoReflect() protoreflect.Message
func (*OnlineQueryFeatherRequest) Reset ¶
func (x *OnlineQueryFeatherRequest) Reset()
func (*OnlineQueryFeatherRequest) String ¶
func (x *OnlineQueryFeatherRequest) String() string
type OnlineQueryFeatherResponse ¶
type OnlineQueryFeatherResponse 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 (*OnlineQueryFeatherResponse) Descriptor
deprecated
func (*OnlineQueryFeatherResponse) Descriptor() ([]byte, []int)
Deprecated: Use OnlineQueryFeatherResponse.ProtoReflect.Descriptor instead.
func (*OnlineQueryFeatherResponse) GetErrors ¶
func (x *OnlineQueryFeatherResponse) GetErrors() []*ChalkError
func (*OnlineQueryFeatherResponse) GetGroupsData ¶ added in v0.4.7
func (x *OnlineQueryFeatherResponse) GetGroupsData() map[string][]byte
func (*OnlineQueryFeatherResponse) GetResponseMeta ¶
func (x *OnlineQueryFeatherResponse) GetResponseMeta() *OnlineQueryMetadata
func (*OnlineQueryFeatherResponse) GetScalarsData ¶ added in v0.4.7
func (x *OnlineQueryFeatherResponse) GetScalarsData() []byte
func (*OnlineQueryFeatherResponse) ProtoMessage ¶
func (*OnlineQueryFeatherResponse) ProtoMessage()
func (*OnlineQueryFeatherResponse) ProtoReflect ¶
func (x *OnlineQueryFeatherResponse) ProtoReflect() protoreflect.Message
func (*OnlineQueryFeatherResponse) Reset ¶
func (x *OnlineQueryFeatherResponse) Reset()
func (*OnlineQueryFeatherResponse) String ¶
func (x *OnlineQueryFeatherResponse) 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 */ // contains filtered or unexported fields }
func (*OnlineQueryMetadata) Descriptor
deprecated
func (*OnlineQueryMetadata) Descriptor() ([]byte, []int)
Deprecated: Use OnlineQueryMetadata.ProtoReflect.Descriptor instead.
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 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 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 }
Represenst 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" 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 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_QUERY_STATUS_CANCELLED QueryStatus = 6 // Cannot be named CANCELLED due to conflict with ChalkError // Successfully ran the job. QueryStatus_QUERY_STATUS_SUCCESSFUL QueryStatus = 7 )
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