rpc

type LocalDispatch func(metadata.DNShard) TxnRequestHandleFunc

type SendResult struct {
	Responses []txn.TxnResponse
	// contains filtered or unexported fields
}

type SenderOption func(*sender)

type TxnRequestHandleFunc func(context.Context, *txn.TxnRequest, *txn.TxnResponse) error

type TxnSender interface {
	// Send send request to the specified DN node, and wait for response synchronously.
	// For any reason, if no response is received, the internal will keep retrying until
	// the Context times out.
	Send(context.Context, []txn.TxnRequest) (*SendResult, error)
	// Close the txn sender
	Close() error
}

type TxnServer interface {
	// Start start the txn server
	Start() error
	// Close the txn server
	Close() error
	// RegisterMethodHandler register txn request handler func
	RegisterMethodHandler(txn.TxnMethod, TxnRequestHandleFunc)
	// SetFilter set filter func. Requests can be modified or filtered out by the filter
	// before they are processed by the handler.
	SetFilter(func(*txn.TxnRequest) bool)
}