taestorage

func HandleWrite[PReq unmarshaler[Req], PResp marshaller[Resp], Req, Resp any](
	ctx context.Context,
	meta txn.TxnMeta,
	payload []byte,
	fn func(context.Context, txn.TxnMeta, PReq, PResp) error,
) (res []byte, err error)

func NewTAEStorage(
	ctx context.Context,
	dataDir string,
	opt *options.Options,
	shard metadata.TNShard,
	rt runtime.Runtime,
	logtailServerAddr string,
	logtailServerCfg *options.LogtailServerCfg,
	txnServer rpc2.TxnServer,
	client client.QueryClient,
) (storage.TxnStorage, error)