Documentation ¶
Index ¶
- type DataStore
- func (*DataStore) Descriptor() ([]byte, []int)
- func (m *DataStore) GetId() string
- func (m *DataStore) GetOptions() map[string]string
- func (*DataStore) ProtoMessage()
- func (m *DataStore) Reset()
- func (m *DataStore) String() string
- func (m *DataStore) XXX_DiscardUnknown()
- func (m *DataStore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DataStore) XXX_Merge(src proto.Message)
- func (m *DataStore) XXX_Size() int
- func (m *DataStore) XXX_Unmarshal(b []byte) error
- type DataStores
- func (*DataStores) Descriptor() ([]byte, []int)
- func (m *DataStores) GetServing() *DataStore
- func (m *DataStores) GetWarehouse() *DataStore
- func (*DataStores) ProtoMessage()
- func (m *DataStores) Reset()
- func (m *DataStores) String() string
- func (m *DataStores) XXX_DiscardUnknown()
- func (m *DataStores) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DataStores) XXX_Merge(src proto.Message)
- func (m *DataStores) XXX_Size() int
- func (m *DataStores) XXX_Unmarshal(b []byte) error
- type EntitySpec
- func (*EntitySpec) Descriptor() ([]byte, []int)
- func (m *EntitySpec) GetDescription() string
- func (m *EntitySpec) GetName() string
- func (m *EntitySpec) GetTags() []string
- func (*EntitySpec) ProtoMessage()
- func (m *EntitySpec) Reset()
- func (m *EntitySpec) String() string
- func (m *EntitySpec) XXX_DiscardUnknown()
- func (m *EntitySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *EntitySpec) XXX_Merge(src proto.Message)
- func (m *EntitySpec) XXX_Size() int
- func (m *EntitySpec) XXX_Unmarshal(b []byte) error
- type FeatureGroupSpec
- func (*FeatureGroupSpec) Descriptor() ([]byte, []int)
- func (m *FeatureGroupSpec) GetDataStores() *DataStores
- func (m *FeatureGroupSpec) GetId() string
- func (m *FeatureGroupSpec) GetTags() []string
- func (*FeatureGroupSpec) ProtoMessage()
- func (m *FeatureGroupSpec) Reset()
- func (m *FeatureGroupSpec) String() string
- func (m *FeatureGroupSpec) XXX_DiscardUnknown()
- func (m *FeatureGroupSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *FeatureGroupSpec) XXX_Merge(src proto.Message)
- func (m *FeatureGroupSpec) XXX_Size() int
- func (m *FeatureGroupSpec) XXX_Unmarshal(b []byte) error
- type FeatureSpec
- func (*FeatureSpec) Descriptor() ([]byte, []int)
- func (m *FeatureSpec) GetDataStores() *DataStores
- func (m *FeatureSpec) GetDescription() string
- func (m *FeatureSpec) GetEntity() string
- func (m *FeatureSpec) GetGranularity() types.Granularity_Enum
- func (m *FeatureSpec) GetGroup() string
- func (m *FeatureSpec) GetId() string
- func (m *FeatureSpec) GetName() string
- func (m *FeatureSpec) GetOptions() map[string]string
- func (m *FeatureSpec) GetOwner() string
- func (m *FeatureSpec) GetTags() []string
- func (m *FeatureSpec) GetUri() string
- func (m *FeatureSpec) GetValueType() types.ValueType_Enum
- func (*FeatureSpec) ProtoMessage()
- func (m *FeatureSpec) Reset()
- func (m *FeatureSpec) String() string
- func (m *FeatureSpec) XXX_DiscardUnknown()
- func (m *FeatureSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *FeatureSpec) XXX_Merge(src proto.Message)
- func (m *FeatureSpec) XXX_Size() int
- func (m *FeatureSpec) XXX_Unmarshal(b []byte) error
- type Field
- func (*Field) Descriptor() ([]byte, []int)
- func (m *Field) GetFeatureId() string
- func (m *Field) GetName() string
- func (*Field) ProtoMessage()
- func (m *Field) Reset()
- func (m *Field) String() string
- func (m *Field) XXX_DiscardUnknown()
- func (m *Field) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Field) XXX_Merge(src proto.Message)
- func (m *Field) XXX_Size() int
- func (m *Field) XXX_Unmarshal(b []byte) error
- type ImportSpec
- func (*ImportSpec) Descriptor() ([]byte, []int)
- func (m *ImportSpec) GetEntities() []string
- func (m *ImportSpec) GetOptions() map[string]string
- func (m *ImportSpec) GetSchema() *Schema
- func (m *ImportSpec) GetType() string
- func (*ImportSpec) ProtoMessage()
- func (m *ImportSpec) Reset()
- func (m *ImportSpec) String() string
- func (m *ImportSpec) XXX_DiscardUnknown()
- func (m *ImportSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ImportSpec) XXX_Merge(src proto.Message)
- func (m *ImportSpec) XXX_Size() int
- func (m *ImportSpec) XXX_Unmarshal(b []byte) error
- type Schema
- func (*Schema) Descriptor() ([]byte, []int)
- func (m *Schema) GetEntityIdColumn() string
- func (m *Schema) GetFields() []*Field
- func (m *Schema) GetTimestamp() isSchema_Timestamp
- func (m *Schema) GetTimestampColumn() string
- func (m *Schema) GetTimestampValue() *timestamp.Timestamp
- func (*Schema) ProtoMessage()
- func (m *Schema) Reset()
- func (m *Schema) String() string
- func (m *Schema) XXX_DiscardUnknown()
- func (m *Schema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Schema) XXX_Merge(src proto.Message)
- func (*Schema) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *Schema) XXX_Size() int
- func (m *Schema) XXX_Unmarshal(b []byte) error
- type Schema_TimestampColumn
- type Schema_TimestampValue
- type StorageSpec
- func (*StorageSpec) Descriptor() ([]byte, []int)
- func (m *StorageSpec) GetId() string
- func (m *StorageSpec) GetOptions() map[string]string
- func (m *StorageSpec) GetType() string
- func (*StorageSpec) ProtoMessage()
- func (m *StorageSpec) Reset()
- func (m *StorageSpec) String() string
- func (m *StorageSpec) XXX_DiscardUnknown()
- func (m *StorageSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StorageSpec) XXX_Merge(src proto.Message)
- func (m *StorageSpec) XXX_Size() int
- func (m *StorageSpec) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataStore ¶
type DataStore struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Options map[string]string `` /* 155-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataStore) Descriptor ¶
func (*DataStore) GetOptions ¶
func (*DataStore) ProtoMessage ¶
func (*DataStore) ProtoMessage()
func (*DataStore) XXX_DiscardUnknown ¶
func (m *DataStore) XXX_DiscardUnknown()
func (*DataStore) XXX_Marshal ¶
func (*DataStore) XXX_Unmarshal ¶
type DataStores ¶
type DataStores struct { Serving *DataStore `protobuf:"bytes,1,opt,name=serving,proto3" json:"serving,omitempty"` Warehouse *DataStore `protobuf:"bytes,2,opt,name=warehouse,proto3" json:"warehouse,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataStores) Descriptor ¶
func (*DataStores) Descriptor() ([]byte, []int)
func (*DataStores) GetServing ¶
func (m *DataStores) GetServing() *DataStore
func (*DataStores) GetWarehouse ¶
func (m *DataStores) GetWarehouse() *DataStore
func (*DataStores) ProtoMessage ¶
func (*DataStores) ProtoMessage()
func (*DataStores) Reset ¶
func (m *DataStores) Reset()
func (*DataStores) String ¶
func (m *DataStores) String() string
func (*DataStores) XXX_DiscardUnknown ¶
func (m *DataStores) XXX_DiscardUnknown()
func (*DataStores) XXX_Marshal ¶
func (m *DataStores) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataStores) XXX_Merge ¶
func (dst *DataStores) XXX_Merge(src proto.Message)
func (*DataStores) XXX_Size ¶
func (m *DataStores) XXX_Size() int
func (*DataStores) XXX_Unmarshal ¶
func (m *DataStores) XXX_Unmarshal(b []byte) error
type EntitySpec ¶
type EntitySpec struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` Tags []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EntitySpec) Descriptor ¶
func (*EntitySpec) Descriptor() ([]byte, []int)
func (*EntitySpec) GetDescription ¶
func (m *EntitySpec) GetDescription() string
func (*EntitySpec) GetName ¶
func (m *EntitySpec) GetName() string
func (*EntitySpec) GetTags ¶
func (m *EntitySpec) GetTags() []string
func (*EntitySpec) ProtoMessage ¶
func (*EntitySpec) ProtoMessage()
func (*EntitySpec) Reset ¶
func (m *EntitySpec) Reset()
func (*EntitySpec) String ¶
func (m *EntitySpec) String() string
func (*EntitySpec) XXX_DiscardUnknown ¶
func (m *EntitySpec) XXX_DiscardUnknown()
func (*EntitySpec) XXX_Marshal ¶
func (m *EntitySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EntitySpec) XXX_Merge ¶
func (dst *EntitySpec) XXX_Merge(src proto.Message)
func (*EntitySpec) XXX_Size ¶
func (m *EntitySpec) XXX_Size() int
func (*EntitySpec) XXX_Unmarshal ¶
func (m *EntitySpec) XXX_Unmarshal(b []byte) error
type FeatureGroupSpec ¶
type FeatureGroupSpec struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Tags []string `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"` DataStores *DataStores `protobuf:"bytes,3,opt,name=dataStores,proto3" json:"dataStores,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FeatureGroupSpec) Descriptor ¶
func (*FeatureGroupSpec) Descriptor() ([]byte, []int)
func (*FeatureGroupSpec) GetDataStores ¶
func (m *FeatureGroupSpec) GetDataStores() *DataStores
func (*FeatureGroupSpec) GetId ¶
func (m *FeatureGroupSpec) GetId() string
func (*FeatureGroupSpec) GetTags ¶
func (m *FeatureGroupSpec) GetTags() []string
func (*FeatureGroupSpec) ProtoMessage ¶
func (*FeatureGroupSpec) ProtoMessage()
func (*FeatureGroupSpec) Reset ¶
func (m *FeatureGroupSpec) Reset()
func (*FeatureGroupSpec) String ¶
func (m *FeatureGroupSpec) String() string
func (*FeatureGroupSpec) XXX_DiscardUnknown ¶
func (m *FeatureGroupSpec) XXX_DiscardUnknown()
func (*FeatureGroupSpec) XXX_Marshal ¶
func (m *FeatureGroupSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FeatureGroupSpec) XXX_Merge ¶
func (dst *FeatureGroupSpec) XXX_Merge(src proto.Message)
func (*FeatureGroupSpec) XXX_Size ¶
func (m *FeatureGroupSpec) XXX_Size() int
func (*FeatureGroupSpec) XXX_Unmarshal ¶
func (m *FeatureGroupSpec) XXX_Unmarshal(b []byte) error
type FeatureSpec ¶
type FeatureSpec struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` Uri string `protobuf:"bytes,5,opt,name=uri,proto3" json:"uri,omitempty"` Granularity types.Granularity_Enum `protobuf:"varint,6,opt,name=granularity,proto3,enum=feast.types.Granularity_Enum" json:"granularity,omitempty"` ValueType types.ValueType_Enum `protobuf:"varint,7,opt,name=valueType,proto3,enum=feast.types.ValueType_Enum" json:"valueType,omitempty"` Entity string `protobuf:"bytes,8,opt,name=entity,proto3" json:"entity,omitempty"` Group string `protobuf:"bytes,9,opt,name=group,proto3" json:"group,omitempty"` Tags []string `protobuf:"bytes,10,rep,name=tags,proto3" json:"tags,omitempty"` Options map[string]string `` /* 156-byte string literal not displayed */ DataStores *DataStores `protobuf:"bytes,12,opt,name=dataStores,proto3" json:"dataStores,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FeatureSpec) Descriptor ¶
func (*FeatureSpec) Descriptor() ([]byte, []int)
func (*FeatureSpec) GetDataStores ¶
func (m *FeatureSpec) GetDataStores() *DataStores
func (*FeatureSpec) GetDescription ¶
func (m *FeatureSpec) GetDescription() string
func (*FeatureSpec) GetEntity ¶
func (m *FeatureSpec) GetEntity() string
func (*FeatureSpec) GetGranularity ¶
func (m *FeatureSpec) GetGranularity() types.Granularity_Enum
func (*FeatureSpec) GetGroup ¶
func (m *FeatureSpec) GetGroup() string
func (*FeatureSpec) GetId ¶
func (m *FeatureSpec) GetId() string
func (*FeatureSpec) GetName ¶
func (m *FeatureSpec) GetName() string
func (*FeatureSpec) GetOptions ¶
func (m *FeatureSpec) GetOptions() map[string]string
func (*FeatureSpec) GetOwner ¶
func (m *FeatureSpec) GetOwner() string
func (*FeatureSpec) GetTags ¶
func (m *FeatureSpec) GetTags() []string
func (*FeatureSpec) GetUri ¶
func (m *FeatureSpec) GetUri() string
func (*FeatureSpec) GetValueType ¶
func (m *FeatureSpec) GetValueType() types.ValueType_Enum
func (*FeatureSpec) ProtoMessage ¶
func (*FeatureSpec) ProtoMessage()
func (*FeatureSpec) Reset ¶
func (m *FeatureSpec) Reset()
func (*FeatureSpec) String ¶
func (m *FeatureSpec) String() string
func (*FeatureSpec) XXX_DiscardUnknown ¶
func (m *FeatureSpec) XXX_DiscardUnknown()
func (*FeatureSpec) XXX_Marshal ¶
func (m *FeatureSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FeatureSpec) XXX_Merge ¶
func (dst *FeatureSpec) XXX_Merge(src proto.Message)
func (*FeatureSpec) XXX_Size ¶
func (m *FeatureSpec) XXX_Size() int
func (*FeatureSpec) XXX_Unmarshal ¶
func (m *FeatureSpec) XXX_Unmarshal(b []byte) error
type Field ¶
type Field struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` FeatureId string `protobuf:"bytes,2,opt,name=featureId,proto3" json:"featureId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Field) Descriptor ¶
func (*Field) GetFeatureId ¶
func (*Field) ProtoMessage ¶
func (*Field) ProtoMessage()
func (*Field) XXX_DiscardUnknown ¶
func (m *Field) XXX_DiscardUnknown()
func (*Field) XXX_Marshal ¶
func (*Field) XXX_Unmarshal ¶
type ImportSpec ¶
type ImportSpec struct { // type should define what sort of store it is // pubsub: topic, subscription (already a featureRow) // kafka: ? (already a featureRow) // file: csv, parquet, json // bigquery: table, query Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Options map[string]string `` /* 155-byte string literal not displayed */ Entities []string `protobuf:"bytes,3,rep,name=entities,proto3" json:"entities,omitempty"` Schema *Schema `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ImportSpec) Descriptor ¶
func (*ImportSpec) Descriptor() ([]byte, []int)
func (*ImportSpec) GetEntities ¶
func (m *ImportSpec) GetEntities() []string
func (*ImportSpec) GetOptions ¶
func (m *ImportSpec) GetOptions() map[string]string
func (*ImportSpec) GetSchema ¶
func (m *ImportSpec) GetSchema() *Schema
func (*ImportSpec) GetType ¶
func (m *ImportSpec) GetType() string
func (*ImportSpec) ProtoMessage ¶
func (*ImportSpec) ProtoMessage()
func (*ImportSpec) Reset ¶
func (m *ImportSpec) Reset()
func (*ImportSpec) String ¶
func (m *ImportSpec) String() string
func (*ImportSpec) XXX_DiscardUnknown ¶
func (m *ImportSpec) XXX_DiscardUnknown()
func (*ImportSpec) XXX_Marshal ¶
func (m *ImportSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ImportSpec) XXX_Merge ¶
func (dst *ImportSpec) XXX_Merge(src proto.Message)
func (*ImportSpec) XXX_Size ¶
func (m *ImportSpec) XXX_Size() int
func (*ImportSpec) XXX_Unmarshal ¶
func (m *ImportSpec) XXX_Unmarshal(b []byte) error
type Schema ¶
type Schema struct { Fields []*Field `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"` // Types that are valid to be assigned to Timestamp: // *Schema_TimestampColumn // *Schema_TimestampValue Timestamp isSchema_Timestamp `protobuf_oneof:"timestamp"` EntityIdColumn string `protobuf:"bytes,7,opt,name=entityIdColumn,proto3" json:"entityIdColumn,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Schema) Descriptor ¶
func (*Schema) GetEntityIdColumn ¶
func (*Schema) GetTimestamp ¶
func (m *Schema) GetTimestamp() isSchema_Timestamp
func (*Schema) GetTimestampColumn ¶
func (*Schema) GetTimestampValue ¶
func (*Schema) ProtoMessage ¶
func (*Schema) ProtoMessage()
func (*Schema) XXX_DiscardUnknown ¶
func (m *Schema) XXX_DiscardUnknown()
func (*Schema) XXX_Marshal ¶
func (*Schema) XXX_OneofFuncs ¶
func (*Schema) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*Schema) XXX_Unmarshal ¶
type Schema_TimestampColumn ¶
type Schema_TimestampColumn struct {
TimestampColumn string `protobuf:"bytes,5,opt,name=timestampColumn,proto3,oneof"`
}
type Schema_TimestampValue ¶
type StorageSpec ¶
type StorageSpec struct { // unique identifier for this instance Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // type should define what sort of store it is // e.g. redis, bigquery, etc Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // options contain (but are not restricted to) options like // connection information. Options map[string]string `` /* 155-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StorageSpec) Descriptor ¶
func (*StorageSpec) Descriptor() ([]byte, []int)
func (*StorageSpec) GetId ¶
func (m *StorageSpec) GetId() string
func (*StorageSpec) GetOptions ¶
func (m *StorageSpec) GetOptions() map[string]string
func (*StorageSpec) GetType ¶
func (m *StorageSpec) GetType() string
func (*StorageSpec) ProtoMessage ¶
func (*StorageSpec) ProtoMessage()
func (*StorageSpec) Reset ¶
func (m *StorageSpec) Reset()
func (*StorageSpec) String ¶
func (m *StorageSpec) String() string
func (*StorageSpec) XXX_DiscardUnknown ¶
func (m *StorageSpec) XXX_DiscardUnknown()
func (*StorageSpec) XXX_Marshal ¶
func (m *StorageSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StorageSpec) XXX_Merge ¶
func (dst *StorageSpec) XXX_Merge(src proto.Message)
func (*StorageSpec) XXX_Size ¶
func (m *StorageSpec) XXX_Size() int
func (*StorageSpec) XXX_Unmarshal ¶
func (m *StorageSpec) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.