rpc

Documentation

Index

• type Handle
  • func NewTAEHandle(path string, opt *options.Options) *Handle
  • func (h *Handle) CacheTxnRequest(ctx context.Context, meta txn.TxnMeta, req any, rsp any) (err error)
  • func (h *Handle) GetTxnEngine() moengine.TxnEngine
  • func (h *Handle) HandleClose(ctx context.Context) (err error)
  • func (h *Handle) HandleCommit(ctx context.Context, meta txn.TxnMeta) (err error)
  • func (h *Handle) HandleCommitting(ctx context.Context, meta txn.TxnMeta) (err error)
  • func (h *Handle) HandleCreateDatabase(ctx context.Context, meta txn.TxnMeta, req db.CreateDatabaseReq, ...) (err error)
  • func (h *Handle) HandleCreateRelation(ctx context.Context, meta txn.TxnMeta, req db.CreateRelationReq, ...) (err error)
  • func (h *Handle) HandleDestroy(ctx context.Context) (err error)
  • func (h *Handle) HandleDropDatabase(ctx context.Context, meta txn.TxnMeta, req db.DropDatabaseReq, ...) (err error)
  • func (h *Handle) HandleDropOrTruncateRelation(ctx context.Context, meta txn.TxnMeta, req db.DropOrTruncateRelationReq, ...) (err error)
  • func (h *Handle) HandleFlushTable(ctx context.Context, meta txn.TxnMeta, req db.FlushTable, ...) (err error)
  • func (h *Handle) HandleGetLogTail(ctx context.Context, meta txn.TxnMeta, req apipb.SyncLogTailReq, ...) (err error)
  • func (h *Handle) HandlePreCommitWrite(ctx context.Context, meta txn.TxnMeta, req apipb.PrecommitWriteCmd, ...) (err error)
  • func (h *Handle) HandlePrepare(ctx context.Context, meta txn.TxnMeta) (pts timestamp.Timestamp, err error)
  • func (h *Handle) HandleRollback(ctx context.Context, meta txn.TxnMeta) (err error)
  • func (h *Handle) HandleStartRecovery(ctx context.Context, ch chan txn.TxnMeta)
  • func (h *Handle) HandleWrite(ctx context.Context, meta txn.TxnMeta, req db.WriteReq, resp *db.WriteResp) (err error)

Types

type Handle

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

TODO::GC the abandoned txn.

func NewTAEHandle

func NewTAEHandle(path string, opt *options.Options) *Handle

func (*Handle) CacheTxnRequest

func (h *Handle) CacheTxnRequest(
	ctx context.Context,
	meta txn.TxnMeta,
	req any,
	rsp any) (err error)

func (*Handle) GetTxnEngine

func (h *Handle) GetTxnEngine() moengine.TxnEngine

func (*Handle) HandleClose

func (h *Handle) HandleClose(ctx context.Context) (err error)

func (*Handle) HandleCommit

func (h *Handle) HandleCommit(
	ctx context.Context,
	meta txn.TxnMeta) (err error)

func (*Handle) HandleCommitting

func (h *Handle) HandleCommitting(
	ctx context.Context,
	meta txn.TxnMeta) (err error)

func (*Handle) HandleCreateDatabase

func (h *Handle) HandleCreateDatabase(
	ctx context.Context,
	meta txn.TxnMeta,
	req db.CreateDatabaseReq,
	resp *db.CreateDatabaseResp) (err error)

func (*Handle) HandleCreateRelation

func (h *Handle) HandleCreateRelation(
	ctx context.Context,
	meta txn.TxnMeta,
	req db.CreateRelationReq,
	resp *db.CreateRelationResp) (err error)

func (*Handle) HandleDestroy

func (h *Handle) HandleDestroy(ctx context.Context) (err error)

func (*Handle) HandleDropDatabase

func (h *Handle) HandleDropDatabase(
	ctx context.Context,
	meta txn.TxnMeta,
	req db.DropDatabaseReq,
	resp *db.DropDatabaseResp) (err error)

func (*Handle) HandleDropOrTruncateRelation

func (h *Handle) HandleDropOrTruncateRelation(
	ctx context.Context,
	meta txn.TxnMeta,
	req db.DropOrTruncateRelationReq,
	resp *db.DropOrTruncateRelationResp) (err error)

func (*Handle) HandleFlushTable

func (h *Handle) HandleFlushTable(
	ctx context.Context,
	meta txn.TxnMeta,
	req db.FlushTable,
	resp *apipb.SyncLogTailResp) (err error)

func (*Handle) HandleGetLogTail

func (h *Handle) HandleGetLogTail(
	ctx context.Context,
	meta txn.TxnMeta,
	req apipb.SyncLogTailReq,
	resp *apipb.SyncLogTailResp) (err error)

func (*Handle) HandlePreCommitWrite

func (h *Handle) HandlePreCommitWrite(
	ctx context.Context,
	meta txn.TxnMeta,
	req apipb.PrecommitWriteCmd,
	resp *apipb.SyncLogTailResp) (err error)

HandlePreCommitWrite only cache the req.

func (*Handle) HandlePrepare

func (h *Handle) HandlePrepare(
	ctx context.Context,
	meta txn.TxnMeta) (pts timestamp.Timestamp, err error)

func (*Handle) HandleRollback

func (h *Handle) HandleRollback(
	ctx context.Context,
	meta txn.TxnMeta) (err error)

func (*Handle) HandleStartRecovery

func (h *Handle) HandleStartRecovery(
	ctx context.Context,
	ch chan txn.TxnMeta)

func (*Handle) HandleWrite

func (h *Handle) HandleWrite(
	ctx context.Context,
	meta txn.TxnMeta,
	req db.WriteReq,
	resp *db.WriteResp) (err error)

HandleWrite Handle DML commands