rpchandle

Documentation

Index

• type Handler

Types

type Handler

type Handler interface {
	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

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

	HandlePreCommitWrite(
		ctx context.Context,
		meta txn.TxnMeta,
		req *apipb.PrecommitWriteCmd,
		resp *apipb.TNStringResponse,
	) error

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

	HandleCommitMerge(
		ctx context.Context,
		meta txn.TxnMeta,
		req *apipb.MergeCommitEntry,
		resp *db.InspectResp,
	) (func(), error)

	HandleForceCheckpoint(
		ctx context.Context,
		meta txn.TxnMeta,
		req *db.Checkpoint,
		resp *apipb.SyncLogTailResp,
	) (func(), error)

	HandleForceGlobalCheckpoint(
		ctx context.Context,
		meta txn.TxnMeta,
		req *db.Checkpoint,
		resp *apipb.SyncLogTailResp,
	) (func(), error)
	HandleDisableCheckpoint(
		ctx context.Context,
		meta txn.TxnMeta,
		req *db.Checkpoint,
		resp *apipb.SyncLogTailResp,
	) (func(), error)
	HandleInspectTN(
		ctx context.Context,
		meta txn.TxnMeta,
		req *db.InspectTN,
		resp *db.InspectResp,
	) (func(), error)

	HandleAddFaultPoint(
		ctx context.Context,
		meta txn.TxnMeta,
		req *db.FaultPoint,
		resp *apipb.SyncLogTailResp,
	) (func(), error)

	HandleBackup(
		ctx context.Context,
		meta txn.TxnMeta,
		req *db.Checkpoint,
		resp *apipb.SyncLogTailResp,
	) (func(), error)

	HandleTraceSpan(
		ctx context.Context,
		meta txn.TxnMeta,
		req *db.TraceSpan,
		resp *apipb.SyncLogTailResp,
	) (func(), error)

	HandleStorageUsage(
		ctx context.Context,
		meta txn.TxnMeta,
		req *db.StorageUsageReq,
		resp *db.StorageUsageResp_V2,
	) (func(), error)

	HandleInterceptCommit(
		ctx context.Context,
		meta txn.TxnMeta,
		req *db.InterceptCommit,
		resp *apipb.SyncLogTailResp,
	) (func(), error)
	HandleDiskCleaner(
		ctx context.Context,
		meta txn.TxnMeta,
		req *db.DiskCleaner,
		resp *apipb.SyncLogTailResp,
	) (cb func(), err error)
}