chalk

Dec 20, 2024

Changes in this version

+ type BoolValue bool

+ func (v BoolValue) ToProto() (*structpb.Value, error)

+ type FloatValue float64

+ func (v FloatValue) ToProto() (*structpb.Value, error)

type OfflineQueryParams

+ QueryContext *QueryContext

type OnlineQueryParams

+ QueryContext *QueryContext

+ type QueryContext map[string]QueryContextValue

+ func NewQueryContext(m map[string]any) (*QueryContext, error)

+ func (qc *QueryContext) ToMap() *map[string]any

+ type QueryContextValue interface

+ ToProto func() (*structpb.Value, error)

+ type StringValue string

+ func (v StringValue) ToProto() (*structpb.Value, error)

Dec 14, 2024

Changes in this version

+ type ChunkResult struct

Sep 30, 2024

Changes in this version

type OnlineQueryParams

+ func (p OnlineQueryParams) WithTags(feature ...string) OnlineQueryParams

type OnlineQueryParamsComplete

+ func (p OnlineQueryParamsComplete) WithTags(tags ...string) OnlineQueryParamsComplete

Sep 23, 2024

Changes in this version

type OfflineQueryParams

+ func (p OfflineQueryParams) WithInputs(inputs map[any][]any) offlineQueryParamsWithInputs

type OnlineQueryParams

+ func (p OnlineQueryParams) WithInputs(inputs map[any]any) onlineQueryParamsWithInputs

type OnlineQueryParamsComplete

+ func (p OnlineQueryParamsComplete) WithInputs(inputs map[any]any) OnlineQueryParamsComplete

Sep 20, 2024

Changes in this version

+ type FeatureEncodingOptions struct

+ EncodeStructsAsObjects bool

type OnlineQueryParams

+ EncodingOptions *FeatureEncodingOptions

Sep 4, 2024

Changes in this version

+ func ConvertTableToRows(table arrow.Table) ([]map[string]any, error)

Aug 21, 2024

Changes in this version

+ func UnmarshalOnlineQueryBulkResponse(response *commonv1.OnlineQueryBulkResponse, resultHolders any) error

+ func UnmarshalOnlineQueryResponse(response *commonv1.OnlineQueryResponse, resultHolder any) error

+ type GRPCClient interface

+ GetAggregates func(ctx context.Context, features []string) (*aggregatev1.GetAggregatesResponse, error)

+ GetToken func() (*TokenResult, error)

+ OnlineQuery func(ctx context.Context, params OnlineQueryParamsComplete) (*commonv1.OnlineQueryResponse, error)

+ OnlineQueryBulk func(ctx context.Context, params OnlineQueryParamsComplete) (*commonv1.OnlineQueryBulkResponse, error)

+ PlanAggregateBackfill func(ctx context.Context, req *aggregatev1.PlanAggregateBackfillRequest) (*aggregatev1.PlanAggregateBackfillResponse, error)

+ UpdateAggregates func(ctx context.Context, params UpdateAggregatesParams) (*commonv1.UploadFeaturesBulkResponse, error)

+ func NewGRPCClient(configs ...*GRPCClientConfig) (GRPCClient, error)

+ type GRPCClientConfig struct

+ ApiServer string

+ Branch string

+ ClientId string

+ ClientSecret string

+ DeploymentTag string

+ EnvironmentId string

+ HTTPClient HTTPClient

+ Logger LeveledLogger

+ QueryServer string

Aug 15, 2024

Changes in this version

type ClientConfig

+ DeploymentTag string

Aug 9, 2024

Changes in this version

type Client

+ PlanAggregateBackfill func(ctx context.Context, req *aggregatev1.PlanAggregateBackfillRequest) (*aggregatev1.PlanAggregateBackfillResponse, error)

Aug 9, 2024

Changes in this version

type Client

+ GetAggregates func(ctx context.Context, features []string) (*aggregatev1.GetAggregatesResponse, error)

Aug 8, 2024

Changes in this version

type OnlineQueryParams

+ Explain bool

+ Now []time.Time

+ RequiredResolverTags []string

+ StorePlanStages bool

Aug 5, 2024

Changes in this version

type OfflineQueryParams

+ Tags []string

Aug 2, 2024

Changes in this version

type Client

+ UpdateAggregates func(args UpdateAggregatesParams) (UpdateAggregatesResult, error)

type OnlineQueryParams

+ QueryNameVersion string

+ func (p OnlineQueryParams) WithQueryName(queryName string) OnlineQueryParams

+ func (p OnlineQueryParams) WithQueryNameVersion(version string) OnlineQueryParams

type OnlineQueryParamsComplete

+ func (p OnlineQueryParamsComplete) WithQueryName(queryName string) OnlineQueryParamsComplete

+ func (p OnlineQueryParamsComplete) WithQueryNameVersion(queryNameVersion string) OnlineQueryParamsComplete

+ type UpdateAggregatesParams struct

+ Context context.Context

+ Inputs map[any]any

+ type UpdateAggregatesResult struct

+ TraceId string

Jul 31, 2024

Changes in this version

type Client

+ GetToken func() (*TokenResult, error)

+ type TokenResult struct

+ AccessToken string

+ Engines map[string]string

+ PrimaryEnvironment string

+ ValidUntil time.Time

Jul 22, 2024

Changes in this version

+ func NewFeatureInitializer() *featureInitializer

Jul 17, 2024

Changes in this version

type ClientConfig

+ UseGrpc bool

Jun 20, 2024

Changes in this version

type ClientConfig

+ QueryServer string

Jun 7, 2024

Changes in this version

+ func SnakeCase(s string) string

May 13, 2024

Changes in this version

type ClientError

+ func UnmarshalTableInto(table arrow.Table, resultHolders any) *ClientError

type OnlineQueryBulkResult

+ func (r *OnlineQueryBulkResult) UnmarshalInto(resultHolders any) *ClientError

May 7, 2024

Changes in this version

+ type SerializationOptions struct

+ ClientConfigBranchId string

Apr 15, 2024

Changes in this version

type OnlineQueryParams

+ BranchId *string

+ func (p OnlineQueryParams) WithBranchId(branchId string) OnlineQueryParams

type OnlineQueryParamsComplete

+ func (p OnlineQueryParamsComplete) WithBranchId(branchId string) OnlineQueryParamsComplete

Mar 7, 2024

Changes in this version

type OnlineQueryParamsComplete

+ func (p OnlineQueryParamsComplete) ToBytes() ([]byte, error)

Dec 5, 2023

Changes in this version

type Client

+ UploadFeatures func(args UploadFeaturesParams) (UploadFeaturesResult, error)

+ type UploadFeaturesParams struct

+ EnvironmentOverride string

+ Inputs map[any]any

+ PreviewDeploymentId string

+ type UploadFeaturesResult struct

+ OperationId string

Sep 21, 2023

Changes in this version

+ type HTTPClient interface

+ Do func(req *http.Request) (*http.Response, error)

+ Get func(url string) (resp *http.Response, err error)

Sep 14, 2023

Changes in this version

type OnlineQueryBulkResult

+ GroupsTables map[string]arrow.Table

+ ScalarsTable arrow.Table

+ func (r OnlineQueryBulkResult) Release()

Aug 29, 2023

Changes in this version

type BuilderErrorType

+ const InvalidRequest

type Client

+ OnlineQueryBulk func(args OnlineQueryParamsComplete) (OnlineQueryBulkResult, *ErrorResponse)

type ClientError

+ func UnmarshalInto(resultHolder any, fqnToValueMap map[Fqn]any, expectedOutputs []string) (returnErr *ClientError)

+ type Fqn = string

+ type OnlineQueryBulkResponse struct

+ QueryResults map[QueryName]onlineQueryResultFeather

+ func (r *OnlineQueryBulkResponse) Unmarshal(body []byte) error

+ type OnlineQueryBulkResult struct

+ GroupsDF map[string]*arrow.Record

+ Meta *QueryMeta

+ ScalarsDF *arrow.Record

type QueryMeta

+ ExecutionDurationS float64

+ type QueryName = string

Apr 11, 2023

Changes in this version

type ClientConfig

+ Branch string

Mar 27, 2023

Changes in this version

type BuilderError

+ Feature any

+ Value any

type BuilderErrorType

+ const InvalidFeatureType

+ const UnwrapFeatureError

Mar 25, 2023

Changes in this version

+ type BuilderError struct

+ Err error

+ FeatureArg any

+ ParamType ParamType

+ Type BuilderErrorType

+ func (e *BuilderError) Error() string

+ type BuilderErrorType int

+ const BuilderErrorInvalidFeature

+ const BuilderErrorUnknown

+ type BuilderErrors []*BuilderError

+ func (e BuilderErrors) Error() string

+ type ParamType string

+ const ParamInput

+ const ParamOutput

+ const ParamRequiredOutput

+ const ParamStaleness

+ const ParamTypeUnknown

Mar 24, 2023

Changes in this version

+ var Cancelled = ErrorCode

+ var DeadlineExceeded = ErrorCode

+ var Field = ErrorCodeCategory

+ var FieldNotFoundError = errors.New("field not found")

+ var InternalServerError = ErrorCode

+ var InvalidQuery = ErrorCode

+ var Network = ErrorCodeCategory

+ var ParseFailed = ErrorCode

+ var Request = ErrorCodeCategory

+ var ResolverFailed = ErrorCode

+ var ResolverNotFound = ErrorCode

+ var ResolverTimedOut = ErrorCode

+ var Unauthenticated = ErrorCode

+ var Unauthorized = ErrorCode

+ var UpstreamFailed = ErrorCode

+ var ValidationFailed = ErrorCode

+ func DesuffixFqn(fqn string) string

+ func InitFeatures(t *T)

+ type Client interface

+ GetRunStatus func(args GetRunStatusParams) (GetRunStatusResult, *ErrorResponse)

+ OfflineQuery func(args OfflineQueryParamsComplete) (Dataset, *ErrorResponse)

+ OnlineQuery func(args OnlineQueryParamsComplete, resultHolder any) (OnlineQueryResult, *ErrorResponse)

+ TriggerResolverRun func(args TriggerResolverRunParams) (TriggerResolverRunResult, *ErrorResponse)

+ func NewClient(config ...*ClientConfig) (Client, error)

+ type ClientConfig struct

+ ApiServer string

+ ClientId string

+ ClientSecret string

+ EnvironmentId string

+ HTTPClient *http.Client

+ Logger *LeveledLogger

+ type ClientError struct

+ Message string

+ func (e *ClientError) Error() string

+ type ColumnMetadata struct

+ ColumnName string

+ Dtype string

+ FeatureFqn string

+ type Dataset struct

+ DatasetId *string

+ DatasetName *string

+ Errors []ServerError

+ IsFinished bool

+ Revisions []DatasetRevision

+ Version int

+ type DatasetFilter struct

+ MaxCacheAge *float64

+ SampleFilters DatasetSampleFilter

+ type DatasetRevision struct

+ CreatedAt *time.Time

+ CreatorId string

+ DatasetId *string

+ DatasetName *string

+ Filters DatasetFilter

+ GivensUri *string

+ NumBytes *int

+ NumPartitions int

+ OutputUris string

+ OutputVersion int

+ Outputs []string

+ RevisionId string

+ StartedAt *string

+ Status QueryStatus

+ TerminatedAt *time.Time

+ func (d *DatasetRevision) DownloadData(path string) *ErrorResponse

+ type DatasetSampleFilter struct

+ LowerBound *time.Time

+ MaxSamples *int

+ UpperBound *time.Time

+ type ErrorCode struct

+ Value string

+ func (e *ErrorCode) UnmarshalJSON(data []byte) error

+ type ErrorCodeCategory struct

+ Value string

+ func (c *ErrorCodeCategory) UnmarshalJSON(data []byte) error

+ type ErrorResponse struct

+ ClientError *ClientError

+ HttpError *HTTPError

+ ServerErrors []ServerError

+ func (e *ErrorResponse) Error() string

+ type Feature struct

+ Fqn string

+ func UnwrapFeature(t any) *Feature

+ type FeatureResolutionMeta struct

+ CacheHit bool

+ ChosenResolverFqn string

+ PrimitiveType string

+ Version int

+ type FeatureResult struct

+ Error *ServerError

+ Field string

+ Meta *FeatureResolutionMeta

+ Pkey any

+ Timestamp time.Time

+ Value any

+ type GetOfflineQueryJobResponse struct

+ Columns []ColumnMetadata

+ Errors []ServerError

+ IsFinished bool

+ Urls []string

+ Version int

+ type GetRunStatusParams struct

+ PreviewDeploymentId string

+ RunId string

+ type GetRunStatusResult struct

+ Id string

+ Status string

+ type HTTPError struct

+ ContentLength int64

+ Message string

+ Path string

+ StatusCode int

+ Trace *string

+ func (e *HTTPError) Error() string

+ type Level uint32

+ const LevelDebug

+ const LevelError

+ const LevelInfo

+ const LevelNull

+ const LevelWarn

+ type LeveledLogger interface

+ Debugf func(format string, v ...interface{})

+ Errorf func(format string, v ...interface{})

+ Infof func(format string, v ...interface{})

+ Warnf func(format string, v ...interface{})

+ var DefaultLeveledLogger LeveledLogger = &StdOutLeveledLogger{ ... }

+ type Numbers interface

+ type OfflineQueryParams struct

+ Branch string

+ DatasetName string

+ DefaultTime *time.Time

+ EnvironmentId string

+ MaxSamples *int

+ func (p OfflineQueryParams) MarshalJSON() ([]byte, error)

+ func (p OfflineQueryParams) WithInput(feature any, values []any) offlineQueryParamsWithInputs

+ func (p OfflineQueryParams) WithOutputs(features ...any) OfflineQueryParamsComplete

+ func (p OfflineQueryParams) WithRequiredOutputs(features ...any) OfflineQueryParamsComplete

+ type OfflineQueryParamsComplete struct

+ func (p OfflineQueryParamsComplete) WithInput(feature any, values []any) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithOutputs(features ...any) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithRequiredOutputs(features ...any) OfflineQueryParamsComplete

+ type OnlineQueryParams struct

+ CorrelationId string

+ EnvironmentId string

+ IncludeMeta bool

+ IncludeMetrics bool

+ Meta map[string]string

+ PreviewDeploymentId string

+ QueryName string

+ Tags []string

+ func (p OnlineQueryParams) WithInput(feature any, value any) onlineQueryParamsWithInputs

+ func (p OnlineQueryParams) WithOutputs(features ...any) onlineQueryParamsWithOutputs

+ func (p OnlineQueryParams) WithStaleness(feature any, duration time.Duration) OnlineQueryParams

+ type OnlineQueryParamsComplete struct

+ func (p OnlineQueryParamsComplete) WithInput(feature any, value any) OnlineQueryParamsComplete

+ func (p OnlineQueryParamsComplete) WithOutputs(features ...any) OnlineQueryParamsComplete

+ func (p OnlineQueryParamsComplete) WithStaleness(feature any, duration time.Duration) OnlineQueryParamsComplete

+ type OnlineQueryResult struct

+ Data []FeatureResult

+ Meta *QueryMeta

+ func (result *OnlineQueryResult) GetFeature(feature any) *FeatureResult

+ func (result *OnlineQueryResult) GetFeatureValue(feature any) any

+ func (result *OnlineQueryResult) UnmarshalInto(resultHolder any) *ClientError

+ type QueryMeta struct

+ DeploymentId string

+ EnvironmentId string

+ EnvironmentName string

+ QueryHash string

+ QueryId string

+ QueryTimestamp *time.Time

+ type QueryStatus int

+ const QueryStatusCancelled

+ const QueryStatusError

+ const QueryStatusExpired

+ const QueryStatusPendingSubmission

+ const QueryStatusRunning

+ const QueryStatusSubmitted

+ const QueryStatusSuccessful

+ type ResolverException struct

+ Kind string

+ Message string

+ Stacktrace string

+ type ServerError struct

+ Category ErrorCodeCategory

+ Code ErrorCode

+ Exception *ResolverException

+ Feature string

+ Message string

+ Resolver string

+ func (e *ServerError) Error() string

+ type StdOutLeveledLogger struct

+ Level Level

+ func (l *StdOutLeveledLogger) Debugf(format string, v ...interface{})

+ func (l *StdOutLeveledLogger) Errorf(format string, v ...interface{})

+ func (l *StdOutLeveledLogger) Infof(format string, v ...interface{})

+ func (l *StdOutLeveledLogger) Warnf(format string, v ...interface{})

+ type TriggerResolverRunParams struct

+ EnvironmentId string

+ PreviewDeploymentId string

+ ResolverFqn string

+ type TriggerResolverRunResult struct

+ Id string

+ Status string

+ type TsFeatureValue struct

+ ObservationTime *time.Time

+ Value any