graphv1

package
v0.20.2 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CacheStrategy_name = map[int32]string{
		0: "CACHE_STRATEGY_UNSPECIFIED",
		1: "CACHE_STRATEGY_ALL",
		2: "CACHE_STRATEGY_NO_NULLS",
		3: "CACHE_STRATEGY_EVICT_NULLS",
		4: "CACHE_STRATEGY_NO_DEFAULTS",
		5: "CACHE_STRATEGY_EVICT_DEFAULTS",
		6: "CACHE_STRATEGY_NO_NULLS_OR_DEFAULTS",
		7: "CACHE_STRATEGY_EVICT_NULLS_AND_DEFAULTS",
	}
	CacheStrategy_value = map[string]int32{
		"CACHE_STRATEGY_UNSPECIFIED":              0,
		"CACHE_STRATEGY_ALL":                      1,
		"CACHE_STRATEGY_NO_NULLS":                 2,
		"CACHE_STRATEGY_EVICT_NULLS":              3,
		"CACHE_STRATEGY_NO_DEFAULTS":              4,
		"CACHE_STRATEGY_EVICT_DEFAULTS":           5,
		"CACHE_STRATEGY_NO_NULLS_OR_DEFAULTS":     6,
		"CACHE_STRATEGY_EVICT_NULLS_AND_DEFAULTS": 7,
	}
)

Enum value maps for CacheStrategy.

View Source 
var (
	ResolverKind_name = map[int32]string{
		0: "RESOLVER_KIND_UNSPECIFIED",
		1: "RESOLVER_KIND_ONLINE",
		2: "RESOLVER_KIND_OFFLINE",
	}
	ResolverKind_value = map[string]int32{
		"RESOLVER_KIND_UNSPECIFIED": 0,
		"RESOLVER_KIND_ONLINE":      1,
		"RESOLVER_KIND_OFFLINE":     2,
	}
)

Enum value maps for ResolverKind.

View Source 
var (
	ResourceHint_name = map[int32]string{
		0: "RESOURCE_HINT_UNSPECIFIED",
		1: "RESOURCE_HINT_CPU",
		2: "RESOURCE_HINT_IO",
	}
	ResourceHint_value = map[string]int32{
		"RESOURCE_HINT_UNSPECIFIED": 0,
		"RESOURCE_HINT_CPU":         1,
		"RESOURCE_HINT_IO":          2,
	}
)

Enum value maps for ResourceHint.

View Source 
var (
	WindowMode_name = map[int32]string{
		0: "WINDOW_MODE_UNSPECIFIED",
		1: "WINDOW_MODE_CONTINUOUS",
		2: "WINDOW_MODE_TUMBLING",
		3: "WINDOW_MODE_CDC",
	}
	WindowMode_value = map[string]int32{
		"WINDOW_MODE_UNSPECIFIED": 0,
		"WINDOW_MODE_CONTINUOUS":  1,
		"WINDOW_MODE_TUMBLING":    2,
		"WINDOW_MODE_CDC":         3,
	}
)

Enum value maps for WindowMode.

View Source 
var (
	StreamSourceType_name = map[int32]string{
		0: "STREAM_SOURCE_TYPE_UNSPECIFIED",
		1: "STREAM_SOURCE_TYPE_KAFKA",
		2: "STREAM_SOURCE_TYPE_KINESIS",
		3: "STREAM_SOURCE_TYPE_PUBSUB",
	}
	StreamSourceType_value = map[string]int32{
		"STREAM_SOURCE_TYPE_UNSPECIFIED": 0,
		"STREAM_SOURCE_TYPE_KAFKA":       1,
		"STREAM_SOURCE_TYPE_KINESIS":     2,
		"STREAM_SOURCE_TYPE_PUBSUB":      3,
	}
)

Enum value maps for StreamSourceType.

View Source 
var (
	DatabaseSourceType_name = map[int32]string{
		0:  "DATABASE_SOURCE_TYPE_UNSPECIFIED",
		1:  "DATABASE_SOURCE_TYPE_BIGQUERY",
		2:  "DATABASE_SOURCE_TYPE_CLOUDSQL",
		3:  "DATABASE_SOURCE_TYPE_DATABRICKS",
		4:  "DATABASE_SOURCE_TYPE_MYSQL",
		5:  "DATABASE_SOURCE_TYPE_POSTGRES",
		6:  "DATABASE_SOURCE_TYPE_REDSHIFT",
		7:  "DATABASE_SOURCE_TYPE_SNOWFLAKE",
		8:  "DATABASE_SOURCE_TYPE_SQLITE",
		9:  "DATABASE_SOURCE_TYPE_SPANNER",
		10: "DATABASE_SOURCE_TYPE_TRINO",
		11: "DATABASE_SOURCE_TYPE_DYNAMODB",
	}
	DatabaseSourceType_value = map[string]int32{
		"DATABASE_SOURCE_TYPE_UNSPECIFIED": 0,
		"DATABASE_SOURCE_TYPE_BIGQUERY":    1,
		"DATABASE_SOURCE_TYPE_CLOUDSQL":    2,
		"DATABASE_SOURCE_TYPE_DATABRICKS":  3,
		"DATABASE_SOURCE_TYPE_MYSQL":       4,
		"DATABASE_SOURCE_TYPE_POSTGRES":    5,
		"DATABASE_SOURCE_TYPE_REDSHIFT":    6,
		"DATABASE_SOURCE_TYPE_SNOWFLAKE":   7,
		"DATABASE_SOURCE_TYPE_SQLITE":      8,
		"DATABASE_SOURCE_TYPE_SPANNER":     9,
		"DATABASE_SOURCE_TYPE_TRINO":       10,
		"DATABASE_SOURCE_TYPE_DYNAMODB":    11,
	}
)

Enum value maps for DatabaseSourceType.

View Source 
var File_chalk_graph_v1_graph_proto protoreflect.FileDescriptor
View Source 
var File_chalk_graph_v1_sources_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BigQuerySource 

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
}

func (*BigQuerySource) Descriptor deprecated 

func (*BigQuerySource) Descriptor() ([]byte, []int)

Deprecated: Use BigQuerySource.ProtoReflect.Descriptor instead.

func (*BigQuerySource) GetAsyncEngineArgs 

func (x *BigQuerySource) GetAsyncEngineArgs() map[string]*v1.ScalarValue

func (*BigQuerySource) GetCredentialsBase64 

func (x *BigQuerySource) GetCredentialsBase64() string

func (*BigQuerySource) GetCredentialsPath 

func (x *BigQuerySource) GetCredentialsPath() string

func (*BigQuerySource) GetDataset 

func (x *BigQuerySource) GetDataset() string

func (*BigQuerySource) GetEngineArgs 

func (x *BigQuerySource) GetEngineArgs() map[string]*v1.ScalarValue

func (*BigQuerySource) GetLocation 

func (x *BigQuerySource) GetLocation() string

func (*BigQuerySource) GetName 

func (x *BigQuerySource) GetName() string

func (*BigQuerySource) GetProject 

func (x *BigQuerySource) GetProject() string

func (*BigQuerySource) ProtoMessage 

func (*BigQuerySource) ProtoMessage()

func (*BigQuerySource) ProtoReflect 

func (x *BigQuerySource) ProtoReflect() protoreflect.Message

func (*BigQuerySource) Reset 

func (x *BigQuerySource) Reset()

func (*BigQuerySource) String 

func (x *BigQuerySource) String() string

type CacheStrategy added in v0.17.2 

type CacheStrategy int32
const (
	CacheStrategy_CACHE_STRATEGY_UNSPECIFIED              CacheStrategy = 0
	CacheStrategy_CACHE_STRATEGY_ALL                      CacheStrategy = 1
	CacheStrategy_CACHE_STRATEGY_NO_NULLS                 CacheStrategy = 2
	CacheStrategy_CACHE_STRATEGY_EVICT_NULLS              CacheStrategy = 3
	CacheStrategy_CACHE_STRATEGY_NO_DEFAULTS              CacheStrategy = 4
	CacheStrategy_CACHE_STRATEGY_EVICT_DEFAULTS           CacheStrategy = 5
	CacheStrategy_CACHE_STRATEGY_NO_NULLS_OR_DEFAULTS     CacheStrategy = 6
	CacheStrategy_CACHE_STRATEGY_EVICT_NULLS_AND_DEFAULTS CacheStrategy = 7
)

func (CacheStrategy) Descriptor added in v0.17.2 

func (CacheStrategy) Descriptor() protoreflect.EnumDescriptor

func (CacheStrategy) Enum added in v0.17.2 

func (x CacheStrategy) Enum() *CacheStrategy

func (CacheStrategy) EnumDescriptor deprecated added in v0.17.2 

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

Deprecated: Use CacheStrategy.Descriptor instead.

func (CacheStrategy) Number added in v0.17.2 

func (x CacheStrategy) Number() protoreflect.EnumNumber

func (CacheStrategy) String added in v0.17.2 

func (x CacheStrategy) String() string

func (CacheStrategy) Type added in v0.17.2 

func (CacheStrategy) Type() protoreflect.EnumType

type CloudSQLSource 

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
}

func (*CloudSQLSource) Descriptor deprecated 

func (*CloudSQLSource) Descriptor() ([]byte, []int)

Deprecated: Use CloudSQLSource.ProtoReflect.Descriptor instead.

func (*CloudSQLSource) GetAsyncEngineArgs 

func (x *CloudSQLSource) GetAsyncEngineArgs() map[string]*v1.ScalarValue

func (*CloudSQLSource) GetDb 

func (x *CloudSQLSource) GetDb() string

func (*CloudSQLSource) GetEngineArgs 

func (x *CloudSQLSource) GetEngineArgs() map[string]*v1.ScalarValue

func (*CloudSQLSource) GetInstanceName 

func (x *CloudSQLSource) GetInstanceName() string

func (*CloudSQLSource) GetName 

func (x *CloudSQLSource) GetName() string

func (*CloudSQLSource) GetPassword 

func (x *CloudSQLSource) GetPassword() string

func (*CloudSQLSource) GetUser 

func (x *CloudSQLSource) GetUser() string

func (*CloudSQLSource) ProtoMessage 

func (*CloudSQLSource) ProtoMessage()

func (*CloudSQLSource) ProtoReflect 

func (x *CloudSQLSource) ProtoReflect() protoreflect.Message

func (*CloudSQLSource) Reset 

func (x *CloudSQLSource) Reset()

func (*CloudSQLSource) String 

func (x *CloudSQLSource) String() string

type CronFilterWithFeatureArgs 

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
}

func (*CronFilterWithFeatureArgs) Descriptor deprecated 

func (*CronFilterWithFeatureArgs) Descriptor() ([]byte, []int)

Deprecated: Use CronFilterWithFeatureArgs.ProtoReflect.Descriptor instead.

func (*CronFilterWithFeatureArgs) GetArgs 

func (x *CronFilterWithFeatureArgs) GetArgs() []*FeatureReference

func (*CronFilterWithFeatureArgs) GetFilter 

func (x *CronFilterWithFeatureArgs) GetFilter() *FunctionReference

func (*CronFilterWithFeatureArgs) ProtoMessage 

func (*CronFilterWithFeatureArgs) ProtoMessage()

func (*CronFilterWithFeatureArgs) ProtoReflect 

func (x *CronFilterWithFeatureArgs) ProtoReflect() protoreflect.Message

func (*CronFilterWithFeatureArgs) Reset 

func (x *CronFilterWithFeatureArgs) Reset()

func (*CronFilterWithFeatureArgs) String 

func (x *CronFilterWithFeatureArgs) String() string

type DataFrameType 

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
}

func (*DataFrameType) Descriptor deprecated 

func (*DataFrameType) Descriptor() ([]byte, []int)

Deprecated: Use DataFrameType.ProtoReflect.Descriptor instead.

func (*DataFrameType) GetFilter 

func (x *DataFrameType) GetFilter() *v1.LogicalExprNode

func (*DataFrameType) GetLimit 

func (x *DataFrameType) GetLimit() uint64

func (*DataFrameType) GetOptionalColumns 

func (x *DataFrameType) GetOptionalColumns() []*FeatureReference

func (*DataFrameType) GetRequiredColumns 

func (x *DataFrameType) GetRequiredColumns() []*FeatureReference

func (*DataFrameType) GetRootNamespace 

func (x *DataFrameType) GetRootNamespace() string

func (*DataFrameType) ProtoMessage 

func (*DataFrameType) ProtoMessage()

func (*DataFrameType) ProtoReflect 

func (x *DataFrameType) ProtoReflect() protoreflect.Message

func (*DataFrameType) Reset 

func (x *DataFrameType) Reset()

func (*DataFrameType) String 

func (x *DataFrameType) String() string

type DatabaseSource 

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
	//	*DatabaseSource_Spanner
	//	*DatabaseSource_Trino
	//	*DatabaseSource_Dynamodb
	Source isDatabaseSource_Source `protobuf_oneof:"source"`
	// contains filtered or unexported fields
}

func (*DatabaseSource) Descriptor deprecated 

func (*DatabaseSource) Descriptor() ([]byte, []int)

Deprecated: Use DatabaseSource.ProtoReflect.Descriptor instead.

func (*DatabaseSource) GetBigquery 

func (x *DatabaseSource) GetBigquery() *BigQuerySource

func (*DatabaseSource) GetCloudsql 

func (x *DatabaseSource) GetCloudsql() *CloudSQLSource

func (*DatabaseSource) GetDatabricks 

func (x *DatabaseSource) GetDatabricks() *DatabricksSource

func (*DatabaseSource) GetDynamodb added in v0.14.0 

func (x *DatabaseSource) GetDynamodb() *DynamoDBSource

func (*DatabaseSource) GetMysql 

func (x *DatabaseSource) GetMysql() *MySQLSource

func (*DatabaseSource) GetPostgres 

func (x *DatabaseSource) GetPostgres() *PostgresSource

func (*DatabaseSource) GetRedshift 

func (x *DatabaseSource) GetRedshift() *RedshiftSource

func (*DatabaseSource) GetSnowflake 

func (x *DatabaseSource) GetSnowflake() *SnowflakeSource

func (*DatabaseSource) GetSource 

func (m *DatabaseSource) GetSource() isDatabaseSource_Source

func (*DatabaseSource) GetSpanner added in v0.8.0 

func (x *DatabaseSource) GetSpanner() *SpannerSource

func (*DatabaseSource) GetSqlite 

func (x *DatabaseSource) GetSqlite() *SQLiteSource

func (*DatabaseSource) GetTrino added in v0.8.1 

func (x *DatabaseSource) GetTrino() *TrinoSource

func (*DatabaseSource) ProtoMessage 

func (*DatabaseSource) ProtoMessage()

func (*DatabaseSource) ProtoReflect 

func (x *DatabaseSource) ProtoReflect() protoreflect.Message

func (*DatabaseSource) Reset 

func (x *DatabaseSource) Reset()

func (*DatabaseSource) String 

func (x *DatabaseSource) String() string

type DatabaseSourceReference 

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
}

func (*DatabaseSourceReference) Descriptor deprecated 

func (*DatabaseSourceReference) Descriptor() ([]byte, []int)

Deprecated: Use DatabaseSourceReference.ProtoReflect.Descriptor instead.

func (*DatabaseSourceReference) GetName 

func (x *DatabaseSourceReference) GetName() string

func (*DatabaseSourceReference) GetType 

func (x *DatabaseSourceReference) GetType() DatabaseSourceType

func (*DatabaseSourceReference) ProtoMessage 

func (*DatabaseSourceReference) ProtoMessage()

func (*DatabaseSourceReference) ProtoReflect 

func (x *DatabaseSourceReference) ProtoReflect() protoreflect.Message

func (*DatabaseSourceReference) Reset 

func (x *DatabaseSourceReference) Reset()

func (*DatabaseSourceReference) String 

func (x *DatabaseSourceReference) String() string

type DatabaseSourceType 

type DatabaseSourceType int32
const (
	DatabaseSourceType_DATABASE_SOURCE_TYPE_UNSPECIFIED DatabaseSourceType = 0
	DatabaseSourceType_DATABASE_SOURCE_TYPE_BIGQUERY    DatabaseSourceType = 1
	DatabaseSourceType_DATABASE_SOURCE_TYPE_CLOUDSQL    DatabaseSourceType = 2
	DatabaseSourceType_DATABASE_SOURCE_TYPE_DATABRICKS  DatabaseSourceType = 3
	DatabaseSourceType_DATABASE_SOURCE_TYPE_MYSQL       DatabaseSourceType = 4
	DatabaseSourceType_DATABASE_SOURCE_TYPE_POSTGRES    DatabaseSourceType = 5
	DatabaseSourceType_DATABASE_SOURCE_TYPE_REDSHIFT    DatabaseSourceType = 6
	DatabaseSourceType_DATABASE_SOURCE_TYPE_SNOWFLAKE   DatabaseSourceType = 7
	DatabaseSourceType_DATABASE_SOURCE_TYPE_SQLITE      DatabaseSourceType = 8
	DatabaseSourceType_DATABASE_SOURCE_TYPE_SPANNER     DatabaseSourceType = 9
	DatabaseSourceType_DATABASE_SOURCE_TYPE_TRINO       DatabaseSourceType = 10
	DatabaseSourceType_DATABASE_SOURCE_TYPE_DYNAMODB    DatabaseSourceType = 11
)

func (DatabaseSourceType) Descriptor 

func (DatabaseSourceType) Descriptor() protoreflect.EnumDescriptor

func (DatabaseSourceType) Enum 

func (x DatabaseSourceType) Enum() *DatabaseSourceType

func (DatabaseSourceType) EnumDescriptor deprecated 

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

Deprecated: Use DatabaseSourceType.Descriptor instead.

func (DatabaseSourceType) Number 

func (x DatabaseSourceType) Number() protoreflect.EnumNumber

func (DatabaseSourceType) String 

func (x DatabaseSourceType) String() string

func (DatabaseSourceType) Type 

func (DatabaseSourceType) Type() protoreflect.EnumType

type DatabaseSource_Bigquery 

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

type DatabaseSource_Cloudsql 

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

type DatabaseSource_Databricks 

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

type DatabaseSource_Dynamodb added in v0.14.0 

type DatabaseSource_Dynamodb struct {
	Dynamodb *DynamoDBSource `protobuf:"bytes,11,opt,name=dynamodb,proto3,oneof"`
}

type DatabaseSource_Mysql 

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

type DatabaseSource_Postgres 

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

type DatabaseSource_Redshift 

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

type DatabaseSource_Snowflake 

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

type DatabaseSource_Spanner added in v0.8.0 

type DatabaseSource_Spanner struct {
	Spanner *SpannerSource `protobuf:"bytes,9,opt,name=spanner,proto3,oneof"`
}

type DatabaseSource_Sqlite 

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

type DatabaseSource_Trino added in v0.8.1 

type DatabaseSource_Trino struct {
	Trino *TrinoSource `protobuf:"bytes,10,opt,name=trino,proto3,oneof"`
}

type DatabricksSource 

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
}

func (*DatabricksSource) Descriptor deprecated 

func (*DatabricksSource) Descriptor() ([]byte, []int)

Deprecated: Use DatabricksSource.ProtoReflect.Descriptor instead.

func (*DatabricksSource) GetAccessToken 

func (x *DatabricksSource) GetAccessToken() string

func (*DatabricksSource) GetAsyncEngineArgs 

func (x *DatabricksSource) GetAsyncEngineArgs() map[string]*v1.ScalarValue

func (*DatabricksSource) GetDb 

func (x *DatabricksSource) GetDb() string

func (*DatabricksSource) GetEngineArgs 

func (x *DatabricksSource) GetEngineArgs() map[string]*v1.ScalarValue

func (*DatabricksSource) GetHost 

func (x *DatabricksSource) GetHost() string

func (*DatabricksSource) GetHttpPath 

func (x *DatabricksSource) GetHttpPath() string

func (*DatabricksSource) GetName 

func (x *DatabricksSource) GetName() string

func (*DatabricksSource) GetPort 

func (x *DatabricksSource) GetPort() string

func (*DatabricksSource) ProtoMessage 

func (*DatabricksSource) ProtoMessage()

func (*DatabricksSource) ProtoReflect 

func (x *DatabricksSource) ProtoReflect() protoreflect.Message

func (*DatabricksSource) Reset 

func (x *DatabricksSource) Reset()

func (*DatabricksSource) String 

func (x *DatabricksSource) String() string

type DynamoDBSource added in v0.14.0 

type DynamoDBSource struct {
	Name                    string                     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	AwsClientIdOverride     *string                    `` /* 128-byte string literal not displayed */
	AwsClientSecretOverride *string                    `` /* 140-byte string literal not displayed */
	AwsRegionOverride       *string                    `protobuf:"bytes,4,opt,name=aws_region_override,json=awsRegionOverride,proto3,oneof" json:"aws_region_override,omitempty"`
	EndpointOverride        *string                    `protobuf:"bytes,5,opt,name=endpoint_override,json=endpointOverride,proto3,oneof" json:"endpoint_override,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
}

func (*DynamoDBSource) Descriptor deprecated added in v0.14.0 

func (*DynamoDBSource) Descriptor() ([]byte, []int)

Deprecated: Use DynamoDBSource.ProtoReflect.Descriptor instead.

func (*DynamoDBSource) GetAsyncEngineArgs added in v0.14.0 

func (x *DynamoDBSource) GetAsyncEngineArgs() map[string]*v1.ScalarValue

func (*DynamoDBSource) GetAwsClientIdOverride added in v0.14.0 

func (x *DynamoDBSource) GetAwsClientIdOverride() string

func (*DynamoDBSource) GetAwsClientSecretOverride added in v0.14.0 

func (x *DynamoDBSource) GetAwsClientSecretOverride() string

func (*DynamoDBSource) GetAwsRegionOverride added in v0.14.0 

func (x *DynamoDBSource) GetAwsRegionOverride() string

func (*DynamoDBSource) GetEndpointOverride added in v0.14.0 

func (x *DynamoDBSource) GetEndpointOverride() string

func (*DynamoDBSource) GetEngineArgs added in v0.14.0 

func (x *DynamoDBSource) GetEngineArgs() map[string]*v1.ScalarValue

func (*DynamoDBSource) GetName added in v0.14.0 

func (x *DynamoDBSource) GetName() string

func (*DynamoDBSource) ProtoMessage added in v0.14.0 

func (*DynamoDBSource) ProtoMessage()

func (*DynamoDBSource) ProtoReflect added in v0.14.0 

func (x *DynamoDBSource) ProtoReflect() protoreflect.Message

func (*DynamoDBSource) Reset added in v0.14.0 

func (x *DynamoDBSource) Reset()

func (*DynamoDBSource) String added in v0.14.0 

func (x *DynamoDBSource) String() string

type FeatureInput 

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
}

func (*FeatureInput) Descriptor deprecated 

func (*FeatureInput) Descriptor() ([]byte, []int)

Deprecated: Use FeatureInput.ProtoReflect.Descriptor instead.

func (*FeatureInput) GetDefaultValue 

func (x *FeatureInput) GetDefaultValue() *v11.ScalarValue

func (*FeatureInput) GetFeature 

func (x *FeatureInput) GetFeature() *FeatureReference

func (*FeatureInput) ProtoMessage 

func (*FeatureInput) ProtoMessage()

func (*FeatureInput) ProtoReflect 

func (x *FeatureInput) ProtoReflect() protoreflect.Message

func (*FeatureInput) Reset 

func (x *FeatureInput) Reset()

func (*FeatureInput) String 

func (x *FeatureInput) String() string

type FeatureReference 

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
}

func (*FeatureReference) Descriptor deprecated 

func (*FeatureReference) Descriptor() ([]byte, []int)

Deprecated: Use FeatureReference.ProtoReflect.Descriptor instead.

func (*FeatureReference) GetDf 

func (x *FeatureReference) GetDf() *DataFrameType

func (*FeatureReference) GetName 

func (x *FeatureReference) GetName() string

func (*FeatureReference) GetNamespace 

func (x *FeatureReference) GetNamespace() string

func (*FeatureReference) GetPath 

func (x *FeatureReference) GetPath() []*FeatureReference

func (*FeatureReference) ProtoMessage 

func (*FeatureReference) ProtoMessage()

func (*FeatureReference) ProtoReflect 

func (x *FeatureReference) ProtoReflect() protoreflect.Message

func (*FeatureReference) Reset 

func (x *FeatureReference) Reset()

func (*FeatureReference) String 

func (x *FeatureReference) String() string

type FeatureSet 

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
}

func (*FeatureSet) Descriptor deprecated 

func (*FeatureSet) Descriptor() ([]byte, []int)

Deprecated: Use FeatureSet.ProtoReflect.Descriptor instead.

func (*FeatureSet) GetClassPath added in v0.4.7 

func (x *FeatureSet) GetClassPath() string

func (*FeatureSet) GetDoc 

func (x *FeatureSet) GetDoc() string

func (*FeatureSet) GetEtlOfflineToOnline 

func (x *FeatureSet) GetEtlOfflineToOnline() bool

func (*FeatureSet) GetFeatures 

func (x *FeatureSet) GetFeatures() []*FeatureType

func (*FeatureSet) GetIsSingleton 

func (x *FeatureSet) GetIsSingleton() bool

func (*FeatureSet) GetMaxStalenessDuration 

func (x *FeatureSet) GetMaxStalenessDuration() *durationpb.Duration

func (*FeatureSet) GetName 

func (x *FeatureSet) GetName() string

func (*FeatureSet) GetOwner 

func (x *FeatureSet) GetOwner() string

func (*FeatureSet) GetTags 

func (x *FeatureSet) GetTags() []string

func (*FeatureSet) ProtoMessage 

func (*FeatureSet) ProtoMessage()

func (*FeatureSet) ProtoReflect 

func (x *FeatureSet) ProtoReflect() protoreflect.Message

func (*FeatureSet) Reset 

func (x *FeatureSet) Reset()

func (*FeatureSet) String 

func (x *FeatureSet) String() string

type FeatureTimeFeatureType 

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
}

func (*FeatureTimeFeatureType) Descriptor deprecated 

func (*FeatureTimeFeatureType) Descriptor() ([]byte, []int)

Deprecated: Use FeatureTimeFeatureType.ProtoReflect.Descriptor instead.

func (*FeatureTimeFeatureType) GetAttributeName added in v0.4.7 

func (x *FeatureTimeFeatureType) GetAttributeName() string

func (*FeatureTimeFeatureType) GetDescription 

func (x *FeatureTimeFeatureType) GetDescription() string

func (*FeatureTimeFeatureType) GetIsAutogenerated 

func (x *FeatureTimeFeatureType) GetIsAutogenerated() bool

func (*FeatureTimeFeatureType) GetName 

func (x *FeatureTimeFeatureType) GetName() string

func (*FeatureTimeFeatureType) GetNamespace 

func (x *FeatureTimeFeatureType) GetNamespace() string

func (*FeatureTimeFeatureType) GetOwner 

func (x *FeatureTimeFeatureType) GetOwner() string

func (*FeatureTimeFeatureType) GetTags 

func (x *FeatureTimeFeatureType) GetTags() []string

func (*FeatureTimeFeatureType) ProtoMessage 

func (*FeatureTimeFeatureType) ProtoMessage()

func (*FeatureTimeFeatureType) ProtoReflect 

func (x *FeatureTimeFeatureType) ProtoReflect() protoreflect.Message

func (*FeatureTimeFeatureType) Reset 

func (x *FeatureTimeFeatureType) Reset()

func (*FeatureTimeFeatureType) String 

func (x *FeatureTimeFeatureType) String() string

type FeatureType 

type FeatureType struct {

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

func (*FeatureType) Descriptor deprecated 

func (*FeatureType) Descriptor() ([]byte, []int)

Deprecated: Use FeatureType.ProtoReflect.Descriptor instead.

func (*FeatureType) GetFeatureTime 

func (x *FeatureType) GetFeatureTime() *FeatureTimeFeatureType

func (*FeatureType) GetGroupBy added in v0.13.5 

func (x *FeatureType) GetGroupBy() *GroupByFeatureType

func (*FeatureType) GetHasMany 

func (x *FeatureType) GetHasMany() *HasManyFeatureType

func (*FeatureType) GetHasOne 

func (x *FeatureType) GetHasOne() *HasOneFeatureType

func (*FeatureType) GetScalar 

func (x *FeatureType) GetScalar() *ScalarFeatureType

func (*FeatureType) GetType 

func (m *FeatureType) GetType() isFeatureType_Type

func (*FeatureType) GetWindowed 

func (x *FeatureType) GetWindowed() *WindowedFeatureType

func (*FeatureType) ProtoMessage 

func (*FeatureType) ProtoMessage()

func (*FeatureType) ProtoReflect 

func (x *FeatureType) ProtoReflect() protoreflect.Message

func (*FeatureType) Reset 

func (x *FeatureType) Reset()

func (*FeatureType) String 

func (x *FeatureType) String() string

type FeatureType_FeatureTime 

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

type FeatureType_GroupBy added in v0.13.5 

type FeatureType_GroupBy struct {
	GroupBy *GroupByFeatureType `protobuf:"bytes,6,opt,name=group_by,json=groupBy,proto3,oneof"`
}

type FeatureType_HasMany 

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

type FeatureType_HasOne 

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

type FeatureType_Scalar 

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

type FeatureType_Windowed 

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

type FeatureValidation 

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
}

func (*FeatureValidation) Descriptor deprecated 

func (*FeatureValidation) Descriptor() ([]byte, []int)

Deprecated: Use FeatureValidation.ProtoReflect.Descriptor instead.

func (*FeatureValidation) GetMax 

func (x *FeatureValidation) GetMax() float32

func (*FeatureValidation) GetMaxLength 

func (x *FeatureValidation) GetMaxLength() uint32

func (*FeatureValidation) GetMin 

func (x *FeatureValidation) GetMin() float32

func (*FeatureValidation) GetMinLength 

func (x *FeatureValidation) GetMinLength() uint32

func (*FeatureValidation) GetStrict 

func (x *FeatureValidation) GetStrict() bool

func (*FeatureValidation) GetValidation 

func (m *FeatureValidation) GetValidation() isFeatureValidation_Validation

func (*FeatureValidation) ProtoMessage 

func (*FeatureValidation) ProtoMessage()

func (*FeatureValidation) ProtoReflect 

func (x *FeatureValidation) ProtoReflect() protoreflect.Message

func (*FeatureValidation) Reset 

func (x *FeatureValidation) Reset()

func (*FeatureValidation) String 

func (x *FeatureValidation) String() string

type FeatureValidation_Max 

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

type FeatureValidation_MaxLength 

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

type FeatureValidation_Min 

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

type FeatureValidation_MinLength 

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

type FunctionReference 

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
}

func (*FunctionReference) Descriptor deprecated 

func (*FunctionReference) Descriptor() ([]byte, []int)

Deprecated: Use FunctionReference.ProtoReflect.Descriptor instead.

func (*FunctionReference) GetFileName 

func (x *FunctionReference) GetFileName() string

func (*FunctionReference) GetFunctionDefinition 

func (x *FunctionReference) GetFunctionDefinition() string

func (*FunctionReference) GetModule 

func (x *FunctionReference) GetModule() string

func (*FunctionReference) GetName 

func (x *FunctionReference) GetName() string

func (*FunctionReference) GetSourceLine added in v0.4.7 

func (x *FunctionReference) GetSourceLine() int32

func (*FunctionReference) ProtoMessage 

func (*FunctionReference) ProtoMessage()

func (*FunctionReference) ProtoReflect 

func (x *FunctionReference) ProtoReflect() protoreflect.Message

func (*FunctionReference) Reset 

func (x *FunctionReference) Reset()

func (*FunctionReference) String 

func (x *FunctionReference) String() string

type Graph 

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"`
	// database_sources is deprecated; see database_sources_v2
	//
	// Deprecated: Marked as deprecated in chalk/graph/v1/graph.proto.
	DatabaseSources []*DatabaseSource `protobuf:"bytes,5,rep,name=database_sources,json=databaseSources,proto3" json:"database_sources,omitempty"`
	// stream_sources is deprecated; see stream_sources_v2
	//
	// Deprecated: Marked as deprecated in chalk/graph/v1/graph.proto.
	StreamSources        []*StreamSource           `protobuf:"bytes,6,rep,name=stream_sources,json=streamSources,proto3" json:"stream_sources,omitempty"`
	NamedQueries         []*NamedQuery             `protobuf:"bytes,7,rep,name=named_queries,json=namedQueries,proto3" json:"named_queries,omitempty"`
	DatabaseSourcesV2    []*v2.DatabaseSource      `protobuf:"bytes,8,rep,name=database_sources_v2,json=databaseSourcesV2,proto3" json:"database_sources_v2,omitempty"`
	DatabaseSourceGroups []*v2.DatabaseSourceGroup `protobuf:"bytes,10,rep,name=database_source_groups,json=databaseSourceGroups,proto3" json:"database_source_groups,omitempty"`
	StreamSourcesV2      []*v2.StreamSource        `protobuf:"bytes,9,rep,name=stream_sources_v2,json=streamSourcesV2,proto3" json:"stream_sources_v2,omitempty"`
	// contains filtered or unexported fields
}

func (*Graph) Descriptor deprecated 

func (*Graph) Descriptor() ([]byte, []int)

Deprecated: Use Graph.ProtoReflect.Descriptor instead.

func (*Graph) GetDatabaseSourceGroups added in v0.18.19 

func (x *Graph) GetDatabaseSourceGroups() []*v2.DatabaseSourceGroup

func (*Graph) GetDatabaseSources deprecated 

func (x *Graph) GetDatabaseSources() []*DatabaseSource

Deprecated: Marked as deprecated in chalk/graph/v1/graph.proto.

func (*Graph) GetDatabaseSourcesV2 added in v0.18.14 

func (x *Graph) GetDatabaseSourcesV2() []*v2.DatabaseSource

func (*Graph) GetFeatureSets 

func (x *Graph) GetFeatureSets() []*FeatureSet

func (*Graph) GetNamedQueries added in v0.13.1 

func (x *Graph) GetNamedQueries() []*NamedQuery

func (*Graph) GetResolvers 

func (x *Graph) GetResolvers() []*Resolver

func (*Graph) GetSinkResolvers 

func (x *Graph) GetSinkResolvers() []*SinkResolver

func (*Graph) GetStreamResolvers 

func (x *Graph) GetStreamResolvers() []*StreamResolver

func (*Graph) GetStreamSources deprecated 

func (x *Graph) GetStreamSources() []*StreamSource

Deprecated: Marked as deprecated in chalk/graph/v1/graph.proto.

func (*Graph) GetStreamSourcesV2 added in v0.18.14 

func (x *Graph) GetStreamSourcesV2() []*v2.StreamSource

func (*Graph) ProtoMessage 

func (*Graph) ProtoMessage()

func (*Graph) ProtoReflect 

func (x *Graph) ProtoReflect() protoreflect.Message

func (*Graph) Reset 

func (x *Graph) Reset()

func (*Graph) String 

func (x *Graph) String() string

type GroupByFeatureType added in v0.13.5 

type GroupByFeatureType 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"`
	IsNullable      bool                   `protobuf:"varint,3,opt,name=is_nullable,json=isNullable,proto3" json:"is_nullable,omitempty"`
	InternalVersion *uint64                `protobuf:"varint,4,opt,name=internal_version,json=internalVersion,proto3,oneof" json:"internal_version,omitempty"`
	ArrowType       *v11.ArrowType         `protobuf:"bytes,5,opt,name=arrow_type,json=arrowType,proto3" json:"arrow_type,omitempty"`
	Aggregation     *WindowAggregation     `protobuf:"bytes,6,opt,name=aggregation,proto3" json:"aggregation,omitempty"`
	WindowDurations []*durationpb.Duration `protobuf:"bytes,7,rep,name=window_durations,json=windowDurations,proto3" json:"window_durations,omitempty"`
	Expression      *v1.LogicalExprNode    `protobuf:"bytes,8,opt,name=expression,proto3" json:"expression,omitempty"`
	DefaultValue    *v11.ScalarValue       `protobuf:"bytes,9,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
	Tags            []string               `protobuf:"bytes,10,rep,name=tags,proto3" json:"tags,omitempty"`
	Description     *string                `protobuf:"bytes,11,opt,name=description,proto3,oneof" json:"description,omitempty"`
	Owner           *string                `protobuf:"bytes,12,opt,name=owner,proto3,oneof" json:"owner,omitempty"`
	Validations     []*FeatureValidation   `protobuf:"bytes,13,rep,name=validations,proto3" json:"validations,omitempty"`
	AttributeName   string                 `protobuf:"bytes,14,opt,name=attribute_name,json=attributeName,proto3" json:"attribute_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupByFeatureType) Descriptor deprecated added in v0.13.5 

func (*GroupByFeatureType) Descriptor() ([]byte, []int)

Deprecated: Use GroupByFeatureType.ProtoReflect.Descriptor instead.

func (*GroupByFeatureType) GetAggregation added in v0.13.5 

func (x *GroupByFeatureType) GetAggregation() *WindowAggregation

func (*GroupByFeatureType) GetArrowType added in v0.13.5 

func (x *GroupByFeatureType) GetArrowType() *v11.ArrowType

func (*GroupByFeatureType) GetAttributeName added in v0.13.5 

func (x *GroupByFeatureType) GetAttributeName() string

func (*GroupByFeatureType) GetDefaultValue added in v0.13.5 

func (x *GroupByFeatureType) GetDefaultValue() *v11.ScalarValue

func (*GroupByFeatureType) GetDescription added in v0.13.5 

func (x *GroupByFeatureType) GetDescription() string

func (*GroupByFeatureType) GetExpression added in v0.13.5 

func (x *GroupByFeatureType) GetExpression() *v1.LogicalExprNode

func (*GroupByFeatureType) GetInternalVersion added in v0.13.5 

func (x *GroupByFeatureType) GetInternalVersion() uint64

func (*GroupByFeatureType) GetIsNullable added in v0.13.5 

func (x *GroupByFeatureType) GetIsNullable() bool

func (*GroupByFeatureType) GetName added in v0.13.5 

func (x *GroupByFeatureType) GetName() string

func (*GroupByFeatureType) GetNamespace added in v0.13.5 

func (x *GroupByFeatureType) GetNamespace() string

func (*GroupByFeatureType) GetOwner added in v0.13.5 

func (x *GroupByFeatureType) GetOwner() string

func (*GroupByFeatureType) GetTags added in v0.13.5 

func (x *GroupByFeatureType) GetTags() []string

func (*GroupByFeatureType) GetValidations added in v0.13.5 

func (x *GroupByFeatureType) GetValidations() []*FeatureValidation

func (*GroupByFeatureType) GetWindowDurations added in v0.13.5 

func (x *GroupByFeatureType) GetWindowDurations() []*durationpb.Duration

func (*GroupByFeatureType) ProtoMessage added in v0.13.5 

func (*GroupByFeatureType) ProtoMessage()

func (*GroupByFeatureType) ProtoReflect added in v0.13.5 

func (x *GroupByFeatureType) ProtoReflect() protoreflect.Message

func (*GroupByFeatureType) Reset added in v0.13.5 

func (x *GroupByFeatureType) Reset()

func (*GroupByFeatureType) String added in v0.13.5 

func (x *GroupByFeatureType) String() string

type HasManyFeatureType 

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
}

func (*HasManyFeatureType) Descriptor deprecated 

func (*HasManyFeatureType) Descriptor() ([]byte, []int)

Deprecated: Use HasManyFeatureType.ProtoReflect.Descriptor instead.

func (*HasManyFeatureType) GetAttributeName added in v0.4.7 

func (x *HasManyFeatureType) GetAttributeName() string

func (*HasManyFeatureType) GetDescription 

func (x *HasManyFeatureType) GetDescription() string

func (*HasManyFeatureType) GetForeignNamespace 

func (x *HasManyFeatureType) GetForeignNamespace() string

func (*HasManyFeatureType) GetIsAutogenerated 

func (x *HasManyFeatureType) GetIsAutogenerated() bool

func (*HasManyFeatureType) GetJoin 

func (x *HasManyFeatureType) GetJoin() *v1.LogicalExprNode

func (*HasManyFeatureType) GetMaxStalenessDuration 

func (x *HasManyFeatureType) GetMaxStalenessDuration() *durationpb.Duration

func (*HasManyFeatureType) GetName 

func (x *HasManyFeatureType) GetName() string

func (*HasManyFeatureType) GetNamespace 

func (x *HasManyFeatureType) GetNamespace() string

func (*HasManyFeatureType) GetOwner 

func (x *HasManyFeatureType) GetOwner() string

func (*HasManyFeatureType) GetTags 

func (x *HasManyFeatureType) GetTags() []string

func (*HasManyFeatureType) ProtoMessage 

func (*HasManyFeatureType) ProtoMessage()

func (*HasManyFeatureType) ProtoReflect 

func (x *HasManyFeatureType) ProtoReflect() protoreflect.Message

func (*HasManyFeatureType) Reset 

func (x *HasManyFeatureType) Reset()

func (*HasManyFeatureType) String 

func (x *HasManyFeatureType) String() string

type HasOneFeatureType 

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
}

func (*HasOneFeatureType) Descriptor deprecated 

func (*HasOneFeatureType) Descriptor() ([]byte, []int)

Deprecated: Use HasOneFeatureType.ProtoReflect.Descriptor instead.

func (*HasOneFeatureType) GetAttributeName added in v0.4.7 

func (x *HasOneFeatureType) GetAttributeName() string

func (*HasOneFeatureType) GetDescription 

func (x *HasOneFeatureType) GetDescription() string

func (*HasOneFeatureType) GetForeignNamespace 

func (x *HasOneFeatureType) GetForeignNamespace() string

func (*HasOneFeatureType) GetIsAutogenerated 

func (x *HasOneFeatureType) GetIsAutogenerated() bool

func (*HasOneFeatureType) GetIsNullable 

func (x *HasOneFeatureType) GetIsNullable() bool

func (*HasOneFeatureType) GetJoin 

func (x *HasOneFeatureType) GetJoin() *v1.LogicalExprNode

func (*HasOneFeatureType) GetName 

func (x *HasOneFeatureType) GetName() string

func (*HasOneFeatureType) GetNamespace 

func (x *HasOneFeatureType) GetNamespace() string

func (*HasOneFeatureType) GetOwner 

func (x *HasOneFeatureType) GetOwner() string

func (*HasOneFeatureType) GetTags 

func (x *HasOneFeatureType) GetTags() []string

func (*HasOneFeatureType) ProtoMessage 

func (*HasOneFeatureType) ProtoMessage()

func (*HasOneFeatureType) ProtoReflect 

func (x *HasOneFeatureType) ProtoReflect() protoreflect.Message

func (*HasOneFeatureType) Reset 

func (x *HasOneFeatureType) Reset()

func (*HasOneFeatureType) String 

func (x *HasOneFeatureType) String() string

type KafkaSource 

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
}

func (*KafkaSource) Descriptor deprecated 

func (*KafkaSource) Descriptor() ([]byte, []int)

Deprecated: Use KafkaSource.ProtoReflect.Descriptor instead.

func (*KafkaSource) GetBootstrapServers 

func (x *KafkaSource) GetBootstrapServers() []string

func (*KafkaSource) GetClientIdPrefix 

func (x *KafkaSource) GetClientIdPrefix() string

func (*KafkaSource) GetDeadLetterQueueTopic 

func (x *KafkaSource) GetDeadLetterQueueTopic() string

func (*KafkaSource) GetGroupIdPrefix 

func (x *KafkaSource) GetGroupIdPrefix() string

func (*KafkaSource) GetLateArrivalDeadline 

func (x *KafkaSource) GetLateArrivalDeadline() *durationpb.Duration

func (*KafkaSource) GetName 

func (x *KafkaSource) GetName() string

func (*KafkaSource) GetSaslMechanism 

func (x *KafkaSource) GetSaslMechanism() string

func (*KafkaSource) GetSaslPassword 

func (x *KafkaSource) GetSaslPassword() string

func (*KafkaSource) GetSaslUsername 

func (x *KafkaSource) GetSaslUsername() string

func (*KafkaSource) GetSecurityProtocol 

func (x *KafkaSource) GetSecurityProtocol() string

func (*KafkaSource) GetSslCaFile 

func (x *KafkaSource) GetSslCaFile() string

func (*KafkaSource) GetSslKeystoreLocation 

func (x *KafkaSource) GetSslKeystoreLocation() string

func (*KafkaSource) GetTopic 

func (x *KafkaSource) GetTopic() string

func (*KafkaSource) ProtoMessage 

func (*KafkaSource) ProtoMessage()

func (*KafkaSource) ProtoReflect 

func (x *KafkaSource) ProtoReflect() protoreflect.Message

func (*KafkaSource) Reset 

func (x *KafkaSource) Reset()

func (*KafkaSource) String 

func (x *KafkaSource) String() string

type KinesisSource 

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
}

func (*KinesisSource) Descriptor deprecated 

func (*KinesisSource) Descriptor() ([]byte, []int)

Deprecated: Use KinesisSource.ProtoReflect.Descriptor instead.

func (*KinesisSource) GetAwsAccessKeyId 

func (x *KinesisSource) GetAwsAccessKeyId() string

func (*KinesisSource) GetAwsSecretAccessKey 

func (x *KinesisSource) GetAwsSecretAccessKey() string

func (*KinesisSource) GetAwsSessionToken 

func (x *KinesisSource) GetAwsSessionToken() string

func (*KinesisSource) GetConsumerRoleArn 

func (x *KinesisSource) GetConsumerRoleArn() string

func (*KinesisSource) GetDeadLetterQueueStreamName 

func (x *KinesisSource) GetDeadLetterQueueStreamName() string

func (*KinesisSource) GetEndpointUrl 

func (x *KinesisSource) GetEndpointUrl() string

func (*KinesisSource) GetLateArrivalDeadline 

func (x *KinesisSource) GetLateArrivalDeadline() *durationpb.Duration

func (*KinesisSource) GetName 

func (x *KinesisSource) GetName() string

func (*KinesisSource) GetRegionName 

func (x *KinesisSource) GetRegionName() string

func (*KinesisSource) GetStreamArn 

func (x *KinesisSource) GetStreamArn() string

func (*KinesisSource) GetStreamName 

func (x *KinesisSource) GetStreamName() string

func (*KinesisSource) ProtoMessage 

func (*KinesisSource) ProtoMessage()

func (*KinesisSource) ProtoReflect 

func (x *KinesisSource) ProtoReflect() protoreflect.Message

func (*KinesisSource) Reset 

func (x *KinesisSource) Reset()

func (*KinesisSource) String 

func (x *KinesisSource) String() string

type MySQLSource 

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
}

func (*MySQLSource) Descriptor deprecated 

func (*MySQLSource) Descriptor() ([]byte, []int)

Deprecated: Use MySQLSource.ProtoReflect.Descriptor instead.

func (*MySQLSource) GetAsyncEngineArgs 

func (x *MySQLSource) GetAsyncEngineArgs() map[string]*v1.ScalarValue

func (*MySQLSource) GetDb 

func (x *MySQLSource) GetDb() string

func (*MySQLSource) GetEngineArgs 

func (x *MySQLSource) GetEngineArgs() map[string]*v1.ScalarValue

func (*MySQLSource) GetHost 

func (x *MySQLSource) GetHost() string

func (*MySQLSource) GetName 

func (x *MySQLSource) GetName() string

func (*MySQLSource) GetPassword 

func (x *MySQLSource) GetPassword() string

func (*MySQLSource) GetPort 

func (x *MySQLSource) GetPort() string

func (*MySQLSource) GetUser 

func (x *MySQLSource) GetUser() string

func (*MySQLSource) ProtoMessage 

func (*MySQLSource) ProtoMessage()

func (*MySQLSource) ProtoReflect 

func (x *MySQLSource) ProtoReflect() protoreflect.Message

func (*MySQLSource) Reset 

func (x *MySQLSource) Reset()

func (*MySQLSource) String 

func (x *MySQLSource) String() string

type NamedQuery added in v0.13.1 

type NamedQuery struct {
	Name           string                          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	QueryVersion   *string                         `protobuf:"bytes,2,opt,name=query_version,json=queryVersion,proto3,oneof" json:"query_version,omitempty"`
	Input          []string                        `protobuf:"bytes,3,rep,name=input,proto3" json:"input,omitempty"`
	Output         []string                        `protobuf:"bytes,4,rep,name=output,proto3" json:"output,omitempty"`
	Tags           []string                        `protobuf:"bytes,5,rep,name=tags,proto3" json:"tags,omitempty"`
	Description    *string                         `protobuf:"bytes,6,opt,name=description,proto3,oneof" json:"description,omitempty"`
	Owner          *string                         `protobuf:"bytes,7,opt,name=owner,proto3,oneof" json:"owner,omitempty"`
	Meta           map[string]string               `` /* 149-byte string literal not displayed */
	Staleness      map[string]*durationpb.Duration `` /* 159-byte string literal not displayed */
	PlannerOptions map[string]string               `` /* 192-byte string literal not displayed */
	FileName       string                          `protobuf:"bytes,11,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// required
	DeploymentId        *string              `protobuf:"bytes,12,opt,name=deployment_id,json=deploymentId,proto3,oneof" json:"deployment_id,omitempty"`
	SourceFileReference *SourceFileReference `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NamedQuery) Descriptor deprecated added in v0.13.1 

func (*NamedQuery) Descriptor() ([]byte, []int)

Deprecated: Use NamedQuery.ProtoReflect.Descriptor instead.

func (*NamedQuery) GetDeploymentId added in v0.16.14 

func (x *NamedQuery) GetDeploymentId() string

func (*NamedQuery) GetDescription added in v0.13.1 

func (x *NamedQuery) GetDescription() string

func (*NamedQuery) GetFileName added in v0.13.1 

func (x *NamedQuery) GetFileName() string

func (*NamedQuery) GetInput added in v0.13.4 

func (x *NamedQuery) GetInput() []string

func (*NamedQuery) GetMeta added in v0.13.1 

func (x *NamedQuery) GetMeta() map[string]string

func (*NamedQuery) GetName added in v0.13.1 

func (x *NamedQuery) GetName() string

func (*NamedQuery) GetOutput added in v0.13.4 

func (x *NamedQuery) GetOutput() []string

func (*NamedQuery) GetOwner added in v0.13.1 

func (x *NamedQuery) GetOwner() string

func (*NamedQuery) GetPlannerOptions added in v0.13.1 

func (x *NamedQuery) GetPlannerOptions() map[string]string

func (*NamedQuery) GetQueryVersion added in v0.14.1 

func (x *NamedQuery) GetQueryVersion() string

func (*NamedQuery) GetSourceFileReference added in v0.17.0 

func (x *NamedQuery) GetSourceFileReference() *SourceFileReference

func (*NamedQuery) GetStaleness added in v0.13.1 

func (x *NamedQuery) GetStaleness() map[string]*durationpb.Duration

func (*NamedQuery) GetTags added in v0.13.1 

func (x *NamedQuery) GetTags() []string

func (*NamedQuery) ProtoMessage added in v0.13.1 

func (*NamedQuery) ProtoMessage()

func (*NamedQuery) ProtoReflect added in v0.13.1 

func (x *NamedQuery) ProtoReflect() protoreflect.Message

func (*NamedQuery) Reset added in v0.13.1 

func (x *NamedQuery) Reset()

func (*NamedQuery) String added in v0.13.1 

func (x *NamedQuery) String() string

type ParseInfo 

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
}

func (*ParseInfo) Descriptor deprecated 

func (*ParseInfo) Descriptor() ([]byte, []int)

Deprecated: Use ParseInfo.ProtoReflect.Descriptor instead.

func (*ParseInfo) GetIsParseFunctionOutputOptional 

func (x *ParseInfo) GetIsParseFunctionOutputOptional() bool

func (*ParseInfo) GetParseFunction 

func (x *ParseInfo) GetParseFunction() *FunctionReference

func (*ParseInfo) GetParseFunctionInputType 

func (x *ParseInfo) GetParseFunctionInputType() *v11.ArrowType

func (*ParseInfo) GetParseFunctionOutputType 

func (x *ParseInfo) GetParseFunctionOutputType() *v11.ArrowType

func (*ParseInfo) ProtoMessage 

func (*ParseInfo) ProtoMessage()

func (*ParseInfo) ProtoReflect 

func (x *ParseInfo) ProtoReflect() protoreflect.Message

func (*ParseInfo) Reset 

func (x *ParseInfo) Reset()

func (*ParseInfo) String 

func (x *ParseInfo) String() string

type PostgresSource 

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
}

func (*PostgresSource) Descriptor deprecated 

func (*PostgresSource) Descriptor() ([]byte, []int)

Deprecated: Use PostgresSource.ProtoReflect.Descriptor instead.

func (*PostgresSource) GetAsyncEngineArgs 

func (x *PostgresSource) GetAsyncEngineArgs() map[string]*v1.ScalarValue

func (*PostgresSource) GetDb 

func (x *PostgresSource) GetDb() string

func (*PostgresSource) GetEngineArgs 

func (x *PostgresSource) GetEngineArgs() map[string]*v1.ScalarValue

func (*PostgresSource) GetHost 

func (x *PostgresSource) GetHost() string

func (*PostgresSource) GetName 

func (x *PostgresSource) GetName() string

func (*PostgresSource) GetPassword 

func (x *PostgresSource) GetPassword() string

func (*PostgresSource) GetPort 

func (x *PostgresSource) GetPort() string

func (*PostgresSource) GetUser 

func (x *PostgresSource) GetUser() string

func (*PostgresSource) ProtoMessage 

func (*PostgresSource) ProtoMessage()

func (*PostgresSource) ProtoReflect 

func (x *PostgresSource) ProtoReflect() protoreflect.Message

func (*PostgresSource) Reset 

func (x *PostgresSource) Reset()

func (*PostgresSource) String 

func (x *PostgresSource) String() string

type PubSubSource added in v0.11.8 

type PubSubSource struct {
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ProjectId            string               `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	SubscriptionId       string               `protobuf:"bytes,3,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	LateArrivalDeadline  *durationpb.Duration `protobuf:"bytes,4,opt,name=late_arrival_deadline,json=lateArrivalDeadline,proto3" json:"late_arrival_deadline,omitempty"`
	DeadLetterQueueTopic string               `protobuf:"bytes,5,opt,name=dead_letter_queue_topic,json=deadLetterQueueTopic,proto3" json:"dead_letter_queue_topic,omitempty"`
	// contains filtered or unexported fields
}

func (*PubSubSource) Descriptor deprecated added in v0.11.8 

func (*PubSubSource) Descriptor() ([]byte, []int)

Deprecated: Use PubSubSource.ProtoReflect.Descriptor instead.

func (*PubSubSource) GetDeadLetterQueueTopic added in v0.11.8 

func (x *PubSubSource) GetDeadLetterQueueTopic() string

func (*PubSubSource) GetLateArrivalDeadline added in v0.11.8 

func (x *PubSubSource) GetLateArrivalDeadline() *durationpb.Duration

func (*PubSubSource) GetName added in v0.11.8 

func (x *PubSubSource) GetName() string

func (*PubSubSource) GetProjectId added in v0.11.8 

func (x *PubSubSource) GetProjectId() string

func (*PubSubSource) GetSubscriptionId added in v0.11.8 

func (x *PubSubSource) GetSubscriptionId() string

func (*PubSubSource) ProtoMessage added in v0.11.8 

func (*PubSubSource) ProtoMessage()

func (*PubSubSource) ProtoReflect added in v0.11.8 

func (x *PubSubSource) ProtoReflect() protoreflect.Message

func (*PubSubSource) Reset added in v0.11.8 

func (x *PubSubSource) Reset()

func (*PubSubSource) String added in v0.11.8 

func (x *PubSubSource) String() string

type RedshiftSource 

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 */
	UnloadIamRole   string                     `protobuf:"bytes,11,opt,name=unload_iam_role,json=unloadIamRole,proto3" json:"unload_iam_role,omitempty"`
	// contains filtered or unexported fields
}

func (*RedshiftSource) Descriptor deprecated 

func (*RedshiftSource) Descriptor() ([]byte, []int)

Deprecated: Use RedshiftSource.ProtoReflect.Descriptor instead.

func (*RedshiftSource) GetAsyncEngineArgs 

func (x *RedshiftSource) GetAsyncEngineArgs() map[string]*v1.ScalarValue

func (*RedshiftSource) GetDb 

func (x *RedshiftSource) GetDb() string

func (*RedshiftSource) GetEngineArgs 

func (x *RedshiftSource) GetEngineArgs() map[string]*v1.ScalarValue

func (*RedshiftSource) GetHost 

func (x *RedshiftSource) GetHost() string

func (*RedshiftSource) GetName 

func (x *RedshiftSource) GetName() string

func (*RedshiftSource) GetPassword 

func (x *RedshiftSource) GetPassword() string

func (*RedshiftSource) GetPort 

func (x *RedshiftSource) GetPort() string

func (*RedshiftSource) GetS3Bucket 

func (x *RedshiftSource) GetS3Bucket() string

func (*RedshiftSource) GetS3Client 

func (x *RedshiftSource) GetS3Client() string

func (*RedshiftSource) GetUnloadIamRole added in v0.17.23 

func (x *RedshiftSource) GetUnloadIamRole() string

func (*RedshiftSource) GetUser 

func (x *RedshiftSource) GetUser() string

func (*RedshiftSource) ProtoMessage 

func (*RedshiftSource) ProtoMessage()

func (*RedshiftSource) ProtoReflect 

func (x *RedshiftSource) ProtoReflect() protoreflect.Message

func (*RedshiftSource) Reset 

func (x *RedshiftSource) Reset()

func (*RedshiftSource) String 

func (x *RedshiftSource) String() string

type Resolver 

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"`
	// data_sources is deprecated; see data_sources_v2
	//
	// Deprecated: Marked as deprecated in chalk/graph/v1/graph.proto.
	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"`
	ResourceHint    ResourceHint                  `` /* 132-byte string literal not displayed */
	IsStatic        bool                          `protobuf:"varint,18,opt,name=is_static,json=isStatic,proto3" json:"is_static,omitempty"`
	IsTotal         *bool                         `protobuf:"varint,19,opt,name=is_total,json=isTotal,proto3,oneof" json:"is_total,omitempty"`
	UniqueOn        []string                      `protobuf:"bytes,20,rep,name=unique_on,json=uniqueOn,proto3" json:"unique_on,omitempty"`
	PartitionedBy   []string                      `protobuf:"bytes,21,rep,name=partitioned_by,json=partitionedBy,proto3" json:"partitioned_by,omitempty"`
	DataSourcesV2   []*v2.DatabaseSourceReference `protobuf:"bytes,22,rep,name=data_sources_v2,json=dataSourcesV2,proto3" json:"data_sources_v2,omitempty"`
	StaticOperation *v1.LogicalExprNode           `protobuf:"bytes,23,opt,name=static_operation,json=staticOperation,proto3" json:"static_operation,omitempty"`
	// contains filtered or unexported fields
}

func (*Resolver) Descriptor deprecated 

func (*Resolver) Descriptor() ([]byte, []int)

Deprecated: Use Resolver.ProtoReflect.Descriptor instead.

func (*Resolver) GetCronFilter 

func (x *Resolver) GetCronFilter() *CronFilterWithFeatureArgs

func (*Resolver) GetDataSources deprecated 

func (x *Resolver) GetDataSources() []*DatabaseSourceReference

Deprecated: Marked as deprecated in chalk/graph/v1/graph.proto.

func (*Resolver) GetDataSourcesV2 added in v0.18.14 

func (x *Resolver) GetDataSourcesV2() []*v2.DatabaseSourceReference

func (*Resolver) GetDoc 

func (x *Resolver) GetDoc() string

func (*Resolver) GetEnvironments 

func (x *Resolver) GetEnvironments() []string

func (*Resolver) GetFqn 

func (x *Resolver) GetFqn() string

func (*Resolver) GetFunction 

func (x *Resolver) GetFunction() *FunctionReference

func (*Resolver) GetInputs 

func (x *Resolver) GetInputs() []*ResolverInput

func (*Resolver) GetIsGenerator 

func (x *Resolver) GetIsGenerator() bool

func (*Resolver) GetIsStatic added in v0.14.0 

func (x *Resolver) GetIsStatic() bool

func (*Resolver) GetIsTotal added in v0.14.2 

func (x *Resolver) GetIsTotal() bool

func (*Resolver) GetKind 

func (x *Resolver) GetKind() ResolverKind

func (*Resolver) GetMachineType 

func (x *Resolver) GetMachineType() string

func (*Resolver) GetOutputs 

func (x *Resolver) GetOutputs() []*ResolverOutput

func (*Resolver) GetOwner 

func (x *Resolver) GetOwner() string

func (*Resolver) GetPartitionedBy added in v0.18.14 

func (x *Resolver) GetPartitionedBy() []string

func (*Resolver) GetResourceHint added in v0.13.1 

func (x *Resolver) GetResourceHint() ResourceHint

func (*Resolver) GetSchedule 

func (x *Resolver) GetSchedule() *Schedule

func (*Resolver) GetStaticOperation added in v0.18.19 

func (x *Resolver) GetStaticOperation() *v1.LogicalExprNode

func (*Resolver) GetTags 

func (x *Resolver) GetTags() []string

func (*Resolver) GetTimeoutDuration 

func (x *Resolver) GetTimeoutDuration() *durationpb.Duration

func (*Resolver) GetUniqueOn added in v0.18.14 

func (x *Resolver) GetUniqueOn() []string

func (*Resolver) GetWhen 

func (x *Resolver) GetWhen() *v1.LogicalExprNode

func (*Resolver) ProtoMessage 

func (*Resolver) ProtoMessage()

func (*Resolver) ProtoReflect 

func (x *Resolver) ProtoReflect() protoreflect.Message

func (*Resolver) Reset 

func (x *Resolver) Reset()

func (*Resolver) String 

func (x *Resolver) String() string

type ResolverInput 

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
}

func (*ResolverInput) Descriptor deprecated 

func (*ResolverInput) Descriptor() ([]byte, []int)

Deprecated: Use ResolverInput.ProtoReflect.Descriptor instead.

func (*ResolverInput) GetAnnotation 

func (m *ResolverInput) GetAnnotation() isResolverInput_Annotation

func (*ResolverInput) GetDf 

func (x *ResolverInput) GetDf() *DataFrameType

func (*ResolverInput) GetFeature 

func (x *ResolverInput) GetFeature() *FeatureInput

func (*ResolverInput) GetState 

func (x *ResolverInput) GetState() *ResolverState

func (*ResolverInput) ProtoMessage 

func (*ResolverInput) ProtoMessage()

func (*ResolverInput) ProtoReflect 

func (x *ResolverInput) ProtoReflect() protoreflect.Message

func (*ResolverInput) Reset 

func (x *ResolverInput) Reset()

func (*ResolverInput) String 

func (x *ResolverInput) String() string

type ResolverInput_Df 

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

type ResolverInput_Feature 

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

type ResolverInput_State 

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

type ResolverKind 

type ResolverKind int32
const (
	ResolverKind_RESOLVER_KIND_UNSPECIFIED ResolverKind = 0
	ResolverKind_RESOLVER_KIND_ONLINE      ResolverKind = 1
	ResolverKind_RESOLVER_KIND_OFFLINE     ResolverKind = 2
)

func (ResolverKind) Descriptor 

func (ResolverKind) Descriptor() protoreflect.EnumDescriptor

func (ResolverKind) Enum 

func (x ResolverKind) Enum() *ResolverKind

func (ResolverKind) EnumDescriptor deprecated 

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

Deprecated: Use ResolverKind.Descriptor instead.

func (ResolverKind) Number 

func (x ResolverKind) Number() protoreflect.EnumNumber

func (ResolverKind) String 

func (x ResolverKind) String() string

func (ResolverKind) Type 

func (ResolverKind) Type() protoreflect.EnumType

type ResolverOutput 

type ResolverOutput struct {

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

func (*ResolverOutput) Descriptor deprecated 

func (*ResolverOutput) Descriptor() ([]byte, []int)

Deprecated: Use ResolverOutput.ProtoReflect.Descriptor instead.

func (*ResolverOutput) GetAnnotation 

func (m *ResolverOutput) GetAnnotation() isResolverOutput_Annotation

func (*ResolverOutput) GetDf 

func (x *ResolverOutput) GetDf() *DataFrameType

func (*ResolverOutput) GetFeature 

func (x *ResolverOutput) GetFeature() *FeatureReference

func (*ResolverOutput) ProtoMessage 

func (*ResolverOutput) ProtoMessage()

func (*ResolverOutput) ProtoReflect 

func (x *ResolverOutput) ProtoReflect() protoreflect.Message

func (*ResolverOutput) Reset 

func (x *ResolverOutput) Reset()

func (*ResolverOutput) String 

func (x *ResolverOutput) String() string

type ResolverOutput_Df 

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

type ResolverOutput_Feature 

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

type ResolverState 

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
}

func (*ResolverState) Descriptor deprecated 

func (*ResolverState) Descriptor() ([]byte, []int)

Deprecated: Use ResolverState.ProtoReflect.Descriptor instead.

func (*ResolverState) GetArrowType 

func (x *ResolverState) GetArrowType() *v11.ArrowType

func (*ResolverState) GetInitial 

func (x *ResolverState) GetInitial() *v11.ScalarValue

func (*ResolverState) ProtoMessage 

func (*ResolverState) ProtoMessage()

func (*ResolverState) ProtoReflect 

func (x *ResolverState) ProtoReflect() protoreflect.Message

func (*ResolverState) Reset 

func (x *ResolverState) Reset()

func (*ResolverState) String 

func (x *ResolverState) String() string

type ResourceHint added in v0.13.1 

type ResourceHint int32
const (
	ResourceHint_RESOURCE_HINT_UNSPECIFIED ResourceHint = 0
	ResourceHint_RESOURCE_HINT_CPU         ResourceHint = 1
	ResourceHint_RESOURCE_HINT_IO          ResourceHint = 2
)

func (ResourceHint) Descriptor added in v0.13.1 

func (ResourceHint) Descriptor() protoreflect.EnumDescriptor

func (ResourceHint) Enum added in v0.13.1 

func (x ResourceHint) Enum() *ResourceHint

func (ResourceHint) EnumDescriptor deprecated added in v0.13.1 

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

Deprecated: Use ResourceHint.Descriptor instead.

func (ResourceHint) Number added in v0.13.1 

func (x ResourceHint) Number() protoreflect.EnumNumber

func (ResourceHint) String added in v0.13.1 

func (x ResourceHint) String() string

func (ResourceHint) Type added in v0.13.1 

func (ResourceHint) Type() protoreflect.EnumType

type SQLiteSource 

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
}

func (*SQLiteSource) Descriptor deprecated 

func (*SQLiteSource) Descriptor() ([]byte, []int)

Deprecated: Use SQLiteSource.ProtoReflect.Descriptor instead.

func (*SQLiteSource) GetAsyncEngineArgs 

func (x *SQLiteSource) GetAsyncEngineArgs() map[string]*v1.ScalarValue

func (*SQLiteSource) GetEngineArgs 

func (x *SQLiteSource) GetEngineArgs() map[string]*v1.ScalarValue

func (*SQLiteSource) GetFileName 

func (x *SQLiteSource) GetFileName() string

func (*SQLiteSource) GetName 

func (x *SQLiteSource) GetName() string

func (*SQLiteSource) ProtoMessage 

func (*SQLiteSource) ProtoMessage()

func (*SQLiteSource) ProtoReflect 

func (x *SQLiteSource) ProtoReflect() protoreflect.Message

func (*SQLiteSource) Reset 

func (x *SQLiteSource) Reset()

func (*SQLiteSource) String 

func (x *SQLiteSource) String() string

type ScalarFeatureType 

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"`
	// Whether the user marked the feature as deprecated.
	IsDeprecated  bool          `protobuf:"varint,24,opt,name=is_deprecated,json=isDeprecated,proto3" json:"is_deprecated,omitempty"`
	CacheStrategy CacheStrategy `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ScalarFeatureType) Descriptor deprecated 

func (*ScalarFeatureType) Descriptor() ([]byte, []int)

Deprecated: Use ScalarFeatureType.ProtoReflect.Descriptor instead.

func (*ScalarFeatureType) GetArrowType 

func (x *ScalarFeatureType) GetArrowType() *v11.ArrowType

func (*ScalarFeatureType) GetAttributeName added in v0.4.7 

func (x *ScalarFeatureType) GetAttributeName() string

func (*ScalarFeatureType) GetCacheStrategy added in v0.17.2 

func (x *ScalarFeatureType) GetCacheStrategy() CacheStrategy

func (*ScalarFeatureType) GetDefaultValue 

func (x *ScalarFeatureType) GetDefaultValue() *v11.ScalarValue

func (*ScalarFeatureType) GetDescription 

func (x *ScalarFeatureType) GetDescription() string

func (*ScalarFeatureType) GetEtlOfflineToOnline 

func (x *ScalarFeatureType) GetEtlOfflineToOnline() bool

func (*ScalarFeatureType) GetExpression 

func (x *ScalarFeatureType) GetExpression() *v1.LogicalExprNode

func (*ScalarFeatureType) GetInternalVersion 

func (x *ScalarFeatureType) GetInternalVersion() uint64

func (*ScalarFeatureType) GetIsAutogenerated 

func (x *ScalarFeatureType) GetIsAutogenerated() bool

func (*ScalarFeatureType) GetIsDeprecated added in v0.17.0 

func (x *ScalarFeatureType) GetIsDeprecated() bool

func (*ScalarFeatureType) GetIsDistancePseudofeature 

func (x *ScalarFeatureType) GetIsDistancePseudofeature() bool

func (*ScalarFeatureType) GetIsNullable 

func (x *ScalarFeatureType) GetIsNullable() bool

func (*ScalarFeatureType) GetIsPrimary 

func (x *ScalarFeatureType) GetIsPrimary() bool

func (*ScalarFeatureType) GetLastFor 

func (x *ScalarFeatureType) GetLastFor() *FeatureReference

func (*ScalarFeatureType) GetMaxStalenessDuration 

func (x *ScalarFeatureType) GetMaxStalenessDuration() *durationpb.Duration

func (*ScalarFeatureType) GetName 

func (x *ScalarFeatureType) GetName() string

func (*ScalarFeatureType) GetNamespace 

func (x *ScalarFeatureType) GetNamespace() string

func (*ScalarFeatureType) GetNoDisplay 

func (x *ScalarFeatureType) GetNoDisplay() bool

func (*ScalarFeatureType) GetOfflineTtlDuration 

func (x *ScalarFeatureType) GetOfflineTtlDuration() *durationpb.Duration

func (*ScalarFeatureType) GetOwner 

func (x *ScalarFeatureType) GetOwner() string

func (*ScalarFeatureType) GetTags 

func (x *ScalarFeatureType) GetTags() []string

func (*ScalarFeatureType) GetValidations 

func (x *ScalarFeatureType) GetValidations() []*FeatureValidation

func (*ScalarFeatureType) GetVersion 

func (x *ScalarFeatureType) GetVersion() *VersionInfo

func (*ScalarFeatureType) GetWindowInfo 

func (x *ScalarFeatureType) GetWindowInfo() *WindowInfo

func (*ScalarFeatureType) ProtoMessage 

func (*ScalarFeatureType) ProtoMessage()

func (*ScalarFeatureType) ProtoReflect 

func (x *ScalarFeatureType) ProtoReflect() protoreflect.Message

func (*ScalarFeatureType) Reset 

func (x *ScalarFeatureType) Reset()

func (*ScalarFeatureType) String 

func (x *ScalarFeatureType) String() string

type Schedule 

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
}

func (*Schedule) Descriptor deprecated 

func (*Schedule) Descriptor() ([]byte, []int)

Deprecated: Use Schedule.ProtoReflect.Descriptor instead.

func (*Schedule) GetCrontab 

func (x *Schedule) GetCrontab() string

func (*Schedule) GetDuration 

func (x *Schedule) GetDuration() *durationpb.Duration

func (*Schedule) GetFilter 

func (x *Schedule) GetFilter() *FunctionReference

func (*Schedule) GetSample 

func (x *Schedule) GetSample() *FunctionReference

func (*Schedule) GetSchedule 

func (m *Schedule) GetSchedule() isSchedule_Schedule

func (*Schedule) ProtoMessage 

func (*Schedule) ProtoMessage()

func (*Schedule) ProtoReflect 

func (x *Schedule) ProtoReflect() protoreflect.Message

func (*Schedule) Reset 

func (x *Schedule) Reset()

func (*Schedule) String 

func (x *Schedule) String() string

type Schedule_Crontab 

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

type Schedule_Duration 

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

type SinkResolver 

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
	//	*SinkResolver_StreamSourceV2
	//	*SinkResolver_DatabaseSourceV2
	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
}

func (*SinkResolver) Descriptor deprecated 

func (*SinkResolver) Descriptor() ([]byte, []int)

Deprecated: Use SinkResolver.ProtoReflect.Descriptor instead.

func (*SinkResolver) GetBufferSize 

func (x *SinkResolver) GetBufferSize() uint64

func (*SinkResolver) GetDatabaseSource deprecated 

func (x *SinkResolver) GetDatabaseSource() *DatabaseSourceReference

Deprecated: Marked as deprecated in chalk/graph/v1/graph.proto.

func (*SinkResolver) GetDatabaseSourceV2 added in v0.18.14 

func (x *SinkResolver) GetDatabaseSourceV2() *v2.DatabaseSourceReference

func (*SinkResolver) GetDebounceDuration 

func (x *SinkResolver) GetDebounceDuration() *durationpb.Duration

func (*SinkResolver) GetDoc 

func (x *SinkResolver) GetDoc() string

func (*SinkResolver) GetEnvironments 

func (x *SinkResolver) GetEnvironments() []string

func (*SinkResolver) GetFqn 

func (x *SinkResolver) GetFqn() string

func (*SinkResolver) GetFunction 

func (x *SinkResolver) GetFunction() *FunctionReference

func (*SinkResolver) GetInputs 

func (x *SinkResolver) GetInputs() []*ResolverInput

func (*SinkResolver) GetIntegration 

func (m *SinkResolver) GetIntegration() isSinkResolver_Integration

func (*SinkResolver) GetMachineType 

func (x *SinkResolver) GetMachineType() string

func (*SinkResolver) GetMaxDelayDuration 

func (x *SinkResolver) GetMaxDelayDuration() *durationpb.Duration

func (*SinkResolver) GetOwner 

func (x *SinkResolver) GetOwner() string

func (*SinkResolver) GetStreamSource deprecated 

func (x *SinkResolver) GetStreamSource() *StreamSourceReference

Deprecated: Marked as deprecated in chalk/graph/v1/graph.proto.

func (*SinkResolver) GetStreamSourceV2 added in v0.18.14 

func (x *SinkResolver) GetStreamSourceV2() *v2.StreamSourceReference

func (*SinkResolver) GetTimeoutDuration 

func (x *SinkResolver) GetTimeoutDuration() *durationpb.Duration

func (*SinkResolver) GetUpsert 

func (x *SinkResolver) GetUpsert() bool

func (*SinkResolver) ProtoMessage 

func (*SinkResolver) ProtoMessage()

func (*SinkResolver) ProtoReflect 

func (x *SinkResolver) ProtoReflect() protoreflect.Message

func (*SinkResolver) Reset 

func (x *SinkResolver) Reset()

func (*SinkResolver) String 

func (x *SinkResolver) String() string

type SinkResolver_DatabaseSource 

type SinkResolver_DatabaseSource struct {
	// database_source is deprecated; see database_source_v2
	//
	// Deprecated: Marked as deprecated in chalk/graph/v1/graph.proto.
	DatabaseSource *DatabaseSourceReference `protobuf:"bytes,8,opt,name=database_source,json=databaseSource,proto3,oneof"`
}

type SinkResolver_DatabaseSourceV2 added in v0.18.14 

type SinkResolver_DatabaseSourceV2 struct {
	DatabaseSourceV2 *v2.DatabaseSourceReference `protobuf:"bytes,16,opt,name=database_source_v2,json=databaseSourceV2,proto3,oneof"`
}

type SinkResolver_StreamSource 

type SinkResolver_StreamSource struct {
	// stream_source is deprecated; see stream_source_v2
	//
	// Deprecated: Marked as deprecated in chalk/graph/v1/graph.proto.
	StreamSource *StreamSourceReference `protobuf:"bytes,7,opt,name=stream_source,json=streamSource,proto3,oneof"`
}

type SinkResolver_StreamSourceV2 added in v0.18.14 

type SinkResolver_StreamSourceV2 struct {
	StreamSourceV2 *v2.StreamSourceReference `protobuf:"bytes,15,opt,name=stream_source_v2,json=streamSourceV2,proto3,oneof"`
}

type SnowflakeSource 

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 */
	PrivateKeyB64     string                     `protobuf:"bytes,11,opt,name=private_key_b64,json=privateKeyB64,proto3" json:"private_key_b64,omitempty"`
	// contains filtered or unexported fields
}

func (*SnowflakeSource) Descriptor deprecated 

func (*SnowflakeSource) Descriptor() ([]byte, []int)

Deprecated: Use SnowflakeSource.ProtoReflect.Descriptor instead.

func (*SnowflakeSource) GetAccountIdentifier 

func (x *SnowflakeSource) GetAccountIdentifier() string

func (*SnowflakeSource) GetAsyncEngineArgs 

func (x *SnowflakeSource) GetAsyncEngineArgs() map[string]*v1.ScalarValue

func (*SnowflakeSource) GetDb 

func (x *SnowflakeSource) GetDb() string

func (*SnowflakeSource) GetEngineArgs 

func (x *SnowflakeSource) GetEngineArgs() map[string]*v1.ScalarValue

func (*SnowflakeSource) GetName 

func (x *SnowflakeSource) GetName() string

func (*SnowflakeSource) GetPassword 

func (x *SnowflakeSource) GetPassword() string

func (*SnowflakeSource) GetPrivateKeyB64 added in v0.10.2 

func (x *SnowflakeSource) GetPrivateKeyB64() string

func (*SnowflakeSource) GetRole 

func (x *SnowflakeSource) GetRole() string

func (*SnowflakeSource) GetSchema 

func (x *SnowflakeSource) GetSchema() string

func (*SnowflakeSource) GetUser 

func (x *SnowflakeSource) GetUser() string

func (*SnowflakeSource) GetWarehouse 

func (x *SnowflakeSource) GetWarehouse() string

func (*SnowflakeSource) ProtoMessage 

func (*SnowflakeSource) ProtoMessage()

func (*SnowflakeSource) ProtoReflect 

func (x *SnowflakeSource) ProtoReflect() protoreflect.Message

func (*SnowflakeSource) Reset 

func (x *SnowflakeSource) Reset()

func (*SnowflakeSource) String 

func (x *SnowflakeSource) String() string

type SourceFileReference added in v0.17.0 

type SourceFileReference struct {
	Range    *v12.Range `protobuf:"bytes,1,opt,name=range,proto3" json:"range,omitempty"`
	Code     *string    `protobuf:"bytes,2,opt,name=code,proto3,oneof" json:"code,omitempty"`
	FileName string     `protobuf:"bytes,3,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceFileReference) Descriptor deprecated added in v0.17.0 

func (*SourceFileReference) Descriptor() ([]byte, []int)

Deprecated: Use SourceFileReference.ProtoReflect.Descriptor instead.

func (*SourceFileReference) GetCode added in v0.17.0 

func (x *SourceFileReference) GetCode() string

func (*SourceFileReference) GetFileName added in v0.17.0 

func (x *SourceFileReference) GetFileName() string

func (*SourceFileReference) GetRange added in v0.17.0 

func (x *SourceFileReference) GetRange() *v12.Range

func (*SourceFileReference) ProtoMessage added in v0.17.0 

func (*SourceFileReference) ProtoMessage()

func (*SourceFileReference) ProtoReflect added in v0.17.0 

func (x *SourceFileReference) ProtoReflect() protoreflect.Message

func (*SourceFileReference) Reset added in v0.17.0 

func (x *SourceFileReference) Reset()

func (*SourceFileReference) String added in v0.17.0 

func (x *SourceFileReference) String() string

type SpannerSource added in v0.8.0 

type SpannerSource 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"`
	Instance          string                     `protobuf:"bytes,3,opt,name=instance,proto3" json:"instance,omitempty"`
	Db                string                     `protobuf:"bytes,4,opt,name=db,proto3" json:"db,omitempty"`
	CredentialsBase64 string                     `protobuf:"bytes,5,opt,name=credentials_base64,json=credentialsBase64,proto3" json:"credentials_base64,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
}

func (*SpannerSource) Descriptor deprecated added in v0.8.0 

func (*SpannerSource) Descriptor() ([]byte, []int)

Deprecated: Use SpannerSource.ProtoReflect.Descriptor instead.

func (*SpannerSource) GetAsyncEngineArgs added in v0.8.0 

func (x *SpannerSource) GetAsyncEngineArgs() map[string]*v1.ScalarValue

func (*SpannerSource) GetCredentialsBase64 added in v0.8.0 

func (x *SpannerSource) GetCredentialsBase64() string

func (*SpannerSource) GetDb added in v0.8.0 

func (x *SpannerSource) GetDb() string

func (*SpannerSource) GetEngineArgs added in v0.8.0 

func (x *SpannerSource) GetEngineArgs() map[string]*v1.ScalarValue

func (*SpannerSource) GetInstance added in v0.8.0 

func (x *SpannerSource) GetInstance() string

func (*SpannerSource) GetName added in v0.8.0 

func (x *SpannerSource) GetName() string

func (*SpannerSource) GetProject added in v0.8.0 

func (x *SpannerSource) GetProject() string

func (*SpannerSource) ProtoMessage added in v0.8.0 

func (*SpannerSource) ProtoMessage()

func (*SpannerSource) ProtoReflect added in v0.8.0 

func (x *SpannerSource) ProtoReflect() protoreflect.Message

func (*SpannerSource) Reset added in v0.8.0 

func (x *SpannerSource) Reset()

func (*SpannerSource) String added in v0.8.0 

func (x *SpannerSource) String() string

type StreamKey 

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
}

func (*StreamKey) Descriptor deprecated 

func (*StreamKey) Descriptor() ([]byte, []int)

Deprecated: Use StreamKey.ProtoReflect.Descriptor instead.

func (*StreamKey) GetFeature 

func (x *StreamKey) GetFeature() *FeatureReference

func (*StreamKey) GetKey 

func (x *StreamKey) GetKey() string

func (*StreamKey) ProtoMessage 

func (*StreamKey) ProtoMessage()

func (*StreamKey) ProtoReflect 

func (x *StreamKey) ProtoReflect() protoreflect.Message

func (*StreamKey) Reset 

func (x *StreamKey) Reset()

func (*StreamKey) String 

func (x *StreamKey) String() string

type StreamResolver 

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"`
	// Deprecated: Marked as deprecated in chalk/graph/v1/graph.proto.
	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"`
	SourceV2               *v2.StreamSourceReference `protobuf:"bytes,16,opt,name=source_v2,json=sourceV2,proto3" json:"source_v2,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamResolver) Descriptor deprecated 

func (*StreamResolver) Descriptor() ([]byte, []int)

Deprecated: Use StreamResolver.ProtoReflect.Descriptor instead.

func (*StreamResolver) GetDoc 

func (x *StreamResolver) GetDoc() string

func (*StreamResolver) GetEnvironments 

func (x *StreamResolver) GetEnvironments() []string

func (*StreamResolver) GetExplicitSchema 

func (x *StreamResolver) GetExplicitSchema() *v11.ArrowType

func (*StreamResolver) GetFqn 

func (x *StreamResolver) GetFqn() string

func (*StreamResolver) GetFunction 

func (x *StreamResolver) GetFunction() *FunctionReference

func (*StreamResolver) GetKeys 

func (x *StreamResolver) GetKeys() []*StreamKey

func (*StreamResolver) GetMachineType 

func (x *StreamResolver) GetMachineType() string

func (*StreamResolver) GetMode 

func (x *StreamResolver) GetMode() WindowMode

func (*StreamResolver) GetOutputs 

func (x *StreamResolver) GetOutputs() []*ResolverOutput

func (*StreamResolver) GetOwner 

func (x *StreamResolver) GetOwner() string

func (*StreamResolver) GetParams 

func (x *StreamResolver) GetParams() []*StreamResolverParam

func (*StreamResolver) GetParseInfo 

func (x *StreamResolver) GetParseInfo() *ParseInfo

func (*StreamResolver) GetSource deprecated 

func (x *StreamResolver) GetSource() *StreamSourceReference

Deprecated: Marked as deprecated in chalk/graph/v1/graph.proto.

func (*StreamResolver) GetSourceV2 added in v0.18.14 

func (x *StreamResolver) GetSourceV2() *v2.StreamSourceReference

func (*StreamResolver) GetTimeoutDuration 

func (x *StreamResolver) GetTimeoutDuration() *durationpb.Duration

func (*StreamResolver) GetTimestampAttributeName 

func (x *StreamResolver) GetTimestampAttributeName() string

func (*StreamResolver) ProtoMessage 

func (*StreamResolver) ProtoMessage()

func (*StreamResolver) ProtoReflect 

func (x *StreamResolver) ProtoReflect() protoreflect.Message

func (*StreamResolver) Reset 

func (x *StreamResolver) Reset()

func (*StreamResolver) String 

func (x *StreamResolver) String() string

type StreamResolverParam 

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
}

func (*StreamResolverParam) Descriptor deprecated 

func (*StreamResolverParam) Descriptor() ([]byte, []int)

Deprecated: Use StreamResolverParam.ProtoReflect.Descriptor instead.

func (*StreamResolverParam) GetMessage 

func (x *StreamResolverParam) GetMessage() *StreamResolverParamMessage

func (*StreamResolverParam) GetMessageWindow 

func (x *StreamResolverParam) GetMessageWindow() *StreamResolverParamMessageWindow

func (*StreamResolverParam) GetState 

func (x *StreamResolverParam) GetState() *ResolverState

func (*StreamResolverParam) GetType 

func (m *StreamResolverParam) GetType() isStreamResolverParam_Type

func (*StreamResolverParam) ProtoMessage 

func (*StreamResolverParam) ProtoMessage()

func (*StreamResolverParam) ProtoReflect 

func (x *StreamResolverParam) ProtoReflect() protoreflect.Message

func (*StreamResolverParam) Reset 

func (x *StreamResolverParam) Reset()

func (*StreamResolverParam) String 

func (x *StreamResolverParam) String() string

type StreamResolverParamMessage 

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
}

func (*StreamResolverParamMessage) Descriptor deprecated 

func (*StreamResolverParamMessage) Descriptor() ([]byte, []int)

Deprecated: Use StreamResolverParamMessage.ProtoReflect.Descriptor instead.

func (*StreamResolverParamMessage) GetArrowType 

func (x *StreamResolverParamMessage) GetArrowType() *v11.ArrowType

func (*StreamResolverParamMessage) GetName 

func (x *StreamResolverParamMessage) GetName() string

func (*StreamResolverParamMessage) ProtoMessage 

func (*StreamResolverParamMessage) ProtoMessage()

func (*StreamResolverParamMessage) ProtoReflect 

func (x *StreamResolverParamMessage) ProtoReflect() protoreflect.Message

func (*StreamResolverParamMessage) Reset 

func (x *StreamResolverParamMessage) Reset()

func (*StreamResolverParamMessage) String 

func (x *StreamResolverParamMessage) String() string

type StreamResolverParamMessageWindow 

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
}

func (*StreamResolverParamMessageWindow) Descriptor deprecated 

func (*StreamResolverParamMessageWindow) Descriptor() ([]byte, []int)

Deprecated: Use StreamResolverParamMessageWindow.ProtoReflect.Descriptor instead.

func (*StreamResolverParamMessageWindow) GetArrowType 

func (x *StreamResolverParamMessageWindow) GetArrowType() *v11.ArrowType

func (*StreamResolverParamMessageWindow) GetName 

func (x *StreamResolverParamMessageWindow) GetName() string

func (*StreamResolverParamMessageWindow) ProtoMessage 

func (*StreamResolverParamMessageWindow) ProtoMessage()

func (*StreamResolverParamMessageWindow) ProtoReflect 

func (x *StreamResolverParamMessageWindow) ProtoReflect() protoreflect.Message

func (*StreamResolverParamMessageWindow) Reset 

func (x *StreamResolverParamMessageWindow) Reset()

func (*StreamResolverParamMessageWindow) String 

func (x *StreamResolverParamMessageWindow) String() string

type StreamResolverParam_Message 

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

type StreamResolverParam_MessageWindow 

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

type StreamResolverParam_State 

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

type StreamSource 

type StreamSource struct {

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

func (*StreamSource) Descriptor deprecated 

func (*StreamSource) Descriptor() ([]byte, []int)

Deprecated: Use StreamSource.ProtoReflect.Descriptor instead.

func (*StreamSource) GetKafka 

func (x *StreamSource) GetKafka() *KafkaSource

func (*StreamSource) GetKinesis 

func (x *StreamSource) GetKinesis() *KinesisSource

func (*StreamSource) GetPubsub added in v0.11.8 

func (x *StreamSource) GetPubsub() *PubSubSource

func (*StreamSource) GetSource 

func (m *StreamSource) GetSource() isStreamSource_Source

func (*StreamSource) ProtoMessage 

func (*StreamSource) ProtoMessage()

func (*StreamSource) ProtoReflect 

func (x *StreamSource) ProtoReflect() protoreflect.Message

func (*StreamSource) Reset 

func (x *StreamSource) Reset()

func (*StreamSource) String 

func (x *StreamSource) String() string

type StreamSourceReference 

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
}

func (*StreamSourceReference) Descriptor deprecated 

func (*StreamSourceReference) Descriptor() ([]byte, []int)

Deprecated: Use StreamSourceReference.ProtoReflect.Descriptor instead.

func (*StreamSourceReference) GetName 

func (x *StreamSourceReference) GetName() string

func (*StreamSourceReference) GetType 

func (x *StreamSourceReference) GetType() StreamSourceType

func (*StreamSourceReference) ProtoMessage 

func (*StreamSourceReference) ProtoMessage()

func (*StreamSourceReference) ProtoReflect 

func (x *StreamSourceReference) ProtoReflect() protoreflect.Message

func (*StreamSourceReference) Reset 

func (x *StreamSourceReference) Reset()

func (*StreamSourceReference) String 

func (x *StreamSourceReference) String() string

type StreamSourceType 

type StreamSourceType int32
const (
	StreamSourceType_STREAM_SOURCE_TYPE_UNSPECIFIED StreamSourceType = 0
	StreamSourceType_STREAM_SOURCE_TYPE_KAFKA       StreamSourceType = 1
	StreamSourceType_STREAM_SOURCE_TYPE_KINESIS     StreamSourceType = 2
	StreamSourceType_STREAM_SOURCE_TYPE_PUBSUB      StreamSourceType = 3
)

func (StreamSourceType) Descriptor 

func (StreamSourceType) Descriptor() protoreflect.EnumDescriptor

func (StreamSourceType) Enum 

func (x StreamSourceType) Enum() *StreamSourceType

func (StreamSourceType) EnumDescriptor deprecated 

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

Deprecated: Use StreamSourceType.Descriptor instead.

func (StreamSourceType) Number 

func (x StreamSourceType) Number() protoreflect.EnumNumber

func (StreamSourceType) String 

func (x StreamSourceType) String() string

func (StreamSourceType) Type 

func (StreamSourceType) Type() protoreflect.EnumType

type StreamSource_Kafka 

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

type StreamSource_Kinesis 

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

type StreamSource_Pubsub added in v0.11.8 

type StreamSource_Pubsub struct {
	Pubsub *PubSubSource `protobuf:"bytes,3,opt,name=pubsub,proto3,oneof"`
}

type StrictValidation 

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
}

func (*StrictValidation) Descriptor deprecated 

func (*StrictValidation) Descriptor() ([]byte, []int)

Deprecated: Use StrictValidation.ProtoReflect.Descriptor instead.

func (*StrictValidation) GetFeature 

func (x *StrictValidation) GetFeature() *FeatureReference

func (*StrictValidation) GetValidations 

func (x *StrictValidation) GetValidations() []*FeatureValidation

func (*StrictValidation) ProtoMessage 

func (*StrictValidation) ProtoMessage()

func (*StrictValidation) ProtoReflect 

func (x *StrictValidation) ProtoReflect() protoreflect.Message

func (*StrictValidation) Reset 

func (x *StrictValidation) Reset()

func (*StrictValidation) String 

func (x *StrictValidation) String() string

type TrinoSource added in v0.8.1 

type TrinoSource 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"`
	Catalog         string                     `protobuf:"bytes,4,opt,name=catalog,proto3" json:"catalog,omitempty"`
	Schema          string                     `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
	User            string                     `protobuf:"bytes,6,opt,name=user,proto3" json:"user,omitempty"`
	Password        string                     `protobuf:"bytes,7,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
}

func (*TrinoSource) Descriptor deprecated added in v0.8.1 

func (*TrinoSource) Descriptor() ([]byte, []int)

Deprecated: Use TrinoSource.ProtoReflect.Descriptor instead.

func (*TrinoSource) GetAsyncEngineArgs added in v0.8.1 

func (x *TrinoSource) GetAsyncEngineArgs() map[string]*v1.ScalarValue

func (*TrinoSource) GetCatalog added in v0.8.1 

func (x *TrinoSource) GetCatalog() string

func (*TrinoSource) GetEngineArgs added in v0.8.1 

func (x *TrinoSource) GetEngineArgs() map[string]*v1.ScalarValue

func (*TrinoSource) GetHost added in v0.8.1 

func (x *TrinoSource) GetHost() string

func (*TrinoSource) GetName added in v0.8.1 

func (x *TrinoSource) GetName() string

func (*TrinoSource) GetPassword added in v0.8.1 

func (x *TrinoSource) GetPassword() string

func (*TrinoSource) GetPort added in v0.8.1 

func (x *TrinoSource) GetPort() string

func (*TrinoSource) GetSchema added in v0.8.1 

func (x *TrinoSource) GetSchema() string

func (*TrinoSource) GetUser added in v0.8.1 

func (x *TrinoSource) GetUser() string

func (*TrinoSource) ProtoMessage added in v0.8.1 

func (*TrinoSource) ProtoMessage()

func (*TrinoSource) ProtoReflect added in v0.8.1 

func (x *TrinoSource) ProtoReflect() protoreflect.Message

func (*TrinoSource) Reset added in v0.8.1 

func (x *TrinoSource) Reset()

func (*TrinoSource) String added in v0.8.1 

func (x *TrinoSource) String() string

type VersionInfo 

type VersionInfo struct {
	Default uint32 `protobuf:"varint,1,opt,name=default,proto3" json:"default,omitempty"`
	Maximum uint32 `protobuf:"varint,2,opt,name=maximum,proto3" json:"maximum,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionInfo) Descriptor deprecated 

func (*VersionInfo) Descriptor() ([]byte, []int)

Deprecated: Use VersionInfo.ProtoReflect.Descriptor instead.

func (*VersionInfo) GetDefault 

func (x *VersionInfo) GetDefault() uint32

func (*VersionInfo) GetMaximum 

func (x *VersionInfo) GetMaximum() uint32

func (*VersionInfo) ProtoMessage 

func (*VersionInfo) ProtoMessage()

func (*VersionInfo) ProtoReflect 

func (x *VersionInfo) ProtoReflect() protoreflect.Message

func (*VersionInfo) Reset 

func (x *VersionInfo) Reset()

func (*VersionInfo) String 

func (x *VersionInfo) String() string

type WindowAggregation added in v0.13.1 

type WindowAggregation struct {
	Namespace      string                `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	GroupBy        []*FeatureReference   `protobuf:"bytes,2,rep,name=group_by,json=groupBy,proto3" json:"group_by,omitempty"`
	BucketDuration *durationpb.Duration  `protobuf:"bytes,3,opt,name=bucket_duration,json=bucketDuration,proto3" json:"bucket_duration,omitempty"`
	Aggregation    string                `protobuf:"bytes,4,opt,name=aggregation,proto3" json:"aggregation,omitempty"`
	AggregateOn    *FeatureReference     `protobuf:"bytes,5,opt,name=aggregate_on,json=aggregateOn,proto3,oneof" json:"aggregate_on,omitempty"`
	ArrowType      *v11.ArrowType        `protobuf:"bytes,6,opt,name=arrow_type,json=arrowType,proto3" json:"arrow_type,omitempty"`
	Filters        []*v1.LogicalExprNode `protobuf:"bytes,7,rep,name=filters,proto3" json:"filters,omitempty"`
	// The resolver to use for back-filling the materialized aggregate.
	// If not provided, the data will be back filled using the resolver
	// that would run for an offline query.
	BackfillResolver *string `protobuf:"bytes,8,opt,name=backfill_resolver,json=backfillResolver,proto3,oneof" json:"backfill_resolver,omitempty"`
	// The amount of time before the start of the previous backfill
	// to consider when running the backfill resolver. Set this parameter
	// to the be equal to the latest arriving data in the backfill window.
	BackfillLookbackDuration *durationpb.Duration `` /* 141-byte string literal not displayed */
	// The time at which to start back filling the materialized aggregate.
	// If not provided, the backfill consider the earliest available data returned
	// by the `backfill_resolver`.
	BackfillStartTime *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=backfill_start_time,json=backfillStartTime,proto3,oneof" json:"backfill_start_time,omitempty"`
	// The resolver to use for continuous updates to the materialized aggregate.
	// If not provided, the data will be updated using the resolver that would run
	// for an online query.
	ContinuousResolver *string `protobuf:"bytes,11,opt,name=continuous_resolver,json=continuousResolver,proto3,oneof" json:"continuous_resolver,omitempty"`
	// The period for which to use the continuous resolver, instead
	// of relying upon the last backfill. If not provided, and a continuous
	// resolver is provided, this will be set to backfill_lookback_duration.
	ContinuousBufferDuration *durationpb.Duration `` /* 142-byte string literal not displayed */
	// A crontab or duration string to specify the schedule for back filling the
	// materialized aggregate.
	BackfillSchedule *string `protobuf:"bytes,13,opt,name=backfill_schedule,json=backfillSchedule,proto3,oneof" json:"backfill_schedule,omitempty"`
	// contains filtered or unexported fields
}

func (*WindowAggregation) Descriptor deprecated added in v0.13.1 

func (*WindowAggregation) Descriptor() ([]byte, []int)

Deprecated: Use WindowAggregation.ProtoReflect.Descriptor instead.

func (*WindowAggregation) GetAggregateOn added in v0.13.5 

func (x *WindowAggregation) GetAggregateOn() *FeatureReference

func (*WindowAggregation) GetAggregation added in v0.13.1 

func (x *WindowAggregation) GetAggregation() string

func (*WindowAggregation) GetArrowType added in v0.13.5 

func (x *WindowAggregation) GetArrowType() *v11.ArrowType

func (*WindowAggregation) GetBackfillLookbackDuration added in v0.18.1 

func (x *WindowAggregation) GetBackfillLookbackDuration() *durationpb.Duration

func (*WindowAggregation) GetBackfillResolver added in v0.18.1 

func (x *WindowAggregation) GetBackfillResolver() string

func (*WindowAggregation) GetBackfillSchedule added in v0.18.2 

func (x *WindowAggregation) GetBackfillSchedule() string

func (*WindowAggregation) GetBackfillStartTime added in v0.18.1 

func (x *WindowAggregation) GetBackfillStartTime() *timestamppb.Timestamp

func (*WindowAggregation) GetBucketDuration added in v0.13.1 

func (x *WindowAggregation) GetBucketDuration() *durationpb.Duration

func (*WindowAggregation) GetContinuousBufferDuration added in v0.18.1 

func (x *WindowAggregation) GetContinuousBufferDuration() *durationpb.Duration

func (*WindowAggregation) GetContinuousResolver added in v0.18.1 

func (x *WindowAggregation) GetContinuousResolver() string

func (*WindowAggregation) GetFilters added in v0.17.2 

func (x *WindowAggregation) GetFilters() []*v1.LogicalExprNode

func (*WindowAggregation) GetGroupBy added in v0.13.2 

func (x *WindowAggregation) GetGroupBy() []*FeatureReference

func (*WindowAggregation) GetNamespace added in v0.13.5 

func (x *WindowAggregation) GetNamespace() string

func (*WindowAggregation) ProtoMessage added in v0.13.1 

func (*WindowAggregation) ProtoMessage()

func (*WindowAggregation) ProtoReflect added in v0.13.1 

func (x *WindowAggregation) ProtoReflect() protoreflect.Message

func (*WindowAggregation) Reset added in v0.13.1 

func (x *WindowAggregation) Reset()

func (*WindowAggregation) String added in v0.13.1 

func (x *WindowAggregation) String() string

type WindowInfo 

type WindowInfo struct {
	Duration    *durationpb.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"`
	Aggregation *WindowAggregation   `protobuf:"bytes,2,opt,name=aggregation,proto3,oneof" json:"aggregation,omitempty"`
	// contains filtered or unexported fields
}

func (*WindowInfo) Descriptor deprecated 

func (*WindowInfo) Descriptor() ([]byte, []int)

Deprecated: Use WindowInfo.ProtoReflect.Descriptor instead.

func (*WindowInfo) GetAggregation added in v0.13.1 

func (x *WindowInfo) GetAggregation() *WindowAggregation

func (*WindowInfo) GetDuration 

func (x *WindowInfo) GetDuration() *durationpb.Duration

func (*WindowInfo) ProtoMessage 

func (*WindowInfo) ProtoMessage()

func (*WindowInfo) ProtoReflect 

func (x *WindowInfo) ProtoReflect() protoreflect.Message

func (*WindowInfo) Reset 

func (x *WindowInfo) Reset()

func (*WindowInfo) String 

func (x *WindowInfo) String() string

type WindowMode 

type WindowMode int32
const (
	WindowMode_WINDOW_MODE_UNSPECIFIED WindowMode = 0
	WindowMode_WINDOW_MODE_CONTINUOUS  WindowMode = 1
	WindowMode_WINDOW_MODE_TUMBLING    WindowMode = 2
	WindowMode_WINDOW_MODE_CDC         WindowMode = 3
)

func (WindowMode) Descriptor 

func (WindowMode) Descriptor() protoreflect.EnumDescriptor

func (WindowMode) Enum 

func (x WindowMode) Enum() *WindowMode

func (WindowMode) EnumDescriptor deprecated 

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

Deprecated: Use WindowMode.Descriptor instead.

func (WindowMode) Number 

func (x WindowMode) Number() protoreflect.EnumNumber

func (WindowMode) String 

func (x WindowMode) String() string

func (WindowMode) Type 

func (WindowMode) Type() protoreflect.EnumType

type WindowedFeatureType 

type WindowedFeatureType 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"`
	WindowDurations []*durationpb.Duration `protobuf:"bytes,4,rep,name=window_durations,json=windowDurations,proto3" json:"window_durations,omitempty"`
	AttributeName   string                 `protobuf:"bytes,5,opt,name=attribute_name,json=attributeName,proto3" json:"attribute_name,omitempty"`
	// contains filtered or unexported fields
}

func (*WindowedFeatureType) Descriptor deprecated 

func (*WindowedFeatureType) Descriptor() ([]byte, []int)

Deprecated: Use WindowedFeatureType.ProtoReflect.Descriptor instead.

func (*WindowedFeatureType) GetAttributeName added in v0.4.7 

func (x *WindowedFeatureType) GetAttributeName() string

func (*WindowedFeatureType) GetIsAutogenerated 

func (x *WindowedFeatureType) GetIsAutogenerated() bool

func (*WindowedFeatureType) GetName 

func (x *WindowedFeatureType) GetName() string

func (*WindowedFeatureType) GetNamespace 

func (x *WindowedFeatureType) GetNamespace() string

func (*WindowedFeatureType) GetWindowDurations 

func (x *WindowedFeatureType) GetWindowDurations() []*durationpb.Duration

func (*WindowedFeatureType) ProtoMessage 

func (*WindowedFeatureType) ProtoMessage()

func (*WindowedFeatureType) ProtoReflect 

func (x *WindowedFeatureType) ProtoReflect() protoreflect.Message

func (*WindowedFeatureType) Reset 

func (x *WindowedFeatureType) Reset()

func (*WindowedFeatureType) String 

func (x *WindowedFeatureType) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.