chalk

Jun 20, 2026

Changes in this version

type OfflineQueryParams

+ UseMetaplanner *bool

type OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithUseMetaplanner(useMetaplanner bool) OfflineQueryParamsComplete

Jun 16, 2026

Changes in this version

+ func VolumeRefSelector(ref string) *volumev2.VersionSelector

+ func VolumeVersionSelector(versionID uint64) *volumev2.VersionSelector

+ type ListVolumeFilesParams struct

+ Cursor string

+ Limit int32

+ Path string

+ Recursive bool

+ Selector *volumev2.VersionSelector

+ Volume VolumeRef

+ type VolumeClient interface

+ CreateVolume func(ctx context.Context, name string) (*volumev2.CreateVolumeResponse, error)

+ DeleteVolume func(ctx context.Context, volume VolumeRef) error

+ DownloadBytes func(ctx context.Context, request VolumeDownloadRequest, onProgress func(uint64)) ([]byte, *volumev2.FileInfo, error)

+ DownloadToDirectory func(ctx context.Context, volumeName string, localDir string, ...) error

+ DownloadToFile func(ctx context.Context, request VolumeDownloadRequest, localPath string, ...) (*volumev2.FileInfo, error)

+ GetFile func(ctx context.Context, volume VolumeRef, path string, ...) (*volumev2.GetFileResponse, error)

+ GetVolume func(ctx context.Context, volume VolumeRef, selector *volumev2.VersionSelector) (*volumev2.GetVolumeResponse, error)

+ ListFiles func(ctx context.Context, params ListVolumeFilesParams) (*volumev2.ListFilesResponse, error)

+ ListVolumeVersions func(ctx context.Context, volume VolumeRef, limit int32, cursor string) (*volumev2.ListVolumeVersionsResponse, error)

+ ListVolumes func(ctx context.Context, limit int32, cursor string) (*volumev2.ListVolumesResponse, error)

+ RemoveFiles func(ctx context.Context, volumeName string, paths []VolumeRemovePath, ...) (*volumev2.CommitStatus, error)

+ UploadDirectory func(ctx context.Context, volumeName string, dir string, config VolumeUploadConfig) ([]*volumev2.CommitStatus, error)

+ UploadFiles func(ctx context.Context, request VolumeUploadRequest, onProgress func(uint64)) ([]*volumev2.CommitStatus, error)

+ func NewVolumeClient(ctx context.Context, configs ...*VolumeClientConfig) (VolumeClient, error)

+ type VolumeClientConfig struct

+ ApiServer string

+ ClientId string

+ ClientSecret string

+ CommitAuthor string

+ ConfigDir *string

+ EnvironmentId string

+ HTTPClient connect.HTTPClient

+ Interceptors []connect.Interceptor

+ JWT *serverv1.GetTokenResponse

+ SkipEngineMapping bool

+ SkipEnvironmentNameMapping bool

+ Timeout time.Duration

+ type VolumeDownloadConfig struct

+ ChunkConcurrency int

+ MaxChunkRetries int

+ func DefaultVolumeDownloadConfig() VolumeDownloadConfig

+ type VolumeDownloadRequest struct

+ Config VolumeDownloadConfig

+ Path string

+ Selector *volumev2.VersionSelector

+ VolumeName string

+ type VolumeRef struct

+ ID string

+ Name string

+ type VolumeRemovePath struct

+ Path string

+ Recursive bool

+ type VolumeUploadConfig struct

+ BatchSize int

+ ChunkConcurrency int

+ ChunkSize uint64

+ FileConcurrency int

+ MaxChunkRetries int

+ MaxCommitRetries int

+ MaxPackBytes uint64

+ MaxRateLimitRetries int

+ func DefaultVolumeUploadConfig() VolumeUploadConfig

+ type VolumeUploadContent struct

+ func VolumeUploadBytes(data []byte) VolumeUploadContent

+ func VolumeUploadLocalPath(path string) VolumeUploadContent

+ type VolumeUploadFile struct

+ Content VolumeUploadContent

+ Metadata *volumev2.FileMetadata

+ Path string

+ type VolumeUploadRequest struct

+ Config VolumeUploadConfig

+ Files []VolumeUploadFile

+ VolumeName string

May 21, 2026

Changes in this version

type OnlineQueryParams

+ TranslateFqns bool

type OnlineQueryParamsComplete

+ func (p OnlineQueryParamsComplete) WithTranslateFqns(translate bool) OnlineQueryParamsComplete

May 15, 2026

Changes in this version

+ type BuildImageOption func(*buildImageOptions)

+ func WithImageBuildPollInterval(interval time.Duration) BuildImageOption

+ func WithImageBuildTimeout(timeout time.Duration) BuildImageOption

+ func WithImageTag(tag string) BuildImageOption

+ func WithImageTargetRegistry(registry string) BuildImageOption

type Client

+ BuildImage func(ctx context.Context, image Image, opts ...BuildImageOption) (ImageBuild, error)

+ GetContainer func(ctx context.Context, ref ContainerRef) (ContainerInfo, error)

+ GetImageBuild func(ctx context.Context, buildID string) (ImageBuild, error)

+ ListContainers func(ctx context.Context) ([]ContainerInfo, error)

+ RunContainer func(ctx context.Context, container Container, opts ...RunContainerOption) (ContainerInfo, error)

+ StopContainer func(ctx context.Context, ref ContainerRef, opts ...StopContainerOption) (ContainerInfo, error)

+ SubmitImageBuild func(ctx context.Context, image Image, opts ...BuildImageOption) (ImageBuild, error)

+ type Container struct

+ func NewContainer(name string, image Image) Container

+ func NewContainerFromImageRef(name string, imageRef string) Container

+ func (c Container) ImageRef() string

+ func (c Container) Name() string

+ func (c Container) WithAuthentication(authentication ContainerAuthentication) Container

+ func (c Container) WithCPU(cpu string) Container

+ func (c Container) WithEntrypoint(args ...string) Container

+ func (c Container) WithEnv(key string, value string) Container

+ func (c Container) WithEnvVars(env map[string]string) Container

+ func (c Container) WithGPU(gpu string) Container

+ func (c Container) WithImage(image Image) Container

+ func (c Container) WithImageRef(imageRef string) Container

+ func (c Container) WithLifetime(lifetime time.Duration) Container

+ func (c Container) WithMemory(memory string) Container

+ func (c Container) WithName(name string) Container

+ func (c Container) WithPort(port int32) Container

+ func (c Container) WithProtocol(protocol ContainerProtocol) Container

+ func (c Container) WithResources(resources ResourceLimits) Container

+ func (c Container) WithRouting(routing ContainerRouting) Container

+ func (c Container) WithSSH(enabled bool) Container

+ func (c Container) WithTag(key string, value string) Container

+ func (c Container) WithTags(tags map[string]string) Container

+ func (c Container) WithVolume(volume VolumeMount) Container

+ type ContainerAuthentication string

+ const ContainerAuthenticationAuthenticated

+ const ContainerAuthenticationUnauthenticated

+ type ContainerInfo struct

+ CreatedAt *time.Time

+ HealthCheck *HealthCheck

+ ID string

+ Name string

+ PodName string

+ SSHHost string

+ SSHPort *int32

+ SSHPrivateKey string

+ SSHUsername string

+ Spec Container

+ Status string

+ StatusMessage string

+ StoppedAt *time.Time

+ WebURL string

+ type ContainerProtocol string

+ const ContainerProtocolGRPC

+ const ContainerProtocolHTTP

+ type ContainerRef struct

+ func ContainerID(id string) ContainerRef

+ func ContainerName(name string) ContainerRef

+ type ContainerRouting string

+ const ContainerRoutingPrivate

+ const ContainerRoutingPublic

+ type FileOption func(*addFileOptions)

+ func FileMode(mode uint32) FileOption

+ type HealthCheck struct

+ Error string

+ Healthy bool

+ StatusCode *int32

+ type Image struct

+ func BaseImage(image string) Image

+ func DebianSlimImage(version ...string) Image

+ func ImageFromDockerfile(path string) (Image, error)

+ func PythonSlimImage(version ...string) Image

+ func (i Image) AddFile(destination string, content []byte, options ...FileOption) Image

+ func (i Image) AddLocalDir(path string, destination string) (Image, error)

+ func (i Image) AddLocalFile(path string, destination string, options ...FileOption) (Image, error)

+ func (i Image) Base() string

+ func (i Image) Cmd(args ...string) Image

+ func (i Image) DockerfileCommands(commands ...string) Image

+ func (i Image) Entrypoint(args ...string) Image

+ func (i Image) Env(vars map[string]string) Image

+ func (i Image) EnvVar(key string, value string) Image

+ func (i Image) PipInstall(packages ...string) Image

+ func (i Image) PipInstallFromRequirements(path string) (Image, error)

+ func (i Image) RunCommands(commands ...string) Image

+ func (i Image) String() string

+ func (i Image) UvPipInstall(packages ...string) Image

+ func (i Image) UvPipInstallFromRequirements(path string) (Image, error)

+ func (i Image) Workdir(path string) Image

+ type ImageBuild struct

+ BuildID string

+ Error string

+ Image string

+ Status string

+ func (b ImageBuild) Failed() bool

+ func (b ImageBuild) Ready() bool

+ type ResourceLimits struct

+ CPU string

+ GPU string

+ Memory string

+ type RunContainerOption func(*runContainerOptions)

+ func WithRunContainerBuildOptions(options ...BuildImageOption) RunContainerOption

+ type StopContainerOption func(*stopContainerOptions)

+ func WithStopGracePeriod(gracePeriod time.Duration) StopContainerOption

+ func WithStopGracePeriodSeconds(seconds int32) StopContainerOption

+ type VolumeKind string

+ const VolumeKindChalkFS

+ const VolumeKindEmptyDir

+ const VolumeKindSharedMemory

+ type VolumeMount struct

+ func ChalkFSVolume(name string, mountPath string) VolumeMount

+ func EmptyDirVolume(name string, mountPath string, sizeLimit string) VolumeMount

+ func SharedMemoryVolume(name string, mountPath string, sizeLimit string) VolumeMount

+ func (v VolumeMount) Kind() VolumeKind

+ func (v VolumeMount) MountPath() string

+ func (v VolumeMount) Name() string

+ func (v VolumeMount) SizeLimit() string

May 13, 2026

Changes in this version

type Client

+ ListDatasets func(ctx context.Context, params ListDatasetsParams) (*GRPCListDatasetsResult, error)

type GRPCClient

+ ListDatasets func(ctx context.Context, params ListDatasetsParams) (*GRPCListDatasetsResult, error)

+ type GRPCListDatasetsResult struct

+ RawResponse *serverv1.ListDatasetsResponse

+ type ListDatasetsParams struct

+ Cursor string

+ Limit int32

+ Search string

Apr 10, 2026

Changes in this version

type Client

+ CancelOfflineQuery func(ctx context.Context, offlineQueryId string) error

Mar 10, 2026

Changes in this version

+ type TimeBound struct

+ Delta *float64

+ Time *time.Time

+ func (t *TimeBound) UnmarshalJSON(data []byte) error

+ func (t TimeBound) MarshalJSON() ([]byte, error)

Jan 30, 2026

Changes in this version

type GRPCClient

+ GetEngineServerInterceptor func() []connect.ClientOption

Dec 2, 2025

Changes in this version

type GRPCClientConfig

+ SkipEngineMapping bool

+ SkipEnvironmentNameMapping bool

Nov 13, 2025

Changes in this version

type GRPCOnlineQueryBulkResult

+ ResponseHeaders *http.Header

type OnlineQueryBulkResult

+ ResponseHeaders *http.Header

type OnlineQueryResult

+ ResponseHeaders *http.Header

Nov 5, 2025

Changes in this version

+ type ServerErrors []ServerError

+ func (e ServerErrors) Error() string

Nov 3, 2025

Changes in this version

type GRPCClientConfig

+ InsecureSkipVerify bool

Oct 2, 2025

Changes in this version

+ var RootFeaturesSingleton fixtures.RootType

+ func GetRootFeatures() (fixtures.RootType, error)

Sep 21, 2025

Changes in this version

+ func PermissionsFromStrings(permissions []string) ([]authv1.Permission, error)

Sep 14, 2025

Changes in this version

type GRPCClient

+ GetGraph func(ctx context.Context, deploymentId string) (*GRPCGetGraphResult, error)

+ UpdateGraph func(ctx context.Context, req *serverv1.UpdateGraphRequest) (*GRPCUpdateGraphResult, error)

+ type GRPCGetGraphResult struct

+ RawResponse *serverv1.GetGraphResponse

+ type GRPCUpdateGraphResult struct

+ RawResponse *serverv1.UpdateGraphResponse

Aug 19, 2025

Changes in this version

type ClientConfig

+ ConfigDir *string

type GRPCClientConfig

+ ConfigDir *string

+ JWT *serverv1.GetTokenResponse

type OnlineQueryParams

+ OutputExprs []expr.ExprI

type OnlineQueryParamsComplete

+ func (p OnlineQueryParamsComplete) WithOutputExprs(exprs ...expr.ExprI) OnlineQueryParamsComplete

Jul 28, 2025

Changes in this version

type OfflineQueryParams

+ RecomputeFeaturesList []string

type OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithRecomputeFeaturesList(features []string) OfflineQueryParamsComplete

Jul 26, 2025

Changes in this version

type OfflineQueryParams

+ func (p OfflineQueryParams) WithFileInput(fileUri string) offlineQueryParamsWithInputs

Jul 17, 2025

Changes in this version

type Client

+ GetDataset func(ctx context.Context, revisionId string) (Dataset, error)

type Dataset

+ EnvironmentID string

+ func (d *Dataset) DownloadUris(ctx context.Context) ([]string, error)

type DatasetRevision

+ Branch *string

+ DashboardURL *string

+ EnvironmentID string

+ NumComputers int

+ func (d *DatasetRevision) DownloadUris(ctx context.Context) ([]string, error)

type OfflineQueryParams

+ CorrelationId string

+ Explain bool

+ FeatureForLowerUpperBound string

+ ObservedAtLowerBound *time.Time

+ ObservedAtUpperBound *time.Time

+ OverlayGraph string

+ OverrideTargetImageTag string

+ PlannerOptions map[string]any

+ RecomputeFeatures bool

+ RecomputeRequestRevisionId string

+ RequiredResolverTags []string

+ SampleFeatures []string

+ SpineSqlQuery string

+ StorePlanStages bool

+ UseJobQueue bool

type OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithCorrelationId(correlationId string) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithExplain(explain bool) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithFeatureForLowerUpperBound(feature string) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithObservedAtLowerBound(lowerBound time.Time) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithObservedAtUpperBound(upperBound time.Time) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithOverlayGraph(overlayGraph string) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithOverrideTargetImageTag(imageTag string) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithPlannerOptions(options map[string]any) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithRecomputeFeatures(recomputeFeatures bool) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithRecomputeRequestRevisionId(revisionId string) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithRequiredResolverTags(tags []string) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithSampleFeatures(sampleFeatures []string) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithSpineSqlQuery(spineSqlQuery string) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithStorePlanStages(storePlanStages bool) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithUseJobQueue(useJobQueue bool) OfflineQueryParamsComplete

Jul 17, 2025

Changes in this version

+ type BatchReport struct

+ AllErrors []ServerError

+ ComputerID *int

+ DeploymentID string

+ EnvironmentID string

+ Error *ServerError

+ GeneratedAt string

+ OperationID string

+ OperationMetadata *map[string]string

+ Status string

+ TeamID string

type Client

+ GetOfflineQueryStatus func(ctx context.Context, args GetOfflineQueryStatusParams) (GetOfflineQueryStatusResult, error)

type Dataset

+ func (d *Dataset) Wait(ctx context.Context) error

+ type GetOfflineQueryStatusParams struct

+ JobId string

+ PreviewDeploymentId string

+ type GetOfflineQueryStatusResult struct

+ Report BatchReport

Jul 17, 2025

Changes in this version

type OfflineQueryParams

+ CompletionDeadline *time.Duration

+ EnableProfiling bool

+ EnvOverrides map[string]string

+ MaxRetries *int

+ NumShards *int

+ NumWorkers *int

+ Resources *ResourceRequests

+ RunAsynchronously bool

+ StoreOffline bool

+ StoreOnline bool

+ UploadInputAsTable bool

+ UseMultipleComputers bool

type OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithCompletionDeadline(deadline time.Duration) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithEnableProfiling(enableProfiling bool) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithEnvOverrides(envOverrides map[string]string) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithMaxRetries(maxRetries int) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithNumShards(numShards int) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithNumWorkers(numWorkers int) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithResources(resources *ResourceRequests) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithRunAsynchronously(runAsynchronously bool) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithStoreOffline(storeOffline bool) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithStoreOnline(storeOnline bool) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithUploadInputAsTable(uploadInputAsTable bool) OfflineQueryParamsComplete

+ func (p OfflineQueryParamsComplete) WithUseMultipleComputers(useMultipleComputers bool) OfflineQueryParamsComplete

+ type ResourceRequests struct

+ CPU *string

+ EphemeralStorage *string

+ EphemeralVolumeSize *string

+ Memory *string

+ ResourceGroup *string

Jun 27, 2025

Changes in this version

type GRPCClientConfig

+ Interceptors []connect.Interceptor

May 15, 2025

Changes in this version

type GRPCOnlineQueryBulkResult

+ func NewGRPCOnlineQueryBulkResult(response *commonv1.OnlineQueryBulkResponse, ...) (*GRPCOnlineQueryBulkResult, error)

+ type NewGRPCOnlineQueryBulkResultOptions struct

+ Allocator memory.Allocator

May 5, 2025

Changes in this version

type GRPCClient

+ GetConfig func() *GRPCClientConfig

+ GetMetadataServerInterceptor func() []connect.ClientOption

Mar 31, 2025

Changes in this version

type GRPCClient

+ GetOnlineQueryBulkRequest func(ctx context.Context, params OnlineQueryParamsComplete) (*connect.Request[commonv1.OnlineQueryBulkRequest], error)

+ GetQueryEndpoint func() string

Mar 19, 2025

Changes in this version

+ type FeatureTable struct

+ ArrowTable arrow.Table

+ func MakeFeatureTable(featureToValues map[any]any, options ...MakeFeatureTableOptions) (*FeatureTable, error)

+ func (f *FeatureTable) Release()

+ func (f *FeatureTable) ToBytes() ([]byte, error)

+ type MakeFeatureTableOptions struct

+ Allocator memory.Allocator

Mar 12, 2025

Changes in this version

type GRPCOnlineQueryBulkResult

+ func (r *GRPCOnlineQueryBulkResult) GetTable() (arrow.Table, error)

Mar 12, 2025

Changes in this version

type ClientConfig

+ Allocator memory.Allocator

+ type FeatureMeta struct

+ ResolverFqn string

+ SourceId string

+ SourceType string

+ type FeatureOutput struct

+ Fqn string

+ Meta *FeatureMeta

+ Value any

type GRPCClientConfig

+ Allocator memory.Allocator

+ type GRPCGetAggregatesResult struct

+ RawResponse *aggregatev1.GetAggregatesResponse

+ type GRPCOnlineQueryBulkResult struct

+ RawResponse *commonv1.OnlineQueryBulkResponse

+ func (r *GRPCOnlineQueryBulkResult) GetErrors() ([]ServerError, error)

+ func (r *GRPCOnlineQueryBulkResult) GetQueryMeta() *QueryMeta

+ func (r *GRPCOnlineQueryBulkResult) GetRow(rowIndex int) (*RowResult, error)

+ func (r *GRPCOnlineQueryBulkResult) UnmarshalInto(resultHolders any) error

+ type GRPCPlanAggregateBackfillResult struct

+ RawResponse *aggregatev1.PlanAggregateBackfillResponse

+ type GRPCUpdateAggregatesResult struct

+ RawResponse *commonv1.UploadFeaturesBulkResponse

+ func (r *GRPCUpdateAggregatesResult) GetErrors() ([]ServerError, error)

+ type RowResult struct

+ Features map[string]FeatureOutput

+ func (r *RowResult) GetFeature(feature any) (*FeatureOutput, error)

+ func (r *RowResult) GetFeatureValue(feature any) (any, error)

type SerializationOptions

+ Allocator memory.Allocator

Feb 12, 2025

Changes in this version

type ClientConfig

+ Timeout time.Duration

type GRPCClientConfig

+ Timeout time.Duration

Feb 6, 2025

Changes in this version

+ func WarmUpUnmarshaller[T any](featureStruct *T) error

Jan 22, 2025

Changes in this version

type OnlineQueryParams

+ PlannerOptions map[string]any

Jan 22, 2025

Changes in this version

+ var HeaderKeyDeploymentTag = "x-chalk-deployment-tag"

+ var HeaderKeyDeploymentType = "x-chalk-deployment-type"

+ var HeaderKeyEnvironmentId = "x-chalk-env-id"

+ var HeaderKeyResourceGroup = "x-chalk-resource-group"

+ var HeaderKeyServerType = "x-chalk-server"

type ClientConfig

+ ResourceGroup string

type GRPCClientConfig

+ ResourceGroup string

type OnlineQueryParams

+ ResourceGroup string

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