common

package

Go to main page

Versions in this module

v0

v0.2.2

Jan 12, 2024

v0.2.1

Jan 11, 2024

Changes in this version

+ func CreateRelease(...) (err error)

+ func CreateTag(...) (err error)

v0.2.0

Jan 10, 2024

v0.1.3

Apr 5, 2023

Changes in this version

+ func LiveExecuteSQLDelete(dbOwner, sqlName string) (err error)

+ func LiveExecuteSQLGet(dbOwner, sqlName string) (sqlText string, err error)

+ func LiveExecuteSQLList(dbOwner string) (sqlNames []string, err error)

+ func LiveExecuteSQLSave(dbOwner, sqlName, sqlText string) (err error)

type DBInfo

+ ForkFolder string

type DatabaseName

+ Folder string

v0.1.2

Mar 27, 2023

Changes in this version

+ func AMQPErrorString(errCode AMQPErrorCode) string

+ type AMQPErrorCode int

+ const AMQPNoError

+ const AMQPRequestedTableNotPresent

v0.1.1

Mar 26, 2023

Changes in this version

+ func MQExecuteResponse(msg amqp.Delivery, channel *amqp.Channel, nodeName string, rowsChanged int, ...) (err error)

v0.1.0

Mar 25, 2023

Changes in this version

+ var AmqpDebug = true

+ func CheckAPIKey(apiKey string) (err error)

+ func ConnectMQ() (channel *amqp.Channel, err error)

+ func LiveDatabasesOnNode(nodeName string) (err error)

+ func MQColumnsResponse(msg amqp.Delivery, channel *amqp.Channel, nodeName string, ...) (err error)

+ func MQDeleteResponse(msg amqp.Delivery, channel *amqp.Channel, nodeName string, errMsg string) (err error)

+ func MQErrorResponse(msg amqp.Delivery, channel *amqp.Channel, nodeName string, errMsg string) (err error)

+ func MQExecResponse(msg amqp.Delivery, channel *amqp.Channel, nodeName string, errMsg string) (err error)

+ func MQIndexesResponse(msg amqp.Delivery, channel *amqp.Channel, nodeName string, ...) (err error)

+ func MQQueryResponse(msg amqp.Delivery, channel *amqp.Channel, nodeName string, ...) (err error)

+ func MQSendRequest(channel *amqp.Channel, ...) (result []byte, err error)

+ func MQTablesResponse(msg amqp.Delivery, channel *amqp.Channel, nodeName string, tables []string, ...) (err error)

+ func MQViewsResponse(msg amqp.Delivery, channel *amqp.Channel, nodeName string, views []string, ...) (err error)

+ func SQLiteExecQueryLive(baseDir, dbOwner, dbName, loggedInUser, query string) (err error)

type LiveDBRequest

+ Query string

+ type LiveDBs struct

+ DBName string

+ DBOwner string

+ DateCreated time.Time

type MetaInfo

+ Environment string

+ Folder string

+ PageSection string

type QuerySource

+ const QuerySourceWebUI

type SQLiteRecordSet

+ func LiveQueryDB(channel *amqp.Channel, nodeName, requestingUser, dbOwner, dbName, query string) (rows SQLiteRecordSet, err error)

v0.0.15

Jan 10, 2024

Changes in this version

+ const SqliteDebug

+ var AmqpChan *amqp.Channel

+ var CheckJobQueue chan struct

+ var CheckResponsesQueue chan struct

+ var JobListenConn *pgx.Conn

+ var JobQueueConn *pgpool.Pool

+ var JobQueueDebug = 0

+ var ResponseQueue *ResponseReceivers

+ var SubmitterInstance string

+ var UseAMQP = false

+ func APIKeyDelete(loggedInUser, uuid string) (err error)

+ func AnalysisRecordUserStorage(userName string, recordDate time.Time, spaceUsedStandard, spaceUsedLive int64) (err error)

+ func AnalysisUsersWithDBs() (userList map[string]int, err error)

+ func ApiCallLog(loggedInUser, dbOwner, dbName, operation, callerSw string)

+ func AuthorizerLive(d interface{}, action sqlite.Action, ...) sqlite.Auth

+ func CheckDBLive(dbOwner, dbName string) (isLive bool, liveNode string, err error)

+ func CheckDBPermissions(loggedInUser, dbOwner, dbName string, writeAccess bool) (bool, error)

+ func ClearCache() (err error)

+ func CloseMQChannel(channel *amqp.Channel) (err error)

+ func CloseMQConnection(connection *amqp.Connection) (err error)

+ func CommitPublicFlag(loggedInUser, dbOwner, dbName, commitID string) (public bool, err error)

+ func ConnectQueue() (channel *amqp.Channel, err error)

+ func CypressSeed(w http.ResponseWriter, r *http.Request)

+ func DataValuesMatch(a []DataValue, b []DataValue) (equal bool)

+ func EnvProd(w http.ResponseWriter, r *http.Request)

+ func EnvTest(w http.ResponseWriter, r *http.Request)

+ func GetFormLive(r *http.Request) (live bool, err error)

+ func GetShares(dbOwner, dbName string) (shares map[string]ShareDatabasePermissions, err error)

+ func HttpErrorLog() *log.Logger

+ func JobQueueCheck()

+ func JobQueueCreateDatabase(req JobRequest) (err error)

+ func JobQueueErrorString(errCode JobQueueErrorCode) string

+ func JobQueueGetSize(DBOwner, DBName string) (size int64, err error)

+ func JobQueueListen()

+ func JobSubmit[T any](response *T, targetNode, operation, requestingUser, dbOwner, dbName string, ...) (err error)

+ func LiveAddDatabasePG(dbOwner, dbName, bucketName, liveNode string, accessType SetAccessType) (err error)

+ func LiveBackup(liveNode, loggedInUser, dbOwner, dbName string) (err error)

+ func LiveColumns(liveNode, loggedInUser, dbOwner, dbName, table string) (columns []sqlite.Column, pk []string, err error)

+ func LiveCreateDB(channel *amqp.Channel, dbOwner, dbName, objectID string) (liveNode string, err error)

+ func LiveDelete(liveNode, loggedInUser, dbOwner, dbName string) (err error)

+ func LiveExecute(liveNode, loggedInUser, dbOwner, dbName, sql string) (rowsChanged int, err error)

+ func LiveGenerateMinioNames(userName string) (bucketName, objectName string, err error)

+ func LiveGetMinioNames(loggedInUser, dbOwner, dbName string) (bucketName, objectName string, err error)

+ func LiveRetrieveDatabaseMinio(baseDir, dbOwner, dbName, objectID string) (dbPath string, err error)

+ func LiveSize(liveNode, loggedInUser, dbOwner, dbName string) (size int64, err error)

+ func LiveSqlHistoryAdd(loggedInUser, dbOwner, dbName, stmt string, state SqlHistoryItemStates, ...) (err error)

+ func LiveSqlHistoryDeleteOld(loggedInUser, dbOwner, dbName string, keepRecords int) (err error)

+ func LiveStoreDatabaseMinio(db *os.File, dbOwner, dbName string, dbSize int64) (minioObjectID string, err error)

+ func LiveTables(liveNode, loggedInUser, dbOwner, dbName string) (tables []string, err error)

+ func LiveTablesAndViews(liveNode, loggedInUser, dbOwner, dbName string) (list []string, err error)

+ func LiveViews(liveNode, loggedInUser, dbOwner, dbName string) (views []string, err error)

+ func MQCreateDBQueue(channel *amqp.Channel) (queue amqp.Queue, err error)

+ func MQCreateQueryQueue(channel *amqp.Channel, nodeName string) (queue amqp.Queue, err error)

+ func MQCreateResponse(msg amqp.Delivery, channel *amqp.Channel, nodeName, result string) (err error)

+ func MQRequest(channel *amqp.Channel, ...) (result []byte, err error)

+ func MQResponse(requestType string, msg amqp.Delivery, channel *amqp.Channel, nodeName string, ...) (err error)

+ func Merge(destOwner, destName, destBranch, srcOwner, srcName string, ...) (newCommitID string, err error)

+ func MinioDeleteDatabase(source, dbOwner, dbName, bucket, id string) (err error)

+ func OpenSQLiteDatabaseLive(baseDir, dbOwner, dbName string) (sdb *sqlite.Conn, err error)

+ func RecordWebLogin(userName string) (err error)

+ func RemoveLiveDB(dbOwner, dbName string) (err error)

+ func ResetDB() error

+ func ResponseComplete(responseID int) (err error)

+ func ResponseQueueCheck()

+ func ResponseQueueListen()

+ func ResponseSubmit(jobID int, submitterNode string, payload []byte) (err error)

+ func SQLiteBackupLive(baseDir, dbOwner, dbName string) (err error)

+ func SQLiteExecuteQueryLive(baseDir, dbOwner, dbName, loggedInUser, query string) (rowsChanged int, err error)

+ func SQLiteGetTablesLive(baseDir, dbOwner, dbName string) (tables []string, err error)

+ func SQLiteGetViewsLive(baseDir, dbOwner, dbName string) (views []string, err error)

+ func SQLiteSanityCheck(fileName string) (tables []string, err error)

+ func SanitiseLogString(v string) (result string)

+ func SignalHandler(done *chan struct{})

+ func StoreShares(dbOwner, dbName string, shares map[string]ShareDatabasePermissions) (err error)

+ func SwitchDefault(w http.ResponseWriter, r *http.Request)

+ func SwitchFirst(w http.ResponseWriter, r *http.Request)

+ func SwitchSecond(w http.ResponseWriter, r *http.Request)

+ func SwitchThird(w http.ResponseWriter, r *http.Request)

+ func TestLogout(w http.ResponseWriter, r *http.Request)

+ func UpdateModified(dbOwner, dbName string) (err error)

+ func ValidateVisualisationName(name string) error

+ func VisualisationRename(dbOwner, dbName, visName, visNewName string) (err error)

+ func WaitForResponse[T any](jobID int, resp *T) (err error)

+ func WriteDBtoDisk(loggedInUser, dbOwner, dbName string, newDB io.Reader) (numBytes int64, tempDB *os.File, sha string, sTbls []string, err error)

type APIJSONIndex

+ func LiveIndexes(liveNode, loggedInUser, dbOwner, dbName string) (indexes []APIJSONIndex, err error)

+ func SQLiteGetIndexesLive(baseDir, dbOwner, dbName string) (indexes []APIJSONIndex, err error)

type APIKey

+ Comment string

+ ExpiryDate *time.Time

+ Uuid string

+ func APIKeyGenerate(loggedInUser string, expiryDate *time.Time, comment string) (key APIKey, err error)

type CommitData

+ Parent string

type DBInfo

+ ForkDatabase string

+ ForkDeleted bool

+ ForkOwner string

+ IsLive bool

+ LiveNode string

+ MyStar bool

+ MyWatch bool

+ Owner string

+ func LiveUserDBs(dbOwner string, public AccessType) (list []DBInfo, err error)

type DataDiff

+ DataAfter []interface{}

+ DataBefore []interface{}

+ type DatabaseName struct

+ Database string

+ Owner string

type Diffs

+ func DBDiff(dbA string, dbB string, merge MergeStrategy, includeData bool) (Diffs, error)

type EventProcessingInfo

+ Smtp2GoKey string

+ type ExecuteResponseContainer struct

+ RowsChanged int

+ Status string

+ type FilteringErrorLogWriter struct

+ func (*FilteringErrorLogWriter) Write(msg []byte) (int, error)

+ type JobQueueErrorCode int

+ const JobQueueNoError

+ const JobQueueRequestedTableNotPresent

+ func SQLiteGetColumnsLive(baseDir, dbOwner, dbName, table string) (columns []sqlite.Column, pk []string, err error, errCode JobQueueErrorCode)

+ type JobRequest struct

+ DBName string

+ DBOwner string

+ Data interface{}

+ Operation string

+ RequestingUser string

+ type JobRequestRows struct

+ CommitID string

+ DbTable string

+ MaxRows int

+ RowOffset int

+ SortCol string

+ SortDir string

+ type JobResponseDBColumns struct

+ Columns []sqlite.Column

+ Err string

+ ErrCode JobQueueErrorCode

+ PkColumns []string

+ type JobResponseDBCreate struct

+ Err string

+ NodeName string

+ type JobResponseDBError struct

+ Err string

+ type JobResponseDBExecute struct

+ Err string

+ RowsChanged int

+ type JobResponseDBIndexes struct

+ Err string

+ Indexes []APIJSONIndex

+ type JobResponseDBQuery struct

+ Err string

+ Results SQLiteRecordSet

+ type JobResponseDBRows struct

+ DatabaseSize int64

+ DefaultTable string

+ Err string

+ RowData SQLiteRecordSet

+ Tables []string

+ type JobResponseDBSize struct

+ Err string

+ Size int64

+ type JobResponseDBTables struct

+ Err string

+ Tables []string

+ type JobResponseDBViews struct

+ Err string

+ Views []string

+ type LiveDBColumnsResponse struct

+ Columns []sqlite.Column

+ ErrCode JobQueueErrorCode

+ Error string

+ Node string

+ PkColumns []string

+ type LiveDBErrorResponse struct

+ Error string

+ Node string

+ type LiveDBExecuteResponse struct

+ Error string

+ Node string

+ RowsChanged int

+ type LiveDBIndexesResponse struct

+ Error string

+ Indexes []APIJSONIndex

+ Node string

+ type LiveDBQueryResponse struct

+ Error string

+ Node string

+ Results SQLiteRecordSet

+ type LiveDBRequest struct

+ DBName string

+ DBOwner string

+ Data interface{}

+ Operation string

+ RequestingUser string

+ type LiveDBResponse struct

+ Error string

+ Node string

+ Result string

+ type LiveDBRowsRequest struct

+ CommitID string

+ DbTable string

+ MaxRows int

+ RowOffset int

+ SortCol string

+ SortDir string

+ type LiveDBRowsResponse struct

+ DatabaseSize int64

+ DefaultTable string

+ Error string

+ Node string

+ RowData SQLiteRecordSet

+ Tables []string

+ type LiveDBSizeResponse struct

+ Error string

+ Node string

+ Size int64

+ type LiveDBTablesResponse struct

+ Error string

+ Node string

+ Tables []string

+ type LiveDBViewsResponse struct

+ Error string

+ Node string

+ Views []string

+ type LiveInfo struct

+ Nodename string

+ StorageDir string

+ type MQInfo struct

+ CertFile string

+ KeyFile string

+ Password string

+ Port int

+ Server string

+ Username string

type QuerySource

+ const QuerySourceAPI

+ const QuerySourceDB4S

+ const QuerySourceInternal

+ const QuerySourceVisualisation

+ type ResponseInfo struct

+ type ResponseReceivers struct

+ func NewResponseQueue() *ResponseReceivers

+ func (r *ResponseReceivers) AddReceiver(jobID int, newReceiver *chan ResponseInfo)

+ func (r *ResponseReceivers) RemoveReceiver(jobID int)

type SQLiteRecordSet

+ PrimaryKeyColumns []string

+ func LiveQuery(liveNode, loggedInUser, dbOwner, dbName, query string) (rows SQLiteRecordSet, err error)

+ func LiveRowData(liveNode, loggedInUser, dbOwner, dbName string, reqData JobRequestRows) (rowData SQLiteRecordSet, err error)

+ func SQLiteReadDatabasePage(...) (tables []string, defaultTable string, rowData SQLiteRecordSet, dbSize int64, ...)

+ func SQLiteRunQueryLive(baseDir, dbOwner, dbName, loggedInUser, query string) (records SQLiteRecordSet, err error)

type SchemaDiff

+ After string

+ Before string

+ type SetAccessType int

+ const KeepCurrentAccessType

+ const SetToPrivate

+ const SetToPublic

+ type SetDBType int

+ const DBTypeLive

+ const DBTypeStandard

+ type ShareDatabasePermissions string

+ const MayRead

+ const MayReadAndWrite

+ type ShareDatabasePermissionsOthers struct

+ DBName string

+ IsLive bool

+ Perms map[string]ShareDatabasePermissions

+ type ShareDatabasePermissionsUser struct

+ DBName string

+ IsLive bool

+ OwnerName string

+ Permission ShareDatabasePermissions

+ func GetSharesForUser(userName string) (shares []ShareDatabasePermissionsUser, err error)

+ type SqlHistoryItem struct

+ Result interface{}

+ State SqlHistoryItemStates

+ Statement string

+ func LiveSqlHistoryGet(loggedInUser, dbOwner, dbName string) (history []SqlHistoryItem, err error)

+ type SqlHistoryItemStates string

+ const Error

+ const Executed

+ const Queried

type TomlConfig

+ Live LiveInfo

+ MQ MQInfo

+ UserMgmt UserMgmtInfo

type UserDetails

+ MinioBucket string

+ type UserMgmtInfo struct

+ BannedUsers []string

+ SizeOverrideUsers []string

v0.0.14

Aug 13, 2020

Changes in this version

+ type StatusResponseContainer struct

+ Status string

v0.0.13

Aug 12, 2020

Changes in this version

+ func UploadResponse(w http.ResponseWriter, r *http.Request, ...) (retMsg map[string]string, httpStatus int, err error)

+ type UploadResponseContainer struct

+ CommitID string

+ URL string

v0.0.12

Aug 8, 2020

Changes in this version

+ type WebpageResponseContainer struct

+ WebPage string

v0.0.11

Aug 6, 2020

Changes in this version

+ type APIJSONIndex struct

+ Columns []APIJSONIndexColumn

+ Name string

+ Table string

+ type APIJSONIndexColumn struct

+ CID int

+ Name string

v0.0.10

Aug 5, 2020

v0.0.9

Aug 4, 2020

Changes in this version

+ func DownloadDatabase(w http.ResponseWriter, r *http.Request, ...) (bytesWritten int64, err error)

type BranchListResponseContainer

+ Branches map[string]BranchEntry

+ DefaultBranch string

v0.0.8

Aug 4, 2020

Changes in this version

+ type BranchListResponseContainer struct

+ Default string

+ Entries map[string]BranchEntry

+ func BranchListResponse(dbOwner, dbFolder, dbName string) (list BranchListResponseContainer, err error)

+ type MetadataResponseContainer struct

+ Branches map[string]BranchEntry

+ Commits map[string]CommitEntry

+ DefBranch string

+ Releases map[string]ReleaseEntry

+ Tags map[string]TagEntry

+ WebPage string

+ func MetadataResponse(dbOwner, dbFolder, dbName string) (meta MetadataResponseContainer, err error)

v0.0.7

Aug 2, 2020

Changes in this version

+ func EscapeIds(ids []string) (escaped []string)

+ func EscapeValues(vals []DataValue) (escaped []string)

+ func GetPrimaryKeyAndOtherColumns(sdb *sqlite.Conn, schema string, table string) (pks []string, implicitPk bool, other []string, err error)

type DiffType

+ const ActionAdd

+ const ActionDelete

+ const ActionModify

+ type MergeStrategy int

+ const NewPkMerge

+ const NoMerge

+ const PreservePkMerge

v0.0.6

Jul 31, 2020

Changes in this version

+ const ACTION_ADD

+ const ACTION_DELETE

+ const ACTION_MODIFY

+ var SQLiteFunctions = []function

+ func APIKeySave(key string, loggedInUser string, dateCreated time.Time) error

+ func AuthorizerSelect(d interface{}, action sqlite.Action, ...) sqlite.Auth

+ func CheckUnicode(rawInput string) (str string, err error)

+ func EscapeId(id string) string

+ func EscapeValue(val DataValue) string

+ func GetAPIKeyUser(key string) (user string, err error)

+ func GetFormODC(r *http.Request) (string, string, string, error)

+ func GetFormOwner(r *http.Request, allowGet bool) (string, error)

+ func GetFormTable(r *http.Request, allowGet bool) (string, error)

+ func GetPrimaryKeyColumns(sdb *sqlite.Conn, schema string, table string) (pks []string, err error)

+ func GetVisualisations(dbOwner, dbFolder, dbName string) (visNames []string, err error)

+ func LogDB4SConnect(userAcc string, ipAddr string, userAgent string, downloadDate time.Time) error

+ func LogSQLiteQueryAfter(insertID, memUsed, memHighWater int64) (err error)

+ func LogSQLiteQueryBefore(...) (int64, error)

+ func OpenSQLiteDatabase(bucket, id string) (*sqlite.Conn, error)

+ func OpenSQLiteDatabaseDefensive(w http.ResponseWriter, r *http.Request, ...) (sdb *sqlite.Conn, err error)

+ func RetrieveDatabaseFile(bucket string, id string) (newDB string, err error)

+ func SQLiteVersionNumber() int32

+ func TablesAndViews(sdb *sqlite.Conn, dbName string) (list []string, err error)

+ func Views(sdb *sqlite.Conn) (vw []string, err error)

+ func VisualisationDeleteParams(dbOwner string, dbFolder string, dbName string, visName string) (err error)

+ func VisualisationSaveData(dbOwner string, dbFolder string, dbName string, commitID string, hash string, ...) (err error)

+ func VisualisationSaveParams(dbOwner string, dbFolder string, dbName string, visName string, ...) (err error)

+ type APIJSONColumn struct

+ Autoinc bool

+ Cid int

+ CollSeq string

+ DataType string

+ DfltValue string

+ Name string

+ NotNull bool

+ Pk int

+ type APIKey struct

+ DateCreated time.Time

+ Key string

+ func GetAPIKeys(user string) ([]APIKey, error)

+ type ApiInfo struct

+ BaseDir string

+ BindAddress string

+ Certificate string

+ CertificateKey string

+ RequestLog string

+ ServerName string

type DB4SInfo

+ Debug bool

+ type DataDiff struct

+ ActionType DiffType

+ Pk []DataValue

+ Sql string

+ type DiffObjectChangeset struct

+ Data []DataDiff

+ ObjectName string

+ ObjectType string

+ Schema SchemaDiff

+ type DiffType string

+ type Diffs struct

+ Diff []DiffObjectChangeset

+ func Diff(ownerA string, folderA string, nameA string, commitA string, ownerB string, ...) (Diffs, error)

type EnvInfo

+ UserOverride string

+ type JsonError struct

+ Error string

+ type QuerySource int

+ const API

+ const DB4S

+ const Internal

+ const Visualisation

+ const WebUI

type SQLiteRecordSet

+ func SQLiteRunQuery(sdb *sqlite.Conn, querySource QuerySource, dbQuery string, ...) (memUsed, memHighWater int64, dataRows SQLiteRecordSet, err error)

+ func SQLiteRunQueryDefensive(w http.ResponseWriter, r *http.Request, querySource QuerySource, ...) (SQLiteRecordSet, error)

+ type SchemaDiff struct

+ ActionType DiffType

+ Sql string

type SigningInfo

+ Enabled bool

type TomlConfig

+ Api ApiInfo

+ type UserInfoSlice []UserInfo

+ func (u UserInfoSlice) Len() int

+ func (u UserInfoSlice) Less(i, j int) bool

+ func (u UserInfoSlice) Swap(i, j int)

+ type VisGetFields struct

+ VisName string

+ type VisParamsV2 struct

+ ChartType string

+ SQL string

+ ShowXLabel bool

+ ShowYLabel bool

+ XAXisColumn string

+ YAXisColumn string

+ func GetVisualisationParams(dbOwner string, dbFolder string, dbName string, visName string) (params VisParamsV2, ok bool, err error)

+ type VisRowV1 struct

+ Name string

+ Value int

+ func GetVisualisationData(dbOwner string, dbFolder string, dbName string, commitID string, hash string) (data []VisRowV1, ok bool, err error)

v0.0.5

Aug 18, 2019

Changes in this version

+ const MaxLicenceSize

+ func CheckLicenceExists(userName string, licenceName string) (exists bool, err error)

+ func DeleteLicence(userName string, licenceName string) (err error)

+ func ValidateCommitID(fieldName string) error

+ func ValidateDisplayName(dbName string) error

+ func ValidateLicenceFullName(licence string) error

type DBInfo

+ Downloads int

+ RepoModified time.Time

+ Views int

+ type LicenceInfo struct

+ LicenceDir string

+ type RedashColumnMeta struct

+ FriendlyName string

+ Name string

+ Type string

+ type RedashTableData struct

+ Columns []RedashColumnMeta

+ Rows []map[string]interface{}

+ func ReadSQLiteDBRedash(sdb *sqlite.Conn, dbTable string) (dash RedashTableData, err error)

type TomlConfig

+ Licence LicenceInfo

v0.0.4

Jan 17, 2019

v0.0.3

Jan 16, 2019

Changes in this version

+ const ALL_TIME

+ const CLOSE

+ const CLOSED_WITHOUT_MERGE

+ const CLOSED_WITH_MERGE

+ const DATABASE

+ const DefaultNumDisplayRows

+ const EVENT_NEW_COMMENT

+ const EVENT_NEW_DISCUSSION

+ const EVENT_NEW_MERGE_REQUEST

+ const EVENT_NEW_RELEASE

+ const LICENCE

+ const MaxDatabaseSize

+ const MinioFolderChars

+ const OPEN

+ const REOPEN

+ const TEXT

+ const THIS_MONTH

+ const THIS_WEEK

+ const TODAY

+ const TREE

+ var Validate *valid.Validate

+ func AddDatabase(r *http.Request, loggedInUser string, dbOwner string, dbFolder string, ...) (numBytes int64, newCommitID string, err error)

+ func AddDefaultLicences() (err error)

+ func AddDefaultUser() error

+ func AddUser(auth0ID string, userName string, password string, email string, ...) error

+ func CacheData(cacheKey string, cacheData interface{}, cacheSeconds int) error

+ func CheckDBExists(loggedInUser string, dbOwner string, dbFolder string, dbName string) (bool, error)

+ func CheckDBID(loggedInUser string, dbOwner string, dbID int64) (avail bool, dbFolder string, dbName string, err error)

+ func CheckDBStarred(loggedInUser string, dbOwner string, dbFolder string, dbName string) (bool, error)

+ func CheckDBWatched(loggedInUser string, dbOwner string, dbFolder string, dbName string) (bool, error)

+ func CheckEmailExists(email string) (bool, error)

+ func CheckUserExists(userName string) (bool, error)

+ func ClientCert(userName string) ([]byte, error)

+ func CommitLicenceSHA(dbOwner string, dbFolder string, dbName string, commitID string) (licenceSHA string, err error)

+ func ConnectCache() error

+ func ConnectMinio() (err error)

+ func ConnectPostgreSQL() (err error)

+ func CreateCommitID(c CommitEntry) string

+ func CreateDBTreeID(entries []DBTreeEntry) string

+ func DB4SDefaultList(loggedInUser string) (map[string]UserInfo, error)

+ func DBDetails(DB *SQLiteDBinfo, loggedInUser string, dbOwner string, dbFolder string, ...) error

+ func DBStars(dbOwner string, dbFolder string, dbName string) (starCount int, err error)

+ func DBWatchers(dbOwner string, dbFolder string, dbName string) (watcherCount int, err error)

+ func DefaultCommit(dbOwner string, dbFolder string, dbName string) (string, error)

+ func DeleteBranchHistory(dbOwner string, dbFolder string, dbName string, branchName string, ...) (isolatedTags []string, isolatedRels []string, err error)

+ func DeleteComment(dbOwner string, dbFolder string, dbName string, discID int, comID int) error

+ func DeleteDatabase(dbOwner string, dbFolder string, dbName string) error

+ func DisconnectPostgreSQL()

+ func FlushViewCount()

+ func ForkDatabase(srcOwner string, dbFolder string, dbName string, dstOwner string) (newForkCount int, err error)

+ func ForkParent(loggedInUser string, dbOwner string, dbFolder string, dbName string) (parentOwner string, parentFolder string, parentDBName string, err error)

+ func ForkedFrom(dbOwner string, dbFolder string, dbName string) (forkOwn string, forkFol string, forkDB string, forkDel bool, err error)

+ func GenerateClientCert(userName string) (_ []byte, err error)

+ func GetBranches(dbOwner string, dbFolder string, dbName string) (branches map[string]BranchEntry, err error)

+ func GetCachedData(cacheKey string, cacheData interface{}) (bool, error)

+ func GetCommitList(dbOwner string, dbFolder string, dbName string) (map[string]CommitEntry, error)

+ func GetCurrentFunctionName() (FuncName string)

+ func GetDatabase(r *http.Request, allowGet bool) (string, error)

+ func GetDefaultBranchName(dbOwner string, dbFolder string, dbName string) (branchName string, err error)

+ func GetDefaultTableName(dbOwner string, dbFolder string, dbName string) (tableName string, err error)

+ func GetDiscussionAndMRCount(dbOwner string, dbFolder string, dbName string) (discCount int, mrCount int, err error)

+ func GetFolder(r *http.Request, allowGet bool) (string, error)

+ func GetFormBranch(r *http.Request) (string, error)

+ func GetFormCommit(r *http.Request) (string, error)

+ func GetFormLicence(r *http.Request) (licenceName string, err error)

+ func GetFormRelease(r *http.Request) (release string, err error)

+ func GetFormSourceURL(r *http.Request) (sourceURL string, err error)

+ func GetFormTag(r *http.Request) (tag string, err error)

+ func GetFormUDC(r *http.Request) (string, string, string, error)

+ func GetLicence(userName string, licenceName string) (txt string, format string, err error)

+ func GetLicenceInfoFromSha256(userName string, sha256 string) (lName string, lURL string, err error)

+ func GetLicenceSha256FromName(userName string, licenceName string) (sha256 string, err error)

+ func GetLicences(user string) (map[string]LicenceEntry, error)

+ func GetOD(ignore_leading int, r *http.Request) (string, string, error)

+ func GetODC(ignore_leading int, r *http.Request) (string, string, string, error)

+ func GetODT(ignore_leading int, r *http.Request) (string, string, string, error)

+ func GetODTC(ignore_leading int, r *http.Request) (string, string, string, string, error)

+ func GetPub(r *http.Request) (bool, error)

+ func GetReleases(dbOwner string, dbFolder string, dbName string) (releases map[string]ReleaseEntry, err error)

+ func GetSQLiteRowCount(sdb *sqlite.Conn, dbTable string) (int, error)

+ func GetTable(r *http.Request) (string, error)

+ func GetTags(dbOwner string, dbFolder string, dbName string) (tags map[string]TagEntry, err error)

+ func GetUFD(r *http.Request, allowGet bool) (string, string, string, error)

+ func GetUsername(r *http.Request, allowGet bool) (string, error)

+ func GetUsernameFromEmail(email string) (userName string, avatarURL string, err error)

+ func GetViewCount(dbOwner string, dbFolder string, dbName string) (count int, err error)

+ func IncrementDownloadCount(dbOwner string, dbFolder string, dbName string) error

+ func IncrementViewCount(dbOwner string, dbFolder string, dbName string) error

+ func InvalidateCacheEntry(loggedInUser string, dbOwner string, dbFolder string, dbName string, ...) error

+ func IsCommitInBranchHistory(dbOwner string, dbFolder string, dbName string, branchName string, ...) (bool, error)

+ func LogDownload(dbOwner string, dbFolder string, dbName string, loggedInUser string, ...) error

+ func LogUpload(dbOwner string, dbFolder string, dbName string, loggedInUser string, ...) error

+ func MemcacheHandle() *memcache.Client

+ func MetadataCacheKey(prefix string, loggedInUser string, dbOwner string, dbFolder string, ...) string

+ func MinioHandle(bucket string, id string) (*minio.Object, error)

+ func MinioHandleClose(userDB *minio.Object) (err error)

+ func MinioLocation(dbOwner string, dbFolder string, dbName string, commitID string, ...) (minioBucket string, minioID string, lastModified time.Time, err error)

+ func NewEvent(details EventDetails) (err error)

+ func OpenMinioObject(bucket string, id string) (*sqlite.Conn, error)

+ func PrefUserMaxRows(loggedInUser string) int

+ func RandomString(length int) string

+ func ReadConfig() error

+ func ReadSQLiteDBCSV(sdb *sqlite.Conn, dbTable string) ([][]string, error)

+ func RenameDatabase(userName string, dbFolder string, dbName string, newName string) error

+ func ReservedUsernamesCheck(userName string) error

+ func SanityCheck(fileName string) (tables []string, err error)

+ func SaveDBSettings(userName string, dbFolder string, dbName string, oneLineDesc string, ...) error

+ func SendEmails()

+ func SetClientCert(newCert []byte, userName string) error

+ func SetUserPreferences(userName string, maxRows int, displayName string, email string) error

+ func SetUserStatusUpdates(userName string, numUpdates int) error

+ func SocialStats(dbOwner string, dbFolder string, dbName string) (wa int, st int, fo int, err error)

+ func StatusUpdateCheck(dbOwner string, dbFolder string, dbName string, thisID int, userName string) (numStatusUpdates int, err error)

+ func StatusUpdates(loggedInUser string) (statusUpdates map[string][]StatusUpdateEntry, err error)

+ func StatusUpdatesLoop()

+ func StoreBranches(dbOwner string, dbFolder string, dbName string, ...) error

+ func StoreComment(dbOwner string, dbFolder string, dbName string, commenter string, discID int, ...) error

+ func StoreCommits(dbOwner string, dbFolder string, dbName string, ...) error

+ func StoreDatabase(dbOwner string, dbFolder string, dbName string, ...) error

+ func StoreDatabaseFile(db *os.File, sha string, dbSize int64) error

+ func StoreDefaultBranchName(dbOwner string, folder string, dbName string, branchName string) error

+ func StoreDefaultTableName(dbOwner string, folder string, dbName string, tableName string) error

+ func StoreDiscussion(dbOwner string, dbFolder string, dbName string, loggedInUser string, ...) (newID int, err error)

+ func StoreLicence(userName string, licenceName string, txt []byte, url string, orderNum int, ...) error

+ func StoreReleases(dbOwner string, dbFolder string, dbName string, ...) error

+ func StoreStatusUpdates(userName string, statusUpdates map[string][]StatusUpdateEntry) error

+ func StoreTags(dbOwner string, dbFolder string, dbName string, tags map[string]TagEntry) error

+ func TableRowsCacheKey(prefix string, loggedInUser string, dbOwner string, dbFolder string, ...) string

+ func Tables(sdb *sqlite.Conn, dbName string) ([]string, error)

+ func ToggleDBStar(loggedInUser string, dbOwner string, dbFolder string, dbName string) error

+ func ToggleDBWatch(loggedInUser string, dbOwner string, dbFolder string, dbName string) error

+ func UpdateAvatarURL(userName string, avatarURL string) error

+ func UpdateComment(dbOwner string, dbFolder string, dbName string, loggedInUser string, ...) error

+ func UpdateContributorsCount(dbOwner string, dbFolder, dbName string) error

+ func UpdateDiscussion(dbOwner string, dbFolder string, dbName string, loggedInUser string, ...) error

+ func UpdateMergeRequestCommits(dbOwner string, dbFolder string, dbName string, discID int, ...) (err error)

+ func UserNameFromAuth0ID(auth0id string) (string, error)

+ func UserStatusUpdates(userName string) (numUpdates int, err error)

+ func ValidateBranchName(fieldName string) error

+ func ValidateDB(dbName string) error

+ func ValidateDiscussionTitle(fieldName string) error

+ func ValidateEmail(email string) error

+ func ValidateFieldName(fieldName string) error

+ func ValidateFolder(folder string) error

+ func ValidateLicence(licence string) error

+ func ValidateMarkdown(fieldName string) error

+ func ValidatePGTable(table string) error

+ func ValidateUser(user string) error

+ func ValidateUserDB(user string, db string) error

+ func ValidateUserDBTable(user string, db string, table string) error

+ func ValidateUserEmail(user string, email string) error

+ func ViewCount(dbOwner string, dbFolder string, dbName string) (viewCount int, err error)

+ type AccessType int

+ const DB_BOTH

+ const DB_PRIVATE

+ const DB_PUBLIC

+ type ActivityRange string

+ type ActivityRow struct

+ Count int

+ DBName string

+ Owner string

+ type ActivityStats struct

+ Downloads []ActivityRow

+ Forked []ActivityRow

+ Starred []ActivityRow

+ Uploads []UploadRow

+ Viewed []ActivityRow

+ func GetActivityStats() (stats ActivityStats, err error)

+ type AdminInfo struct

+ Certificate string

+ CertificateKey string

+ HTTPS bool

+ Server string

+ type Auth0Info struct

+ ClientID string

+ ClientSecret string

+ Domain string

+ type Auth0Set struct

+ CallbackURL string

+ ClientID string

+ Domain string

+ type BranchEntry struct

+ Commit string

+ CommitCount int

+ Description string

+ type CommitData struct

+ AuthorAvatar string

+ AuthorEmail string

+ AuthorName string

+ AuthorUsername string

+ ID string

+ LicenceChange string

+ Message string

+ Timestamp time.Time

+ type CommitEntry struct

+ AuthorEmail string

+ AuthorName string

+ CommitterEmail string

+ CommitterName string

+ ID string

+ Message string

+ OtherParents []string

+ Parent string

+ Timestamp time.Time

+ Tree DBTree

+ func GetCommonAncestorCommits(srcOwner string, srcFolder string, srcDBName string, srcBranch string, ...) (ancestorID string, commitList []CommitEntry, err error, errType int)

+ type DB4SInfo struct

+ CAChain string

+ Certificate string

+ CertificateKey string

+ Port int

+ Server string

+ type DBEntry struct

+ DBName string

+ DateEntry time.Time

+ Folder string

+ Owner string

+ OwnerDisplayName string

+ func UserStarredDBs(userName string) (list []DBEntry, err error)

+ func UserWatchingDBs(userName string) (list []DBEntry, err error)

+ func UsersStarredDB(dbOwner string, dbFolder string, dbName string) (list []DBEntry, err error)

+ func UsersWatchingDB(dbOwner string, dbFolder string, dbName string) (list []DBEntry, err error)

+ type DBInfo struct

+ Branch string

+ BranchList []string

+ Branches int

+ CommitID string

+ Commits int

+ Contributors int

+ DBEntry DBTreeEntry

+ Database string

+ DateCreated time.Time

+ DefaultBranch string

+ DefaultTable string

+ Discussions int

+ Folder string

+ Forks int

+ FullDesc string

+ LastModified time.Time

+ Licence string

+ LicenceURL string

+ MRs int

+ OneLineDesc string

+ Public bool

+ Releases int

+ SHA256 string

+ Size int

+ SourceURL string

+ Stars int

+ Tables []string

+ Tags int

+ Watchers int

+ func UserDBs(userName string, public AccessType) (list []DBInfo, err error)

+ type DBTree struct

+ Entries []DBTreeEntry

+ ID string

+ type DBTreeEntry struct

+ EntryType DBTreeEntryType

+ LastModified time.Time

+ LicenceSHA string

+ Name string

+ Sha256 string

+ Size int

+ type DBTreeEntryType string

+ type DataRow []DataValue

+ type DataValue struct

+ Name string

+ Type ValType

+ Value interface{}

+ type DiscussionCommentEntry struct

+ AvatarURL string

+ Body string

+ BodyRendered string

+ Commenter string

+ DateCreated time.Time

+ EntryType DiscussionCommentType

+ ID int

+ func DiscussionComments(dbOwner string, dbFolder string, dbName string, discID int, comID int) (list []DiscussionCommentEntry, err error)

+ type DiscussionCommentType string

+ type DiscussionEntry struct

+ AvatarURL string

+ Body string

+ BodyRendered string

+ CommentCount int

+ Creator string

+ DateCreated time.Time

+ ID int

+ LastModified time.Time

+ MRDetails MergeRequestEntry

+ Open bool

+ Title string

+ Type DiscussionType

+ func Discussions(dbOwner string, dbFolder string, dbName string, discType DiscussionType, ...) (list []DiscussionEntry, err error)

+ type DiscussionType int

+ const DISCUSSION

+ const MERGE_REQUEST

+ type DiskCacheInfo struct

+ Directory string

+ type EnvInfo struct

+ Environment string

+ type EventDetails struct

+ DBName string

+ DiscID int

+ Folder string

+ ID string

+ Message string

+ Owner string

+ Timestamp time.Time

+ Title string

+ Type EventType

+ URL string

+ UserName string

+ type EventProcessingInfo struct

+ Delay time.Duration

+ EmailQueueDir string

+ EmailQueueProcessingDelay time.Duration

+ type EventType int

+ type ForkEntry struct

+ DBName string

+ Deleted bool

+ Folder string

+ ForkedFrom int

+ ID int

+ IconList []ForkType

+ Owner string

+ Processed bool

+ Public bool

+ func ForkTree(loggedInUser string, dbOwner string, dbFolder string, dbName string) (outputList []ForkEntry, err error)

+ type ForkType int

+ const BRANCH

+ const END

+ const ROOT

+ const SPACE

+ const STEM

+ type LicenceEntry struct

+ FileFormat string

+ FullName string

+ Order int

+ Sha256 string

+ URL string

+ type LicenseInfo struct

+ LicenseDir string

+ type MemcacheInfo struct

+ DefaultCacheTime int

+ Server string

+ ViewCountFlushDelay time.Duration

+ type MergeRequestEntry struct

+ Commits []CommitEntry

+ DestBranch string

+ SourceBranch string

+ SourceDBID int64

+ SourceDBName string

+ SourceFolder string

+ SourceOwner string

+ State MergeRequestState

+ type MergeRequestState int

+ type MetaInfo struct

+ AvatarURL string

+ Database string

+ ForkDatabase string

+ ForkDeleted bool

+ ForkFolder string

+ ForkOwner string

+ LoggedInUser string

+ NumStatusUpdates int

+ Owner string

+ Protocol string

+ Server string

+ Title string

+ type MinioInfo struct

+ AccessKey string

+ HTTPS bool

+ Secret string

+ Server string

+ type PGInfo struct

+ Database string

+ NumConnections int

+ Password string

+ Port int

+ SSL bool

+ Server string

+ Username string

+ type ReleaseEntry struct

+ Commit string

+ Date time.Time

+ Description string

+ ReleaserEmail string

+ ReleaserName string

+ Size int

+ type SQLiteDBinfo struct

+ Info DBInfo

+ MaxRows int

+ MinioBkt string

+ MinioId string

+ type SQLiteRecordSet struct

+ ColCount int

+ ColNames []string

+ Offset int

+ Records []DataRow

+ RowCount int

+ SortCol string

+ SortDir string

+ Tablename string

+ TotalRows int

+ func ReadSQLiteDB(sdb *sqlite.Conn, dbTable string, maxRows int, sortCol string, sortDir string, ...) (SQLiteRecordSet, error)

+ func ReadSQLiteDBCols(sdb *sqlite.Conn, dbTable string, ignoreBinary bool, ignoreNull bool, ...) (SQLiteRecordSet, error)

+ type SigningInfo struct

+ CertDaysValid int

+ IntermediateCert string

+ IntermediateKey string

+ type StatusUpdateEntry struct

+ DiscID int

+ Title string

+ URL string

+ type TagEntry struct

+ Commit string

+ Date time.Time

+ Description string

+ TaggerEmail string

+ TaggerName string

+ type TomlConfig struct

+ Admin AdminInfo

+ Auth0 Auth0Info

+ DB4S DB4SInfo

+ DiskCache DiskCacheInfo

+ Environment EnvInfo

+ Event EventProcessingInfo

+ License LicenseInfo

+ Memcache MemcacheInfo

+ Minio MinioInfo

+ Pg PGInfo

+ Sign SigningInfo

+ Web WebInfo

+ var Conf TomlConfig

+ type UploadRow struct

+ DBName string

+ Owner string

+ UploadDate time.Time

+ type UserDetails struct

+ AvatarURL string

+ ClientCert []byte

+ DateJoined time.Time

+ DisplayName string

+ Email string

+ PHash []byte

+ PVerify string

+ Password string

+ Username string

+ func User(userName string) (user UserDetails, err error)

+ type UserInfo struct

+ FullName string

+ LastModified time.Time

+ Username string

+ type ValType int

+ const Binary

+ const Float

+ const Image

+ const Integer

+ const Null

+ const Text

+ type WebInfo struct

+ BaseDir string

+ BindAddress string

+ Certificate string

+ CertificateKey string

+ RequestLog string

+ ServerName string

+ SessionStorePassword string

+ type WhereClause struct

+ Column string

+ Type string

+ Value string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL