qpu

package
v0.0.0-...-726f7ef Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	AttributePredicate_PredicateType_name = map[int32]string{
		0: "ISNULL",
		1: "ISNOTNULL",
		2: "RANGE",
		3: "EQ",
	}
	AttributePredicate_PredicateType_value = map[string]int32{
		"ISNULL":    0,
		"ISNOTNULL": 1,
		"RANGE":     2,
		"EQ":        3,
	}
)

Enum value maps for AttributePredicate_PredicateType.

View Source 
var (
	SnapshotTime_SnapshotTimeType_name = map[int32]string{
		0: "LATEST",
		1: "ZERO",
		2: "INF",
		3: "VECTORCLOCK",
	}
	SnapshotTime_SnapshotTimeType_value = map[string]int32{
		"LATEST":      0,
		"ZERO":        1,
		"INF":         2,
		"VECTORCLOCK": 3,
	}
)

Enum value maps for SnapshotTime_SnapshotTimeType.

View Source 
var File_qpu_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Attribute 

type Attribute struct {
	AttrKey string `protobuf:"bytes,1,opt,name=attr_key,json=attrKey,proto3" json:"attr_key,omitempty"`
	Value   *Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Attribute) Descriptor deprecated 

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

Deprecated: Use Attribute.ProtoReflect.Descriptor instead.

func (*Attribute) GetAttrKey 

func (x *Attribute) GetAttrKey() string

func (*Attribute) GetValue 

func (x *Attribute) GetValue() *Value

func (*Attribute) ProtoMessage 

func (*Attribute) ProtoMessage()

func (*Attribute) ProtoReflect 

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

func (*Attribute) Reset 

func (x *Attribute) Reset()

func (*Attribute) String 

func (x *Attribute) String() string

type AttributePredicate 

type AttributePredicate struct {
	Attr *Attribute                       `protobuf:"bytes,1,opt,name=attr,proto3" json:"attr,omitempty"`
	Type AttributePredicate_PredicateType `protobuf:"varint,2,opt,name=type,proto3,enum=qpu.AttributePredicate_PredicateType" json:"type,omitempty"`
	// Lower bound.
	Lbound *Value `protobuf:"bytes,3,opt,name=lbound,proto3" json:"lbound,omitempty"`
	// Upper bound.
	Ubound *Value `protobuf:"bytes,4,opt,name=ubound,proto3" json:"ubound,omitempty"`
	// contains filtered or unexported fields
}

func (*AttributePredicate) Descriptor deprecated 

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

Deprecated: Use AttributePredicate.ProtoReflect.Descriptor instead.

func (*AttributePredicate) GetAttr 

func (x *AttributePredicate) GetAttr() *Attribute

func (*AttributePredicate) GetLbound 

func (x *AttributePredicate) GetLbound() *Value

func (*AttributePredicate) GetType 

func (x *AttributePredicate) GetType() AttributePredicate_PredicateType

func (*AttributePredicate) GetUbound 

func (x *AttributePredicate) GetUbound() *Value

func (*AttributePredicate) ProtoMessage 

func (*AttributePredicate) ProtoMessage()

func (*AttributePredicate) ProtoReflect 

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

func (*AttributePredicate) Reset 

func (x *AttributePredicate) Reset()

func (*AttributePredicate) String 

func (x *AttributePredicate) String() string

type AttributePredicate_PredicateType 

type AttributePredicate_PredicateType int32
const (
	// Used to implement the SQL 'IS NULL'.
	AttributePredicate_ISNULL AttributePredicate_PredicateType = 0
	// Used to implement the SQL 'IS NOT NULL'
	AttributePredicate_ISNOTNULL AttributePredicate_PredicateType = 1
	// Represents the >, <, >=, <= operators
	AttributePredicate_RANGE AttributePredicate_PredicateType = 2
	// Represents the = operator
	AttributePredicate_EQ AttributePredicate_PredicateType = 3
)

func (AttributePredicate_PredicateType) Descriptor 

func (AttributePredicate_PredicateType) Descriptor() protoreflect.EnumDescriptor

func (AttributePredicate_PredicateType) Enum 

func (x AttributePredicate_PredicateType) Enum() *AttributePredicate_PredicateType

func (AttributePredicate_PredicateType) EnumDescriptor deprecated 

func (AttributePredicate_PredicateType) EnumDescriptor() ([]byte, []int)

Deprecated: Use AttributePredicate_PredicateType.Descriptor instead.

func (AttributePredicate_PredicateType) Number 

func (x AttributePredicate_PredicateType) Number() protoreflect.EnumNumber

func (AttributePredicate_PredicateType) String 

func (x AttributePredicate_PredicateType) String() string

func (AttributePredicate_PredicateType) Type 

func (AttributePredicate_PredicateType) Type() protoreflect.EnumType

type LogOperation 

type LogOperation struct {
	ObjectId string `protobuf:"bytes,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	// Bucket/Table
	// TODO: use a single term through the codebase
	Bucket    string       `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Timestamp *Vectorclock `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Payload   *Payload     `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The important part of every stream record.

func (*LogOperation) Descriptor deprecated 

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

Deprecated: Use LogOperation.ProtoReflect.Descriptor instead.

func (*LogOperation) GetBucket 

func (x *LogOperation) GetBucket() string

func (*LogOperation) GetObjectId 

func (x *LogOperation) GetObjectId() string

func (*LogOperation) GetPayload 

func (x *LogOperation) GetPayload() *Payload

func (*LogOperation) GetTimestamp 

func (x *LogOperation) GetTimestamp() *Vectorclock

func (*LogOperation) ProtoMessage 

func (*LogOperation) ProtoMessage()

func (*LogOperation) ProtoReflect 

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

func (*LogOperation) Reset 

func (x *LogOperation) Reset()

func (*LogOperation) String 

func (x *LogOperation) String() string

type ObjectState 

type ObjectState struct {

	// Data model: a data item is a primary key (object_id) + a set of attributes.
	// An attribute is a key value pair (attrKey, attrValue)
	Attributes map[string]*Value `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ObjectState) Descriptor deprecated 

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

Deprecated: Use ObjectState.ProtoReflect.Descriptor instead.

func (*ObjectState) GetAttributes 

func (x *ObjectState) GetAttributes() map[string]*Value

func (*ObjectState) ProtoMessage 

func (*ObjectState) ProtoMessage()

func (*ObjectState) ProtoReflect 

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

func (*ObjectState) Reset 

func (x *ObjectState) Reset()

func (*ObjectState) String 

func (x *ObjectState) String() string

type Payload 

type Payload struct {

	// Types that are assignable to Val:
	//	*Payload_State
	//	*Payload_Delta
	Val isPayload_Val `protobuf_oneof:"val"`
	// contains filtered or unexported fields
}

func (*Payload) Descriptor deprecated 

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

Deprecated: Use Payload.ProtoReflect.Descriptor instead.

func (*Payload) GetDelta 

func (x *Payload) GetDelta() *Payload_StateDelta

func (*Payload) GetState 

func (x *Payload) GetState() *ObjectState

func (*Payload) GetVal 

func (m *Payload) GetVal() isPayload_Val

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) ProtoReflect 

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

func (*Payload) Reset 

func (x *Payload) Reset()

func (*Payload) String 

func (x *Payload) String() string

type Payload_Delta 

type Payload_Delta struct {
	Delta *Payload_StateDelta `protobuf:"bytes,2,opt,name=delta,proto3,oneof"`
}

type Payload_State 

type Payload_State struct {
	State *ObjectState `protobuf:"bytes,1,opt,name=state,proto3,oneof"`
}

type Payload_StateDelta 

type Payload_StateDelta struct {
	Old *ObjectState `protobuf:"bytes,1,opt,name=old,proto3" json:"old,omitempty"`
	New *ObjectState `protobuf:"bytes,2,opt,name=new,proto3" json:"new,omitempty"`
	// contains filtered or unexported fields
}

func (*Payload_StateDelta) Descriptor deprecated 

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

Deprecated: Use Payload_StateDelta.ProtoReflect.Descriptor instead.

func (*Payload_StateDelta) GetNew 

func (x *Payload_StateDelta) GetNew() *ObjectState

func (*Payload_StateDelta) GetOld 

func (x *Payload_StateDelta) GetOld() *ObjectState

func (*Payload_StateDelta) ProtoMessage 

func (*Payload_StateDelta) ProtoMessage()

func (*Payload_StateDelta) ProtoReflect 

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

func (*Payload_StateDelta) Reset 

func (x *Payload_StateDelta) Reset()

func (*Payload_StateDelta) String 

func (x *Payload_StateDelta) String() string

type SnapshotTime 

type SnapshotTime struct {
	Type  SnapshotTime_SnapshotTimeType `protobuf:"varint,1,opt,name=type,proto3,enum=qpu.SnapshotTime_SnapshotTimeType" json:"type,omitempty"`
	Value *Vectorclock                  `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// SnapshotTime is always used in ranges.
	// isClosed is used to signify if a range is open or closed.
	// E.g. (isClosed=true, isClosed=false) -> [SnapshotTime1, SnapshotTime2).
	IsClosed bool `protobuf:"varint,3,opt,name=isClosed,proto3" json:"isClosed,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotTime) Descriptor deprecated 

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

Deprecated: Use SnapshotTime.ProtoReflect.Descriptor instead.

func (*SnapshotTime) GetIsClosed 

func (x *SnapshotTime) GetIsClosed() bool

func (*SnapshotTime) GetType 

func (x *SnapshotTime) GetType() SnapshotTime_SnapshotTimeType

func (*SnapshotTime) GetValue 

func (x *SnapshotTime) GetValue() *Vectorclock

func (*SnapshotTime) ProtoMessage 

func (*SnapshotTime) ProtoMessage()

func (*SnapshotTime) ProtoReflect 

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

func (*SnapshotTime) Reset 

func (x *SnapshotTime) Reset()

func (*SnapshotTime) String 

func (x *SnapshotTime) String() string

type SnapshotTimePredicate 

type SnapshotTimePredicate struct {
	Lbound *SnapshotTime `protobuf:"bytes,1,opt,name=lbound,proto3" json:"lbound,omitempty"`
	Ubound *SnapshotTime `protobuf:"bytes,2,opt,name=ubound,proto3" json:"ubound,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotTimePredicate) Descriptor deprecated 

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

Deprecated: Use SnapshotTimePredicate.ProtoReflect.Descriptor instead.

func (*SnapshotTimePredicate) GetLbound 

func (x *SnapshotTimePredicate) GetLbound() *SnapshotTime

func (*SnapshotTimePredicate) GetUbound 

func (x *SnapshotTimePredicate) GetUbound() *SnapshotTime

func (*SnapshotTimePredicate) ProtoMessage 

func (*SnapshotTimePredicate) ProtoMessage()

func (*SnapshotTimePredicate) ProtoReflect 

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

func (*SnapshotTimePredicate) Reset 

func (x *SnapshotTimePredicate) Reset()

func (*SnapshotTimePredicate) String 

func (x *SnapshotTimePredicate) String() string

type SnapshotTime_SnapshotTimeType 

type SnapshotTime_SnapshotTimeType int32
const (
	// Keyword used to refer to for the most recent snapshot if we don't know
	// the actual timestamp value.
	SnapshotTime_LATEST SnapshotTime_SnapshotTimeType = 0
	// Keyword used to refer to the earliest snapshot in the system.
	SnapshotTime_ZERO SnapshotTime_SnapshotTimeType = 1
	// Keyword used to refer to a timestamp that is always greater than any
	// other timestamp
	// Used to implement long-lived queries.
	// Results in a stream that stays open indefinitely.
	SnapshotTime_INF SnapshotTime_SnapshotTimeType = 2
	// Keyword used to signify that this SnapshotTime has an actual value.
	SnapshotTime_VECTORCLOCK SnapshotTime_SnapshotTimeType = 3
)

func (SnapshotTime_SnapshotTimeType) Descriptor 

func (SnapshotTime_SnapshotTimeType) Descriptor() protoreflect.EnumDescriptor

func (SnapshotTime_SnapshotTimeType) Enum 

func (x SnapshotTime_SnapshotTimeType) Enum() *SnapshotTime_SnapshotTimeType

func (SnapshotTime_SnapshotTimeType) EnumDescriptor deprecated 

func (SnapshotTime_SnapshotTimeType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SnapshotTime_SnapshotTimeType.Descriptor instead.

func (SnapshotTime_SnapshotTimeType) Number 

func (x SnapshotTime_SnapshotTimeType) Number() protoreflect.EnumNumber

func (SnapshotTime_SnapshotTimeType) String 

func (x SnapshotTime_SnapshotTimeType) String() string

func (SnapshotTime_SnapshotTimeType) Type 

func (SnapshotTime_SnapshotTimeType) Type() protoreflect.EnumType

type Value 

type Value struct {

	// Types that are assignable to Val:
	//	*Value_Str
	//	*Value_Int
	//	*Value_Flt
	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) GetFlt 

func (x *Value) GetFlt() float64

func (*Value) GetInt 

func (x *Value) GetInt() int32

func (*Value) GetStr 

func (x *Value) GetStr() 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 Value_Flt 

type Value_Flt struct {
	Flt float64 `protobuf:"fixed64,3,opt,name=flt,proto3,oneof"`
}

type Value_Int 

type Value_Int struct {
	Int int32 `protobuf:"varint,2,opt,name=int,proto3,oneof"`
}

type Value_Str 

type Value_Str struct {
	Str string `protobuf:"bytes,1,opt,name=str,proto3,oneof"`
}

type Vectorclock 

type Vectorclock struct {
	Vc map[string]*timestamp.Timestamp `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Vectorclock) Descriptor deprecated 

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

Deprecated: Use Vectorclock.ProtoReflect.Descriptor instead.

func (*Vectorclock) GetVc 

func (x *Vectorclock) GetVc() map[string]*timestamp.Timestamp

func (*Vectorclock) ProtoMessage 

func (*Vectorclock) ProtoMessage()

func (*Vectorclock) ProtoReflect 

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

func (*Vectorclock) Reset 

func (x *Vectorclock) Reset()

func (*Vectorclock) String 

func (x *Vectorclock) String() string

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.