commonv1

package
v0.4.7-alpha Latest Latest
Warning

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

 Go to latest Published: Mar 27, 2024 License: Apache-2.0 Imports: 7 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 (
	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.

View Source 
var File_chalk_common_v1_chalk_error_proto protoreflect.FileDescriptor
View Source 
var File_chalk_common_v1_dataset_response_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

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) 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 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"`
	// 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) 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,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 (*OnlineQueryFeatherRequest) Descriptor deprecated 

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

Deprecated: Use OnlineQueryFeatherRequest.ProtoReflect.Descriptor instead.

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

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.