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