docdb

package
v0.0.0-...-c201ef6 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_yb_docdb_docdb_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ApplyExternalTransactionPB 

type ApplyExternalTransactionPB struct {
	TransactionId    []byte  `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId" json:"transaction_id,omitempty"`
	CommitHybridTime *uint64 `protobuf:"fixed64,2,opt,name=commit_hybrid_time,json=commitHybridTime" json:"commit_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyExternalTransactionPB) Descriptor deprecated 

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

Deprecated: Use ApplyExternalTransactionPB.ProtoReflect.Descriptor instead.

func (*ApplyExternalTransactionPB) GetCommitHybridTime 

func (x *ApplyExternalTransactionPB) GetCommitHybridTime() uint64

func (*ApplyExternalTransactionPB) GetTransactionId 

func (x *ApplyExternalTransactionPB) GetTransactionId() []byte

func (*ApplyExternalTransactionPB) MarshalJSON 

func (m *ApplyExternalTransactionPB) MarshalJSON() ([]byte, error)

func (*ApplyExternalTransactionPB) ProtoMessage 

func (*ApplyExternalTransactionPB) ProtoMessage()

func (*ApplyExternalTransactionPB) ProtoReflect 

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

func (*ApplyExternalTransactionPB) Reset 

func (x *ApplyExternalTransactionPB) Reset()

func (*ApplyExternalTransactionPB) String 

func (x *ApplyExternalTransactionPB) String() string

func (*ApplyExternalTransactionPB) UnmarshalJSON 

func (m *ApplyExternalTransactionPB) UnmarshalJSON(b []byte) error

type ApplyTransactionStatePB 

type ApplyTransactionStatePB struct {

	// Apply should be continued from this key in reverse index.
	Key []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	// Write id for first continued record.
	WriteId *uint32 `protobuf:"varint,2,opt,name=write_id,json=writeId" json:"write_id,omitempty"`
	// Transaction commit hybrid time.
	CommitHt *uint64 `protobuf:"fixed64,3,opt,name=commit_ht,json=commitHt" json:"commit_ht,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyTransactionStatePB) Descriptor deprecated 

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

Deprecated: Use ApplyTransactionStatePB.ProtoReflect.Descriptor instead.

func (*ApplyTransactionStatePB) GetCommitHt 

func (x *ApplyTransactionStatePB) GetCommitHt() uint64

func (*ApplyTransactionStatePB) GetKey 

func (x *ApplyTransactionStatePB) GetKey() []byte

func (*ApplyTransactionStatePB) GetWriteId 

func (x *ApplyTransactionStatePB) GetWriteId() uint32

func (*ApplyTransactionStatePB) MarshalJSON 

func (m *ApplyTransactionStatePB) MarshalJSON() ([]byte, error)

func (*ApplyTransactionStatePB) ProtoMessage 

func (*ApplyTransactionStatePB) ProtoMessage()

func (*ApplyTransactionStatePB) ProtoReflect 

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

func (*ApplyTransactionStatePB) Reset 

func (x *ApplyTransactionStatePB) Reset()

func (*ApplyTransactionStatePB) String 

func (x *ApplyTransactionStatePB) String() string

func (*ApplyTransactionStatePB) UnmarshalJSON 

func (m *ApplyTransactionStatePB) UnmarshalJSON(b []byte) error

type ConsensusFrontierPB 

type ConsensusFrontierPB struct {
	OpId             *util.OpIdPB `protobuf:"bytes,1,opt,name=op_id,json=opId" json:"op_id,omitempty"`
	HybridTime       *uint64      `protobuf:"fixed64,2,opt,name=hybrid_time,json=hybridTime" json:"hybrid_time,omitempty"`
	HistoryCutoff    *uint64      `protobuf:"fixed64,3,opt,name=history_cutoff,json=historyCutoff" json:"history_cutoff,omitempty"`
	HybridTimeFilter *uint64      `protobuf:"fixed64,4,opt,name=hybrid_time_filter,json=hybridTimeFilter" json:"hybrid_time_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsensusFrontierPB) Descriptor deprecated 

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

Deprecated: Use ConsensusFrontierPB.ProtoReflect.Descriptor instead.

func (*ConsensusFrontierPB) GetHistoryCutoff 

func (x *ConsensusFrontierPB) GetHistoryCutoff() uint64

func (*ConsensusFrontierPB) GetHybridTime 

func (x *ConsensusFrontierPB) GetHybridTime() uint64

func (*ConsensusFrontierPB) GetHybridTimeFilter 

func (x *ConsensusFrontierPB) GetHybridTimeFilter() uint64

func (*ConsensusFrontierPB) GetOpId 

func (x *ConsensusFrontierPB) GetOpId() *util.OpIdPB

func (*ConsensusFrontierPB) MarshalJSON 

func (m *ConsensusFrontierPB) MarshalJSON() ([]byte, error)

func (*ConsensusFrontierPB) ProtoMessage 

func (*ConsensusFrontierPB) ProtoMessage()

func (*ConsensusFrontierPB) ProtoReflect 

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

func (*ConsensusFrontierPB) Reset 

func (x *ConsensusFrontierPB) Reset()

func (*ConsensusFrontierPB) String 

func (x *ConsensusFrontierPB) String() string

func (*ConsensusFrontierPB) UnmarshalJSON 

func (m *ConsensusFrontierPB) UnmarshalJSON(b []byte) error

type KeyValuePairPB 

type KeyValuePairPB struct {
	Key                []byte  `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value              []byte  `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	ExternalHybridTime *uint64 `protobuf:"fixed64,3,opt,name=external_hybrid_time,json=externalHybridTime" json:"external_hybrid_time,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyValuePairPB) Descriptor deprecated 

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

Deprecated: Use KeyValuePairPB.ProtoReflect.Descriptor instead.

func (*KeyValuePairPB) GetExternalHybridTime 

func (x *KeyValuePairPB) GetExternalHybridTime() uint64

func (*KeyValuePairPB) GetKey 

func (x *KeyValuePairPB) GetKey() []byte

func (*KeyValuePairPB) GetValue 

func (x *KeyValuePairPB) GetValue() []byte

func (*KeyValuePairPB) MarshalJSON 

func (m *KeyValuePairPB) MarshalJSON() ([]byte, error)

func (*KeyValuePairPB) ProtoMessage 

func (*KeyValuePairPB) ProtoMessage()

func (*KeyValuePairPB) ProtoReflect 

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

func (*KeyValuePairPB) Reset 

func (x *KeyValuePairPB) Reset()

func (*KeyValuePairPB) String 

func (x *KeyValuePairPB) String() string

func (*KeyValuePairPB) UnmarshalJSON 

func (m *KeyValuePairPB) UnmarshalJSON(b []byte) error

type KeyValueWriteBatchPB 

type KeyValueWriteBatchPB struct {
	WritePairs                []*KeyValuePairPB             `protobuf:"bytes,1,rep,name=write_pairs,json=writePairs" json:"write_pairs,omitempty"`
	Transaction               *common.TransactionMetadataPB `protobuf:"bytes,2,opt,name=transaction" json:"transaction,omitempty"`
	DEPRECATEDMayHaveMetadata *bool                         `` /* 134-byte string literal not displayed */
	// Used by serializable isolation transactions and row locking statements to store read intents.
	// In case of read-modify-write operation both read_pairs and write_pairs could present.
	ReadPairs                 []*KeyValuePairPB             `protobuf:"bytes,5,rep,name=read_pairs,json=readPairs" json:"read_pairs,omitempty"`
	RowMarkType               *common.RowMarkType           `protobuf:"varint,6,opt,name=row_mark_type,json=rowMarkType,enum=yb.RowMarkType" json:"row_mark_type,omitempty"`
	ApplyExternalTransactions []*ApplyExternalTransactionPB `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

A set of key/value pairs to be written into RocksDB.

func (*KeyValueWriteBatchPB) Descriptor deprecated 

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

Deprecated: Use KeyValueWriteBatchPB.ProtoReflect.Descriptor instead.

func (*KeyValueWriteBatchPB) GetApplyExternalTransactions 

func (x *KeyValueWriteBatchPB) GetApplyExternalTransactions() []*ApplyExternalTransactionPB

func (*KeyValueWriteBatchPB) GetDEPRECATEDMayHaveMetadata 

func (x *KeyValueWriteBatchPB) GetDEPRECATEDMayHaveMetadata() bool

func (*KeyValueWriteBatchPB) GetReadPairs 

func (x *KeyValueWriteBatchPB) GetReadPairs() []*KeyValuePairPB

func (*KeyValueWriteBatchPB) GetRowMarkType 

func (x *KeyValueWriteBatchPB) GetRowMarkType() common.RowMarkType

func (*KeyValueWriteBatchPB) GetTransaction 

func (x *KeyValueWriteBatchPB) GetTransaction() *common.TransactionMetadataPB

func (*KeyValueWriteBatchPB) GetWritePairs 

func (x *KeyValueWriteBatchPB) GetWritePairs() []*KeyValuePairPB

func (*KeyValueWriteBatchPB) MarshalJSON 

func (m *KeyValueWriteBatchPB) MarshalJSON() ([]byte, error)

func (*KeyValueWriteBatchPB) ProtoMessage 

func (*KeyValueWriteBatchPB) ProtoMessage()

func (*KeyValueWriteBatchPB) ProtoReflect 

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

func (*KeyValueWriteBatchPB) Reset 

func (x *KeyValueWriteBatchPB) Reset()

func (*KeyValueWriteBatchPB) String 

func (x *KeyValueWriteBatchPB) String() string

func (*KeyValueWriteBatchPB) UnmarshalJSON 

func (m *KeyValueWriteBatchPB) UnmarshalJSON(b []byte) error

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.