types

package
v0.5.1-dev Latest Latest
Warning

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

 Go to latest Published: May 21, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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 File_feast_types_FeatureRowExtended_proto protoreflect.FileDescriptor
View Source 
var File_feast_types_FeatureRow_proto protoreflect.FileDescriptor
View Source 
var File_feast_types_Field_proto protoreflect.FileDescriptor
View Source 
var File_feast_types_Value_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Attempt 

type Attempt struct {
	Attempts int32  `protobuf:"varint,1,opt,name=attempts,proto3" json:"attempts,omitempty"`
	Error    *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*Attempt) Descriptor deprecated 

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

Deprecated: Use Attempt.ProtoReflect.Descriptor instead.

func (*Attempt) GetAttempts 

func (x *Attempt) GetAttempts() int32

func (*Attempt) GetError 

func (x *Attempt) GetError() *Error

func (*Attempt) ProtoMessage 

func (*Attempt) ProtoMessage()

func (*Attempt) ProtoReflect 

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

func (*Attempt) Reset 

func (x *Attempt) Reset()

func (*Attempt) String 

func (x *Attempt) 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 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 Error 

type Error struct {
	Cause      string `protobuf:"bytes,1,opt,name=cause,proto3" json:"cause,omitempty"`         // exception class name
	Transform  string `protobuf:"bytes,2,opt,name=transform,proto3" json:"transform,omitempty"` // name of transform where the error occurred
	Message    string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	StackTrace string `protobuf:"bytes,4,opt,name=stack_trace,json=stackTrace,proto3" json:"stack_trace,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCause 

func (x *Error) GetCause() string

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (*Error) GetStackTrace 

func (x *Error) GetStackTrace() string

func (*Error) GetTransform 

func (x *Error) GetTransform() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type FeatureRow 

type FeatureRow struct {

	// Fields in the feature row.
	Fields []*Field `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	// Timestamp of the feature row. While the actual definition of this timestamp may vary
	// depending on the upstream feature creation pipelines, this is the timestamp that Feast
	// will use to perform joins, determine latest values, and coalesce rows.
	EventTimestamp *timestamp.Timestamp `protobuf:"bytes,3,opt,name=event_timestamp,json=eventTimestamp,proto3" json:"event_timestamp,omitempty"`
	// Complete reference to the featureSet this featureRow belongs to, in the form of
	// <project>/<feature-set-name>. This value will be used by the feast ingestion job to filter
	// rows, and write the values to the correct tables.
	FeatureSet string `protobuf:"bytes,6,opt,name=feature_set,json=featureSet,proto3" json:"feature_set,omitempty"`
	// Identifier tying this feature row to a specific ingestion job.
	IngestionId string `protobuf:"bytes,7,opt,name=ingestion_id,json=ingestionId,proto3" json:"ingestion_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureRow) Descriptor deprecated 

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

Deprecated: Use FeatureRow.ProtoReflect.Descriptor instead.

func (*FeatureRow) GetEventTimestamp 

func (x *FeatureRow) GetEventTimestamp() *timestamp.Timestamp

func (*FeatureRow) GetFeatureSet 

func (x *FeatureRow) GetFeatureSet() string

func (*FeatureRow) GetFields 

func (x *FeatureRow) GetFields() []*Field

func (*FeatureRow) GetIngestionId 

func (x *FeatureRow) GetIngestionId() string

func (*FeatureRow) ProtoMessage 

func (*FeatureRow) ProtoMessage()

func (*FeatureRow) ProtoReflect 

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

func (*FeatureRow) Reset 

func (x *FeatureRow) Reset()

func (*FeatureRow) String 

func (x *FeatureRow) String() string

type FeatureRowExtended 

type FeatureRowExtended struct {
	Row         *FeatureRow          `protobuf:"bytes,1,opt,name=row,proto3" json:"row,omitempty"`
	LastAttempt *Attempt             `protobuf:"bytes,2,opt,name=last_attempt,json=lastAttempt,proto3" json:"last_attempt,omitempty"`
	FirstSeen   *timestamp.Timestamp `protobuf:"bytes,3,opt,name=first_seen,json=firstSeen,proto3" json:"first_seen,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureRowExtended) Descriptor deprecated 

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

Deprecated: Use FeatureRowExtended.ProtoReflect.Descriptor instead.

func (*FeatureRowExtended) GetFirstSeen 

func (x *FeatureRowExtended) GetFirstSeen() *timestamp.Timestamp

func (*FeatureRowExtended) GetLastAttempt 

func (x *FeatureRowExtended) GetLastAttempt() *Attempt

func (*FeatureRowExtended) GetRow 

func (x *FeatureRowExtended) GetRow() *FeatureRow

func (*FeatureRowExtended) ProtoMessage 

func (*FeatureRowExtended) ProtoMessage()

func (*FeatureRowExtended) ProtoReflect 

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

func (*FeatureRowExtended) Reset 

func (x *FeatureRowExtended) Reset()

func (*FeatureRowExtended) String 

func (x *FeatureRowExtended) String() string

type Field 

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

func (*Field) Descriptor deprecated 

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

Deprecated: Use Field.ProtoReflect.Descriptor instead.

func (*Field) GetName 

func (x *Field) GetName() string

func (*Field) GetValue 

func (x *Field) GetValue() *Value

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) ProtoReflect 

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

func (*Field) Reset 

func (x *Field) Reset()

func (*Field) String 

func (x *Field) String() string

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 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 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 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.