internal

Documentation

Index

• Constants
• func ChalkMarshal(attrs map[string]any) ([]byte, error)
• func ChalkUnmarshal(body []byte) (map[string]any, error)
• func ConvertBytesToTable(byteArr []byte) (result arrow.Table, err error)
• func CreateOnlineQueryBulkBody(inputs map[string]any, header FeatherRequestHeader) ([]byte, error)
• func CreateUploadFeaturesBody(inputs map[string]any) ([]byte, error)
• func ExpandTilde(path string) (string, error)
• func FileExists(path string) bool
• func FormatBucketDuration(duration int) string
• func GenerateGetEnumFunction[K comparable](valueToEnum map[string]K, enumName string) func(string) (*K, error)
• func GetReflectValue(value any, elemType reflect.Type) (reflect.Value, error)
• func IsDataclass(field reflect.Value) bool
• func IsDataclassPointer(field reflect.Value) bool
• func ParseBucketDuration(durationStr string) (int, error)
• func StringOrNil(value string) *string
• type BufferWriteSeeker
  • func (b *BufferWriteSeeker) Bytes() []byte
  • func (b *BufferWriteSeeker) Seek(offset int64, whence int) (int64, error)
  • func (b *BufferWriteSeeker) Write(p []byte) (n int, err error)
• type FeatherRequestHeader
• type Numbers

Constants

const ApiServerEnvVarKey = "CHALK_API_SERVER"

const ClientIdEnvVarKey = "CHALK_CLIENT_ID"

const ClientSecretEnvVarKey = "CHALK_CLIENT_SECRET"

const EnvironmentEnvVarKey = "CHALK_ACTIVE_ENVIRONMENT"

Functions

func ChalkMarshal

func ChalkMarshal(attrs map[string]any) ([]byte, error)

ChalkMarshal converts a map to a byte array. Follows the byte-packing format as described in the Chalk Python repo's `byte_transmit.serialize()` function.

func ChalkUnmarshal

func ChalkUnmarshal(body []byte) (map[string]any, error)

func ConvertBytesToTable

func ConvertBytesToTable(byteArr []byte) (result arrow.Table, err error)

func CreateOnlineQueryBulkBody

func CreateOnlineQueryBulkBody(inputs map[string]any, header FeatherRequestHeader) ([]byte, error)

func CreateUploadFeaturesBody

func CreateUploadFeaturesBody(inputs map[string]any) ([]byte, error)

func ExpandTilde

func ExpandTilde(path string) (string, error)

func FileExists

func FileExists(path string) bool

func FormatBucketDuration

func FormatBucketDuration(duration int) string

FormatBucketDuration takes an integer number of seconds and returns a string representation that satisfies these conditions:

• the largest possible unit of time (e.g. "10m" instead of "600s")
• a single unit of time (e.g. "601s" instead of "10m1s")

func GenerateGetEnumFunction

func GenerateGetEnumFunction[K comparable](valueToEnum map[string]K, enumName string) func(string) (*K, error)

func GetReflectValue

func GetReflectValue(value any, elemType reflect.Type) (reflect.Value, error)

func IsDataclass

func IsDataclass(field reflect.Value) bool

func IsDataclassPointer

func IsDataclassPointer(field reflect.Value) bool

func ParseBucketDuration

func ParseBucketDuration(durationStr string) (int, error)

ParseBucketDuration parses a bucket duration string and returns the duration in seconds. The input string must be of the form "Nunit" where N is a positive integer and unit is one of "s", "m", "h", "d", or "w".

func StringOrNil

func StringOrNil(value string) *string

Types

type BufferWriteSeeker

type BufferWriteSeeker struct {
	// contains filtered or unexported fields
}

func (*BufferWriteSeeker) Bytes

func (b *BufferWriteSeeker) Bytes() []byte

func (*BufferWriteSeeker) Seek

func (b *BufferWriteSeeker) Seek(offset int64, whence int) (int64, error)

func (*BufferWriteSeeker) Write

func (b *BufferWriteSeeker) Write(p []byte) (n int, err error)

type FeatherRequestHeader

type FeatherRequestHeader struct {
	Outputs  []string `json:"outputs"`
	BranchId *string  `json:"branch_id"`
	Explain  bool     `json:"explain"`
}

type Numbers

type Numbers interface {
	int | int8 | int16 | int32 | int64 | uint8 | uint16 | uint32 | uint64 | float32 | float64
}