Documentation
¶
Index ¶
- func AddTableWithCheck(t *storage.MetaTransaction, projectID, party string, table storage.TableMeta) error
- func AskInfoByChecksumResult(session *application.Session, compRes pb.ChecksumCompareResult, ...) (askInfoTriggered bool, err error)
- func AskProjectInfoFromParties(app *application.App, projectID string, tableNames []string, ...) (err error)
- func CheckInvitationCompatibleWithProj(invitation storage.Invitation, proj storage.Project) error
- func CheckMemberExistInProject(manager *storage.MetaManager, projectID string, member string) error
- func DropTableWithCheck(t *storage.MetaTransaction, projectID, party string, ...) (exist bool, err error)
- func FeedResponse(c *gin.Context, response proto.Message, err error, ...)
- func GrantColumnConstraintsWithCheck(t *storage.MetaTransaction, projectID string, privs []storage.ColumnPriv, ...) error
- func LogWithError(logEntry *logutil.BrokerMonitorLogEntry, err error)
- func PostSyncInfo(app *application.App, projectID string, action pb.ChangeEntry_Action, data any, ...) (err error)
- func RevokeColumnConstraintsWithCheck(t *storage.MetaTransaction, projectID, party string, ...) error
- func VerifyProjectID(projectID string) error
- func VerifyTableMeta(meta storage.TableMeta) error
- type InfoAskerAndUpdater
- type OwnerChecker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddTableWithCheck ¶
func AskInfoByChecksumResult ¶
func AskInfoByChecksumResult(session *application.Session, compRes pb.ChecksumCompareResult, tables []core.DbTable, targetParty string) (askInfoTriggered bool, err error)
use this function if you know table owner
func AskProjectInfoFromParties ¶
func AskProjectInfoFromParties(app *application.App, projectID string, tableNames []string, cclDestParties []string, sourceParties []string) (err error)
use this function if you don't know table owner and set source parties as project members except self
func CheckInvitationCompatibleWithProj ¶
func CheckInvitationCompatibleWithProj(invitation storage.Invitation, proj storage.Project) error
Check Archived/ProjectConf/Creator
func CheckMemberExistInProject ¶
func CheckMemberExistInProject(manager *storage.MetaManager, projectID string, member string) error
check project exist and current party is member
func DropTableWithCheck ¶
func DropTableWithCheck(t *storage.MetaTransaction, projectID, party string, tableId storage.TableIdentifier) (exist bool, err error)
if table not exist, return false, nil if table exist and drop it successfully return true, nil
func FeedResponse ¶
func GrantColumnConstraintsWithCheck ¶
func GrantColumnConstraintsWithCheck(t *storage.MetaTransaction, projectID string, privs []storage.ColumnPriv, columnOwnerChecker OwnerChecker) error
func LogWithError ¶
func LogWithError(logEntry *logutil.BrokerMonitorLogEntry, err error)
func PostSyncInfo ¶
func PostSyncInfo(app *application.App, projectID string, action pb.ChangeEntry_Action, data any, targetParties []string) (err error)
func RevokeColumnConstraintsWithCheck ¶
func RevokeColumnConstraintsWithCheck(t *storage.MetaTransaction, projectID, party string, privIDs []storage.ColumnPrivIdentifier) error
func VerifyProjectID ¶
func VerifyTableMeta ¶
Types ¶
type InfoAskerAndUpdater ¶
type InfoAskerAndUpdater struct {
// contains filtered or unexported fields
}
type OwnerChecker ¶
Source Files
Click to show internal directories.
Click to hide internal directories.