graphv1

type BigQuerySource struct {
	Name              string                     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Project           string                     `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	Dataset           string                     `protobuf:"bytes,3,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Location          string                     `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"`
	CredentialsBase64 string                     `protobuf:"bytes,5,opt,name=credentials_base64,json=credentialsBase64,proto3" json:"credentials_base64,omitempty"`
	CredentialsPath   string                     `protobuf:"bytes,6,opt,name=credentials_path,json=credentialsPath,proto3" json:"credentials_path,omitempty"`
	EngineArgs        map[string]*v1.ScalarValue `` /* 179-byte string literal not displayed */
	AsyncEngineArgs   map[string]*v1.ScalarValue `` /* 196-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CloudSQLSource struct {
	Name            string                     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Db              string                     `protobuf:"bytes,2,opt,name=db,proto3" json:"db,omitempty"`
	User            string                     `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	Password        string                     `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	InstanceName    string                     `protobuf:"bytes,5,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	EngineArgs      map[string]*v1.ScalarValue `` /* 179-byte string literal not displayed */
	AsyncEngineArgs map[string]*v1.ScalarValue `` /* 196-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CronFilterWithFeatureArgs struct {
	Filter *FunctionReference  `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	Args   []*FeatureReference `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

type DataFrameType struct {
	RootNamespace   string              `protobuf:"bytes,1,opt,name=root_namespace,json=rootNamespace,proto3" json:"root_namespace,omitempty"`
	RequiredColumns []*FeatureReference `protobuf:"bytes,2,rep,name=required_columns,json=requiredColumns,proto3" json:"required_columns,omitempty"`
	OptionalColumns []*FeatureReference `protobuf:"bytes,3,rep,name=optional_columns,json=optionalColumns,proto3" json:"optional_columns,omitempty"`
	Filter          *v1.LogicalExprNode `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	Limit           *uint64             `protobuf:"varint,5,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type DatabaseSource struct {

	// Types that are assignable to Source:
	//
	//	*DatabaseSource_Bigquery
	//	*DatabaseSource_Cloudsql
	//	*DatabaseSource_Databricks
	//	*DatabaseSource_Mysql
	//	*DatabaseSource_Postgres
	//	*DatabaseSource_Redshift
	//	*DatabaseSource_Snowflake
	//	*DatabaseSource_Sqlite
	Source isDatabaseSource_Source `protobuf_oneof:"source"`
	// contains filtered or unexported fields
}

type DatabaseSourceReference struct {
	Type DatabaseSourceType `protobuf:"varint,1,opt,name=type,proto3,enum=chalk.graph.v1.DatabaseSourceType" json:"type,omitempty"`
	Name string             `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type DatabaseSourceType int32

type DatabaseSource_Bigquery struct {
	Bigquery *BigQuerySource `protobuf:"bytes,1,opt,name=bigquery,proto3,oneof"`
}

type DatabaseSource_Cloudsql struct {
	Cloudsql *CloudSQLSource `protobuf:"bytes,2,opt,name=cloudsql,proto3,oneof"`
}

type DatabaseSource_Databricks struct {
	Databricks *DatabricksSource `protobuf:"bytes,3,opt,name=databricks,proto3,oneof"`
}

type DatabaseSource_Mysql struct {
	Mysql *MySQLSource `protobuf:"bytes,4,opt,name=mysql,proto3,oneof"`
}

type DatabaseSource_Postgres struct {
	Postgres *PostgresSource `protobuf:"bytes,5,opt,name=postgres,proto3,oneof"`
}

type DatabaseSource_Redshift struct {
	Redshift *RedshiftSource `protobuf:"bytes,6,opt,name=redshift,proto3,oneof"`
}

type DatabaseSource_Snowflake struct {
	Snowflake *SnowflakeSource `protobuf:"bytes,7,opt,name=snowflake,proto3,oneof"`
}

type DatabaseSource_Sqlite struct {
	Sqlite *SQLiteSource `protobuf:"bytes,8,opt,name=sqlite,proto3,oneof"`
}

type DatabricksSource struct {
	Name            string                     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Host            string                     `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Port            string                     `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"`
	Db              string                     `protobuf:"bytes,4,opt,name=db,proto3" json:"db,omitempty"`
	HttpPath        string                     `protobuf:"bytes,5,opt,name=http_path,json=httpPath,proto3" json:"http_path,omitempty"`
	AccessToken     string                     `protobuf:"bytes,6,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	EngineArgs      map[string]*v1.ScalarValue `` /* 179-byte string literal not displayed */
	AsyncEngineArgs map[string]*v1.ScalarValue `` /* 196-byte string literal not displayed */
	// contains filtered or unexported fields
}

type FeatureInput struct {
	Feature      *FeatureReference `protobuf:"bytes,1,opt,name=feature,proto3" json:"feature,omitempty"`
	DefaultValue *v11.ScalarValue  `protobuf:"bytes,2,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
	// contains filtered or unexported fields
}

type FeatureReference struct {
	Name      string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace string              `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Path      []*FeatureReference `protobuf:"bytes,3,rep,name=path,proto3" json:"path,omitempty"`
	Df        *DataFrameType      `protobuf:"bytes,4,opt,name=df,proto3" json:"df,omitempty"`
	// contains filtered or unexported fields
}

type FeatureSet struct {
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Features             []*FeatureType       `protobuf:"bytes,2,rep,name=features,proto3" json:"features,omitempty"`
	MaxStalenessDuration *durationpb.Duration `protobuf:"bytes,3,opt,name=max_staleness_duration,json=maxStalenessDuration,proto3" json:"max_staleness_duration,omitempty"`
	IsSingleton          bool                 `protobuf:"varint,4,opt,name=is_singleton,json=isSingleton,proto3" json:"is_singleton,omitempty"`
	Tags                 []string             `protobuf:"bytes,5,rep,name=tags,proto3" json:"tags,omitempty"`
	Owner                *string              `protobuf:"bytes,6,opt,name=owner,proto3,oneof" json:"owner,omitempty"`
	// The docstring of the class on which the features are defined.
	Doc                *string `protobuf:"bytes,7,opt,name=doc,proto3,oneof" json:"doc,omitempty"`
	EtlOfflineToOnline *bool   `` /* 126-byte string literal not displayed */
	ClassPath          *string `protobuf:"bytes,9,opt,name=class_path,json=classPath,proto3,oneof" json:"class_path,omitempty"`
	// contains filtered or unexported fields
}

type FeatureTimeFeatureType struct {
	Name            string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace       string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	IsAutogenerated bool     `protobuf:"varint,3,opt,name=is_autogenerated,json=isAutogenerated,proto3" json:"is_autogenerated,omitempty"`
	Tags            []string `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	Description     *string  `protobuf:"bytes,5,opt,name=description,proto3,oneof" json:"description,omitempty"`
	Owner           *string  `protobuf:"bytes,6,opt,name=owner,proto3,oneof" json:"owner,omitempty"`
	AttributeName   string   `protobuf:"bytes,7,opt,name=attribute_name,json=attributeName,proto3" json:"attribute_name,omitempty"`
	// contains filtered or unexported fields
}

type FeatureType struct {

	// Types that are assignable to Type:
	//
	//	*FeatureType_Scalar
	//	*FeatureType_HasOne
	//	*FeatureType_HasMany
	//	*FeatureType_FeatureTime
	//	*FeatureType_Windowed
	Type isFeatureType_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type FeatureType_FeatureTime struct {
	FeatureTime *FeatureTimeFeatureType `protobuf:"bytes,4,opt,name=feature_time,json=featureTime,proto3,oneof"`
}

type FeatureType_HasMany struct {
	HasMany *HasManyFeatureType `protobuf:"bytes,3,opt,name=has_many,json=hasMany,proto3,oneof"`
}

type FeatureType_HasOne struct {
	HasOne *HasOneFeatureType `protobuf:"bytes,2,opt,name=has_one,json=hasOne,proto3,oneof"`
}

type FeatureType_Scalar struct {
	Scalar *ScalarFeatureType `protobuf:"bytes,1,opt,name=scalar,proto3,oneof"`
}

type FeatureType_Windowed struct {
	Windowed *WindowedFeatureType `protobuf:"bytes,5,opt,name=windowed,proto3,oneof"`
}

type FeatureValidation struct {

	// Types that are assignable to Validation:
	//
	//	*FeatureValidation_Min
	//	*FeatureValidation_Max
	//	*FeatureValidation_MinLength
	//	*FeatureValidation_MaxLength
	Validation isFeatureValidation_Validation `protobuf_oneof:"validation"`
	Strict     bool                           `protobuf:"varint,5,opt,name=strict,proto3" json:"strict,omitempty"`
	// contains filtered or unexported fields
}

type FeatureValidation_Max struct {
	Max float32 `protobuf:"fixed32,2,opt,name=max,proto3,oneof"`
}

type FeatureValidation_MaxLength struct {
	MaxLength uint32 `protobuf:"varint,4,opt,name=max_length,json=maxLength,proto3,oneof"`
}

type FeatureValidation_Min struct {
	Min float32 `protobuf:"fixed32,1,opt,name=min,proto3,oneof"`
}

type FeatureValidation_MinLength struct {
	MinLength uint32 `protobuf:"varint,3,opt,name=min_length,json=minLength,proto3,oneof"`
}

type FunctionReference struct {
	Name               string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Module             string `protobuf:"bytes,2,opt,name=module,proto3" json:"module,omitempty"`
	FileName           string `protobuf:"bytes,3,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	FunctionDefinition string `protobuf:"bytes,4,opt,name=function_definition,json=functionDefinition,proto3" json:"function_definition,omitempty"`
	SourceLine         *int32 `protobuf:"varint,5,opt,name=source_line,json=sourceLine,proto3,oneof" json:"source_line,omitempty"`
	// contains filtered or unexported fields
}

type Graph struct {
	FeatureSets     []*FeatureSet     `protobuf:"bytes,1,rep,name=feature_sets,json=featureSets,proto3" json:"feature_sets,omitempty"`
	Resolvers       []*Resolver       `protobuf:"bytes,2,rep,name=resolvers,proto3" json:"resolvers,omitempty"`
	StreamResolvers []*StreamResolver `protobuf:"bytes,3,rep,name=stream_resolvers,json=streamResolvers,proto3" json:"stream_resolvers,omitempty"`
	SinkResolvers   []*SinkResolver   `protobuf:"bytes,4,rep,name=sink_resolvers,json=sinkResolvers,proto3" json:"sink_resolvers,omitempty"`
	DatabaseSources []*DatabaseSource `protobuf:"bytes,5,rep,name=database_sources,json=databaseSources,proto3" json:"database_sources,omitempty"`
	StreamSources   []*StreamSource   `protobuf:"bytes,6,rep,name=stream_sources,json=streamSources,proto3" json:"stream_sources,omitempty"`
	// contains filtered or unexported fields
}

type HasManyFeatureType struct {
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string               `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ForeignNamespace     string               `protobuf:"bytes,3,opt,name=foreign_namespace,json=foreignNamespace,proto3" json:"foreign_namespace,omitempty"`
	Join                 *v1.LogicalExprNode  `protobuf:"bytes,4,opt,name=join,proto3" json:"join,omitempty"`
	IsAutogenerated      bool                 `protobuf:"varint,5,opt,name=is_autogenerated,json=isAutogenerated,proto3" json:"is_autogenerated,omitempty"`
	MaxStalenessDuration *durationpb.Duration `protobuf:"bytes,6,opt,name=max_staleness_duration,json=maxStalenessDuration,proto3" json:"max_staleness_duration,omitempty"`
	Tags                 []string             `protobuf:"bytes,7,rep,name=tags,proto3" json:"tags,omitempty"`
	Description          *string              `protobuf:"bytes,8,opt,name=description,proto3,oneof" json:"description,omitempty"`
	Owner                *string              `protobuf:"bytes,9,opt,name=owner,proto3,oneof" json:"owner,omitempty"`
	AttributeName        string               `protobuf:"bytes,10,opt,name=attribute_name,json=attributeName,proto3" json:"attribute_name,omitempty"`
	// contains filtered or unexported fields
}

type HasOneFeatureType struct {
	Name             string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace        string              `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ForeignNamespace string              `protobuf:"bytes,3,opt,name=foreign_namespace,json=foreignNamespace,proto3" json:"foreign_namespace,omitempty"`
	Join             *v1.LogicalExprNode `protobuf:"bytes,4,opt,name=join,proto3" json:"join,omitempty"`
	IsNullable       bool                `protobuf:"varint,5,opt,name=is_nullable,json=isNullable,proto3" json:"is_nullable,omitempty"`
	IsAutogenerated  bool                `protobuf:"varint,6,opt,name=is_autogenerated,json=isAutogenerated,proto3" json:"is_autogenerated,omitempty"`
	Tags             []string            `protobuf:"bytes,7,rep,name=tags,proto3" json:"tags,omitempty"`
	Description      *string             `protobuf:"bytes,8,opt,name=description,proto3,oneof" json:"description,omitempty"`
	Owner            *string             `protobuf:"bytes,9,opt,name=owner,proto3,oneof" json:"owner,omitempty"`
	AttributeName    string              `protobuf:"bytes,10,opt,name=attribute_name,json=attributeName,proto3" json:"attribute_name,omitempty"`
	// contains filtered or unexported fields
}

type KafkaSource struct {
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	BootstrapServers     []string             `protobuf:"bytes,2,rep,name=bootstrap_servers,json=bootstrapServers,proto3" json:"bootstrap_servers,omitempty"`
	Topic                string               `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	SslKeystoreLocation  string               `protobuf:"bytes,4,opt,name=ssl_keystore_location,json=sslKeystoreLocation,proto3" json:"ssl_keystore_location,omitempty"`
	SslCaFile            string               `protobuf:"bytes,5,opt,name=ssl_ca_file,json=sslCaFile,proto3" json:"ssl_ca_file,omitempty"`
	ClientIdPrefix       string               `protobuf:"bytes,6,opt,name=client_id_prefix,json=clientIdPrefix,proto3" json:"client_id_prefix,omitempty"`
	GroupIdPrefix        string               `protobuf:"bytes,7,opt,name=group_id_prefix,json=groupIdPrefix,proto3" json:"group_id_prefix,omitempty"`
	SecurityProtocol     string               `protobuf:"bytes,8,opt,name=security_protocol,json=securityProtocol,proto3" json:"security_protocol,omitempty"`
	SaslMechanism        string               `protobuf:"bytes,9,opt,name=sasl_mechanism,json=saslMechanism,proto3" json:"sasl_mechanism,omitempty"`
	SaslUsername         string               `protobuf:"bytes,10,opt,name=sasl_username,json=saslUsername,proto3" json:"sasl_username,omitempty"`
	SaslPassword         string               `protobuf:"bytes,11,opt,name=sasl_password,json=saslPassword,proto3" json:"sasl_password,omitempty"`
	LateArrivalDeadline  *durationpb.Duration `protobuf:"bytes,12,opt,name=late_arrival_deadline,json=lateArrivalDeadline,proto3" json:"late_arrival_deadline,omitempty"`
	DeadLetterQueueTopic string               `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

type KinesisSource struct {
	Name                      string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	StreamName                string               `protobuf:"bytes,2,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	StreamArn                 string               `protobuf:"bytes,3,opt,name=stream_arn,json=streamArn,proto3" json:"stream_arn,omitempty"`
	RegionName                string               `protobuf:"bytes,4,opt,name=region_name,json=regionName,proto3" json:"region_name,omitempty"`
	LateArrivalDeadline       *durationpb.Duration `protobuf:"bytes,5,opt,name=late_arrival_deadline,json=lateArrivalDeadline,proto3" json:"late_arrival_deadline,omitempty"`
	DeadLetterQueueStreamName string               `` /* 142-byte string literal not displayed */
	AwsAccessKeyId            string               `protobuf:"bytes,7,opt,name=aws_access_key_id,json=awsAccessKeyId,proto3" json:"aws_access_key_id,omitempty"`
	AwsSecretAccessKey        string               `protobuf:"bytes,8,opt,name=aws_secret_access_key,json=awsSecretAccessKey,proto3" json:"aws_secret_access_key,omitempty"`
	AwsSessionToken           string               `protobuf:"bytes,9,opt,name=aws_session_token,json=awsSessionToken,proto3" json:"aws_session_token,omitempty"`
	EndpointUrl               string               `protobuf:"bytes,10,opt,name=endpoint_url,json=endpointUrl,proto3" json:"endpoint_url,omitempty"`
	ConsumerRoleArn           string               `protobuf:"bytes,11,opt,name=consumer_role_arn,json=consumerRoleArn,proto3" json:"consumer_role_arn,omitempty"`
	// contains filtered or unexported fields
}

type MySQLSource struct {
	Name            string                     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Host            string                     `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Port            string                     `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"`
	Db              string                     `protobuf:"bytes,4,opt,name=db,proto3" json:"db,omitempty"`
	User            string                     `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	Password        string                     `protobuf:"bytes,6,opt,name=password,proto3" json:"password,omitempty"`
	EngineArgs      map[string]*v1.ScalarValue `` /* 179-byte string literal not displayed */
	AsyncEngineArgs map[string]*v1.ScalarValue `` /* 196-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ParseInfo struct {
	ParseFunction                 *FunctionReference `protobuf:"bytes,1,opt,name=parse_function,json=parseFunction,proto3" json:"parse_function,omitempty"`
	ParseFunctionInputType        *v11.ArrowType     `` /* 131-byte string literal not displayed */
	ParseFunctionOutputType       *v11.ArrowType     `` /* 134-byte string literal not displayed */
	IsParseFunctionOutputOptional bool               `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

type PostgresSource struct {
	Name            string                     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Host            string                     `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Port            string                     `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"`
	Db              string                     `protobuf:"bytes,4,opt,name=db,proto3" json:"db,omitempty"`
	User            string                     `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	Password        string                     `protobuf:"bytes,6,opt,name=password,proto3" json:"password,omitempty"`
	EngineArgs      map[string]*v1.ScalarValue `` /* 179-byte string literal not displayed */
	AsyncEngineArgs map[string]*v1.ScalarValue `` /* 196-byte string literal not displayed */
	// contains filtered or unexported fields
}

type RedshiftSource struct {
	Name            string                     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Host            string                     `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Port            string                     `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"`
	Db              string                     `protobuf:"bytes,4,opt,name=db,proto3" json:"db,omitempty"`
	User            string                     `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	Password        string                     `protobuf:"bytes,6,opt,name=password,proto3" json:"password,omitempty"`
	S3Client        string                     `protobuf:"bytes,7,opt,name=s3_client,json=s3Client,proto3" json:"s3_client,omitempty"`
	S3Bucket        string                     `protobuf:"bytes,8,opt,name=s3_bucket,json=s3Bucket,proto3" json:"s3_bucket,omitempty"`
	EngineArgs      map[string]*v1.ScalarValue `` /* 179-byte string literal not displayed */
	AsyncEngineArgs map[string]*v1.ScalarValue `` /* 197-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Resolver struct {
	Fqn         string                     `protobuf:"bytes,1,opt,name=fqn,proto3" json:"fqn,omitempty"`
	Kind        ResolverKind               `protobuf:"varint,2,opt,name=kind,proto3,enum=chalk.graph.v1.ResolverKind" json:"kind,omitempty"`
	Inputs      []*ResolverInput           `protobuf:"bytes,3,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs     []*ResolverOutput          `protobuf:"bytes,4,rep,name=outputs,proto3" json:"outputs,omitempty"`
	IsGenerator bool                       `protobuf:"varint,5,opt,name=is_generator,json=isGenerator,proto3" json:"is_generator,omitempty"`
	DataSources []*DatabaseSourceReference `protobuf:"bytes,6,rep,name=data_sources,json=dataSources,proto3" json:"data_sources,omitempty"`
	MachineType *string                    `protobuf:"bytes,7,opt,name=machine_type,json=machineType,proto3,oneof" json:"machine_type,omitempty"`
	Tags        []string                   `protobuf:"bytes,8,rep,name=tags,proto3" json:"tags,omitempty"`
	Owner       *string                    `protobuf:"bytes,9,opt,name=owner,proto3,oneof" json:"owner,omitempty"`
	// The docstring of the python function
	Doc             *string                    `protobuf:"bytes,10,opt,name=doc,proto3,oneof" json:"doc,omitempty"`
	Environments    []string                   `protobuf:"bytes,11,rep,name=environments,proto3" json:"environments,omitempty"`
	TimeoutDuration *durationpb.Duration       `protobuf:"bytes,12,opt,name=timeout_duration,json=timeoutDuration,proto3" json:"timeout_duration,omitempty"`
	Schedule        *Schedule                  `protobuf:"bytes,13,opt,name=schedule,proto3" json:"schedule,omitempty"`
	When            *v1.LogicalExprNode        `protobuf:"bytes,14,opt,name=when,proto3" json:"when,omitempty"`
	CronFilter      *CronFilterWithFeatureArgs `protobuf:"bytes,15,opt,name=cron_filter,json=cronFilter,proto3" json:"cron_filter,omitempty"`
	Function        *FunctionReference         `protobuf:"bytes,16,opt,name=function,proto3" json:"function,omitempty"`
	// contains filtered or unexported fields
}

type ResolverInput struct {

	// Types that are assignable to Annotation:
	//
	//	*ResolverInput_Feature
	//	*ResolverInput_Df
	//	*ResolverInput_State
	Annotation isResolverInput_Annotation `protobuf_oneof:"annotation"`
	// contains filtered or unexported fields
}

type ResolverInput_Df struct {
	Df *DataFrameType `protobuf:"bytes,2,opt,name=df,proto3,oneof"`
}

type ResolverInput_Feature struct {
	Feature *FeatureInput `protobuf:"bytes,1,opt,name=feature,proto3,oneof"`
}

type ResolverInput_State struct {
	State *ResolverState `protobuf:"bytes,3,opt,name=state,proto3,oneof"`
}

type ResolverKind int32

type ResolverOutput struct {

	// Types that are assignable to Annotation:
	//
	//	*ResolverOutput_Feature
	//	*ResolverOutput_Df
	Annotation isResolverOutput_Annotation `protobuf_oneof:"annotation"`
	// contains filtered or unexported fields
}

type ResolverOutput_Df struct {
	Df *DataFrameType `protobuf:"bytes,2,opt,name=df,proto3,oneof"`
}

type ResolverOutput_Feature struct {
	Feature *FeatureReference `protobuf:"bytes,1,opt,name=feature,proto3,oneof"`
}

type ResolverState struct {
	Initial   *v11.ScalarValue `protobuf:"bytes,1,opt,name=initial,proto3" json:"initial,omitempty"`
	ArrowType *v11.ArrowType   `protobuf:"bytes,2,opt,name=arrow_type,json=arrowType,proto3" json:"arrow_type,omitempty"`
	// contains filtered or unexported fields
}

type SQLiteSource struct {
	Name            string                     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	FileName        string                     `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	EngineArgs      map[string]*v1.ScalarValue `` /* 179-byte string literal not displayed */
	AsyncEngineArgs map[string]*v1.ScalarValue `` /* 196-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ScalarFeatureType struct {
	Name            string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace       string  `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	IsAutogenerated bool    `protobuf:"varint,3,opt,name=is_autogenerated,json=isAutogenerated,proto3" json:"is_autogenerated,omitempty"`
	NoDisplay       bool    `protobuf:"varint,4,opt,name=no_display,json=noDisplay,proto3" json:"no_display,omitempty"`
	IsPrimary       bool    `protobuf:"varint,5,opt,name=is_primary,json=isPrimary,proto3" json:"is_primary,omitempty"`
	IsNullable      bool    `protobuf:"varint,6,opt,name=is_nullable,json=isNullable,proto3" json:"is_nullable,omitempty"`
	InternalVersion *uint64 `protobuf:"varint,7,opt,name=internal_version,json=internalVersion,proto3,oneof" json:"internal_version,omitempty"`
	// This represents whatever arg the user passed into the `feature()` call.
	// If both set, this should take precedence over the value in `FeatureSet`.
	// If unset here, the value in `FeatureSet` should be used.
	MaxStalenessDuration *durationpb.Duration `protobuf:"bytes,8,opt,name=max_staleness_duration,json=maxStalenessDuration,proto3" json:"max_staleness_duration,omitempty"`
	OfflineTtlDuration   *durationpb.Duration `protobuf:"bytes,10,opt,name=offline_ttl_duration,json=offlineTtlDuration,proto3" json:"offline_ttl_duration,omitempty"`
	ArrowType            *v11.ArrowType       `protobuf:"bytes,11,opt,name=arrow_type,json=arrowType,proto3" json:"arrow_type,omitempty"`
	Version              *VersionInfo         `protobuf:"bytes,12,opt,name=version,proto3" json:"version,omitempty"`
	WindowInfo           *WindowInfo          `protobuf:"bytes,13,opt,name=window_info,json=windowInfo,proto3" json:"window_info,omitempty"`
	DefaultValue         *v11.ScalarValue     `protobuf:"bytes,14,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
	Tags                 []string             `protobuf:"bytes,15,rep,name=tags,proto3" json:"tags,omitempty"`
	Description          *string              `protobuf:"bytes,16,opt,name=description,proto3,oneof" json:"description,omitempty"`
	Owner                *string              `protobuf:"bytes,17,opt,name=owner,proto3,oneof" json:"owner,omitempty"`
	Expression           *v1.LogicalExprNode  `protobuf:"bytes,18,opt,name=expression,proto3" json:"expression,omitempty"`
	Validations          []*FeatureValidation `protobuf:"bytes,19,rep,name=validations,proto3" json:"validations,omitempty"`
	LastFor              *FeatureReference    `protobuf:"bytes,20,opt,name=last_for,json=lastFor,proto3" json:"last_for,omitempty"`
	// This represents whatever arg the user passed into the `feature()` call.
	// If both set, this should take precedence over the value in `FeatureSet`.
	// If unset here, the value in `FeatureSet` should be used.
	EtlOfflineToOnline      *bool  `` /* 127-byte string literal not displayed */
	IsDistancePseudofeature bool   `` /* 134-byte string literal not displayed */
	AttributeName           string `protobuf:"bytes,23,opt,name=attribute_name,json=attributeName,proto3" json:"attribute_name,omitempty"`
	// contains filtered or unexported fields
}

type Schedule struct {

	// Types that are assignable to Schedule:
	//
	//	*Schedule_Crontab
	//	*Schedule_Duration
	Schedule isSchedule_Schedule `protobuf_oneof:"schedule"`
	Filter   *FunctionReference  `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	Sample   *FunctionReference  `protobuf:"bytes,4,opt,name=sample,proto3" json:"sample,omitempty"`
	// contains filtered or unexported fields
}

type Schedule_Crontab struct {
	Crontab string `protobuf:"bytes,1,opt,name=crontab,proto3,oneof"`
}

type Schedule_Duration struct {
	Duration *durationpb.Duration `protobuf:"bytes,2,opt,name=duration,proto3,oneof"`
}

type SinkResolver struct {
	Fqn              string               `protobuf:"bytes,1,opt,name=fqn,proto3" json:"fqn,omitempty"`
	Inputs           []*ResolverInput     `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	BufferSize       *uint64              `protobuf:"varint,3,opt,name=buffer_size,json=bufferSize,proto3,oneof" json:"buffer_size,omitempty"`
	DebounceDuration *durationpb.Duration `protobuf:"bytes,4,opt,name=debounce_duration,json=debounceDuration,proto3" json:"debounce_duration,omitempty"`
	MaxDelayDuration *durationpb.Duration `protobuf:"bytes,5,opt,name=max_delay_duration,json=maxDelayDuration,proto3" json:"max_delay_duration,omitempty"`
	Upsert           bool                 `protobuf:"varint,6,opt,name=upsert,proto3" json:"upsert,omitempty"`
	// Types that are assignable to Integration:
	//
	//	*SinkResolver_StreamSource
	//	*SinkResolver_DatabaseSource
	Integration     isSinkResolver_Integration `protobuf_oneof:"integration"`
	MachineType     *string                    `protobuf:"bytes,9,opt,name=machine_type,json=machineType,proto3,oneof" json:"machine_type,omitempty"`
	Doc             *string                    `protobuf:"bytes,10,opt,name=doc,proto3,oneof" json:"doc,omitempty"`
	Owner           *string                    `protobuf:"bytes,11,opt,name=owner,proto3,oneof" json:"owner,omitempty"`
	Environments    []string                   `protobuf:"bytes,12,rep,name=environments,proto3" json:"environments,omitempty"`
	TimeoutDuration *durationpb.Duration       `protobuf:"bytes,13,opt,name=timeout_duration,json=timeoutDuration,proto3" json:"timeout_duration,omitempty"`
	Function        *FunctionReference         `protobuf:"bytes,14,opt,name=function,proto3" json:"function,omitempty"`
	// contains filtered or unexported fields
}

type SinkResolver_DatabaseSource struct {
	DatabaseSource *DatabaseSourceReference `protobuf:"bytes,8,opt,name=database_source,json=databaseSource,proto3,oneof"`
}

type SinkResolver_StreamSource struct {
	StreamSource *StreamSourceReference `protobuf:"bytes,7,opt,name=stream_source,json=streamSource,proto3,oneof"`
}

type SnowflakeSource struct {
	Name              string                     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Db                string                     `protobuf:"bytes,2,opt,name=db,proto3" json:"db,omitempty"`
	Schema            string                     `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	Role              string                     `protobuf:"bytes,4,opt,name=role,proto3" json:"role,omitempty"`
	User              string                     `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	Password          string                     `protobuf:"bytes,6,opt,name=password,proto3" json:"password,omitempty"`
	AccountIdentifier string                     `protobuf:"bytes,7,opt,name=account_identifier,json=accountIdentifier,proto3" json:"account_identifier,omitempty"`
	Warehouse         string                     `protobuf:"bytes,8,opt,name=warehouse,proto3" json:"warehouse,omitempty"`
	EngineArgs        map[string]*v1.ScalarValue `` /* 179-byte string literal not displayed */
	AsyncEngineArgs   map[string]*v1.ScalarValue `` /* 197-byte string literal not displayed */
	// contains filtered or unexported fields
}

type StreamKey struct {
	Key     string            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Feature *FeatureReference `protobuf:"bytes,2,opt,name=feature,proto3" json:"feature,omitempty"`
	// contains filtered or unexported fields
}

type StreamResolver struct {
	Fqn                    string                 `protobuf:"bytes,1,opt,name=fqn,proto3" json:"fqn,omitempty"`
	Params                 []*StreamResolverParam `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"`
	Outputs                []*ResolverOutput      `protobuf:"bytes,3,rep,name=outputs,proto3" json:"outputs,omitempty"`
	ExplicitSchema         *v11.ArrowType         `protobuf:"bytes,4,opt,name=explicit_schema,json=explicitSchema,proto3" json:"explicit_schema,omitempty"`
	Keys                   []*StreamKey           `protobuf:"bytes,5,rep,name=keys,proto3" json:"keys,omitempty"`
	Source                 *StreamSourceReference `protobuf:"bytes,6,opt,name=source,proto3" json:"source,omitempty"`
	ParseInfo              *ParseInfo             `protobuf:"bytes,7,opt,name=parse_info,json=parseInfo,proto3" json:"parse_info,omitempty"`
	Mode                   WindowMode             `protobuf:"varint,8,opt,name=mode,proto3,enum=chalk.graph.v1.WindowMode" json:"mode,omitempty"`
	Environments           []string               `protobuf:"bytes,9,rep,name=environments,proto3" json:"environments,omitempty"`
	TimeoutDuration        *durationpb.Duration   `protobuf:"bytes,10,opt,name=timeout_duration,json=timeoutDuration,proto3" json:"timeout_duration,omitempty"`
	TimestampAttributeName *string                `` /* 136-byte string literal not displayed */
	Owner                  *string                `protobuf:"bytes,12,opt,name=owner,proto3,oneof" json:"owner,omitempty"`
	Doc                    *string                `protobuf:"bytes,13,opt,name=doc,proto3,oneof" json:"doc,omitempty"`
	MachineType            *string                `protobuf:"bytes,14,opt,name=machine_type,json=machineType,proto3,oneof" json:"machine_type,omitempty"`
	Function               *FunctionReference     `protobuf:"bytes,15,opt,name=function,proto3" json:"function,omitempty"`
	// contains filtered or unexported fields
}

type StreamResolverParam struct {

	// Types that are assignable to Type:
	//
	//	*StreamResolverParam_Message
	//	*StreamResolverParam_MessageWindow
	//	*StreamResolverParam_State
	Type isStreamResolverParam_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type StreamResolverParamMessage struct {
	Name      string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ArrowType *v11.ArrowType `protobuf:"bytes,2,opt,name=arrow_type,json=arrowType,proto3" json:"arrow_type,omitempty"`
	// contains filtered or unexported fields
}

type StreamResolverParamMessageWindow struct {
	Name      string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ArrowType *v11.ArrowType `protobuf:"bytes,2,opt,name=arrow_type,json=arrowType,proto3" json:"arrow_type,omitempty"`
	// contains filtered or unexported fields
}

type StreamResolverParam_Message struct {
	Message *StreamResolverParamMessage `protobuf:"bytes,1,opt,name=message,proto3,oneof"`
}

type StreamResolverParam_MessageWindow struct {
	MessageWindow *StreamResolverParamMessageWindow `protobuf:"bytes,2,opt,name=message_window,json=messageWindow,proto3,oneof"`
}

type StreamResolverParam_State struct {
	State *ResolverState `protobuf:"bytes,3,opt,name=state,proto3,oneof"`
}

type StreamSource struct {

	// Types that are assignable to Source:
	//
	//	*StreamSource_Kafka
	//	*StreamSource_Kinesis
	Source isStreamSource_Source `protobuf_oneof:"source"`
	// contains filtered or unexported fields
}

type StreamSourceReference struct {
	Type StreamSourceType `protobuf:"varint,1,opt,name=type,proto3,enum=chalk.graph.v1.StreamSourceType" json:"type,omitempty"`
	Name string           `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type StreamSourceType int32

type StreamSource_Kafka struct {
	Kafka *KafkaSource `protobuf:"bytes,1,opt,name=kafka,proto3,oneof"`
}

type StreamSource_Kinesis struct {
	Kinesis *KinesisSource `protobuf:"bytes,2,opt,name=kinesis,proto3,oneof"`
}

type StrictValidation struct {
	Feature     *FeatureReference    `protobuf:"bytes,1,opt,name=feature,proto3" json:"feature,omitempty"`
	Validations []*FeatureValidation `protobuf:"bytes,2,rep,name=validations,proto3" json:"validations,omitempty"`
	// contains filtered or unexported fields
}