memorystorage

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Dec 29, 2023 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type AttributeRow ¶ 

type AttributeRow struct {
	ID         ID
	RelationID ID
	Order      int
	Nullable   bool
	engine.Attribute
}

func (*AttributeRow) AttrByName ¶ 

func (a *AttributeRow) AttrByName(handler *MemHandler, tx *Transaction, name string) (ret Nullable, err error)

func (*AttributeRow) Indexes ¶ 

func (a *AttributeRow) Indexes() []Tuple

func (*AttributeRow) Key ¶ 

func (a *AttributeRow) Key() ID

func (*AttributeRow) UniqueIndexes ¶ 

func (a *AttributeRow) UniqueIndexes() []Tuple

func (*AttributeRow) Value ¶ 

func (a *AttributeRow) Value() *AttributeRow

type AttributeRowIter ¶ 

type AttributeRowIter = Iter[ID, *AttributeRow]

type Bool ¶ 

type Bool = memorytable.Bool

type CatalogHandler ¶ 

type CatalogHandler struct {
	// contains filtered or unexported fields
}

CatalogHandler handles read-only requests for catalog

func NewCatalogHandler ¶ 

func NewCatalogHandler(upstream *MemHandler) (*CatalogHandler, error)

func (*CatalogHandler) HandleAddTableDef ¶ 

func (c *CatalogHandler) HandleAddTableDef(ctx context.Context, meta txn.TxnMeta, req *memoryengine.AddTableDefReq, resp *memoryengine.AddTableDefResp) (err error)

func (*CatalogHandler) HandleClose ¶ 

func (c *CatalogHandler) HandleClose(ctx context.Context) error

func (*CatalogHandler) HandleCloseTableIter ¶ 

func (c *CatalogHandler) HandleCloseTableIter(ctx context.Context, meta txn.TxnMeta, req *memoryengine.CloseTableIterReq, resp *memoryengine.CloseTableIterResp) (err error)

func (*CatalogHandler) HandleCommit ¶ 

func (c *CatalogHandler) HandleCommit(ctx context.Context, meta txn.TxnMeta) (timestamp.Timestamp, error)

func (*CatalogHandler) HandleCommitting ¶ 

func (c *CatalogHandler) HandleCommitting(ctx context.Context, meta txn.TxnMeta) error

func (*CatalogHandler) HandleCreateDatabase ¶ 

func (c *CatalogHandler) HandleCreateDatabase(ctx context.Context, meta txn.TxnMeta, req *memoryengine.CreateDatabaseReq, resp *memoryengine.CreateDatabaseResp) (err error)

func (*CatalogHandler) HandleCreateRelation ¶ 

func (c *CatalogHandler) HandleCreateRelation(ctx context.Context, meta txn.TxnMeta, req *memoryengine.CreateRelationReq, resp *memoryengine.CreateRelationResp) (err error)

func (*CatalogHandler) HandleDelTableDef ¶ 

func (c *CatalogHandler) HandleDelTableDef(ctx context.Context, meta txn.TxnMeta, req *memoryengine.DelTableDefReq, resp *memoryengine.DelTableDefResp) (err error)

func (*CatalogHandler) HandleDelete ¶ 

func (c *CatalogHandler) HandleDelete(ctx context.Context, meta txn.TxnMeta, req *memoryengine.DeleteReq, resp *memoryengine.DeleteResp) (err error)

func (*CatalogHandler) HandleDeleteDatabase ¶ 

func (c *CatalogHandler) HandleDeleteDatabase(ctx context.Context, meta txn.TxnMeta, req *memoryengine.DeleteDatabaseReq, resp *memoryengine.DeleteDatabaseResp) (err error)

func (*CatalogHandler) HandleDeleteRelation ¶ 

func (c *CatalogHandler) HandleDeleteRelation(ctx context.Context, meta txn.TxnMeta, req *memoryengine.DeleteRelationReq, resp *memoryengine.DeleteRelationResp) (err error)

func (*CatalogHandler) HandleDestroy ¶ 

func (c *CatalogHandler) HandleDestroy(ctx context.Context) error

func (*CatalogHandler) HandleGetDatabases ¶ 

func (c *CatalogHandler) HandleGetDatabases(ctx context.Context, meta txn.TxnMeta, req *memoryengine.GetDatabasesReq, resp *memoryengine.GetDatabasesResp) error

func (*CatalogHandler) HandleGetHiddenKeys ¶ 

func (c *CatalogHandler) HandleGetHiddenKeys(ctx context.Context, meta txn.TxnMeta, req *memoryengine.GetHiddenKeysReq, resp *memoryengine.GetHiddenKeysResp) (err error)

func (*CatalogHandler) HandleGetPrimaryKeys ¶ 

func (c *CatalogHandler) HandleGetPrimaryKeys(ctx context.Context, meta txn.TxnMeta, req *memoryengine.GetPrimaryKeysReq, resp *memoryengine.GetPrimaryKeysResp) (err error)

func (*CatalogHandler) HandleGetRelations ¶ 

func (c *CatalogHandler) HandleGetRelations(ctx context.Context, meta txn.TxnMeta, req *memoryengine.GetRelationsReq, resp *memoryengine.GetRelationsResp) (err error)

func (*CatalogHandler) HandleGetTableColumns ¶ 

func (c *CatalogHandler) HandleGetTableColumns(ctx context.Context, meta txn.TxnMeta, req *memoryengine.GetTableColumnsReq, resp *memoryengine.GetTableColumnsResp) (err error)

func (*CatalogHandler) HandleGetTableDefs ¶ 

func (c *CatalogHandler) HandleGetTableDefs(ctx context.Context, meta txn.TxnMeta, req *memoryengine.GetTableDefsReq, resp *memoryengine.GetTableDefsResp) (err error)

func (*CatalogHandler) HandleNewTableIter ¶ 

func (c *CatalogHandler) HandleNewTableIter(ctx context.Context, meta txn.TxnMeta, req *memoryengine.NewTableIterReq, resp *memoryengine.NewTableIterResp) (err error)

func (*CatalogHandler) HandleOpenDatabase ¶ 

func (c *CatalogHandler) HandleOpenDatabase(ctx context.Context, meta txn.TxnMeta, req *memoryengine.OpenDatabaseReq, resp *memoryengine.OpenDatabaseResp) (err error)

func (*CatalogHandler) HandleOpenRelation ¶ 

func (c *CatalogHandler) HandleOpenRelation(ctx context.Context, meta txn.TxnMeta, req *memoryengine.OpenRelationReq, resp *memoryengine.OpenRelationResp) (err error)

func (*CatalogHandler) HandlePrepare ¶ 

func (c *CatalogHandler) HandlePrepare(ctx context.Context, meta txn.TxnMeta) (timestamp.Timestamp, error)

func (*CatalogHandler) HandleRead ¶ 

func (c *CatalogHandler) HandleRead(ctx context.Context, meta txn.TxnMeta, req *memoryengine.ReadReq, resp *memoryengine.ReadResp) (err error)

func (*CatalogHandler) HandleRollback ¶ 

func (c *CatalogHandler) HandleRollback(ctx context.Context, meta txn.TxnMeta) error

func (*CatalogHandler) HandleStartRecovery ¶ 

func (c *CatalogHandler) HandleStartRecovery(ctx context.Context, ch chan txn.TxnMeta)

func (*CatalogHandler) HandleTableStats ¶ 

func (c *CatalogHandler) HandleTableStats(ctx context.Context, meta txn.TxnMeta, req *memoryengine.TableStatsReq, resp *memoryengine.TableStatsResp) (err error)

func (*CatalogHandler) HandleTruncateRelation ¶ 

func (c *CatalogHandler) HandleTruncateRelation(ctx context.Context, meta txn.TxnMeta, req *memoryengine.TruncateRelationReq, resp *memoryengine.TruncateRelationResp) (err error)

func (*CatalogHandler) HandleUpdate ¶ 

func (c *CatalogHandler) HandleUpdate(ctx context.Context, meta txn.TxnMeta, req *memoryengine.UpdateReq, resp *memoryengine.UpdateResp) (err error)

func (*CatalogHandler) HandleWrite ¶ 

func (c *CatalogHandler) HandleWrite(ctx context.Context, meta txn.TxnMeta, req *memoryengine.WriteReq, resp *memoryengine.WriteResp) (err error)

type DataKey ¶ 

type DataKey struct {
	// contains filtered or unexported fields
}

func (DataKey) Less ¶ 

func (d DataKey) Less(than DataKey) bool

type DataRow ¶ 

type DataRow struct {
	// contains filtered or unexported fields
}

func NewDataRow ¶ 

func NewDataRow(
	tableID ID,
	indexes []Tuple,
) *DataRow

func (DataRow) Indexes ¶ 

func (a DataRow) Indexes() []Tuple

func (DataRow) Key ¶ 

func (a DataRow) Key() DataKey

func (*DataRow) String ¶ 

func (a *DataRow) String() string

func (DataRow) UniqueIndexes ¶ 

func (a DataRow) UniqueIndexes() []Tuple

func (DataRow) Value ¶ 

func (a DataRow) Value() DataValue

type DataValue ¶ 

type DataValue = []Nullable

use AttributeRow.Order as index

type DatabaseRow ¶ 

type DatabaseRow struct {
	ID        ID
	AccountID uint32 // 0 is the sys account
	Name      []byte
	Typ       []byte
	CreateSql []byte
}

func (*DatabaseRow) AttrByName ¶ 

func (d *DatabaseRow) AttrByName(handler *MemHandler, tx *Transaction, name string) (ret Nullable, err error)

func (*DatabaseRow) Indexes ¶ 

func (d *DatabaseRow) Indexes() []Tuple

func (*DatabaseRow) Key ¶ 

func (d *DatabaseRow) Key() ID

func (*DatabaseRow) UniqueIndexes ¶ 

func (d *DatabaseRow) UniqueIndexes() []Tuple

func (*DatabaseRow) Value ¶ 

func (d *DatabaseRow) Value() *DatabaseRow

type DatabaseRowIter ¶ 

type DatabaseRowIter = Iter[ID, *DatabaseRow]

type DynamicStorage ¶ 

type DynamicStorage struct {
	// contains filtered or unexported fields
}

func NewDynamicStorage ¶ 

func NewDynamicStorage(
	newStorage func() (*Storage, error),
	keyFunc func(context.Context) (any, error),
) *DynamicStorage

func (*DynamicStorage) Close ¶ 

func (d *DynamicStorage) Close(ctx context.Context) error

func (*DynamicStorage) Commit ¶ 

func (d *DynamicStorage) Commit(ctx context.Context, txnMeta txn.TxnMeta) (timestamp.Timestamp, error)

func (*DynamicStorage) Committing ¶ 

func (d *DynamicStorage) Committing(ctx context.Context, txnMeta txn.TxnMeta) error

func (*DynamicStorage) Debug ¶ 

func (d *DynamicStorage) Debug(context.Context, txn.TxnMeta, uint32, []byte) ([]byte, error)

func (*DynamicStorage) Destroy ¶ 

func (d *DynamicStorage) Destroy(ctx context.Context) error

func (*DynamicStorage) Prepare ¶ 

func (d *DynamicStorage) Prepare(ctx context.Context, txnMeta txn.TxnMeta) (ts timestamp.Timestamp, err error)

func (*DynamicStorage) Read ¶ 

func (d *DynamicStorage) Read(ctx context.Context, txnMeta txn.TxnMeta, op uint32, payload []byte) (res storage.ReadResult, err error)

func (*DynamicStorage) Rollback ¶ 

func (d *DynamicStorage) Rollback(ctx context.Context, txnMeta txn.TxnMeta) error

func (*DynamicStorage) Start ¶ added in v0.7.0 

func (d *DynamicStorage) Start() error

func (*DynamicStorage) StartRecovery ¶ 

func (d *DynamicStorage) StartRecovery(ctx context.Context, ch chan txn.TxnMeta)

func (*DynamicStorage) Write ¶ 

func (d *DynamicStorage) Write(ctx context.Context, txnMeta txn.TxnMeta, op uint32, payload []byte) ([]byte, error)

type Handler ¶ 

type Handler interface {
	memoryengine.OperationHandler

	HandleCommit(
		ctx context.Context,
		meta txn.TxnMeta,
	) (timestamp.Timestamp, error)

	HandleRollback(
		ctx context.Context,
		meta txn.TxnMeta,
	) error

	HandleCommitting(
		ctx context.Context,
		meta txn.TxnMeta,
	) error

	HandlePrepare(
		ctx context.Context,
		meta txn.TxnMeta,
	) (
		timestamp.Timestamp,
		error,
	)

	HandleStartRecovery(
		ctx context.Context,
		ch chan txn.TxnMeta,
	)

	HandleClose(ctx context.Context) error

	HandleDestroy(ctx context.Context) error
}

type ID ¶ 

type ID = memoryengine.ID

type Iter ¶ 

type Iter[
	K memorytable.Ordered[K],
	V any,
] struct {
	TableIter *memorytable.TableIter[K, V]
	TableID   ID
	AttrsMap  map[string]*AttributeRow
	Expr      *plan.Expr

	Tx *Transaction
	// contains filtered or unexported fields
}

type MemHandler ¶ 

type MemHandler struct {
	// contains filtered or unexported fields
}

func NewMemHandler ¶ 

func NewMemHandler(
	mp *mpool.MPool,
	clock clock.Clock,
	idGenerator memoryengine.IDGenerator,
) *MemHandler

func (*MemHandler) HandleAddTableDef ¶ 

func (m *MemHandler) HandleAddTableDef(ctx context.Context, meta txn.TxnMeta, req *memoryengine.AddTableDefReq, resp *memoryengine.AddTableDefResp) error

func (*MemHandler) HandleClose ¶ 

func (*MemHandler) HandleClose(ctx context.Context) error

func (*MemHandler) HandleCloseTableIter ¶ 

func (m *MemHandler) HandleCloseTableIter(ctx context.Context, meta txn.TxnMeta, req *memoryengine.CloseTableIterReq, resp *memoryengine.CloseTableIterResp) error

func (*MemHandler) HandleCommit ¶ 

func (m *MemHandler) HandleCommit(ctx context.Context, meta txn.TxnMeta) (timestamp.Timestamp, error)

func (*MemHandler) HandleCommitting ¶ 

func (m *MemHandler) HandleCommitting(ctx context.Context, meta txn.TxnMeta) error

func (*MemHandler) HandleCreateDatabase ¶ 

func (m *MemHandler) HandleCreateDatabase(ctx context.Context, meta txn.TxnMeta, req *memoryengine.CreateDatabaseReq, resp *memoryengine.CreateDatabaseResp) error

func (*MemHandler) HandleCreateRelation ¶ 

func (m *MemHandler) HandleCreateRelation(ctx context.Context, meta txn.TxnMeta, req *memoryengine.CreateRelationReq, resp *memoryengine.CreateRelationResp) error

func (*MemHandler) HandleDelTableDef ¶ 

func (m *MemHandler) HandleDelTableDef(ctx context.Context, meta txn.TxnMeta, req *memoryengine.DelTableDefReq, resp *memoryengine.DelTableDefResp) error

func (*MemHandler) HandleDelete ¶ 

func (m *MemHandler) HandleDelete(ctx context.Context, meta txn.TxnMeta, req *memoryengine.DeleteReq, resp *memoryengine.DeleteResp) error

func (*MemHandler) HandleDeleteDatabase ¶ 

func (m *MemHandler) HandleDeleteDatabase(ctx context.Context, meta txn.TxnMeta, req *memoryengine.DeleteDatabaseReq, resp *memoryengine.DeleteDatabaseResp) error

func (*MemHandler) HandleDeleteRelation ¶ 

func (m *MemHandler) HandleDeleteRelation(ctx context.Context, meta txn.TxnMeta, req *memoryengine.DeleteRelationReq, resp *memoryengine.DeleteRelationResp) error

func (*MemHandler) HandleDestroy ¶ 

func (m *MemHandler) HandleDestroy(ctx context.Context) error

func (*MemHandler) HandleGetDatabases ¶ 

func (m *MemHandler) HandleGetDatabases(ctx context.Context, meta txn.TxnMeta, req *memoryengine.GetDatabasesReq, resp *memoryengine.GetDatabasesResp) error

func (*MemHandler) HandleGetHiddenKeys ¶ 

func (m *MemHandler) HandleGetHiddenKeys(ctx context.Context, meta txn.TxnMeta, req *memoryengine.GetHiddenKeysReq, resp *memoryengine.GetHiddenKeysResp) error

func (*MemHandler) HandleGetPrimaryKeys ¶ 

func (m *MemHandler) HandleGetPrimaryKeys(ctx context.Context, meta txn.TxnMeta, req *memoryengine.GetPrimaryKeysReq, resp *memoryengine.GetPrimaryKeysResp) error

func (*MemHandler) HandleGetRelations ¶ 

func (m *MemHandler) HandleGetRelations(ctx context.Context, meta txn.TxnMeta, req *memoryengine.GetRelationsReq, resp *memoryengine.GetRelationsResp) error

func (*MemHandler) HandleGetTableColumns ¶ 

func (m *MemHandler) HandleGetTableColumns(ctx context.Context, meta txn.TxnMeta, req *memoryengine.GetTableColumnsReq, resp *memoryengine.GetTableColumnsResp) error

func (*MemHandler) HandleGetTableDefs ¶ 

func (m *MemHandler) HandleGetTableDefs(ctx context.Context, meta txn.TxnMeta, req *memoryengine.GetTableDefsReq, resp *memoryengine.GetTableDefsResp) error

func (*MemHandler) HandleNewTableIter ¶ 

func (m *MemHandler) HandleNewTableIter(ctx context.Context, meta txn.TxnMeta, req *memoryengine.NewTableIterReq, resp *memoryengine.NewTableIterResp) error

func (*MemHandler) HandleOpenDatabase ¶ 

func (m *MemHandler) HandleOpenDatabase(ctx context.Context, meta txn.TxnMeta, req *memoryengine.OpenDatabaseReq, resp *memoryengine.OpenDatabaseResp) error

func (*MemHandler) HandleOpenRelation ¶ 

func (m *MemHandler) HandleOpenRelation(ctx context.Context, meta txn.TxnMeta, req *memoryengine.OpenRelationReq, resp *memoryengine.OpenRelationResp) error

func (*MemHandler) HandlePrepare ¶ 

func (m *MemHandler) HandlePrepare(ctx context.Context, meta txn.TxnMeta) (timestamp.Timestamp, error)

func (*MemHandler) HandleRead ¶ 

func (m *MemHandler) HandleRead(ctx context.Context, meta txn.TxnMeta, req *memoryengine.ReadReq, resp *memoryengine.ReadResp) error

func (*MemHandler) HandleRollback ¶ 

func (m *MemHandler) HandleRollback(ctx context.Context, meta txn.TxnMeta) error

func (*MemHandler) HandleStartRecovery ¶ 

func (m *MemHandler) HandleStartRecovery(ctx context.Context, ch chan txn.TxnMeta)

func (*MemHandler) HandleTableStats ¶ 

func (m *MemHandler) HandleTableStats(ctx context.Context, meta txn.TxnMeta, req *memoryengine.TableStatsReq, resp *memoryengine.TableStatsResp) (err error)

func (*MemHandler) HandleTruncateRelation ¶ 

func (m *MemHandler) HandleTruncateRelation(ctx context.Context, meta txn.TxnMeta, req *memoryengine.TruncateRelationReq, resp *memoryengine.TruncateRelationResp) error

func (*MemHandler) HandleUpdate ¶ 

func (m *MemHandler) HandleUpdate(ctx context.Context, meta txn.TxnMeta, req *memoryengine.UpdateReq, resp *memoryengine.UpdateResp) error

func (*MemHandler) HandleWrite ¶ 

func (m *MemHandler) HandleWrite(ctx context.Context, meta txn.TxnMeta, req *memoryengine.WriteReq, resp *memoryengine.WriteResp) error

type NamedDataRow ¶ 

type NamedDataRow struct {
	Value    DataValue
	AttrsMap map[string]*AttributeRow
}

func (*NamedDataRow) AttrByName ¶ 

func (n *NamedDataRow) AttrByName(handler *MemHandler, tx *Transaction, name string) (Nullable, error)

type NamedRow ¶ 

type NamedRow interface {
	AttrByName(handler *MemHandler, tx *Transaction, name string) (Nullable, error)
}

type Nullable ¶ 

type Nullable = memorytable.Nullable

type RelationRow ¶ 

type RelationRow struct {
	ID           ID
	DatabaseID   ID
	Name         []byte
	Type         memoryengine.RelationType
	Comments     []byte
	Properties   map[string]string
	Partitioned  int8   // 1 : the table has partitions. 0 : no partition
	PartitionDef []byte // partition info for the table has paritions
	ViewDef      []byte
	Constraint   []byte
}

func (*RelationRow) AttrByName ¶ 

func (r *RelationRow) AttrByName(handler *MemHandler, tx *Transaction, name string) (ret Nullable, err error)

func (*RelationRow) Indexes ¶ 

func (r *RelationRow) Indexes() []Tuple

func (*RelationRow) Key ¶ 

func (r *RelationRow) Key() ID

func (*RelationRow) UniqueIndexes ¶ 

func (r *RelationRow) UniqueIndexes() []Tuple

func (*RelationRow) Value ¶ 

func (r *RelationRow) Value() *RelationRow

type RelationRowIter ¶ 

type RelationRowIter = Iter[ID, *RelationRow]

type Storage ¶ 

type Storage struct {
	// contains filtered or unexported fields
}

func New ¶ 

func New(
	handler Handler,
) (*Storage, error)

func NewMemoryStorage ¶ 

func NewMemoryStorage(
	mheap *mpool.MPool,
	clock clock.Clock,
	idGenerator memoryengine.IDGenerator,
) (*Storage, error)

func (*Storage) Close ¶ 

func (s *Storage) Close(ctx context.Context) error

func (*Storage) Commit ¶ 

func (s *Storage) Commit(ctx context.Context, txnMeta txn.TxnMeta) (timestamp.Timestamp, error)

func (*Storage) Committing ¶ 

func (s *Storage) Committing(ctx context.Context, txnMeta txn.TxnMeta) error

func (*Storage) Debug ¶ 

func (s *Storage) Debug(context.Context, txn.TxnMeta, uint32, []byte) ([]byte, error)

func (*Storage) Destroy ¶ 

func (s *Storage) Destroy(ctx context.Context) error

func (*Storage) Prepare ¶ 

func (s *Storage) Prepare(ctx context.Context, txnMeta txn.TxnMeta) (timestamp.Timestamp, error)

func (*Storage) Read ¶ 

func (s *Storage) Read(ctx context.Context, txnMeta txn.TxnMeta, op uint32, payload []byte) (res storage.ReadResult, err error)

func (*Storage) Rollback ¶ 

func (s *Storage) Rollback(ctx context.Context, txnMeta txn.TxnMeta) error

func (*Storage) Start ¶ added in v0.7.0 

func (s *Storage) Start() error

func (*Storage) StartRecovery ¶ 

func (s *Storage) StartRecovery(ctx context.Context, ch chan txn.TxnMeta)

func (*Storage) Write ¶ 

func (s *Storage) Write(ctx context.Context, txnMeta txn.TxnMeta, op uint32, payload []byte) (result []byte, err error)

type StorageTxnClient ¶ 

type StorageTxnClient struct {
	// contains filtered or unexported fields
}

func NewStorageTxnClient ¶ 

func NewStorageTxnClient(
	clock clock.Clock,
	storages map[string]*Storage,
) *StorageTxnClient

func (*StorageTxnClient) AbortAllRunningTxn ¶ added in v0.8.0 

func (*StorageTxnClient) AbortAllRunningTxn()

func (*StorageTxnClient) CNBasedConsistencyEnabled ¶ added in v1.0.0 

func (*StorageTxnClient) CNBasedConsistencyEnabled() bool

func (*StorageTxnClient) Close ¶ 

func (*StorageTxnClient) Close() error

func (*StorageTxnClient) GetLatestCommitTS ¶ added in v1.0.0 

func (*StorageTxnClient) GetLatestCommitTS() timestamp.Timestamp

func (*StorageTxnClient) GetState ¶ added in v1.1.0 

func (s *StorageTxnClient) GetState() client.TxnState

func (*StorageTxnClient) GetSyncLatestCommitTSTimes ¶ added in v1.0.0 

func (*StorageTxnClient) GetSyncLatestCommitTSTimes() uint64

func (*StorageTxnClient) IterTxns ¶ added in v1.0.0 

func (s *StorageTxnClient) IterTxns(func(client.TxnOverview) bool)

func (*StorageTxnClient) MinTimestamp ¶ added in v0.8.0 

func (*StorageTxnClient) MinTimestamp() timestamp.Timestamp

func (*StorageTxnClient) New ¶ 

func (s *StorageTxnClient) New(
	ctx context.Context,
	ts timestamp.Timestamp,
	options ...client.TxnOption) (client.TxnOperator, error)

func (*StorageTxnClient) NewWithSnapshot ¶ 

func (*StorageTxnClient) NewWithSnapshot(snapshot []byte) (client.TxnOperator, error)

func (*StorageTxnClient) Pause ¶ added in v1.0.0 

func (*StorageTxnClient) Pause()

func (*StorageTxnClient) RefreshExpressionEnabled ¶ added in v1.0.0 

func (*StorageTxnClient) RefreshExpressionEnabled() bool

func (*StorageTxnClient) Resume ¶ added in v1.0.0 

func (*StorageTxnClient) Resume()

func (*StorageTxnClient) SyncLatestCommitTS ¶ added in v1.0.0 

func (*StorageTxnClient) SyncLatestCommitTS(timestamp.Timestamp)

func (*StorageTxnClient) WaitLogTailAppliedAt ¶ added in v0.8.0 

func (*StorageTxnClient) WaitLogTailAppliedAt(
	ctx context.Context,
	ts timestamp.Timestamp) (timestamp.Timestamp, error)

type StorageTxnOperator ¶ 

type StorageTxnOperator struct {
	// contains filtered or unexported fields
}

func (*StorageTxnOperator) AddLockTable ¶ added in v0.8.0 

func (s *StorageTxnOperator) AddLockTable(lock.LockTable) error

func (*StorageTxnOperator) AddWaitLock ¶ added in v1.0.0 

func (s *StorageTxnOperator) AddWaitLock(tableID uint64, rows [][]byte, opt lock.LockOptions) uint64

func (*StorageTxnOperator) AddWorkspace ¶ added in v0.8.0 

func (s *StorageTxnOperator) AddWorkspace(_ client.Workspace)

func (*StorageTxnOperator) AppendEventCallback ¶ added in v1.0.0 

func (s *StorageTxnOperator) AppendEventCallback(event client.EventType, callbacks ...func(txn.TxnMeta))

func (*StorageTxnOperator) ApplySnapshot ¶ 

func (s *StorageTxnOperator) ApplySnapshot(data []byte) error

func (*StorageTxnOperator) Commit ¶ 

func (s *StorageTxnOperator) Commit(ctx context.Context) error

func (*StorageTxnOperator) Debug ¶ added in v1.0.0 

func (s *StorageTxnOperator) Debug(ctx context.Context, ops []txn.TxnRequest) (*rpc.SendResult, error)

func (*StorageTxnOperator) GetOperationHandler ¶ 

func (s *StorageTxnOperator) GetOperationHandler(shard memoryengine.Shard) (memoryengine.OperationHandler, txn.TxnMeta)

func (*StorageTxnOperator) GetOverview ¶ added in v1.0.0 

func (s *StorageTxnOperator) GetOverview() client.TxnOverview

func (*StorageTxnOperator) GetWorkspace ¶ added in v0.8.0 

func (s *StorageTxnOperator) GetWorkspace() client.Workspace

func (*StorageTxnOperator) IsOpenLog ¶ added in v1.1.0 

func (s *StorageTxnOperator) IsOpenLog() bool

func (*StorageTxnOperator) IsRetry ¶ added in v1.0.0 

func (s *StorageTxnOperator) IsRetry() bool

func (*StorageTxnOperator) LockSkipped ¶ added in v1.1.0 

func (s *StorageTxnOperator) LockSkipped(tableID uint64, mode lock.LockMode) bool

func (*StorageTxnOperator) Read ¶ 

func (s *StorageTxnOperator) Read(ctx context.Context, ops []txn.TxnRequest) (*rpc.SendResult, error)

func (*StorageTxnOperator) RemoveWaitLock ¶ added in v1.0.0 

func (s *StorageTxnOperator) RemoveWaitLock(key uint64)

func (*StorageTxnOperator) ResetRetry ¶ added in v1.0.0 

func (s *StorageTxnOperator) ResetRetry(retry bool)

func (*StorageTxnOperator) Rollback ¶ 

func (s *StorageTxnOperator) Rollback(ctx context.Context) error

func (*StorageTxnOperator) SetOpenLog ¶ added in v1.1.0 

func (s *StorageTxnOperator) SetOpenLog(retry bool)

func (*StorageTxnOperator) Snapshot ¶ 

func (*StorageTxnOperator) Snapshot() ([]byte, error)

func (*StorageTxnOperator) SnapshotTS ¶ added in v1.0.0 

func (s *StorageTxnOperator) SnapshotTS() timestamp.Timestamp

func (*StorageTxnOperator) Status ¶ added in v1.0.0 

func (s *StorageTxnOperator) Status() txn.TxnStatus

func (*StorageTxnOperator) Txn ¶ 

func (s *StorageTxnOperator) Txn() txn.TxnMeta

func (*StorageTxnOperator) TxnRef ¶ added in v0.8.0 

func (s *StorageTxnOperator) TxnRef() *txn.TxnMeta

func (*StorageTxnOperator) UpdateSnapshot ¶ added in v0.8.0 

func (s *StorageTxnOperator) UpdateSnapshot(ctx context.Context, ts timestamp.Timestamp) error

func (*StorageTxnOperator) Write ¶ 

func (s *StorageTxnOperator) Write(ctx context.Context, ops []txn.TxnRequest) (*rpc.SendResult, error)

func (*StorageTxnOperator) WriteAndCommit ¶ 

func (s *StorageTxnOperator) WriteAndCommit(ctx context.Context, ops []txn.TxnRequest) (*rpc.SendResult, error)

type Text ¶ 

type Text = memorytable.Text

type Time ¶ 

type Time = memorytable.Time

type Transaction ¶ 

type Transaction = memorytable.Transaction

type Tuple ¶ 

type Tuple = memorytable.Tuple

type Uint ¶ 

type Uint = memorytable.Uint

Source Files ¶

View all Source files

Directories ¶

Path Synopsis

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.