commonv1

package
v0.4.12 Latest Latest
Warning

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

Go to latest
Published: Apr 18, 2024 License: Apache-2.0 Imports: 8 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 (
	FeatherBodyType_name = map[int32]string{
		0: "FEATHER_BODY_TYPE_UNSPECIFIED",
		1: "FEATHER_BODY_TYPE_TABLE",
		2: "FEATHER_BODY_TYPE_RECORD_BATCHES",
	}
	FeatherBodyType_value = map[string]int32{
		"FEATHER_BODY_TYPE_UNSPECIFIED":    0,
		"FEATHER_BODY_TYPE_TABLE":          1,
		"FEATHER_BODY_TYPE_RECORD_BATCHES": 2,
	}
)

Enum value maps for FeatherBodyType.

View Source
var 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 (*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 (*ColumnMetadataList_ColumnMetadata) GetFeatureFqn

func (x *ColumnMetadataList_ColumnMetadata) GetFeatureFqn() string

func (*ColumnMetadataList_ColumnMetadata) ProtoMessage

func (*ColumnMetadataList_ColumnMetadata) ProtoMessage()

func (*ColumnMetadataList_ColumnMetadata) ProtoReflect

func (*ColumnMetadataList_ColumnMetadata) Reset

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

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) Enum

func (ErrorCodeCategory) EnumDescriptor deprecated

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

Deprecated: Use ErrorCodeCategory.Descriptor instead.

func (ErrorCodeCategory) Number

func (ErrorCodeCategory) String

func (x ErrorCodeCategory) String() string

func (ErrorCodeCategory) Type

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) 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 (FeatherBodyType) String added in v0.4.7

func (x FeatherBodyType) String() string

func (FeatherBodyType) Type added in v0.4.7

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 (*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 (*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 (*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 (*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 (*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 (*OfflineQueryRecomputeFeatures) GetImpl

func (m *OfflineQueryRecomputeFeatures) GetImpl() isOfflineQueryRecomputeFeatures_Impl

func (*OfflineQueryRecomputeFeatures) ProtoMessage

func (*OfflineQueryRecomputeFeatures) ProtoMessage()

func (*OfflineQueryRecomputeFeatures) ProtoReflect

func (*OfflineQueryRecomputeFeatures) Reset

func (x *OfflineQueryRecomputeFeatures) Reset()

func (*OfflineQueryRecomputeFeatures) 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) ProtoReflect

func (*OfflineQueryRecomputeFeatures_FeatureList) Reset

func (*OfflineQueryRecomputeFeatures_FeatureList) 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 (*OnlineQueryFeatherRequest) GetInputsFeather

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

func (*OnlineQueryFeatherRequest) GetNow

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 (*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 (*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 (*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 (*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) 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL