specs

package
v0.0.2 Latest Latest
Warning

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

Go to latest
Published: Mar 11, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

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

func (*DataStore) GetId

func (m *DataStore) GetId() string

func (*DataStore) GetOptions

func (m *DataStore) GetOptions() map[string]string

func (*DataStore) ProtoMessage

func (*DataStore) ProtoMessage()

func (*DataStore) Reset

func (m *DataStore) Reset()

func (*DataStore) String

func (m *DataStore) String() string

func (*DataStore) XXX_DiscardUnknown

func (m *DataStore) XXX_DiscardUnknown()

func (*DataStore) XXX_Marshal

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

func (*DataStore) XXX_Merge

func (dst *DataStore) XXX_Merge(src proto.Message)

func (*DataStore) XXX_Size

func (m *DataStore) XXX_Size() int

func (*DataStore) XXX_Unmarshal

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

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) 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 (dst *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 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) 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 (dst *Schema) XXX_Merge(src proto.Message)

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_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 (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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL