Documentation
¶
Index ¶
- Constants
- func GetSysdbVersion(dbconnstr string) (int64, error)
- func GoUpdateUserPerms(dc, dcsuper *pgx.Conn, trackedTables []dbx.Table)
- func Init(s string) error
- func InitCreate(connString string) error
- func UserRead(dq dbx.Queryable) (map[string]*util.RegexList, error)
- func ValidateSysdbVersion(dbconnstr string) error
- type ColumnSchema
- type DatabaseConnector
- type SourceConnector
- type TableSchema
Constants ¶
View Source
const OpenOptions = "?_busy_timeout=30000" +
"&_foreign_keys=on" +
"&_journal_mode=WAL" +
"&_locking_mode=NORMAL" +
"&_synchronous=3"
Deprecated
Variables ¶
This section is empty.
Functions ¶
func GetSysdbVersion ¶ added in v0.10.0
func GoUpdateUserPerms ¶ added in v1.0.4
func InitCreate ¶
func UserRead ¶ added in v0.9.0
func UpdateUser(rq *api.UserUpdateRequest) error { sysMu.Lock() defer sysMu.Unlock() return userWrite(rq.Name, rq.Tables) }
func DeleteUser(rq *api.UserDeleteRequest) (*api.UserDeleteResponse, error) { sysMu.Lock() defer sysMu.Unlock() found, err := userDelete(rq.Name) if err != nil { return nil, err } return &api.UserDeleteResponse{NameNotFound: !found}, nil }
func ValidateSysdbVersion ¶ added in v0.10.0
Types ¶
type ColumnSchema ¶
type DatabaseConnector ¶
type SourceConnector ¶
type SourceConnector struct { ID int64 Name string Enable bool Brokers string Security string Topics []string Group string SchemaPassFilter []string SchemaStopFilter []string TableStopFilter []string TrimSchemaPrefix string AddSchemaPrefix string Module string Status status.Status }
func ReadSourceConnectors ¶
func ReadSourceConnectors(db *dbx.DB) ([]*SourceConnector, error)
type TableSchema ¶
type TableSchema struct {
Column []ColumnSchema
}
Source Files
¶
Click to show internal directories.
Click to hide internal directories.