storage

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

Jump to

Keyboard shortcuts

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