Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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 (m *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"`
	Options              map[string]string `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*FeatureGroupSpec) Descriptor 

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

func (*FeatureGroupSpec) GetId 

func (m *FeatureGroupSpec) GetId() string

func (*FeatureGroupSpec) GetOptions 

func (m *FeatureGroupSpec) GetOptions() map[string]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 (m *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"`
	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 */
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*FeatureSpec) Descriptor 

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

func (*FeatureSpec) GetDescription 

func (m *FeatureSpec) GetDescription() string

func (*FeatureSpec) GetEntity 

func (m *FeatureSpec) GetEntity() string

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 (m *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) Descriptor() ([]byte, []int)

func (*Field) GetFeatureId 

func (m *Field) GetFeatureId() string

func (*Field) GetName 

func (m *Field) GetName() string

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) Reset 

func (m *Field) Reset()

func (*Field) String 

func (m *Field) String() string

func (*Field) XXX_DiscardUnknown 

func (m *Field) XXX_DiscardUnknown()

func (*Field) XXX_Marshal 

func (m *Field) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Field) XXX_Merge 

func (m *Field) XXX_Merge(src proto.Message)

func (*Field) XXX_Size 

func (m *Field) XXX_Size() int

func (*Field) XXX_Unmarshal 

func (m *Field) XXX_Unmarshal(b []byte) error

type ImportJobSpecs 

type ImportJobSpecs struct {
	JobId                string         `protobuf:"bytes,1,opt,name=jobId,proto3" json:"jobId,omitempty"`
	ImportSpec           *ImportSpec    `protobuf:"bytes,2,opt,name=importSpec,proto3" json:"importSpec,omitempty"`
	EntitySpecs          []*EntitySpec  `protobuf:"bytes,3,rep,name=entitySpecs,proto3" json:"entitySpecs,omitempty"`
	FeatureSpecs         []*FeatureSpec `protobuf:"bytes,4,rep,name=featureSpecs,proto3" json:"featureSpecs,omitempty"`
	ServingStorageSpec   *StorageSpec   `protobuf:"bytes,5,opt,name=servingStorageSpec,proto3" json:"servingStorageSpec,omitempty"`
	WarehouseStorageSpec *StorageSpec   `protobuf:"bytes,6,opt,name=warehouseStorageSpec,proto3" json:"warehouseStorageSpec,omitempty"`
	ErrorsStorageSpec    *StorageSpec   `protobuf:"bytes,7,opt,name=errorsStorageSpec,proto3" json:"errorsStorageSpec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ImportJobSpecs) Descriptor 

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

func (*ImportJobSpecs) GetEntitySpecs 

func (m *ImportJobSpecs) GetEntitySpecs() []*EntitySpec

func (*ImportJobSpecs) GetErrorsStorageSpec 

func (m *ImportJobSpecs) GetErrorsStorageSpec() *StorageSpec

func (*ImportJobSpecs) GetFeatureSpecs 

func (m *ImportJobSpecs) GetFeatureSpecs() []*FeatureSpec

func (*ImportJobSpecs) GetImportSpec 

func (m *ImportJobSpecs) GetImportSpec() *ImportSpec

func (*ImportJobSpecs) GetJobId 

func (m *ImportJobSpecs) GetJobId() string

func (*ImportJobSpecs) GetServingStorageSpec 

func (m *ImportJobSpecs) GetServingStorageSpec() *StorageSpec

func (*ImportJobSpecs) GetWarehouseStorageSpec 

func (m *ImportJobSpecs) GetWarehouseStorageSpec() *StorageSpec

func (*ImportJobSpecs) ProtoMessage 

func (*ImportJobSpecs) ProtoMessage()

func (*ImportJobSpecs) Reset 

func (m *ImportJobSpecs) Reset()

func (*ImportJobSpecs) String 

func (m *ImportJobSpecs) String() string

func (*ImportJobSpecs) XXX_DiscardUnknown 

func (m *ImportJobSpecs) XXX_DiscardUnknown()

func (*ImportJobSpecs) XXX_Marshal 

func (m *ImportJobSpecs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImportJobSpecs) XXX_Merge 

func (m *ImportJobSpecs) XXX_Merge(src proto.Message)

func (*ImportJobSpecs) XXX_Size 

func (m *ImportJobSpecs) XXX_Size() int

func (*ImportJobSpecs) XXX_Unmarshal 

func (m *ImportJobSpecs) XXX_Unmarshal(b []byte) error

type ImportSpec 

type ImportSpec struct {
	Type                 string            `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	SourceOptions        map[string]string `` /* 167-byte string literal not displayed */
	JobOptions           map[string]string `` /* 161-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) GetJobOptions 

func (m *ImportSpec) GetJobOptions() map[string]string

func (*ImportSpec) GetSchema 

func (m *ImportSpec) GetSchema() *Schema

func (*ImportSpec) GetSourceOptions 

func (m *ImportSpec) GetSourceOptions() map[string]string

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 (m *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"`
	// the event timestamp to set per row.
	//
	// 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) Descriptor() ([]byte, []int)

func (*Schema) GetEntityIdColumn 

func (m *Schema) GetEntityIdColumn() string

func (*Schema) GetFields 

func (m *Schema) GetFields() []*Field

func (*Schema) GetTimestamp 

func (m *Schema) GetTimestamp() isSchema_Timestamp

func (*Schema) GetTimestampColumn 

func (m *Schema) GetTimestampColumn() string

func (*Schema) GetTimestampValue 

func (m *Schema) GetTimestampValue() *timestamp.Timestamp

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) Reset 

func (m *Schema) Reset()

func (*Schema) String 

func (m *Schema) String() string

func (*Schema) XXX_DiscardUnknown 

func (m *Schema) XXX_DiscardUnknown()

func (*Schema) XXX_Marshal 

func (m *Schema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Schema) XXX_Merge 

func (m *Schema) XXX_Merge(src proto.Message)

func (*Schema) XXX_OneofWrappers 

func (*Schema) XXX_OneofWrappers() []interface{}

    XXX_OneofWrappers is for the internal use of the proto package.

    func (*Schema) XXX_Size 

    func (m *Schema) XXX_Size() int

    func (*Schema) XXX_Unmarshal 

    func (m *Schema) XXX_Unmarshal(b []byte) error

    type Schema_TimestampColumn 

    type Schema_TimestampColumn struct {
	TimestampColumn string `protobuf:"bytes,5,opt,name=timestampColumn,proto3,oneof"`
}

    type Schema_TimestampValue 

    type Schema_TimestampValue struct {
	TimestampValue *timestamp.Timestamp `protobuf:"bytes,6,opt,name=timestampValue,proto3,oneof"`
}

    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 (m *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

    Source Files

    View all