core

package
v0.8.4 Latest Latest
Warning

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

 Go to latest Published: May 24, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	GetOnlineStoreResponse_Status_name = map[int32]string{
		0: "ACTIVE",
		1: "ARCHIVED",
	}
	GetOnlineStoreResponse_Status_value = map[string]int32{
		"ACTIVE":   0,
		"ARCHIVED": 1,
	}
)

Enum value maps for GetOnlineStoreResponse_Status.

View Source 
var (
	RegisterOnlineStoreResponse_Status_name = map[int32]string{
		0: "NO_CHANGE",
		1: "REGISTERED",
		2: "UPDATED",
	}
	RegisterOnlineStoreResponse_Status_value = map[string]int32{
		"NO_CHANGE":  0,
		"REGISTERED": 1,
		"UPDATED":    2,
	}
)

Enum value maps for RegisterOnlineStoreResponse_Status.

View Source 
var (
	DataSource_SourceType_name = map[int32]string{
		0: "INVALID",
		1: "BATCH_FILE",
		2: "BATCH_BIGQUERY",
		3: "STREAM_KAFKA",
		4: "STREAM_KINESIS",
	}
	DataSource_SourceType_value = map[string]int32{
		"INVALID":        0,
		"BATCH_FILE":     1,
		"BATCH_BIGQUERY": 2,
		"STREAM_KAFKA":   3,
		"STREAM_KINESIS": 4,
	}
)

Enum value maps for DataSource_SourceType.

View Source 
var (
	StoreType_name = map[int32]string{
		0: "UNSET",
		1: "BIGTABLE",
		2: "REDIS",
	}
	StoreType_value = map[string]int32{
		"UNSET":    0,
		"BIGTABLE": 1,
		"REDIS":    2,
	}
)

Enum value maps for StoreType.

View Source 
var (
	ValueType_Enum_name = map[int32]string{
		0:  "INVALID",
		1:  "BYTES",
		2:  "STRING",
		3:  "INT32",
		4:  "INT64",
		5:  "DOUBLE",
		6:  "FLOAT",
		7:  "BOOL",
		11: "BYTES_LIST",
		12: "STRING_LIST",
		13: "INT32_LIST",
		14: "INT64_LIST",
		15: "DOUBLE_LIST",
		16: "FLOAT_LIST",
		17: "BOOL_LIST",
	}
	ValueType_Enum_value = map[string]int32{
		"INVALID":     0,
		"BYTES":       1,
		"STRING":      2,
		"INT32":       3,
		"INT64":       4,
		"DOUBLE":      5,
		"FLOAT":       6,
		"BOOL":        7,
		"BYTES_LIST":  11,
		"STRING_LIST": 12,
		"INT32_LIST":  13,
		"INT64_LIST":  14,
		"DOUBLE_LIST": 15,
		"FLOAT_LIST":  16,
		"BOOL_LIST":   17,
	}
)

Enum value maps for ValueType_Enum.

View Source 
var CoreService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "feast.core.CoreService",
	HandlerType: (*CoreServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetFeastCoreVersion",
			Handler:    _CoreService_GetFeastCoreVersion_Handler,
		},
		{
			MethodName: "GetEntity",
			Handler:    _CoreService_GetEntity_Handler,
		},
		{
			MethodName: "ListFeatures",
			Handler:    _CoreService_ListFeatures_Handler,
		},
		{
			MethodName: "ApplyEntity",
			Handler:    _CoreService_ApplyEntity_Handler,
		},
		{
			MethodName: "ListEntities",
			Handler:    _CoreService_ListEntities_Handler,
		},
		{
			MethodName: "CreateProject",
			Handler:    _CoreService_CreateProject_Handler,
		},
		{
			MethodName: "ArchiveProject",
			Handler:    _CoreService_ArchiveProject_Handler,
		},
		{
			MethodName: "ListProjects",
			Handler:    _CoreService_ListProjects_Handler,
		},
		{
			MethodName: "ApplyFeatureTable",
			Handler:    _CoreService_ApplyFeatureTable_Handler,
		},
		{
			MethodName: "ListFeatureTables",
			Handler:    _CoreService_ListFeatureTables_Handler,
		},
		{
			MethodName: "GetFeatureTable",
			Handler:    _CoreService_GetFeatureTable_Handler,
		},
		{
			MethodName: "DeleteFeatureTable",
			Handler:    _CoreService_DeleteFeatureTable_Handler,
		},
		{
			MethodName: "ListOnlineStores",
			Handler:    _CoreService_ListOnlineStores_Handler,
		},
		{
			MethodName: "GetOnlineStore",
			Handler:    _CoreService_GetOnlineStore_Handler,
		},
		{
			MethodName: "RegisterOnlineStore",
			Handler:    _CoreService_RegisterOnlineStore_Handler,
		},
		{
			MethodName: "ArchiveOnlineStore",
			Handler:    _CoreService_ArchiveOnlineStore_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "feast/core/CoreService.proto",
}

CoreService_ServiceDesc is the grpc.ServiceDesc for CoreService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_feast_core_CoreService_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_DataFormat_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_DataSource_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_Entity_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_FeatureTable_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_Feature_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_OnlineStore_proto protoreflect.FileDescriptor
View Source 
var File_feast_types_Value_proto protoreflect.FileDescriptor

Functions

func RegisterCoreServiceServer 

func RegisterCoreServiceServer(s grpc.ServiceRegistrar, srv CoreServiceServer)

Types

type ApplyEntityRequest 

type ApplyEntityRequest struct {

	// If project is unspecified, will default to 'default' project.
	// If project specified does not exist, the project would be automatically created.
	Spec *EntitySpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// Name of project that this entity belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyEntityRequest) Descriptor deprecated 

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

Deprecated: Use ApplyEntityRequest.ProtoReflect.Descriptor instead.

func (*ApplyEntityRequest) GetProject 

func (x *ApplyEntityRequest) GetProject() string

func (*ApplyEntityRequest) GetSpec 

func (x *ApplyEntityRequest) GetSpec() *EntitySpec

func (*ApplyEntityRequest) ProtoMessage 

func (*ApplyEntityRequest) ProtoMessage()

func (*ApplyEntityRequest) ProtoReflect 

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

func (*ApplyEntityRequest) Reset 

func (x *ApplyEntityRequest) Reset()

func (*ApplyEntityRequest) String 

func (x *ApplyEntityRequest) String() string

type ApplyEntityResponse 

type ApplyEntityResponse struct {
	Entity *Entity `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyEntityResponse) Descriptor deprecated 

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

Deprecated: Use ApplyEntityResponse.ProtoReflect.Descriptor instead.

func (*ApplyEntityResponse) GetEntity 

func (x *ApplyEntityResponse) GetEntity() *Entity

func (*ApplyEntityResponse) ProtoMessage 

func (*ApplyEntityResponse) ProtoMessage()

func (*ApplyEntityResponse) ProtoReflect 

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

func (*ApplyEntityResponse) Reset 

func (x *ApplyEntityResponse) Reset()

func (*ApplyEntityResponse) String 

func (x *ApplyEntityResponse) String() string

type ApplyFeatureTableRequest 

type ApplyFeatureTableRequest struct {

	// Optional. Name of the Project to apply the Feature Table to.
	// If unspecified, will apply FeatureTable to the default project.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Feature Table specification to apply
	TableSpec *FeatureTableSpec `protobuf:"bytes,2,opt,name=table_spec,json=tableSpec,proto3" json:"table_spec,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyFeatureTableRequest) Descriptor deprecated 

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

Deprecated: Use ApplyFeatureTableRequest.ProtoReflect.Descriptor instead.

func (*ApplyFeatureTableRequest) GetProject 

func (x *ApplyFeatureTableRequest) GetProject() string

func (*ApplyFeatureTableRequest) GetTableSpec 

func (x *ApplyFeatureTableRequest) GetTableSpec() *FeatureTableSpec

func (*ApplyFeatureTableRequest) ProtoMessage 

func (*ApplyFeatureTableRequest) ProtoMessage()

func (*ApplyFeatureTableRequest) ProtoReflect 

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

func (*ApplyFeatureTableRequest) Reset 

func (x *ApplyFeatureTableRequest) Reset()

func (*ApplyFeatureTableRequest) String 

func (x *ApplyFeatureTableRequest) String() string

type ApplyFeatureTableResponse 

type ApplyFeatureTableResponse struct {
	Table *FeatureTable `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyFeatureTableResponse) Descriptor deprecated 

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

Deprecated: Use ApplyFeatureTableResponse.ProtoReflect.Descriptor instead.

func (*ApplyFeatureTableResponse) GetTable 

func (x *ApplyFeatureTableResponse) GetTable() *FeatureTable

func (*ApplyFeatureTableResponse) ProtoMessage 

func (*ApplyFeatureTableResponse) ProtoMessage()

func (*ApplyFeatureTableResponse) ProtoReflect 

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

func (*ApplyFeatureTableResponse) Reset 

func (x *ApplyFeatureTableResponse) Reset()

func (*ApplyFeatureTableResponse) String 

func (x *ApplyFeatureTableResponse) String() string

type ArchiveOnlineStoreRequest 

type ArchiveOnlineStoreRequest struct {

	// Name of online store to be archived
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for the archival of an online store

func (*ArchiveOnlineStoreRequest) Descriptor deprecated 

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

Deprecated: Use ArchiveOnlineStoreRequest.ProtoReflect.Descriptor instead.

func (*ArchiveOnlineStoreRequest) GetName 

func (x *ArchiveOnlineStoreRequest) GetName() string

func (*ArchiveOnlineStoreRequest) ProtoMessage 

func (*ArchiveOnlineStoreRequest) ProtoMessage()

func (*ArchiveOnlineStoreRequest) ProtoReflect 

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

func (*ArchiveOnlineStoreRequest) Reset 

func (x *ArchiveOnlineStoreRequest) Reset()

func (*ArchiveOnlineStoreRequest) String 

func (x *ArchiveOnlineStoreRequest) String() string

type ArchiveOnlineStoreResponse 

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

Response for archival of an online store

func (*ArchiveOnlineStoreResponse) Descriptor deprecated 

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

Deprecated: Use ArchiveOnlineStoreResponse.ProtoReflect.Descriptor instead.

func (*ArchiveOnlineStoreResponse) ProtoMessage 

func (*ArchiveOnlineStoreResponse) ProtoMessage()

func (*ArchiveOnlineStoreResponse) ProtoReflect 

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

func (*ArchiveOnlineStoreResponse) Reset 

func (x *ArchiveOnlineStoreResponse) Reset()

func (*ArchiveOnlineStoreResponse) String 

func (x *ArchiveOnlineStoreResponse) String() string

type ArchiveProjectRequest 

type ArchiveProjectRequest struct {

	// Name of project to be archived
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for the archival of a project

func (*ArchiveProjectRequest) Descriptor deprecated 

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

Deprecated: Use ArchiveProjectRequest.ProtoReflect.Descriptor instead.

func (*ArchiveProjectRequest) GetName 

func (x *ArchiveProjectRequest) GetName() string

func (*ArchiveProjectRequest) ProtoMessage 

func (*ArchiveProjectRequest) ProtoMessage()

func (*ArchiveProjectRequest) ProtoReflect 

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

func (*ArchiveProjectRequest) Reset 

func (x *ArchiveProjectRequest) Reset()

func (*ArchiveProjectRequest) String 

func (x *ArchiveProjectRequest) String() string

type ArchiveProjectResponse 

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

Response for archival of a project

func (*ArchiveProjectResponse) Descriptor deprecated 

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

Deprecated: Use ArchiveProjectResponse.ProtoReflect.Descriptor instead.

func (*ArchiveProjectResponse) ProtoMessage 

func (*ArchiveProjectResponse) ProtoMessage()

func (*ArchiveProjectResponse) ProtoReflect 

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

func (*ArchiveProjectResponse) Reset 

func (x *ArchiveProjectResponse) Reset()

func (*ArchiveProjectResponse) String 

func (x *ArchiveProjectResponse) String() string

type BoolList 

type BoolList struct {
	Val []bool `protobuf:"varint,1,rep,packed,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

func (*BoolList) Descriptor deprecated 

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

Deprecated: Use BoolList.ProtoReflect.Descriptor instead.

func (*BoolList) GetVal 

func (x *BoolList) GetVal() []bool

func (*BoolList) ProtoMessage 

func (*BoolList) ProtoMessage()

func (*BoolList) ProtoReflect 

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

func (*BoolList) Reset 

func (x *BoolList) Reset()

func (*BoolList) String 

func (x *BoolList) String() string

type BytesList 

type BytesList struct {
	Val [][]byte `protobuf:"bytes,1,rep,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

func (*BytesList) Descriptor deprecated 

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

Deprecated: Use BytesList.ProtoReflect.Descriptor instead.

func (*BytesList) GetVal 

func (x *BytesList) GetVal() [][]byte

func (*BytesList) ProtoMessage 

func (*BytesList) ProtoMessage()

func (*BytesList) ProtoReflect 

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

func (*BytesList) Reset 

func (x *BytesList) Reset()

func (*BytesList) String 

func (x *BytesList) String() string

type CoreServiceClient 

type CoreServiceClient interface {
	// Retrieve version information about this Feast deployment
	GetFeastCoreVersion(ctx context.Context, in *GetFeastCoreVersionRequest, opts ...grpc.CallOption) (*GetFeastCoreVersionResponse, error)
	// Returns a specific entity
	GetEntity(ctx context.Context, in *GetEntityRequest, opts ...grpc.CallOption) (*GetEntityResponse, error)
	// Returns all feature references and respective features matching that filter. If none are found
	// an empty map will be returned
	// If no filter is provided in the request, the response will contain all the features
	// currently stored in the default project.
	ListFeatures(ctx context.Context, in *ListFeaturesRequest, opts ...grpc.CallOption) (*ListFeaturesResponse, error)
	// Create or update and existing entity.
	//
	// This function is idempotent - it will not create a new entity if schema does not change.
	// Schema changes will update the entity if the changes are valid.
	// Following changes are not valid:
	// - Changes to name
	// - Changes to type
	ApplyEntity(ctx context.Context, in *ApplyEntityRequest, opts ...grpc.CallOption) (*ApplyEntityResponse, error)
	// Returns all entity references and respective entities matching that filter. If none are found
	// an empty map will be returned
	// If no filter is provided in the request, the response will contain all the entities
	// currently stored in the default project.
	ListEntities(ctx context.Context, in *ListEntitiesRequest, opts ...grpc.CallOption) (*ListEntitiesResponse, error)
	// Creates a project. Projects serve as namespaces within which resources like features will be
	// created. Feature table names as must be unique within a project while field (Feature/Entity) names
	// must be unique within a Feature Table. Project names themselves must be globally unique.
	CreateProject(ctx context.Context, in *CreateProjectRequest, opts ...grpc.CallOption) (*CreateProjectResponse, error)
	// Archives a project. Archived projects will continue to exist and function, but won't be visible
	// through the Core API. Any existing ingestion or serving requests will continue to function,
	// but will result in warning messages being logged. It is not possible to unarchive a project
	// through the Core API
	ArchiveProject(ctx context.Context, in *ArchiveProjectRequest, opts ...grpc.CallOption) (*ArchiveProjectResponse, error)
	// Lists all projects active projects.
	ListProjects(ctx context.Context, in *ListProjectsRequest, opts ...grpc.CallOption) (*ListProjectsResponse, error)
	// Create or update an existing feature table.
	// This function is idempotent - it will not create a new feature table if the schema does not change.
	// Schema changes will update the feature table if the changes are valid.
	// All changes except the following are valid:
	// - Changes to feature table name.
	// - Changes to entities
	// - Changes to feature name and type
	ApplyFeatureTable(ctx context.Context, in *ApplyFeatureTableRequest, opts ...grpc.CallOption) (*ApplyFeatureTableResponse, error)
	// List feature tables that match a given filter.
	// Returns the references of the Feature Tables matching that filter. If none are found,
	// an empty list will be returned.
	// If no filter is provided in the request, the response will match all the feature
	// tables currently stored in the registry.
	ListFeatureTables(ctx context.Context, in *ListFeatureTablesRequest, opts ...grpc.CallOption) (*ListFeatureTablesResponse, error)
	// Returns a specific feature table
	GetFeatureTable(ctx context.Context, in *GetFeatureTableRequest, opts ...grpc.CallOption) (*GetFeatureTableResponse, error)
	// Delete a specific feature table
	DeleteFeatureTable(ctx context.Context, in *DeleteFeatureTableRequest, opts ...grpc.CallOption) (*DeleteFeatureTableResponse, error)
	// Lists all online stores
	ListOnlineStores(ctx context.Context, in *ListOnlineStoresRequest, opts ...grpc.CallOption) (*ListOnlineStoresResponse, error)
	// Returns a specific online stores
	GetOnlineStore(ctx context.Context, in *GetOnlineStoreRequest, opts ...grpc.CallOption) (*GetOnlineStoreResponse, error)
	// Registers new online store to feast core
	// or updates properties for existing online store
	RegisterOnlineStore(ctx context.Context, in *RegisterOnlineStoreRequest, opts ...grpc.CallOption) (*RegisterOnlineStoreResponse, error)
	// Archives an online store to mark it deprecated
	ArchiveOnlineStore(ctx context.Context, in *ArchiveOnlineStoreRequest, opts ...grpc.CallOption) (*ArchiveOnlineStoreResponse, error)
}

CoreServiceClient is the client API for CoreService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCoreServiceClient 

func NewCoreServiceClient(cc grpc.ClientConnInterface) CoreServiceClient

type CoreServiceServer 

type CoreServiceServer interface {
	// Retrieve version information about this Feast deployment
	GetFeastCoreVersion(context.Context, *GetFeastCoreVersionRequest) (*GetFeastCoreVersionResponse, error)
	// Returns a specific entity
	GetEntity(context.Context, *GetEntityRequest) (*GetEntityResponse, error)
	// Returns all feature references and respective features matching that filter. If none are found
	// an empty map will be returned
	// If no filter is provided in the request, the response will contain all the features
	// currently stored in the default project.
	ListFeatures(context.Context, *ListFeaturesRequest) (*ListFeaturesResponse, error)
	// Create or update and existing entity.
	//
	// This function is idempotent - it will not create a new entity if schema does not change.
	// Schema changes will update the entity if the changes are valid.
	// Following changes are not valid:
	// - Changes to name
	// - Changes to type
	ApplyEntity(context.Context, *ApplyEntityRequest) (*ApplyEntityResponse, error)
	// Returns all entity references and respective entities matching that filter. If none are found
	// an empty map will be returned
	// If no filter is provided in the request, the response will contain all the entities
	// currently stored in the default project.
	ListEntities(context.Context, *ListEntitiesRequest) (*ListEntitiesResponse, error)
	// Creates a project. Projects serve as namespaces within which resources like features will be
	// created. Feature table names as must be unique within a project while field (Feature/Entity) names
	// must be unique within a Feature Table. Project names themselves must be globally unique.
	CreateProject(context.Context, *CreateProjectRequest) (*CreateProjectResponse, error)
	// Archives a project. Archived projects will continue to exist and function, but won't be visible
	// through the Core API. Any existing ingestion or serving requests will continue to function,
	// but will result in warning messages being logged. It is not possible to unarchive a project
	// through the Core API
	ArchiveProject(context.Context, *ArchiveProjectRequest) (*ArchiveProjectResponse, error)
	// Lists all projects active projects.
	ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error)
	// Create or update an existing feature table.
	// This function is idempotent - it will not create a new feature table if the schema does not change.
	// Schema changes will update the feature table if the changes are valid.
	// All changes except the following are valid:
	// - Changes to feature table name.
	// - Changes to entities
	// - Changes to feature name and type
	ApplyFeatureTable(context.Context, *ApplyFeatureTableRequest) (*ApplyFeatureTableResponse, error)
	// List feature tables that match a given filter.
	// Returns the references of the Feature Tables matching that filter. If none are found,
	// an empty list will be returned.
	// If no filter is provided in the request, the response will match all the feature
	// tables currently stored in the registry.
	ListFeatureTables(context.Context, *ListFeatureTablesRequest) (*ListFeatureTablesResponse, error)
	// Returns a specific feature table
	GetFeatureTable(context.Context, *GetFeatureTableRequest) (*GetFeatureTableResponse, error)
	// Delete a specific feature table
	DeleteFeatureTable(context.Context, *DeleteFeatureTableRequest) (*DeleteFeatureTableResponse, error)
	// Lists all online stores
	ListOnlineStores(context.Context, *ListOnlineStoresRequest) (*ListOnlineStoresResponse, error)
	// Returns a specific online stores
	GetOnlineStore(context.Context, *GetOnlineStoreRequest) (*GetOnlineStoreResponse, error)
	// Registers new online store to feast core
	// or updates properties for existing online store
	RegisterOnlineStore(context.Context, *RegisterOnlineStoreRequest) (*RegisterOnlineStoreResponse, error)
	// Archives an online store to mark it deprecated
	ArchiveOnlineStore(context.Context, *ArchiveOnlineStoreRequest) (*ArchiveOnlineStoreResponse, error)
}

CoreServiceServer is the server API for CoreService service. All implementations should embed UnimplementedCoreServiceServer for forward compatibility

type CreateProjectRequest 

type CreateProjectRequest struct {

	// Name of project (required)
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request to create a project

func (*CreateProjectRequest) Descriptor deprecated 

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

Deprecated: Use CreateProjectRequest.ProtoReflect.Descriptor instead.

func (*CreateProjectRequest) GetName 

func (x *CreateProjectRequest) GetName() string

func (*CreateProjectRequest) ProtoMessage 

func (*CreateProjectRequest) ProtoMessage()

func (*CreateProjectRequest) ProtoReflect 

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

func (*CreateProjectRequest) Reset 

func (x *CreateProjectRequest) Reset()

func (*CreateProjectRequest) String 

func (x *CreateProjectRequest) String() string

type CreateProjectResponse 

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

Response for creation of a project

func (*CreateProjectResponse) Descriptor deprecated 

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

Deprecated: Use CreateProjectResponse.ProtoReflect.Descriptor instead.

func (*CreateProjectResponse) ProtoMessage 

func (*CreateProjectResponse) ProtoMessage()

func (*CreateProjectResponse) ProtoReflect 

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

func (*CreateProjectResponse) Reset 

func (x *CreateProjectResponse) Reset()

func (*CreateProjectResponse) String 

func (x *CreateProjectResponse) String() string

type DataSource 

type DataSource struct {
	Type DataSource_SourceType `protobuf:"varint,1,opt,name=type,proto3,enum=feast.core.DataSource_SourceType" json:"type,omitempty"`
	// Defines mapping between fields in the sourced data
	// and fields in parent FeatureTable.
	FieldMapping map[string]string `` /* 185-byte string literal not displayed */
	// Must specify event timestamp column name
	EventTimestampColumn string `protobuf:"bytes,3,opt,name=event_timestamp_column,json=eventTimestampColumn,proto3" json:"event_timestamp_column,omitempty"`
	// (Optional) Specify partition column
	// useful for file sources
	DatePartitionColumn string `protobuf:"bytes,4,opt,name=date_partition_column,json=datePartitionColumn,proto3" json:"date_partition_column,omitempty"`
	// Must specify creation timestamp column name
	CreatedTimestampColumn string `` /* 129-byte string literal not displayed */
	// DataSource options.
	//
	// Types that are assignable to Options:
	//	*DataSource_FileOptions_
	//	*DataSource_BigqueryOptions
	//	*DataSource_KafkaOptions_
	//	*DataSource_KinesisOptions_
	Options isDataSource_Options `protobuf_oneof:"options"`
	// contains filtered or unexported fields
}

Defines a Data Source that can be used source Feature data

func (*DataSource) Descriptor deprecated 

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

Deprecated: Use DataSource.ProtoReflect.Descriptor instead.

func (*DataSource) GetBigqueryOptions 

func (x *DataSource) GetBigqueryOptions() *DataSource_BigQueryOptions

func (*DataSource) GetCreatedTimestampColumn 

func (x *DataSource) GetCreatedTimestampColumn() string

func (*DataSource) GetDatePartitionColumn 

func (x *DataSource) GetDatePartitionColumn() string

func (*DataSource) GetEventTimestampColumn 

func (x *DataSource) GetEventTimestampColumn() string

func (*DataSource) GetFieldMapping 

func (x *DataSource) GetFieldMapping() map[string]string

func (*DataSource) GetFileOptions 

func (x *DataSource) GetFileOptions() *DataSource_FileOptions

func (*DataSource) GetKafkaOptions 

func (x *DataSource) GetKafkaOptions() *DataSource_KafkaOptions

func (*DataSource) GetKinesisOptions 

func (x *DataSource) GetKinesisOptions() *DataSource_KinesisOptions

func (*DataSource) GetOptions 

func (m *DataSource) GetOptions() isDataSource_Options

func (*DataSource) GetType 

func (x *DataSource) GetType() DataSource_SourceType

func (*DataSource) ProtoMessage 

func (*DataSource) ProtoMessage()

func (*DataSource) ProtoReflect 

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

func (*DataSource) Reset 

func (x *DataSource) Reset()

func (*DataSource) String 

func (x *DataSource) String() string

type DataSource_BigQueryOptions 

type DataSource_BigQueryOptions struct {

	// Full table reference in the form of [project:dataset.table]
	TableRef string `protobuf:"bytes,1,opt,name=table_ref,json=tableRef,proto3" json:"table_ref,omitempty"`
	// contains filtered or unexported fields
}

Defines options for DataSource that sources features from a BigQuery Query

func (*DataSource_BigQueryOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_BigQueryOptions.ProtoReflect.Descriptor instead.

func (*DataSource_BigQueryOptions) GetTableRef 

func (x *DataSource_BigQueryOptions) GetTableRef() string

func (*DataSource_BigQueryOptions) ProtoMessage 

func (*DataSource_BigQueryOptions) ProtoMessage()

func (*DataSource_BigQueryOptions) ProtoReflect 

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

func (*DataSource_BigQueryOptions) Reset 

func (x *DataSource_BigQueryOptions) Reset()

func (*DataSource_BigQueryOptions) String 

func (x *DataSource_BigQueryOptions) String() string

type DataSource_BigqueryOptions 

type DataSource_BigqueryOptions struct {
	BigqueryOptions *DataSource_BigQueryOptions `protobuf:"bytes,12,opt,name=bigquery_options,json=bigqueryOptions,proto3,oneof"`
}

type DataSource_FileOptions 

type DataSource_FileOptions struct {
	FileFormat *FileFormat `protobuf:"bytes,1,opt,name=file_format,json=fileFormat,proto3" json:"file_format,omitempty"`
	// Target URL of file to retrieve and source features from.
	// s3://path/to/file for AWS S3 storage
	// gs://path/to/file for GCP GCS storage
	// file:///path/to/file for local storage
	FileUrl string `protobuf:"bytes,2,opt,name=file_url,json=fileUrl,proto3" json:"file_url,omitempty"`
	// contains filtered or unexported fields
}

Defines options for DataSource that sources features from a file

func (*DataSource_FileOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_FileOptions.ProtoReflect.Descriptor instead.

func (*DataSource_FileOptions) GetFileFormat 

func (x *DataSource_FileOptions) GetFileFormat() *FileFormat

func (*DataSource_FileOptions) GetFileUrl 

func (x *DataSource_FileOptions) GetFileUrl() string

func (*DataSource_FileOptions) ProtoMessage 

func (*DataSource_FileOptions) ProtoMessage()

func (*DataSource_FileOptions) ProtoReflect 

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

func (*DataSource_FileOptions) Reset 

func (x *DataSource_FileOptions) Reset()

func (*DataSource_FileOptions) String 

func (x *DataSource_FileOptions) String() string

type DataSource_FileOptions_ 

type DataSource_FileOptions_ struct {
	FileOptions *DataSource_FileOptions `protobuf:"bytes,11,opt,name=file_options,json=fileOptions,proto3,oneof"`
}

type DataSource_KafkaOptions 

type DataSource_KafkaOptions struct {

	// Comma separated list of Kafka bootstrap servers. Used for feature tables without a defined source host[:port]]
	BootstrapServers string `protobuf:"bytes,1,opt,name=bootstrap_servers,json=bootstrapServers,proto3" json:"bootstrap_servers,omitempty"`
	// Kafka topic to collect feature data from.
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// Defines the stream data format encoding feature/entity data in Kafka messages.
	MessageFormat *StreamFormat `protobuf:"bytes,3,opt,name=message_format,json=messageFormat,proto3" json:"message_format,omitempty"`
	// contains filtered or unexported fields
}

Defines options for DataSource that sources features from Kafka messages. Each message should be a Protobuf that can be decoded with the generated Java Protobuf class at the given class path

func (*DataSource_KafkaOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_KafkaOptions.ProtoReflect.Descriptor instead.

func (*DataSource_KafkaOptions) GetBootstrapServers 

func (x *DataSource_KafkaOptions) GetBootstrapServers() string

func (*DataSource_KafkaOptions) GetMessageFormat 

func (x *DataSource_KafkaOptions) GetMessageFormat() *StreamFormat

func (*DataSource_KafkaOptions) GetTopic 

func (x *DataSource_KafkaOptions) GetTopic() string

func (*DataSource_KafkaOptions) ProtoMessage 

func (*DataSource_KafkaOptions) ProtoMessage()

func (*DataSource_KafkaOptions) ProtoReflect 

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

func (*DataSource_KafkaOptions) Reset 

func (x *DataSource_KafkaOptions) Reset()

func (*DataSource_KafkaOptions) String 

func (x *DataSource_KafkaOptions) String() string

type DataSource_KafkaOptions_ 

type DataSource_KafkaOptions_ struct {
	KafkaOptions *DataSource_KafkaOptions `protobuf:"bytes,13,opt,name=kafka_options,json=kafkaOptions,proto3,oneof"`
}

type DataSource_KinesisOptions 

type DataSource_KinesisOptions struct {

	// AWS region of the Kinesis stream
	Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	// Name of the Kinesis stream to obtain feature data from.
	StreamName string `protobuf:"bytes,2,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	// Defines the data format encoding the feature/entity data in Kinesis records.
	// Kinesis Data Sources support Avro and Proto as data formats.
	RecordFormat *StreamFormat `protobuf:"bytes,3,opt,name=record_format,json=recordFormat,proto3" json:"record_format,omitempty"`
	// contains filtered or unexported fields
}

Defines options for DataSource that sources features from Kinesis records. Each record should be a Protobuf that can be decoded with the generated Java Protobuf class at the given class path

func (*DataSource_KinesisOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_KinesisOptions.ProtoReflect.Descriptor instead.

func (*DataSource_KinesisOptions) GetRecordFormat 

func (x *DataSource_KinesisOptions) GetRecordFormat() *StreamFormat

func (*DataSource_KinesisOptions) GetRegion 

func (x *DataSource_KinesisOptions) GetRegion() string

func (*DataSource_KinesisOptions) GetStreamName 

func (x *DataSource_KinesisOptions) GetStreamName() string

func (*DataSource_KinesisOptions) ProtoMessage 

func (*DataSource_KinesisOptions) ProtoMessage()

func (*DataSource_KinesisOptions) ProtoReflect 

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

func (*DataSource_KinesisOptions) Reset 

func (x *DataSource_KinesisOptions) Reset()

func (*DataSource_KinesisOptions) String 

func (x *DataSource_KinesisOptions) String() string

type DataSource_KinesisOptions_ 

type DataSource_KinesisOptions_ struct {
	KinesisOptions *DataSource_KinesisOptions `protobuf:"bytes,14,opt,name=kinesis_options,json=kinesisOptions,proto3,oneof"`
}

type DataSource_SourceType 

type DataSource_SourceType int32

Type of Data Source. 

const (
	DataSource_INVALID        DataSource_SourceType = 0
	DataSource_BATCH_FILE     DataSource_SourceType = 1
	DataSource_BATCH_BIGQUERY DataSource_SourceType = 2
	DataSource_STREAM_KAFKA   DataSource_SourceType = 3
	DataSource_STREAM_KINESIS DataSource_SourceType = 4
)

func (DataSource_SourceType) Descriptor 

func (DataSource_SourceType) Descriptor() protoreflect.EnumDescriptor

func (DataSource_SourceType) Enum 

func (x DataSource_SourceType) Enum() *DataSource_SourceType

func (DataSource_SourceType) EnumDescriptor deprecated 

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

Deprecated: Use DataSource_SourceType.Descriptor instead.

func (DataSource_SourceType) Number 

func (x DataSource_SourceType) Number() protoreflect.EnumNumber

func (DataSource_SourceType) String 

func (x DataSource_SourceType) String() string

func (DataSource_SourceType) Type 

func (DataSource_SourceType) Type() protoreflect.EnumType

type DeleteFeatureTableRequest 

type DeleteFeatureTableRequest struct {

	// Optional. Name of the Project to delete the Feature Table from.
	// If unspecified, will delete FeatureTable from the default project.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the FeatureTable to delete.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteFeatureTableRequest) Descriptor deprecated 

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

Deprecated: Use DeleteFeatureTableRequest.ProtoReflect.Descriptor instead.

func (*DeleteFeatureTableRequest) GetName 

func (x *DeleteFeatureTableRequest) GetName() string

func (*DeleteFeatureTableRequest) GetProject 

func (x *DeleteFeatureTableRequest) GetProject() string

func (*DeleteFeatureTableRequest) ProtoMessage 

func (*DeleteFeatureTableRequest) ProtoMessage()

func (*DeleteFeatureTableRequest) ProtoReflect 

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

func (*DeleteFeatureTableRequest) Reset 

func (x *DeleteFeatureTableRequest) Reset()

func (*DeleteFeatureTableRequest) String 

func (x *DeleteFeatureTableRequest) String() string

type DeleteFeatureTableResponse 

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

func (*DeleteFeatureTableResponse) Descriptor deprecated 

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

Deprecated: Use DeleteFeatureTableResponse.ProtoReflect.Descriptor instead.

func (*DeleteFeatureTableResponse) ProtoMessage 

func (*DeleteFeatureTableResponse) ProtoMessage()

func (*DeleteFeatureTableResponse) ProtoReflect 

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

func (*DeleteFeatureTableResponse) Reset 

func (x *DeleteFeatureTableResponse) Reset()

func (*DeleteFeatureTableResponse) String 

func (x *DeleteFeatureTableResponse) String() string

type DoubleList 

type DoubleList struct {
	Val []float64 `protobuf:"fixed64,1,rep,packed,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

func (*DoubleList) Descriptor deprecated 

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

Deprecated: Use DoubleList.ProtoReflect.Descriptor instead.

func (*DoubleList) GetVal 

func (x *DoubleList) GetVal() []float64

func (*DoubleList) ProtoMessage 

func (*DoubleList) ProtoMessage()

func (*DoubleList) ProtoReflect 

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

func (*DoubleList) Reset 

func (x *DoubleList) Reset()

func (*DoubleList) String 

func (x *DoubleList) String() string

type Entity 

type Entity struct {

	// User-specified specifications of this entity.
	Spec *EntitySpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// System-populated metadata for this entity.
	Meta *EntityMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*Entity) Descriptor deprecated 

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

Deprecated: Use Entity.ProtoReflect.Descriptor instead.

func (*Entity) GetMeta 

func (x *Entity) GetMeta() *EntityMeta

func (*Entity) GetSpec 

func (x *Entity) GetSpec() *EntitySpec

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) ProtoReflect 

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

func (*Entity) Reset 

func (x *Entity) Reset()

func (*Entity) String 

func (x *Entity) String() string

type EntityMeta 

type EntityMeta struct {
	CreatedTimestamp     *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	LastUpdatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_updated_timestamp,json=lastUpdatedTimestamp,proto3" json:"last_updated_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityMeta) Descriptor deprecated 

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

Deprecated: Use EntityMeta.ProtoReflect.Descriptor instead.

func (*EntityMeta) GetCreatedTimestamp 

func (x *EntityMeta) GetCreatedTimestamp() *timestamppb.Timestamp

func (*EntityMeta) GetLastUpdatedTimestamp 

func (x *EntityMeta) GetLastUpdatedTimestamp() *timestamppb.Timestamp

func (*EntityMeta) ProtoMessage 

func (*EntityMeta) ProtoMessage()

func (*EntityMeta) ProtoReflect 

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

func (*EntityMeta) Reset 

func (x *EntityMeta) Reset()

func (*EntityMeta) String 

func (x *EntityMeta) String() string

type EntitySpec 

type EntitySpec struct {

	// Name of the entity.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the entity.
	ValueType ValueType_Enum `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=feast.types.ValueType_Enum" json:"value_type,omitempty"`
	// Description of the entity.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// User defined metadata
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EntitySpec) Descriptor deprecated 

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

Deprecated: Use EntitySpec.ProtoReflect.Descriptor instead.

func (*EntitySpec) GetDescription 

func (x *EntitySpec) GetDescription() string

func (*EntitySpec) GetLabels 

func (x *EntitySpec) GetLabels() map[string]string

func (*EntitySpec) GetName 

func (x *EntitySpec) GetName() string

func (*EntitySpec) GetValueType 

func (x *EntitySpec) GetValueType() ValueType_Enum

func (*EntitySpec) ProtoMessage 

func (*EntitySpec) ProtoMessage()

func (*EntitySpec) ProtoReflect 

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

func (*EntitySpec) Reset 

func (x *EntitySpec) Reset()

func (*EntitySpec) String 

func (x *EntitySpec) String() string

type FeatureSpec 

type FeatureSpec struct {

	// Name of the feature. Not updatable.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Value type of the feature. Not updatable.
	ValueType ValueType_Enum `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=feast.types.ValueType_Enum" json:"value_type,omitempty"`
	// Labels for user defined metadata on a feature
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FeatureSpec) Descriptor deprecated 

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

Deprecated: Use FeatureSpec.ProtoReflect.Descriptor instead.

func (*FeatureSpec) GetLabels 

func (x *FeatureSpec) GetLabels() map[string]string

func (*FeatureSpec) GetName 

func (x *FeatureSpec) GetName() string

func (*FeatureSpec) GetValueType 

func (x *FeatureSpec) GetValueType() ValueType_Enum

func (*FeatureSpec) ProtoMessage 

func (*FeatureSpec) ProtoMessage()

func (*FeatureSpec) ProtoReflect 

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

func (*FeatureSpec) Reset 

func (x *FeatureSpec) Reset()

func (*FeatureSpec) String 

func (x *FeatureSpec) String() string

type FeatureTable 

type FeatureTable struct {

	// User-specified specifications of this feature table.
	Spec *FeatureTableSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// System-populated metadata for this feature table.
	Meta *FeatureTableMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureTable) Descriptor deprecated 

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

Deprecated: Use FeatureTable.ProtoReflect.Descriptor instead.

func (*FeatureTable) GetMeta 

func (x *FeatureTable) GetMeta() *FeatureTableMeta

func (*FeatureTable) GetSpec 

func (x *FeatureTable) GetSpec() *FeatureTableSpec

func (*FeatureTable) ProtoMessage 

func (*FeatureTable) ProtoMessage()

func (*FeatureTable) ProtoReflect 

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

func (*FeatureTable) Reset 

func (x *FeatureTable) Reset()

func (*FeatureTable) String 

func (x *FeatureTable) String() string

type FeatureTableMeta 

type FeatureTableMeta struct {

	// Time where this Feature Table is created
	CreatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	// Time where this Feature Table is last updated
	LastUpdatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_updated_timestamp,json=lastUpdatedTimestamp,proto3" json:"last_updated_timestamp,omitempty"`
	// Auto incrementing revision no. of this Feature Table
	Revision int64 `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"`
	// Hash entities, features, batch_source and stream_source to inform JobService if
	// jobs should be restarted should hash change
	Hash string `protobuf:"bytes,4,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureTableMeta) Descriptor deprecated 

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

Deprecated: Use FeatureTableMeta.ProtoReflect.Descriptor instead.

func (*FeatureTableMeta) GetCreatedTimestamp 

func (x *FeatureTableMeta) GetCreatedTimestamp() *timestamppb.Timestamp

func (*FeatureTableMeta) GetHash 

func (x *FeatureTableMeta) GetHash() string

func (*FeatureTableMeta) GetLastUpdatedTimestamp 

func (x *FeatureTableMeta) GetLastUpdatedTimestamp() *timestamppb.Timestamp

func (*FeatureTableMeta) GetRevision 

func (x *FeatureTableMeta) GetRevision() int64

func (*FeatureTableMeta) ProtoMessage 

func (*FeatureTableMeta) ProtoMessage()

func (*FeatureTableMeta) ProtoReflect 

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

func (*FeatureTableMeta) Reset 

func (x *FeatureTableMeta) Reset()

func (*FeatureTableMeta) String 

func (x *FeatureTableMeta) String() string

type FeatureTableSpec 

type FeatureTableSpec struct {

	// Name of the feature table. Must be unique. Not updated.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// List names of entities to associate with the Features defined in this
	// Feature Table. Not updatable.
	Entities []string `protobuf:"bytes,3,rep,name=entities,proto3" json:"entities,omitempty"`
	// List of features specifications for each feature defined with this feature table.
	Features []*FeatureSpec `protobuf:"bytes,4,rep,name=features,proto3" json:"features,omitempty"`
	// User defined metadata
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Features in this feature table can only be retrieved from online serving
	// younger than max age. Age is measured as the duration of time between
	// the feature's event timestamp and when the feature is retrieved
	// Feature values outside max age will be returned as unset values and indicated to end user
	MaxAge *durationpb.Duration `protobuf:"bytes,6,opt,name=max_age,json=maxAge,proto3" json:"max_age,omitempty"`
	// Batch/Offline DataSource to source batch/offline feature data.
	// Only batch DataSource can be specified
	// (ie source type should start with 'BATCH_')
	BatchSource *DataSource `protobuf:"bytes,7,opt,name=batch_source,json=batchSource,proto3" json:"batch_source,omitempty"`
	// Stream/Online DataSource to source stream/online feature data.
	// Only stream DataSource can be specified
	// (ie source type should start with 'STREAM_')
	StreamSource *DataSource `protobuf:"bytes,8,opt,name=stream_source,json=streamSource,proto3" json:"stream_source,omitempty"`
	// Threshold to detect features that are close to be evicted.
	// Used by Feast Serving to indicate that feature is stale.
	// Must be less than max_age, since after max_age feature most probably will be garbage collected
	StalenessThreshold *durationpb.Duration `protobuf:"bytes,9,opt,name=staleness_threshold,json=stalenessThreshold,proto3" json:"staleness_threshold,omitempty"`
	// Database where features are stored for online serving
	OnlineStore *OnlineStore `protobuf:"bytes,10,opt,name=online_store,json=onlineStore,proto3" json:"online_store,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureTableSpec) Descriptor deprecated 

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

Deprecated: Use FeatureTableSpec.ProtoReflect.Descriptor instead.

func (*FeatureTableSpec) GetBatchSource 

func (x *FeatureTableSpec) GetBatchSource() *DataSource

func (*FeatureTableSpec) GetEntities 

func (x *FeatureTableSpec) GetEntities() []string

func (*FeatureTableSpec) GetFeatures 

func (x *FeatureTableSpec) GetFeatures() []*FeatureSpec

func (*FeatureTableSpec) GetLabels 

func (x *FeatureTableSpec) GetLabels() map[string]string

func (*FeatureTableSpec) GetMaxAge 

func (x *FeatureTableSpec) GetMaxAge() *durationpb.Duration

func (*FeatureTableSpec) GetName 

func (x *FeatureTableSpec) GetName() string

func (*FeatureTableSpec) GetOnlineStore 

func (x *FeatureTableSpec) GetOnlineStore() *OnlineStore

func (*FeatureTableSpec) GetStalenessThreshold 

func (x *FeatureTableSpec) GetStalenessThreshold() *durationpb.Duration

func (*FeatureTableSpec) GetStreamSource 

func (x *FeatureTableSpec) GetStreamSource() *DataSource

func (*FeatureTableSpec) ProtoMessage 

func (*FeatureTableSpec) ProtoMessage()

func (*FeatureTableSpec) ProtoReflect 

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

func (*FeatureTableSpec) Reset 

func (x *FeatureTableSpec) Reset()

func (*FeatureTableSpec) String 

func (x *FeatureTableSpec) String() string

type FileFormat 

type FileFormat struct {

	// Types that are assignable to Format:
	//	*FileFormat_ParquetFormat_
	Format isFileFormat_Format `protobuf_oneof:"format"`
	// contains filtered or unexported fields
}

Defines the file format encoding the features/entity data in files

func (*FileFormat) Descriptor deprecated 

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

Deprecated: Use FileFormat.ProtoReflect.Descriptor instead.

func (*FileFormat) GetFormat 

func (m *FileFormat) GetFormat() isFileFormat_Format

func (*FileFormat) GetParquetFormat 

func (x *FileFormat) GetParquetFormat() *FileFormat_ParquetFormat

func (*FileFormat) ProtoMessage 

func (*FileFormat) ProtoMessage()

func (*FileFormat) ProtoReflect 

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

func (*FileFormat) Reset 

func (x *FileFormat) Reset()

func (*FileFormat) String 

func (x *FileFormat) String() string

type FileFormat_ParquetFormat 

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

Defines options for the Parquet data format

func (*FileFormat_ParquetFormat) Descriptor deprecated 

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

Deprecated: Use FileFormat_ParquetFormat.ProtoReflect.Descriptor instead.

func (*FileFormat_ParquetFormat) ProtoMessage 

func (*FileFormat_ParquetFormat) ProtoMessage()

func (*FileFormat_ParquetFormat) ProtoReflect 

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

func (*FileFormat_ParquetFormat) Reset 

func (x *FileFormat_ParquetFormat) Reset()

func (*FileFormat_ParquetFormat) String 

func (x *FileFormat_ParquetFormat) String() string

type FileFormat_ParquetFormat_ 

type FileFormat_ParquetFormat_ struct {
	ParquetFormat *FileFormat_ParquetFormat `protobuf:"bytes,1,opt,name=parquet_format,json=parquetFormat,proto3,oneof"`
}

type FloatList 

type FloatList struct {
	Val []float32 `protobuf:"fixed32,1,rep,packed,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

func (*FloatList) Descriptor deprecated 

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

Deprecated: Use FloatList.ProtoReflect.Descriptor instead.

func (*FloatList) GetVal 

func (x *FloatList) GetVal() []float32

func (*FloatList) ProtoMessage 

func (*FloatList) ProtoMessage()

func (*FloatList) ProtoReflect 

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

func (*FloatList) Reset 

func (x *FloatList) Reset()

func (*FloatList) String 

func (x *FloatList) String() string

type GetEntityRequest 

type GetEntityRequest struct {

	// Name of entity (required).
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of project the entity belongs to. If omitted will default to 'default' project.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

Request for a single entity

func (*GetEntityRequest) Descriptor deprecated 

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

Deprecated: Use GetEntityRequest.ProtoReflect.Descriptor instead.

func (*GetEntityRequest) GetName 

func (x *GetEntityRequest) GetName() string

func (*GetEntityRequest) GetProject 

func (x *GetEntityRequest) GetProject() string

func (*GetEntityRequest) ProtoMessage 

func (*GetEntityRequest) ProtoMessage()

func (*GetEntityRequest) ProtoReflect 

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

func (*GetEntityRequest) Reset 

func (x *GetEntityRequest) Reset()

func (*GetEntityRequest) String 

func (x *GetEntityRequest) String() string

type GetEntityResponse 

type GetEntityResponse struct {
	Entity *Entity `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	// contains filtered or unexported fields
}

Response containing a single entity

func (*GetEntityResponse) Descriptor deprecated 

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

Deprecated: Use GetEntityResponse.ProtoReflect.Descriptor instead.

func (*GetEntityResponse) GetEntity 

func (x *GetEntityResponse) GetEntity() *Entity

func (*GetEntityResponse) ProtoMessage 

func (*GetEntityResponse) ProtoMessage()

func (*GetEntityResponse) ProtoReflect 

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

func (*GetEntityResponse) Reset 

func (x *GetEntityResponse) Reset()

func (*GetEntityResponse) String 

func (x *GetEntityResponse) String() string

type GetFeastCoreVersionRequest 

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

func (*GetFeastCoreVersionRequest) Descriptor deprecated 

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

Deprecated: Use GetFeastCoreVersionRequest.ProtoReflect.Descriptor instead.

func (*GetFeastCoreVersionRequest) ProtoMessage 

func (*GetFeastCoreVersionRequest) ProtoMessage()

func (*GetFeastCoreVersionRequest) ProtoReflect 

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

func (*GetFeastCoreVersionRequest) Reset 

func (x *GetFeastCoreVersionRequest) Reset()

func (*GetFeastCoreVersionRequest) String 

func (x *GetFeastCoreVersionRequest) String() string

type GetFeastCoreVersionResponse 

type GetFeastCoreVersionResponse struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFeastCoreVersionResponse) Descriptor deprecated 

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

Deprecated: Use GetFeastCoreVersionResponse.ProtoReflect.Descriptor instead.

func (*GetFeastCoreVersionResponse) GetVersion 

func (x *GetFeastCoreVersionResponse) GetVersion() string

func (*GetFeastCoreVersionResponse) ProtoMessage 

func (*GetFeastCoreVersionResponse) ProtoMessage()

func (*GetFeastCoreVersionResponse) ProtoReflect 

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

func (*GetFeastCoreVersionResponse) Reset 

func (x *GetFeastCoreVersionResponse) Reset()

func (*GetFeastCoreVersionResponse) String 

func (x *GetFeastCoreVersionResponse) String() string

type GetFeatureTableRequest 

type GetFeatureTableRequest struct {

	// Optional. Name of the Project to retrieve the Feature Table from.
	// If unspecified, will apply FeatureTable to the default project.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the FeatureTable to retrieve.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFeatureTableRequest) Descriptor deprecated 

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

Deprecated: Use GetFeatureTableRequest.ProtoReflect.Descriptor instead.

func (*GetFeatureTableRequest) GetName 

func (x *GetFeatureTableRequest) GetName() string

func (*GetFeatureTableRequest) GetProject 

func (x *GetFeatureTableRequest) GetProject() string

func (*GetFeatureTableRequest) ProtoMessage 

func (*GetFeatureTableRequest) ProtoMessage()

func (*GetFeatureTableRequest) ProtoReflect 

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

func (*GetFeatureTableRequest) Reset 

func (x *GetFeatureTableRequest) Reset()

func (*GetFeatureTableRequest) String 

func (x *GetFeatureTableRequest) String() string

type GetFeatureTableResponse 

type GetFeatureTableResponse struct {

	// The Feature Table retrieved.
	Table *FeatureTable `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFeatureTableResponse) Descriptor deprecated 

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

Deprecated: Use GetFeatureTableResponse.ProtoReflect.Descriptor instead.

func (*GetFeatureTableResponse) GetTable 

func (x *GetFeatureTableResponse) GetTable() *FeatureTable

func (*GetFeatureTableResponse) ProtoMessage 

func (*GetFeatureTableResponse) ProtoMessage()

func (*GetFeatureTableResponse) ProtoReflect 

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

func (*GetFeatureTableResponse) Reset 

func (x *GetFeatureTableResponse) Reset()

func (*GetFeatureTableResponse) String 

func (x *GetFeatureTableResponse) String() string

type GetOnlineStoreRequest 

type GetOnlineStoreRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOnlineStoreRequest) Descriptor deprecated 

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

Deprecated: Use GetOnlineStoreRequest.ProtoReflect.Descriptor instead.

func (*GetOnlineStoreRequest) GetName 

func (x *GetOnlineStoreRequest) GetName() string

func (*GetOnlineStoreRequest) ProtoMessage 

func (*GetOnlineStoreRequest) ProtoMessage()

func (*GetOnlineStoreRequest) ProtoReflect 

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

func (*GetOnlineStoreRequest) Reset 

func (x *GetOnlineStoreRequest) Reset()

func (*GetOnlineStoreRequest) String 

func (x *GetOnlineStoreRequest) String() string

type GetOnlineStoreResponse 

type GetOnlineStoreResponse struct {
	OnlineStore *OnlineStore                  `protobuf:"bytes,1,opt,name=online_store,json=onlineStore,proto3" json:"online_store,omitempty"`
	Status      GetOnlineStoreResponse_Status `protobuf:"varint,2,opt,name=status,proto3,enum=feast.core.GetOnlineStoreResponse_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOnlineStoreResponse) Descriptor deprecated 

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

Deprecated: Use GetOnlineStoreResponse.ProtoReflect.Descriptor instead.

func (*GetOnlineStoreResponse) GetOnlineStore 

func (x *GetOnlineStoreResponse) GetOnlineStore() *OnlineStore

func (*GetOnlineStoreResponse) GetStatus 

func (x *GetOnlineStoreResponse) GetStatus() GetOnlineStoreResponse_Status

func (*GetOnlineStoreResponse) ProtoMessage 

func (*GetOnlineStoreResponse) ProtoMessage()

func (*GetOnlineStoreResponse) ProtoReflect 

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

func (*GetOnlineStoreResponse) Reset 

func (x *GetOnlineStoreResponse) Reset()

func (*GetOnlineStoreResponse) String 

func (x *GetOnlineStoreResponse) String() string

type GetOnlineStoreResponse_Status 

type GetOnlineStoreResponse_Status int32
const (
	// Requested online store is active
	GetOnlineStoreResponse_ACTIVE GetOnlineStoreResponse_Status = 0
	// Requested online store is archived
	GetOnlineStoreResponse_ARCHIVED GetOnlineStoreResponse_Status = 1
)

func (GetOnlineStoreResponse_Status) Descriptor 

func (GetOnlineStoreResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (GetOnlineStoreResponse_Status) Enum 

func (x GetOnlineStoreResponse_Status) Enum() *GetOnlineStoreResponse_Status

func (GetOnlineStoreResponse_Status) EnumDescriptor deprecated 

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

Deprecated: Use GetOnlineStoreResponse_Status.Descriptor instead.

func (GetOnlineStoreResponse_Status) Number 

func (x GetOnlineStoreResponse_Status) Number() protoreflect.EnumNumber

func (GetOnlineStoreResponse_Status) String 

func (x GetOnlineStoreResponse_Status) String() string

func (GetOnlineStoreResponse_Status) Type 

func (GetOnlineStoreResponse_Status) Type() protoreflect.EnumType

type Int32List 

type Int32List struct {
	Val []int32 `protobuf:"varint,1,rep,packed,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

func (*Int32List) Descriptor deprecated 

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

Deprecated: Use Int32List.ProtoReflect.Descriptor instead.

func (*Int32List) GetVal 

func (x *Int32List) GetVal() []int32

func (*Int32List) ProtoMessage 

func (*Int32List) ProtoMessage()

func (*Int32List) ProtoReflect 

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

func (*Int32List) Reset 

func (x *Int32List) Reset()

func (*Int32List) String 

func (x *Int32List) String() string

type Int64List 

type Int64List struct {
	Val []int64 `protobuf:"varint,1,rep,packed,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

func (*Int64List) Descriptor deprecated 

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

Deprecated: Use Int64List.ProtoReflect.Descriptor instead.

func (*Int64List) GetVal 

func (x *Int64List) GetVal() []int64

func (*Int64List) ProtoMessage 

func (*Int64List) ProtoMessage()

func (*Int64List) ProtoReflect 

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

func (*Int64List) Reset 

func (x *Int64List) Reset()

func (*Int64List) String 

func (x *Int64List) String() string

type ListEntitiesRequest 

type ListEntitiesRequest struct {
	Filter *ListEntitiesRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

Retrieves details for all versions of a specific entity

func (*ListEntitiesRequest) Descriptor deprecated 

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

Deprecated: Use ListEntitiesRequest.ProtoReflect.Descriptor instead.

func (*ListEntitiesRequest) GetFilter 

func (x *ListEntitiesRequest) GetFilter() *ListEntitiesRequest_Filter

func (*ListEntitiesRequest) ProtoMessage 

func (*ListEntitiesRequest) ProtoMessage()

func (*ListEntitiesRequest) ProtoReflect 

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

func (*ListEntitiesRequest) Reset 

func (x *ListEntitiesRequest) Reset()

func (*ListEntitiesRequest) String 

func (x *ListEntitiesRequest) String() string

type ListEntitiesRequest_Filter 

type ListEntitiesRequest_Filter struct {

	// Optional. Specifies the name of the project to list Entities in.
	// It is NOT possible to provide an asterisk with a string in order to do pattern matching.
	// If unspecified, this field will default to the default project 'default'.
	Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	// Optional. User defined metadata for entity.
	// Entities with all matching labels will be returned.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListEntitiesRequest_Filter) Descriptor deprecated 

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

Deprecated: Use ListEntitiesRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListEntitiesRequest_Filter) GetLabels 

func (x *ListEntitiesRequest_Filter) GetLabels() map[string]string

func (*ListEntitiesRequest_Filter) GetProject 

func (x *ListEntitiesRequest_Filter) GetProject() string

func (*ListEntitiesRequest_Filter) ProtoMessage 

func (*ListEntitiesRequest_Filter) ProtoMessage()

func (*ListEntitiesRequest_Filter) ProtoReflect 

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

func (*ListEntitiesRequest_Filter) Reset 

func (x *ListEntitiesRequest_Filter) Reset()

func (*ListEntitiesRequest_Filter) String 

func (x *ListEntitiesRequest_Filter) String() string

type ListEntitiesResponse 

type ListEntitiesResponse struct {
	Entities []*Entity `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEntitiesResponse) Descriptor deprecated 

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

Deprecated: Use ListEntitiesResponse.ProtoReflect.Descriptor instead.

func (*ListEntitiesResponse) GetEntities 

func (x *ListEntitiesResponse) GetEntities() []*Entity

func (*ListEntitiesResponse) ProtoMessage 

func (*ListEntitiesResponse) ProtoMessage()

func (*ListEntitiesResponse) ProtoReflect 

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

func (*ListEntitiesResponse) Reset 

func (x *ListEntitiesResponse) Reset()

func (*ListEntitiesResponse) String 

func (x *ListEntitiesResponse) String() string

type ListFeatureTablesRequest 

type ListFeatureTablesRequest struct {

	// Filter used when listing Feature Tables
	Filter *ListFeatureTablesRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFeatureTablesRequest) Descriptor deprecated 

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

Deprecated: Use ListFeatureTablesRequest.ProtoReflect.Descriptor instead.

func (*ListFeatureTablesRequest) GetFilter 

func (x *ListFeatureTablesRequest) GetFilter() *ListFeatureTablesRequest_Filter

func (*ListFeatureTablesRequest) ProtoMessage 

func (*ListFeatureTablesRequest) ProtoMessage()

func (*ListFeatureTablesRequest) ProtoReflect 

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

func (*ListFeatureTablesRequest) Reset 

func (x *ListFeatureTablesRequest) Reset()

func (*ListFeatureTablesRequest) String 

func (x *ListFeatureTablesRequest) String() string

type ListFeatureTablesRequest_Filter 

type ListFeatureTablesRequest_Filter struct {

	// Optional. Specifies the name of the project to list Feature Tables in.
	// If unspecified would list Feature Tables in the default project.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Optional. Feature Tables with all matching labels will be returned.
	// If unspecified would list Feature Tables without filtering by labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListFeatureTablesRequest_Filter) Descriptor deprecated 

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

Deprecated: Use ListFeatureTablesRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListFeatureTablesRequest_Filter) GetLabels 

func (x *ListFeatureTablesRequest_Filter) GetLabels() map[string]string

func (*ListFeatureTablesRequest_Filter) GetProject 

func (x *ListFeatureTablesRequest_Filter) GetProject() string

func (*ListFeatureTablesRequest_Filter) ProtoMessage 

func (*ListFeatureTablesRequest_Filter) ProtoMessage()

func (*ListFeatureTablesRequest_Filter) ProtoReflect 

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

func (*ListFeatureTablesRequest_Filter) Reset 

func (x *ListFeatureTablesRequest_Filter) Reset()

func (*ListFeatureTablesRequest_Filter) String 

func (x *ListFeatureTablesRequest_Filter) String() string

type ListFeatureTablesResponse 

type ListFeatureTablesResponse struct {

	// List of matching Feature Tables
	Tables []*FeatureTable `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFeatureTablesResponse) Descriptor deprecated 

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

Deprecated: Use ListFeatureTablesResponse.ProtoReflect.Descriptor instead.

func (*ListFeatureTablesResponse) GetTables 

func (x *ListFeatureTablesResponse) GetTables() []*FeatureTable

func (*ListFeatureTablesResponse) ProtoMessage 

func (*ListFeatureTablesResponse) ProtoMessage()

func (*ListFeatureTablesResponse) ProtoReflect 

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

func (*ListFeatureTablesResponse) Reset 

func (x *ListFeatureTablesResponse) Reset()

func (*ListFeatureTablesResponse) String 

func (x *ListFeatureTablesResponse) String() string

type ListFeaturesRequest 

type ListFeaturesRequest struct {
	Filter *ListFeaturesRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFeaturesRequest) Descriptor deprecated 

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

Deprecated: Use ListFeaturesRequest.ProtoReflect.Descriptor instead.

func (*ListFeaturesRequest) GetFilter 

func (x *ListFeaturesRequest) GetFilter() *ListFeaturesRequest_Filter

func (*ListFeaturesRequest) ProtoMessage 

func (*ListFeaturesRequest) ProtoMessage()

func (*ListFeaturesRequest) ProtoReflect 

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

func (*ListFeaturesRequest) Reset 

func (x *ListFeaturesRequest) Reset()

func (*ListFeaturesRequest) String 

func (x *ListFeaturesRequest) String() string

type ListFeaturesRequest_Filter 

type ListFeaturesRequest_Filter struct {

	// User defined metadata for feature.
	// Features with all matching labels will be returned.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// List of entities contained within the featureSet that the feature belongs to.
	// Only feature tables with these entities will be searched for features.
	Entities []string `protobuf:"bytes,2,rep,name=entities,proto3" json:"entities,omitempty"`
	// Name of project that the feature tables belongs to. Filtering on projects is disabled.
	// It is NOT possible to provide an asterisk with a string in order to do pattern matching.
	// If unspecified this field will default to the default project 'default'.
	Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFeaturesRequest_Filter) Descriptor deprecated 

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

Deprecated: Use ListFeaturesRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListFeaturesRequest_Filter) GetEntities 

func (x *ListFeaturesRequest_Filter) GetEntities() []string

func (*ListFeaturesRequest_Filter) GetLabels 

func (x *ListFeaturesRequest_Filter) GetLabels() map[string]string

func (*ListFeaturesRequest_Filter) GetProject 

func (x *ListFeaturesRequest_Filter) GetProject() string

func (*ListFeaturesRequest_Filter) ProtoMessage 

func (*ListFeaturesRequest_Filter) ProtoMessage()

func (*ListFeaturesRequest_Filter) ProtoReflect 

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

func (*ListFeaturesRequest_Filter) Reset 

func (x *ListFeaturesRequest_Filter) Reset()

func (*ListFeaturesRequest_Filter) String 

func (x *ListFeaturesRequest_Filter) String() string

type ListFeaturesResponse 

type ListFeaturesResponse struct {
	Features map[string]*FeatureSpec `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListFeaturesResponse) Descriptor deprecated 

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

Deprecated: Use ListFeaturesResponse.ProtoReflect.Descriptor instead.

func (*ListFeaturesResponse) GetFeatures 

func (x *ListFeaturesResponse) GetFeatures() map[string]*FeatureSpec

func (*ListFeaturesResponse) ProtoMessage 

func (*ListFeaturesResponse) ProtoMessage()

func (*ListFeaturesResponse) ProtoReflect 

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

func (*ListFeaturesResponse) Reset 

func (x *ListFeaturesResponse) Reset()

func (*ListFeaturesResponse) String 

func (x *ListFeaturesResponse) String() string

type ListOnlineStoresRequest 

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

func (*ListOnlineStoresRequest) Descriptor deprecated 

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

Deprecated: Use ListOnlineStoresRequest.ProtoReflect.Descriptor instead.

func (*ListOnlineStoresRequest) ProtoMessage 

func (*ListOnlineStoresRequest) ProtoMessage()

func (*ListOnlineStoresRequest) ProtoReflect 

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

func (*ListOnlineStoresRequest) Reset 

func (x *ListOnlineStoresRequest) Reset()

func (*ListOnlineStoresRequest) String 

func (x *ListOnlineStoresRequest) String() string

type ListOnlineStoresResponse 

type ListOnlineStoresResponse struct {
	OnlineStore []*OnlineStore `protobuf:"bytes,1,rep,name=online_store,json=onlineStore,proto3" json:"online_store,omitempty"`
	// contains filtered or unexported fields
}

func (*ListOnlineStoresResponse) Descriptor deprecated 

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

Deprecated: Use ListOnlineStoresResponse.ProtoReflect.Descriptor instead.

func (*ListOnlineStoresResponse) GetOnlineStore 

func (x *ListOnlineStoresResponse) GetOnlineStore() []*OnlineStore

func (*ListOnlineStoresResponse) ProtoMessage 

func (*ListOnlineStoresResponse) ProtoMessage()

func (*ListOnlineStoresResponse) ProtoReflect 

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

func (*ListOnlineStoresResponse) Reset 

func (x *ListOnlineStoresResponse) Reset()

func (*ListOnlineStoresResponse) String 

func (x *ListOnlineStoresResponse) String() string

type ListProjectsRequest 

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

Request for listing of projects

func (*ListProjectsRequest) Descriptor deprecated 

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

Deprecated: Use ListProjectsRequest.ProtoReflect.Descriptor instead.

func (*ListProjectsRequest) ProtoMessage 

func (*ListProjectsRequest) ProtoMessage()

func (*ListProjectsRequest) ProtoReflect 

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

func (*ListProjectsRequest) Reset 

func (x *ListProjectsRequest) Reset()

func (*ListProjectsRequest) String 

func (x *ListProjectsRequest) String() string

type ListProjectsResponse 

type ListProjectsResponse struct {

	// List of project names (archived projects are filtered out)
	Projects []string `protobuf:"bytes,1,rep,name=projects,proto3" json:"projects,omitempty"`
	// contains filtered or unexported fields
}

Response for listing of projects

func (*ListProjectsResponse) Descriptor deprecated 

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

Deprecated: Use ListProjectsResponse.ProtoReflect.Descriptor instead.

func (*ListProjectsResponse) GetProjects 

func (x *ListProjectsResponse) GetProjects() []string

func (*ListProjectsResponse) ProtoMessage 

func (*ListProjectsResponse) ProtoMessage()

func (*ListProjectsResponse) ProtoReflect 

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

func (*ListProjectsResponse) Reset 

func (x *ListProjectsResponse) Reset()

func (*ListProjectsResponse) String 

func (x *ListProjectsResponse) String() string

type OnlineStore 

type OnlineStore struct {

	// Name of the store.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of store.
	Type StoreType `protobuf:"varint,2,opt,name=type,proto3,enum=feast.core.StoreType" json:"type,omitempty"`
	// Description.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

OnlineStore provides a location where Feast reads and writes feature values. Feature values will be written to the Store in the form of FeatureRow elements. The way FeatureRow is encoded and decoded when it is written to and read from the Store depends on the type of the Store.

func (*OnlineStore) Descriptor deprecated 

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

Deprecated: Use OnlineStore.ProtoReflect.Descriptor instead.

func (*OnlineStore) GetDescription 

func (x *OnlineStore) GetDescription() string

func (*OnlineStore) GetName 

func (x *OnlineStore) GetName() string

func (*OnlineStore) GetType 

func (x *OnlineStore) GetType() StoreType

func (*OnlineStore) ProtoMessage 

func (*OnlineStore) ProtoMessage()

func (*OnlineStore) ProtoReflect 

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

func (*OnlineStore) Reset 

func (x *OnlineStore) Reset()

func (*OnlineStore) String 

func (x *OnlineStore) String() string

type RegisterOnlineStoreRequest 

type RegisterOnlineStoreRequest struct {
	OnlineStore *OnlineStore `protobuf:"bytes,1,opt,name=online_store,json=onlineStore,proto3" json:"online_store,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterOnlineStoreRequest) Descriptor deprecated 

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

Deprecated: Use RegisterOnlineStoreRequest.ProtoReflect.Descriptor instead.

func (*RegisterOnlineStoreRequest) GetOnlineStore 

func (x *RegisterOnlineStoreRequest) GetOnlineStore() *OnlineStore

func (*RegisterOnlineStoreRequest) ProtoMessage 

func (*RegisterOnlineStoreRequest) ProtoMessage()

func (*RegisterOnlineStoreRequest) ProtoReflect 

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

func (*RegisterOnlineStoreRequest) Reset 

func (x *RegisterOnlineStoreRequest) Reset()

func (*RegisterOnlineStoreRequest) String 

func (x *RegisterOnlineStoreRequest) String() string

type RegisterOnlineStoreResponse 

type RegisterOnlineStoreResponse struct {
	OnlineStore *OnlineStore                       `protobuf:"bytes,1,opt,name=online_store,json=onlineStore,proto3" json:"online_store,omitempty"`
	Status      RegisterOnlineStoreResponse_Status `protobuf:"varint,2,opt,name=status,proto3,enum=feast.core.RegisterOnlineStoreResponse_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterOnlineStoreResponse) Descriptor deprecated 

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

Deprecated: Use RegisterOnlineStoreResponse.ProtoReflect.Descriptor instead.

func (*RegisterOnlineStoreResponse) GetOnlineStore 

func (x *RegisterOnlineStoreResponse) GetOnlineStore() *OnlineStore

func (*RegisterOnlineStoreResponse) GetStatus 

func (x *RegisterOnlineStoreResponse) GetStatus() RegisterOnlineStoreResponse_Status

func (*RegisterOnlineStoreResponse) ProtoMessage 

func (*RegisterOnlineStoreResponse) ProtoMessage()

func (*RegisterOnlineStoreResponse) ProtoReflect 

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

func (*RegisterOnlineStoreResponse) Reset 

func (x *RegisterOnlineStoreResponse) Reset()

func (*RegisterOnlineStoreResponse) String 

func (x *RegisterOnlineStoreResponse) String() string

type RegisterOnlineStoreResponse_Status 

type RegisterOnlineStoreResponse_Status int32
const (
	// Existing store properties matching the given online store is identical to the given request
	RegisterOnlineStoreResponse_NO_CHANGE RegisterOnlineStoreResponse_Status = 0
	// New online store created or existing properties updated.
	RegisterOnlineStoreResponse_REGISTERED RegisterOnlineStoreResponse_Status = 1
	// Existing online store updated.
	RegisterOnlineStoreResponse_UPDATED RegisterOnlineStoreResponse_Status = 2
)

func (RegisterOnlineStoreResponse_Status) Descriptor 

func (RegisterOnlineStoreResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (RegisterOnlineStoreResponse_Status) Enum 

func (x RegisterOnlineStoreResponse_Status) Enum() *RegisterOnlineStoreResponse_Status

func (RegisterOnlineStoreResponse_Status) EnumDescriptor deprecated 

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

Deprecated: Use RegisterOnlineStoreResponse_Status.Descriptor instead.

func (RegisterOnlineStoreResponse_Status) Number 

func (x RegisterOnlineStoreResponse_Status) Number() protoreflect.EnumNumber

func (RegisterOnlineStoreResponse_Status) String 

func (x RegisterOnlineStoreResponse_Status) String() string

func (RegisterOnlineStoreResponse_Status) Type 

func (RegisterOnlineStoreResponse_Status) Type() protoreflect.EnumType

type StoreType 

type StoreType int32
const (
	// Unset
	StoreType_UNSET StoreType = 0
	// google cloud NOSQL database service
	StoreType_BIGTABLE StoreType = 1
	// redis in-memory database
	StoreType_REDIS StoreType = 2
)

func (StoreType) Descriptor 

func (StoreType) Descriptor() protoreflect.EnumDescriptor

func (StoreType) Enum 

func (x StoreType) Enum() *StoreType

func (StoreType) EnumDescriptor deprecated 

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

Deprecated: Use StoreType.Descriptor instead.

func (StoreType) Number 

func (x StoreType) Number() protoreflect.EnumNumber

func (StoreType) String 

func (x StoreType) String() string

func (StoreType) Type 

func (StoreType) Type() protoreflect.EnumType

type StreamFormat 

type StreamFormat struct {

	// Specifies the data format and format specific options
	//
	// Types that are assignable to Format:
	//	*StreamFormat_AvroFormat_
	//	*StreamFormat_ProtoFormat_
	Format isStreamFormat_Format `protobuf_oneof:"format"`
	// contains filtered or unexported fields
}

Defines the data format encoding features/entity data in data streams

func (*StreamFormat) Descriptor deprecated 

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

Deprecated: Use StreamFormat.ProtoReflect.Descriptor instead.

func (*StreamFormat) GetAvroFormat 

func (x *StreamFormat) GetAvroFormat() *StreamFormat_AvroFormat

func (*StreamFormat) GetFormat 

func (m *StreamFormat) GetFormat() isStreamFormat_Format

func (*StreamFormat) GetProtoFormat 

func (x *StreamFormat) GetProtoFormat() *StreamFormat_ProtoFormat

func (*StreamFormat) ProtoMessage 

func (*StreamFormat) ProtoMessage()

func (*StreamFormat) ProtoReflect 

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

func (*StreamFormat) Reset 

func (x *StreamFormat) Reset()

func (*StreamFormat) String 

func (x *StreamFormat) String() string

type StreamFormat_AvroFormat 

type StreamFormat_AvroFormat struct {

	// Optional if used in a File DataSource as schema is embedded in avro file.
	// Specifies the schema of the Avro message as JSON string.
	SchemaJson string `protobuf:"bytes,1,opt,name=schema_json,json=schemaJson,proto3" json:"schema_json,omitempty"`
	// contains filtered or unexported fields
}

Defines options for the avro data format

func (*StreamFormat_AvroFormat) Descriptor deprecated 

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

Deprecated: Use StreamFormat_AvroFormat.ProtoReflect.Descriptor instead.

func (*StreamFormat_AvroFormat) GetSchemaJson 

func (x *StreamFormat_AvroFormat) GetSchemaJson() string

func (*StreamFormat_AvroFormat) ProtoMessage 

func (*StreamFormat_AvroFormat) ProtoMessage()

func (*StreamFormat_AvroFormat) ProtoReflect 

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

func (*StreamFormat_AvroFormat) Reset 

func (x *StreamFormat_AvroFormat) Reset()

func (*StreamFormat_AvroFormat) String 

func (x *StreamFormat_AvroFormat) String() string

type StreamFormat_AvroFormat_ 

type StreamFormat_AvroFormat_ struct {
	AvroFormat *StreamFormat_AvroFormat `protobuf:"bytes,1,opt,name=avro_format,json=avroFormat,proto3,oneof"`
}

type StreamFormat_ProtoFormat 

type StreamFormat_ProtoFormat struct {

	// Classpath to the generated Java Protobuf class that can be used to decode
	// Feature data from the obtained stream message
	ClassPath string `protobuf:"bytes,1,opt,name=class_path,json=classPath,proto3" json:"class_path,omitempty"`
	// contains filtered or unexported fields
}

Defines options for the protobuf data format

func (*StreamFormat_ProtoFormat) Descriptor deprecated 

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

Deprecated: Use StreamFormat_ProtoFormat.ProtoReflect.Descriptor instead.

func (*StreamFormat_ProtoFormat) GetClassPath 

func (x *StreamFormat_ProtoFormat) GetClassPath() string

func (*StreamFormat_ProtoFormat) ProtoMessage 

func (*StreamFormat_ProtoFormat) ProtoMessage()

func (*StreamFormat_ProtoFormat) ProtoReflect 

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

func (*StreamFormat_ProtoFormat) Reset 

func (x *StreamFormat_ProtoFormat) Reset()

func (*StreamFormat_ProtoFormat) String 

func (x *StreamFormat_ProtoFormat) String() string

type StreamFormat_ProtoFormat_ 

type StreamFormat_ProtoFormat_ struct {
	ProtoFormat *StreamFormat_ProtoFormat `protobuf:"bytes,2,opt,name=proto_format,json=protoFormat,proto3,oneof"`
}

type StringList 

type StringList struct {
	Val []string `protobuf:"bytes,1,rep,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

func (*StringList) Descriptor deprecated 

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

Deprecated: Use StringList.ProtoReflect.Descriptor instead.

func (*StringList) GetVal 

func (x *StringList) GetVal() []string

func (*StringList) ProtoMessage 

func (*StringList) ProtoMessage()

func (*StringList) ProtoReflect 

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

func (*StringList) Reset 

func (x *StringList) Reset()

func (*StringList) String 

func (x *StringList) String() string

type UnimplementedCoreServiceServer 

type UnimplementedCoreServiceServer struct {
}

UnimplementedCoreServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedCoreServiceServer) ApplyEntity 

func (UnimplementedCoreServiceServer) ApplyEntity(context.Context, *ApplyEntityRequest) (*ApplyEntityResponse, error)

func (UnimplementedCoreServiceServer) ApplyFeatureTable 

func (UnimplementedCoreServiceServer) ApplyFeatureTable(context.Context, *ApplyFeatureTableRequest) (*ApplyFeatureTableResponse, error)

func (UnimplementedCoreServiceServer) ArchiveOnlineStore 

func (UnimplementedCoreServiceServer) ArchiveOnlineStore(context.Context, *ArchiveOnlineStoreRequest) (*ArchiveOnlineStoreResponse, error)

func (UnimplementedCoreServiceServer) ArchiveProject 

func (UnimplementedCoreServiceServer) ArchiveProject(context.Context, *ArchiveProjectRequest) (*ArchiveProjectResponse, error)

func (UnimplementedCoreServiceServer) CreateProject 

func (UnimplementedCoreServiceServer) CreateProject(context.Context, *CreateProjectRequest) (*CreateProjectResponse, error)

func (UnimplementedCoreServiceServer) DeleteFeatureTable 

func (UnimplementedCoreServiceServer) DeleteFeatureTable(context.Context, *DeleteFeatureTableRequest) (*DeleteFeatureTableResponse, error)

func (UnimplementedCoreServiceServer) GetEntity 

func (UnimplementedCoreServiceServer) GetEntity(context.Context, *GetEntityRequest) (*GetEntityResponse, error)

func (UnimplementedCoreServiceServer) GetFeastCoreVersion 

func (UnimplementedCoreServiceServer) GetFeastCoreVersion(context.Context, *GetFeastCoreVersionRequest) (*GetFeastCoreVersionResponse, error)

func (UnimplementedCoreServiceServer) GetFeatureTable 

func (UnimplementedCoreServiceServer) GetFeatureTable(context.Context, *GetFeatureTableRequest) (*GetFeatureTableResponse, error)

func (UnimplementedCoreServiceServer) GetOnlineStore 

func (UnimplementedCoreServiceServer) GetOnlineStore(context.Context, *GetOnlineStoreRequest) (*GetOnlineStoreResponse, error)

func (UnimplementedCoreServiceServer) ListEntities 

func (UnimplementedCoreServiceServer) ListEntities(context.Context, *ListEntitiesRequest) (*ListEntitiesResponse, error)

func (UnimplementedCoreServiceServer) ListFeatureTables 

func (UnimplementedCoreServiceServer) ListFeatureTables(context.Context, *ListFeatureTablesRequest) (*ListFeatureTablesResponse, error)

func (UnimplementedCoreServiceServer) ListFeatures 

func (UnimplementedCoreServiceServer) ListFeatures(context.Context, *ListFeaturesRequest) (*ListFeaturesResponse, error)

func (UnimplementedCoreServiceServer) ListOnlineStores 

func (UnimplementedCoreServiceServer) ListOnlineStores(context.Context, *ListOnlineStoresRequest) (*ListOnlineStoresResponse, error)

func (UnimplementedCoreServiceServer) ListProjects 

func (UnimplementedCoreServiceServer) ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error)

func (UnimplementedCoreServiceServer) RegisterOnlineStore 

func (UnimplementedCoreServiceServer) RegisterOnlineStore(context.Context, *RegisterOnlineStoreRequest) (*RegisterOnlineStoreResponse, error)

type UnsafeCoreServiceServer 

type UnsafeCoreServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeCoreServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CoreServiceServer will result in compilation errors.

type Value 

type Value struct {

	// ValueType is referenced by the metadata types, FeatureInfo and EntityInfo.
	// The enum values do not have to match the oneof val field ids, but they should.
	//
	// Types that are assignable to Val:
	//	*Value_BytesVal
	//	*Value_StringVal
	//	*Value_Int32Val
	//	*Value_Int64Val
	//	*Value_DoubleVal
	//	*Value_FloatVal
	//	*Value_BoolVal
	//	*Value_BytesListVal
	//	*Value_StringListVal
	//	*Value_Int32ListVal
	//	*Value_Int64ListVal
	//	*Value_DoubleListVal
	//	*Value_FloatListVal
	//	*Value_BoolListVal
	Val isValue_Val `protobuf_oneof:"val"`
	// contains filtered or unexported fields
}

func (*Value) Descriptor deprecated 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetBoolListVal 

func (x *Value) GetBoolListVal() *BoolList

func (*Value) GetBoolVal 

func (x *Value) GetBoolVal() bool

func (*Value) GetBytesListVal 

func (x *Value) GetBytesListVal() *BytesList

func (*Value) GetBytesVal 

func (x *Value) GetBytesVal() []byte

func (*Value) GetDoubleListVal 

func (x *Value) GetDoubleListVal() *DoubleList

func (*Value) GetDoubleVal 

func (x *Value) GetDoubleVal() float64

func (*Value) GetFloatListVal 

func (x *Value) GetFloatListVal() *FloatList

func (*Value) GetFloatVal 

func (x *Value) GetFloatVal() float32

func (*Value) GetInt32ListVal 

func (x *Value) GetInt32ListVal() *Int32List

func (*Value) GetInt32Val 

func (x *Value) GetInt32Val() int32

func (*Value) GetInt64ListVal 

func (x *Value) GetInt64ListVal() *Int64List

func (*Value) GetInt64Val 

func (x *Value) GetInt64Val() int64

func (*Value) GetStringListVal 

func (x *Value) GetStringListVal() *StringList

func (*Value) GetStringVal 

func (x *Value) GetStringVal() string

func (*Value) GetVal 

func (m *Value) GetVal() isValue_Val

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

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

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) String() string

type ValueType 

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

func (*ValueType) Descriptor deprecated 

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

Deprecated: Use ValueType.ProtoReflect.Descriptor instead.

func (*ValueType) ProtoMessage 

func (*ValueType) ProtoMessage()

func (*ValueType) ProtoReflect 

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

func (*ValueType) Reset 

func (x *ValueType) Reset()

func (*ValueType) String 

func (x *ValueType) String() string

type ValueType_Enum 

type ValueType_Enum int32
const (
	ValueType_INVALID     ValueType_Enum = 0
	ValueType_BYTES       ValueType_Enum = 1
	ValueType_STRING      ValueType_Enum = 2
	ValueType_INT32       ValueType_Enum = 3
	ValueType_INT64       ValueType_Enum = 4
	ValueType_DOUBLE      ValueType_Enum = 5
	ValueType_FLOAT       ValueType_Enum = 6
	ValueType_BOOL        ValueType_Enum = 7
	ValueType_BYTES_LIST  ValueType_Enum = 11
	ValueType_STRING_LIST ValueType_Enum = 12
	ValueType_INT32_LIST  ValueType_Enum = 13
	ValueType_INT64_LIST  ValueType_Enum = 14
	ValueType_DOUBLE_LIST ValueType_Enum = 15
	ValueType_FLOAT_LIST  ValueType_Enum = 16
	ValueType_BOOL_LIST   ValueType_Enum = 17
)

func (ValueType_Enum) Descriptor 

func (ValueType_Enum) Descriptor() protoreflect.EnumDescriptor

func (ValueType_Enum) Enum 

func (x ValueType_Enum) Enum() *ValueType_Enum

func (ValueType_Enum) EnumDescriptor deprecated 

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

Deprecated: Use ValueType_Enum.Descriptor instead.

func (ValueType_Enum) Number 

func (x ValueType_Enum) Number() protoreflect.EnumNumber

func (ValueType_Enum) String 

func (x ValueType_Enum) String() string

func (ValueType_Enum) Type 

func (ValueType_Enum) Type() protoreflect.EnumType

type Value_BoolListVal 

type Value_BoolListVal struct {
	BoolListVal *BoolList `protobuf:"bytes,17,opt,name=bool_list_val,json=boolListVal,proto3,oneof"`
}

type Value_BoolVal 

type Value_BoolVal struct {
	BoolVal bool `protobuf:"varint,7,opt,name=bool_val,json=boolVal,proto3,oneof"`
}

type Value_BytesListVal 

type Value_BytesListVal struct {
	BytesListVal *BytesList `protobuf:"bytes,11,opt,name=bytes_list_val,json=bytesListVal,proto3,oneof"`
}

type Value_BytesVal 

type Value_BytesVal struct {
	BytesVal []byte `protobuf:"bytes,1,opt,name=bytes_val,json=bytesVal,proto3,oneof"`
}

type Value_DoubleListVal 

type Value_DoubleListVal struct {
	DoubleListVal *DoubleList `protobuf:"bytes,15,opt,name=double_list_val,json=doubleListVal,proto3,oneof"`
}

type Value_DoubleVal 

type Value_DoubleVal struct {
	DoubleVal float64 `protobuf:"fixed64,5,opt,name=double_val,json=doubleVal,proto3,oneof"`
}

type Value_FloatListVal 

type Value_FloatListVal struct {
	FloatListVal *FloatList `protobuf:"bytes,16,opt,name=float_list_val,json=floatListVal,proto3,oneof"`
}

type Value_FloatVal 

type Value_FloatVal struct {
	FloatVal float32 `protobuf:"fixed32,6,opt,name=float_val,json=floatVal,proto3,oneof"`
}

type Value_Int32ListVal 

type Value_Int32ListVal struct {
	Int32ListVal *Int32List `protobuf:"bytes,13,opt,name=int32_list_val,json=int32ListVal,proto3,oneof"`
}

type Value_Int32Val 

type Value_Int32Val struct {
	Int32Val int32 `protobuf:"varint,3,opt,name=int32_val,json=int32Val,proto3,oneof"`
}

type Value_Int64ListVal 

type Value_Int64ListVal struct {
	Int64ListVal *Int64List `protobuf:"bytes,14,opt,name=int64_list_val,json=int64ListVal,proto3,oneof"`
}

type Value_Int64Val 

type Value_Int64Val struct {
	Int64Val int64 `protobuf:"varint,4,opt,name=int64_val,json=int64Val,proto3,oneof"`
}

type Value_StringListVal 

type Value_StringListVal struct {
	StringListVal *StringList `protobuf:"bytes,12,opt,name=string_list_val,json=stringListVal,proto3,oneof"`
}

type Value_StringVal 

type Value_StringVal struct {
	StringVal string `protobuf:"bytes,2,opt,name=string_val,json=stringVal,proto3,oneof"`
}

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.