Documentation ¶
Index ¶
- type BigTableRowKey
- func (*BigTableRowKey) Descriptor() ([]byte, []int)
- func (m *BigTableRowKey) GetEntityKey() string
- func (m *BigTableRowKey) GetReversedMillis() string
- func (m *BigTableRowKey) GetSha1Prefix() string
- func (*BigTableRowKey) ProtoMessage()
- func (m *BigTableRowKey) Reset()
- func (m *BigTableRowKey) String() string
- func (m *BigTableRowKey) XXX_DiscardUnknown()
- func (m *BigTableRowKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *BigTableRowKey) XXX_Merge(src proto.Message)
- func (m *BigTableRowKey) XXX_Size() int
- func (m *BigTableRowKey) XXX_Unmarshal(b []byte) error
- type RedisBucketKey
- func (*RedisBucketKey) Descriptor() ([]byte, []int)
- func (m *RedisBucketKey) GetBucketId() uint64
- func (m *RedisBucketKey) GetEntityKey() string
- func (m *RedisBucketKey) GetFeatureIdSha1Prefix() string
- func (*RedisBucketKey) ProtoMessage()
- func (m *RedisBucketKey) Reset()
- func (m *RedisBucketKey) String() string
- func (m *RedisBucketKey) XXX_DiscardUnknown()
- func (m *RedisBucketKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RedisBucketKey) XXX_Merge(src proto.Message)
- func (m *RedisBucketKey) XXX_Size() int
- func (m *RedisBucketKey) XXX_Unmarshal(b []byte) error
- type RedisBucketValue
- func (*RedisBucketValue) Descriptor() ([]byte, []int)
- func (m *RedisBucketValue) GetEventTimestamp() *timestamp.Timestamp
- func (m *RedisBucketValue) GetValue() *types.Value
- func (*RedisBucketValue) ProtoMessage()
- func (m *RedisBucketValue) Reset()
- func (m *RedisBucketValue) String() string
- func (m *RedisBucketValue) XXX_DiscardUnknown()
- func (m *RedisBucketValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RedisBucketValue) XXX_Merge(src proto.Message)
- func (m *RedisBucketValue) XXX_Size() int
- func (m *RedisBucketValue) XXX_Unmarshal(b []byte) error
- type RedisBucketValueList
- func (*RedisBucketValueList) Descriptor() ([]byte, []int)
- func (m *RedisBucketValueList) GetValues() []*RedisBucketValue
- func (*RedisBucketValueList) ProtoMessage()
- func (m *RedisBucketValueList) Reset()
- func (m *RedisBucketValueList) String() string
- func (m *RedisBucketValueList) XXX_DiscardUnknown()
- func (m *RedisBucketValueList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RedisBucketValueList) XXX_Merge(src proto.Message)
- func (m *RedisBucketValueList) XXX_Size() int
- func (m *RedisBucketValueList) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BigTableRowKey ¶
type BigTableRowKey struct { // This should be the first 7 characters of a sha1 of the entityKey proto encoded Sha1Prefix string `protobuf:"bytes,1,opt,name=sha1Prefix,proto3" json:"sha1Prefix,omitempty"` EntityKey string `protobuf:"bytes,2,opt,name=entityKey,proto3" json:"entityKey,omitempty"` // This should be String.valueOf(int64.MAX_VALUE - roundToEntityGranularity(eventTimestamp)) ReversedMillis string `protobuf:"bytes,3,opt,name=reversedMillis,proto3" json:"reversedMillis,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BigTableRowKey) Descriptor ¶
func (*BigTableRowKey) Descriptor() ([]byte, []int)
func (*BigTableRowKey) GetEntityKey ¶
func (m *BigTableRowKey) GetEntityKey() string
func (*BigTableRowKey) GetReversedMillis ¶
func (m *BigTableRowKey) GetReversedMillis() string
func (*BigTableRowKey) GetSha1Prefix ¶
func (m *BigTableRowKey) GetSha1Prefix() string
func (*BigTableRowKey) ProtoMessage ¶
func (*BigTableRowKey) ProtoMessage()
func (*BigTableRowKey) Reset ¶
func (m *BigTableRowKey) Reset()
func (*BigTableRowKey) String ¶
func (m *BigTableRowKey) String() string
func (*BigTableRowKey) XXX_DiscardUnknown ¶
func (m *BigTableRowKey) XXX_DiscardUnknown()
func (*BigTableRowKey) XXX_Marshal ¶
func (m *BigTableRowKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BigTableRowKey) XXX_Merge ¶
func (dst *BigTableRowKey) XXX_Merge(src proto.Message)
func (*BigTableRowKey) XXX_Size ¶
func (m *BigTableRowKey) XXX_Size() int
func (*BigTableRowKey) XXX_Unmarshal ¶
func (m *BigTableRowKey) XXX_Unmarshal(b []byte) error
type RedisBucketKey ¶
type RedisBucketKey struct { // Entity key from the FeatureRow EntityKey string `protobuf:"bytes,2,opt,name=entityKey,proto3" json:"entityKey,omitempty"` // * // This should be the first 7 characters of a sha1 of the featureId // This is just to save storage space as it's kept in memory. FeatureIdSha1Prefix string `protobuf:"bytes,3,opt,name=featureIdSha1Prefix,proto3" json:"featureIdSha1Prefix,omitempty"` // * // This groups a feature's values (for different eventTimestamps), // into buckets so many can be retrieved together. // // See FeatureRowToRedisMutationDoFn. // bucketId = roundedToGranularity(eventTimestamp).seconds / bucketSize.seconds BucketId uint64 `protobuf:"fixed64,4,opt,name=bucketId,proto3" json:"bucketId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RedisBucketKey) Descriptor ¶
func (*RedisBucketKey) Descriptor() ([]byte, []int)
func (*RedisBucketKey) GetBucketId ¶
func (m *RedisBucketKey) GetBucketId() uint64
func (*RedisBucketKey) GetEntityKey ¶
func (m *RedisBucketKey) GetEntityKey() string
func (*RedisBucketKey) GetFeatureIdSha1Prefix ¶
func (m *RedisBucketKey) GetFeatureIdSha1Prefix() string
func (*RedisBucketKey) ProtoMessage ¶
func (*RedisBucketKey) ProtoMessage()
func (*RedisBucketKey) Reset ¶
func (m *RedisBucketKey) Reset()
func (*RedisBucketKey) String ¶
func (m *RedisBucketKey) String() string
func (*RedisBucketKey) XXX_DiscardUnknown ¶
func (m *RedisBucketKey) XXX_DiscardUnknown()
func (*RedisBucketKey) XXX_Marshal ¶
func (m *RedisBucketKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RedisBucketKey) XXX_Merge ¶
func (dst *RedisBucketKey) XXX_Merge(src proto.Message)
func (*RedisBucketKey) XXX_Size ¶
func (m *RedisBucketKey) XXX_Size() int
func (*RedisBucketKey) XXX_Unmarshal ¶
func (m *RedisBucketKey) XXX_Unmarshal(b []byte) error
type RedisBucketValue ¶
type RedisBucketValue struct { Value *types.Value `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` EventTimestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=eventTimestamp,proto3" json:"eventTimestamp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Because in redis features are stored as a key per feature not per feature row, we need the event timestamp in the value.
func (*RedisBucketValue) Descriptor ¶
func (*RedisBucketValue) Descriptor() ([]byte, []int)
func (*RedisBucketValue) GetEventTimestamp ¶
func (m *RedisBucketValue) GetEventTimestamp() *timestamp.Timestamp
func (*RedisBucketValue) GetValue ¶
func (m *RedisBucketValue) GetValue() *types.Value
func (*RedisBucketValue) ProtoMessage ¶
func (*RedisBucketValue) ProtoMessage()
func (*RedisBucketValue) Reset ¶
func (m *RedisBucketValue) Reset()
func (*RedisBucketValue) String ¶
func (m *RedisBucketValue) String() string
func (*RedisBucketValue) XXX_DiscardUnknown ¶
func (m *RedisBucketValue) XXX_DiscardUnknown()
func (*RedisBucketValue) XXX_Marshal ¶
func (m *RedisBucketValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RedisBucketValue) XXX_Merge ¶
func (dst *RedisBucketValue) XXX_Merge(src proto.Message)
func (*RedisBucketValue) XXX_Size ¶
func (m *RedisBucketValue) XXX_Size() int
func (*RedisBucketValue) XXX_Unmarshal ¶
func (m *RedisBucketValue) XXX_Unmarshal(b []byte) error
type RedisBucketValueList ¶
type RedisBucketValueList struct { Values []*RedisBucketValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* This allows us to group multiple bucket values together in a single list to make it easier to keep sets together
func (*RedisBucketValueList) Descriptor ¶
func (*RedisBucketValueList) Descriptor() ([]byte, []int)
func (*RedisBucketValueList) GetValues ¶
func (m *RedisBucketValueList) GetValues() []*RedisBucketValue
func (*RedisBucketValueList) ProtoMessage ¶
func (*RedisBucketValueList) ProtoMessage()
func (*RedisBucketValueList) Reset ¶
func (m *RedisBucketValueList) Reset()
func (*RedisBucketValueList) String ¶
func (m *RedisBucketValueList) String() string
func (*RedisBucketValueList) XXX_DiscardUnknown ¶
func (m *RedisBucketValueList) XXX_DiscardUnknown()
func (*RedisBucketValueList) XXX_Marshal ¶
func (m *RedisBucketValueList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RedisBucketValueList) XXX_Merge ¶
func (dst *RedisBucketValueList) XXX_Merge(src proto.Message)
func (*RedisBucketValueList) XXX_Size ¶
func (m *RedisBucketValueList) XXX_Size() int
func (*RedisBucketValueList) XXX_Unmarshal ¶
func (m *RedisBucketValueList) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.