vostok

package module

Go to main page

Versions in this module

v5

v5.9.5

Apr 21, 2023

v5.9.4

Mar 23, 2023

v5.9.3

Feb 10, 2023

v5.9.2

Feb 9, 2023

v5.9.1

Jan 10, 2023

v5.9.0

Jan 9, 2023

v5.8.6

Nov 23, 2022

v5.8.5

Nov 23, 2022

v5.8.4

Nov 7, 2022

v5.8.3

Oct 26, 2022

v5.8.2

Oct 21, 2022

Changes in this version

type Appserv

+ func (sAppserv *Appserv) TempLogKeep()

+ func (sAppserv *Appserv) TempLogStart(frameSkip int) *TimedTempLog

type AppservChild

+ func (sAppservChild *AppservChild) TempLogKeep()

+ func (sAppservChild *AppservChild) TempLogStart(frameSkip int) *TimedTempLog

type JobWorker

+ func (thisWorker *JobWorker) TempLogKeep()

+ func (thisWorker *JobWorker) TempLogStart(frameSkip int) *TimedTempLog

type LoggingScope

+ TempLogKeep func()

+ TempLogStart func(frameSkip int) *TimedTempLog

+ type TimedTempLog struct

+ func (thislog *TimedTempLog) StopAtExit()

v5.8.1

Oct 13, 2022

v5.8.0

Oct 13, 2022

Changes in this version

type Appserv

+ func (sAppserv *Appserv) IsTempLogging() bool

+ func (sAppserv *Appserv) StartTraceHere(frameSkip int) *FuncTempLogCtx

+ func (sAppserv *Appserv) TempLog(frameSkip int, message string, params ...interface{})

type AppservChild

+ func (sAppservChild *AppservChild) EndTempLogging(removelog bool)

+ func (sAppservChild *AppservChild) IsTempLogging() bool

+ func (sAppservChild *AppservChild) StartTraceHere(frameSkip int) *FuncTempLogCtx

+ func (sAppservChild *AppservChild) TempLog(frameSkip int, message string, params ...interface{})

+ type FuncTempLogCtx struct

+ func (thislog *FuncTempLogCtx) AndStopAtExit()

type JobWorker

+ func (thisWorker *JobWorker) IsTempLogging() bool

+ func (thisWorker *JobWorker) StartTraceHere(frameSkip int) *FuncTempLogCtx

+ func (thisWorker *JobWorker) TempLog(frameSkip int, message string, params ...interface{})

type LoggingScope

+ IsTempLogging func() bool

+ StartTraceHere func(frameSkip int) *FuncTempLogCtx

+ TempLog func(frameSkip int, message string, params ...interface{})

v5.7.2

Oct 11, 2022

v5.7.1

Oct 6, 2022

v5.7.0

Oct 6, 2022

v5.6.5

Oct 5, 2022

v5.6.4

Aug 5, 2022

v5.6.3

Jul 13, 2022

Changes in this version

type Appserv

+ func (sAppserv *Appserv) GetSecondaryIDB(pDbID string, pCheck bool) (IDB, error)

type AppservChild

+ func (sAppservChild *AppservChild) GetSecondaryIDB(pDbID string, pCheck bool) (IDB, error)

type IAppservSibling

+ GetSecondaryIDB func(pDbID string, pCheck bool) (IDB, error)

type JobWorker

+ func (thisWorker *JobWorker) GetSecondaryIDB(pDbID string, pCheck bool) (IDB, error)

v5.6.2

May 17, 2022

v5.6.1

May 16, 2022

v5.6.0

May 16, 2022

v5.5.2

Apr 28, 2022

v5.5.1

Mar 23, 2022

v5.4.2

Mar 16, 2022

v5.4.1

Mar 15, 2022

Changes in this version

type Appserv

+ func (sAppserv *Appserv) InitProfilingTools(restrictAccess bool)

v5.3.8

Mar 8, 2022

v5.3.7

Mar 4, 2022

Changes in this version

type AppservChild

+ func (sAppservChild *AppservChild) IsCustomAccessAuthorized() (bool, error)

v5.3.6

Mar 3, 2022

Changes in this version

+ const RootPathCUSTOMAUTH

+ var URICutCUSTOMAUTH int

type Appserv

+ func (sAppserv *Appserv) SetAuthCustomService(authCustomService IAuthCustomService)

type AppservChild

+ func (sAppservChild *AppservChild) IsAccessAuthorized() (bool, error)

+ func (sAppservChild *AppservChild) IsCustomAuthUsed() bool

+ type CustomAuthAction string

+ const CustomAuthLOGIN

+ type CustomAuthLoginResponse struct

+ AccessToken string

+ Expires string

+ TokenType string

+ type IAuthCustomService interface

+ CheckAuth func(appservChild *AppservChild, request *http.Request) (userInfo *UserInfo, targeted bool, statusCode int, reponseBody interface{})

+ IsAccessAuthorized func(appServChild *AppservChild) (isAuthorized bool, err error)

+ Login func(appservChild *AppservChild, request *http.Request) (string, string, error)

v5.3.5

Feb 27, 2022

v5.3.4

Feb 27, 2022

v5.3.3

Nov 18, 2021

v5.3.2

Nov 16, 2021

v5.3.1

Nov 11, 2021

v5.2.2

Oct 28, 2021

Changes in this version

+ func DefineBatchFunction(funcName BatchFuncName, function BatchFunction, ...) (batchFnDef *batchFunctionDefinition)

type BatchCompartment

+ func (thisCompartment *BatchCompartment) GetBatchJobID() BatchJobID

+ type BatchCompartmentConfigCheckingFn func(compConf IBatchCompartmentConfig) error

+ type BatchJobID string

type Batcher

+ func (thisBatcher *Batcher) GetCompartmentsForJob(batchJobUID BatchJobID) map[BatchCompartmentID]*BatchCompartment

+ func (thisBatcher *Batcher) StartBatchJob(batchJobID BatchJobID, execContext IBatchFunctionContext)

type IBatchCompartmentConfig

+ GetBatchJobID func() BatchJobID

v5.2.1

Oct 21, 2021

v5.1.5

Oct 10, 2021

v5.1.4

Jun 24, 2021

v5.1.3

Jun 23, 2021

v5.1.2

Jun 23, 2021

v5.1.1

Jun 23, 2021

v5.0.1

Jun 23, 2021

v5.0.0

Jun 23, 2021

Changes in this version

+ const CountersTableName

+ const CountersTableNameConstraint

+ const DBDefaultIDValue

+ const DateFormatMICROSEC

+ const DateFormatSECONDS

+ const DateFormatYYYYsMMsDD

+ const DbMgrMYSQL

+ const DbMgrPOSTGRES

+ const GlobalCacheDurationDEFAULT

+ const GlobalCacheDurationFOREVER

+ const GlobalCacheDurationNEVER

+ const LocalCacheDEFEXPIRATION

+ const LocalCacheNOEXPIRATION

+ const RootPathOAUTH

+ const RootPathREST

+ const RootPathSESSIONAUTH

+ const RootPathSTATELESSAUTH

+ const SQLLibSQLX

+ var URICutOAUTH int

+ var URICutREST int

+ var URICutSESSIONAUTH int

+ var URICutSTATELESSAUTH int

+ func Abs(num int) int

+ func BatchFunctionSet(name BatchFuncName, function BatchFunction, checkFn batchFunctionConfigCheckFn)

+ func BuildConfigWith(pConfigFilePath string, pConfigFileObject IConfigFile) (*ServerConfig, ICustomConfig, error)

+ func CamelToShort(camelCasedString string) string

+ func CamelToSnake(camelCasedString string) string

+ func CheckAndAcquireTimestamp(pString string) (string, error)

+ func Count(db IDB, table string, wherePart string, whereValues ...interface{}) (int, error)

+ func DateStringToTime(dateString string, format string) (*time.Time, error)

+ func DayToTime(simpleDayString string) *time.Time

+ func FindCountryA2CodeStr(codeOrTranslation string) string

+ func Float64FromNullFloat64(pNf64 *sql.NullFloat64) float64

+ func GenerateRandomString(source rand.Source, n int) string

+ func GetAppToken(tokenRespObj ITokenResponse, appName string, tokenURL string, user string, ...) (string, error)

+ func GetFileContent(pFile *os.File) (string, error)

+ func GetIP(r *http.Request) string

+ func GetJSONExample() string

+ func GetPwdHashingFunc() func(pwd []byte, salt []byte) ([]byte, error)

+ func GetPwdMatchingFunc() func(hashedPwd []byte, pwd []byte, salt []byte) error

+ func GetScopeSignature(scope LoggingScope) string

+ func GetUserAgent(r *http.Request) string

+ func IDFromNullID(pNID64 *sql.NullInt64) int64

+ func InitGlobalCacheFromConfig(globalCacheConfig *applicationGlobalCacheConfig)

+ func InitLocalCacheForTests(localDefaultExpiration time.Duration, localCleanupInterval time.Duration)

+ func InitLocalCacheFromConfig(localCacheConfig *applicationLocalCacheConfig)

+ func Int64FromNullInt64(pNi64 *sql.NullInt64) int64

+ func IntLen(num int) int

+ func LeftPad(s string, pad string, length int) string

+ func MaxDuration(a, b time.Duration) time.Duration

+ func MaxInt(a, b int) int

+ func MaxInt64(a, b int64) int64

+ func MinDuration(a, b time.Duration) time.Duration

+ func MinInt(a, b int) int

+ func MinInt64(a, b int64) int64

+ func NewRandSource() rand.Source

+ func NormalizeAndCapOnce(str string) (result string, err error)

+ func NormalizeStringOnce(str string) (result string, err error)

+ func Now() *time.Time

+ func PascalToCamel(pascalCasedString string) string

+ func PascalToSnake(pascalCasedString string) string

+ func PurgeAuthTokens(expiredSince time.Duration, doClean bool) (totalSize int, detected int, treated int, err error)

+ func RandBool(source rand.Source) bool

+ func RandDate(source rand.Source, withMicrosec bool) *time.Time

+ func RandDigit(source rand.Source) int64

+ func RandDuration(source rand.Source, maxduration string) time.Duration

+ func RandFloatString(source rand.Source, minlength int, maxlength int, maxdecimals int) string

+ func RandInt(source rand.Source, min int, max int) int

+ func RandIntByte(source rand.Source) byte

+ func RandIntString(source rand.Source, minlength int, maxlength int) string

+ func RandNum(source rand.Source, min int, max int) int64

+ func RandSampleInt(source rand.Source, fromIntValues []int) (sample []int)

+ func RandString(source rand.Source, minlength int, maxlength int) string

+ func RightPad(s string, pad string, length int) string

+ func Round(num float64) int64

+ func Round1f32(num float32) float32

+ func Round1f64(num float64) float64

+ func Round2f32(num float32) float32

+ func Round2f64(num float64) float64

+ func Round32(num float32) int64

+ func SaveAuthClient(authClient osin.Client) error

+ func SetNeededCountryCodes(alpha2Code ...string)

+ func SetPwdHashingFunc(daFunc func(pwd []byte, salt []byte) ([]byte, error))

+ func SetPwdMatchingFunc(daFunc func(hashedPwd []byte, pwd []byte, salt []byte) error)

+ func SnakeToShort(snakeCasedString string) string

+ func StringFromNullString(pNs *sql.NullString) string

+ func StringInSlice(str string, slice []string) bool

+ func TimeToSimpleString(time *time.Time) string

+ func ToDuration32(timeInFloat float32) time.Duration

+ func ToDuration64(timeInFloat float64) time.Duration

+ func ToDurationStr(str string) time.Duration

+ func ToMicrosec(nanoseconds time.Duration) int64

+ func ToMillisec(nanoseconds time.Duration) int64

+ func TrimIfLong(s string, maxlength int) string

+ type Amount float64

+ func (a Amount) MarshalJSON() ([]byte, error)

+ type AppMode int

+ const AppModeDEV

+ const AppModeLIVE

+ const AppModePRELIVE

+ const AppModeTEST

+ type Appserv struct

+ func NewAppserv(pRootPath string, pConfigFilePath string, instanceID int) (*Appserv, error)

+ func NewAppservWithConfig(pRootPath string, pConfigFilePath string, pConfigFileObject IConfigFile, ...) (*Appserv, error)

+ func (sAppserv *Appserv) AddActionHandler(pAction string, pNeedLogin bool, pCall AppservCall)

+ func (sAppserv *Appserv) AddLoggerHook(loggerHook logrus.Hook)

+ func (sAppserv *Appserv) Batcher() *Batcher

+ func (sAppserv *Appserv) BeginDbTransaction() (*sql.Tx, error)

+ func (sAppserv *Appserv) BindOriginalFunction(name string, jfunc interface{})

+ func (sAppserv *Appserv) Exec(pQuery string, pParams ...interface{}) (sql.Result, error)

+ func (sAppserv *Appserv) GetAppName() string

+ func (sAppserv *Appserv) GetAppPath() string

+ func (sAppserv *Appserv) GetAppURL() string

+ func (sAppserv *Appserv) GetBox() string

+ func (sAppserv *Appserv) GetCustomConfig() ICustomConfig

+ func (sAppserv *Appserv) GetDbName() string

+ func (sAppserv *Appserv) GetDescription() string

+ func (sAppserv *Appserv) GetLogger() *logrus.Logger

+ func (sAppserv *Appserv) GetMode() AppMode

+ func (sAppserv *Appserv) GetNotAuthenticatedCode() int

+ func (sAppserv *Appserv) GetOriginalJobConfig(jobID string, doPanicIfNotFound bool) *JobConfig

+ func (sAppserv *Appserv) GetParentScope() LoggingScope

+ func (sAppserv *Appserv) GetRoutinePoolCapacity() int

+ func (sAppserv *Appserv) GetRoutineStats() (currentUse, maxParaUse, totalUse int)

+ func (sAppserv *Appserv) GetScheduledFunction(name string) interface{}

+ func (sAppserv *Appserv) GetScopeID() string

+ func (sAppserv *Appserv) GetSecondaryDB(pDbID string, pCheck bool) (*sql.DB, error)

+ func (sAppserv *Appserv) GetSecondaryDBx(pDbID string, pCheck bool) (*sqlx.DB, error)

+ func (sAppserv *Appserv) GetSecondaryDbName(id string) string

+ func (sAppserv *Appserv) GetSeparator() string

+ func (sAppserv *Appserv) GetSignature() string

+ func (sAppserv *Appserv) GetSqlLogThreshold() time.Duration

+ func (sAppserv *Appserv) GetTokenExp() time.Duration

+ func (sAppserv *Appserv) GetUniqueID(counterName string) (int, error)

+ func (sAppserv *Appserv) GetVersion() string

+ func (sAppserv *Appserv) GetVostokAppToken(appName string, appURL string, user string, password string, ...) (string, error)

+ func (sAppserv *Appserv) HasDb() bool

+ func (sAppserv *Appserv) InitAppDB() (vDbManager string, vDbUsername string, vDbName string, ...)

+ func (sAppserv *Appserv) InitAuth()

+ func (sAppserv *Appserv) InitBatcher()

+ func (sAppserv *Appserv) InitGlobalCache()

+ func (sAppserv *Appserv) InitLocalCache()

+ func (sAppserv *Appserv) InitLoggers()

+ func (sAppserv *Appserv) InitRoutinePool()

+ func (sAppserv *Appserv) IsDBOpen() bool

+ func (sAppserv *Appserv) IsHideFunctionName() bool

+ func (sAppserv *Appserv) IsTestMode() bool

+ func (sAppserv *Appserv) IsVerbose() bool

+ func (sAppserv *Appserv) Log() LogEntry

+ func (sAppserv *Appserv) LogF(skip int, fields logrus.Fields) LogEntry

+ func (sAppserv *Appserv) NewBatchRoutineContext(scopeID string) IBatchRoutineContext

+ func (sAppserv *Appserv) NewRoutine(scopeID string) Routine

+ func (sAppserv *Appserv) OpenAndTweakDBConnection(c *applicationDBConfig) (db IDB, errOpen error)

+ func (sAppserv *Appserv) OpenDBConnection(pDriverName string, pDbName string, pDbHost string, pUsername string, ...) (IDB, error)

+ func (sAppserv *Appserv) PullJobWorker() (*JobWorker, error)

+ func (sAppserv *Appserv) QueryRow(pQuery string, pParams ...interface{}) *sql.Row

+ func (sAppserv *Appserv) QuerySQL(pQuery string, pParams ...interface{}) (*sql.Rows, error)

+ func (sAppserv *Appserv) ReleaseJobWorker(jobWorker *JobWorker)

+ func (sAppserv *Appserv) RemoveFunction(name string)

+ func (sAppserv *Appserv) ScheduleFunction(name string, schedule string, fn interface{}, args ...interface{}) error

+ func (sAppserv *Appserv) ScheduleJob(jobID string, jobFunc scheduledJobFunc) error

+ func (sAppserv *Appserv) ServeHTTP(pResponseWriter http.ResponseWriter, pRequest *http.Request)

+ func (sAppserv *Appserv) SetAuthClientGetterFn(fn AuthClientGetterFn)

+ func (sAppserv *Appserv) SetMainLogger(logger *logrus.Logger)

+ func (sAppserv *Appserv) Start()

+ func (sAppserv *Appserv) StartBatchJob(batchUID BatchUID)

+ type AppservCall func(pAppservChild *AppservChild)

+ type AppservChild struct

+ func (sAppservChild *AppservChild) Batcher() *Batcher

+ func (sAppservChild *AppservChild) BeginDbTransaction() (*sql.Tx, error)

+ func (sAppservChild *AppservChild) BindOriginalFunction(name string, jfunc interface{})

+ func (sAppservChild *AppservChild) DecryptData(pEncryptedData []byte) ([]byte, error)

+ func (sAppservChild *AppservChild) EncryptData(pData []byte) ([]byte, error)

+ func (sAppservChild *AppservChild) EscapeStringJavascript(pString string) string

+ func (sAppservChild *AppservChild) Exec(pQuery string, pParams ...interface{}) (sql.Result, error)

+ func (sAppservChild *AppservChild) ExecuteStatement(pName string, pParams ...interface{}) (sql.Result, error)

+ func (sAppservChild *AppservChild) GetAction() string

+ func (sAppservChild *AppservChild) GetAppName() string

+ func (sAppservChild *AppservChild) GetAppPath() string

+ func (sAppservChild *AppservChild) GetAppURL() string

+ func (sAppservChild *AppservChild) GetBox() string

+ func (sAppservChild *AppservChild) GetChildNumber() int

+ func (sAppservChild *AppservChild) GetCookie(pName string) ([]byte, error)

+ func (sAppservChild *AppservChild) GetCurrentHTTPRequest() *http.Request

+ func (sAppservChild *AppservChild) GetCurrentResponseWriter() http.ResponseWriter

+ func (sAppservChild *AppservChild) GetCurrentURL() *url.URL

+ func (sAppservChild *AppservChild) GetCustomConfig() ICustomConfig

+ func (sAppservChild *AppservChild) GetDbName() string

+ func (sAppservChild *AppservChild) GetDescription() string

+ func (sAppservChild *AppservChild) GetHTTPMethod() string

+ func (sAppservChild *AppservChild) GetIPAddress() string

+ func (sAppservChild *AppservChild) GetLogger() *logrus.Logger

+ func (sAppservChild *AppservChild) GetLogin() bool

+ func (sAppservChild *AppservChild) GetMode() AppMode

+ func (sAppservChild *AppservChild) GetOriginalJobConfig(jobID string, doPanicIfNotFound bool) *JobConfig

+ func (sAppservChild *AppservChild) GetParentScope() LoggingScope

+ func (sAppservChild *AppservChild) GetRoutinePoolCapacity() int

+ func (sAppservChild *AppservChild) GetRoutineStats() (currentUse, maxParaUse, totalUse int)

+ func (sAppservChild *AppservChild) GetScheduledFunction(name string) interface{}

+ func (sAppservChild *AppservChild) GetScopeID() string

+ func (sAppservChild *AppservChild) GetSecondaryDB(pDbID string, pCheck bool) (*sql.DB, error)

+ func (sAppservChild *AppservChild) GetSecondaryDBx(pDbID string, pCheck bool) (*sqlx.DB, error)

+ func (sAppservChild *AppservChild) GetSecondaryDbName(id string) string

+ func (sAppservChild *AppservChild) GetSeparator() string

+ func (sAppservChild *AppservChild) GetSignature() string

+ func (sAppservChild *AppservChild) GetSqlLogThreshold() time.Duration

+ func (sAppservChild *AppservChild) GetStartTime() time.Time

+ func (sAppservChild *AppservChild) GetStatement(pName string) *sql.Stmt

+ func (sAppservChild *AppservChild) GetTokenExp() time.Duration

+ func (sAppservChild *AppservChild) GetUniqueID(counterName string) (int, error)

+ func (sAppservChild *AppservChild) GetUserInfo() *UserInfo

+ func (sAppservChild *AppservChild) GetVersion() string

+ func (sAppservChild *AppservChild) GetVostokAppToken(appName string, appURL string, user string, password string, ...) (string, error)

+ func (sAppservChild *AppservChild) IsDBOpen() bool

+ func (sAppservChild *AppservChild) IsHideFunctionName() bool

+ func (sAppservChild *AppservChild) IsTestMode() bool

+ func (sAppservChild *AppservChild) IsVerbose() bool

+ func (sAppservChild *AppservChild) Log() LogEntry

+ func (sAppservChild *AppservChild) LogF(skip int, fields logrus.Fields) LogEntry

+ func (sAppservChild *AppservChild) NewRoutine(scopeID string) Routine

+ func (sAppservChild *AppservChild) PlayJSON(pJSONObject interface{}, pIndent bool)

+ func (sAppservChild *AppservChild) PlayJSONError(pCallName string, pCallVersion string, pErrorCode string, pErrorTitle string, ...)

+ func (sAppservChild *AppservChild) PlayJSONIndent(pJSONObject interface{}, pIndentString string)

+ func (sAppservChild *AppservChild) PlayJSONIndentWithCode(pJSONObject interface{}, pIndentString string, pCode int)

+ func (sAppservChild *AppservChild) PlayJSONResponse(pCallName string, pCallVersion string, pDataObject interface{})

+ func (sAppservChild *AppservChild) PlayJSONStatus()

+ func (sAppservChild *AppservChild) PlayTemplate(pTemplateName string, pTemplateType string, pTemplateData interface{})

+ func (sAppservChild *AppservChild) PullJobWorker() (*JobWorker, error)

+ func (sAppservChild *AppservChild) QueryRow(pQuery string, pParams ...interface{}) *sql.Row

+ func (sAppservChild *AppservChild) QuerySQL(pQuery string, pParams ...interface{}) (*sql.Rows, error)

+ func (sAppservChild *AppservChild) QueryStatement(pName string, pParams ...interface{}) (*sql.Rows, error)

+ func (sAppservChild *AppservChild) Redirect(pURL string)

+ func (sAppservChild *AppservChild) ReleaseJobWorker(jobWorker *JobWorker)

+ func (sAppservChild *AppservChild) RemoveFunction(name string)

+ func (sAppservChild *AppservChild) ScheduleFunction(name string, schedule string, fn interface{}, args ...interface{}) error

+ func (sAppservChild *AppservChild) SetCookie(pName string, pValue []byte)

+ func (sAppservChild *AppservChild) SetLogin(pLoginState bool)

+ func (sAppservChild *AppservChild) SetUserInfo(pUserInfo *UserInfo)

+ type AppservError struct

+ LogMessage string

+ Message string

+ Title string

+ type AuthClientGetterFn func(appServChild *AppservChild, id string) (*UserInfo, error)

+ type AuthLoginRequest struct

+ Password string

+ Username string

+ type AuthLoginResponse struct

+ Error *authError

+ Expires time.Time

+ UserInfo *UserInfo

+ type BaseUser struct

+ Active bool

+ Admin bool

+ FirstName string

+ LastName string

+ Password string

+ Physical bool

+ RedirectURI string

+ SuperUser bool

+ Username string

+ func (thisUser *BaseUser) ClientSecretMatches(secret string) bool

+ func (thisUser *BaseUser) GetId() string

+ func (thisUser *BaseUser) GetRedirectUri() string

+ func (thisUser *BaseUser) GetSecret() string

+ func (thisUser *BaseUser) GetUserData() interface{}

+ type BatchCompartment struct

+ func (thisCompartment *BatchCompartment) ApplyBatchFunction(batchFnCtx IBatchFunctionContext, batchFn BatchFunction, doPurge bool) (nbTreated, nbUnitsTot int, err error)

+ func (thisCompartment *BatchCompartment) GetBatchCompartmentID() BatchCompartmentID

+ func (thisCompartment *BatchCompartment) GetBatchesSize() int

+ func (thisCompartment *BatchCompartment) GetConfig() IBatchCompartmentConfig

+ func (thisCompartment *BatchCompartment) GetContext() interface{}

+ func (thisCompartment *BatchCompartment) GetParams() map[string]string

+ func (thisCompartment *BatchCompartment) SetContext(compartmentContext IBatchCompartmentContext)

+ type BatchCompartmentID string

+ func BatchInsertCompartmentID(db string, table string) BatchCompartmentID

+ type BatchFuncName string

+ const BatchFunctionBULKINSERTLINES

+ type BatchFunction func(ctx IBatchFunctionContext, compartment *BatchCompartment, units []IBatchUnit) error

+ type BatchUID string

+ type BatchUnitAutoSign struct

+ func (thisSign *BatchUnitAutoSign) Matches(compartmentSignature IBatchSignature) error

+ func (thisSign *BatchUnitAutoSign) ToString() string

+ type Batcher struct

+ func (thisBatcher *Batcher) GetCompartments(handleWithJob BatchUID) map[BatchCompartmentID]*BatchCompartment

+ func (thisBatcher *Batcher) HasPendingWork() bool

+ func (thisBatcher *Batcher) IsShut() bool

+ func (thisBatcher *Batcher) Push(handleWithJob BatchUID, unit IBatchUnit) (nbInBasket, nbBatches, batchSize int, err error)

+ func (thisBatcher *Batcher) Shut()

+ type BulkInsertionsContext struct

+ type CountryCode struct

+ Alpha2Code string

+ Alpha3Code string

+ NumCode int

+ Translations map[Lang]*Translation

+ func FindCountryCode(codeOrTranslation string) *CountryCode

+ type Currency struct

+ Code CurrencyCode

+ Label string

+ Num int

+ func GetCurrency(currencyCode string) *Currency

+ type CurrencyCode string

+ const CurrencyCodeCHF

+ const CurrencyCodeEUR

+ const CurrencyCodeGBP

+ const CurrencyCodeUSD

+ func (thisCurrencyCode CurrencyCode) Label() string

+ func (thisCurrencyCode CurrencyCode) Num() int

+ func (thisCurrencyCode CurrencyCode) String() string

+ type Email string

+ type ErrorMessage struct

+ Message string

+ Title string

+ Valid bool

+ type IAppservSibling interface

+ BeginDbTransaction func() (*sql.Tx, error)

+ Exec func(pQuery string, pParams ...interface{}) (sql.Result, error)

+ GetAppName func() string

+ GetAppPath func() string

+ GetCustomConfig func() ICustomConfig

+ GetDbName func() string

+ GetDescription func() string

+ GetMode func() AppMode

+ GetSecondaryDB func(pDbID string, pCheck bool) (*sql.DB, error)

+ GetSecondaryDBx func(pDbID string, pCheck bool) (*sqlx.DB, error)

+ GetSecondaryDbName func(id string) string

+ GetSqlLogThreshold func() time.Duration

+ GetUniqueID func(counterName string) (int, error)

+ GetVersion func() string

+ GetVostokAppToken func(appName string, appURL string, user string, password string, ...) (string, error)

+ IsDBOpen func() bool

+ IsTestMode func() bool

+ IsVerbose func() bool

+ Log func() LogEntry

+ LogF func(skip int, fields logrus.Fields) LogEntry

+ QueryRow func(pQuery string, pParams ...interface{}) *sql.Row

+ QuerySQL func(pQuery string, pParams ...interface{}) (*sql.Rows, error)

+ type IBatchCompartmentConfig interface

+ GetBatchCompartmentID func() BatchCompartmentID

+ GetBatchUID func() BatchUID

+ GetBatchesSize func() int

+ GetNbBatchesAtOnce func() int

+ GetParams func() map[string]string

+ GetPurgeBasketAfter func() time.Duration

+ type IBatchCompartmentContext interface

+ type IBatchFunctionContext interface

+ NewBatchRoutineContext func(scopeID string) IBatchRoutineContext

+ type IBatchInsertUnit interface

+ GetInsertColumns func() []string

+ GetInsertValues func() []interface{}

+ type IBatchRoutineContext interface

+ Release func()

+ type IBatchSignature interface

+ Matches func(compartmentSignature IBatchSignature) error

+ ToString func() string

+ type IBatchUnit interface

+ GetBatchCompartmentID func() BatchCompartmentID

+ GetSignature func() IBatchSignature

+ IsAllowed func(compartment *BatchCompartment) error

+ type IBatcherOwner interface

+ Batcher func() *Batcher

+ type ICache interface

+ Add func(key string, object interface{}, expiration time.Duration) error

+ Delete func(key string)

+ Flush func()

+ Get func(key string) (interface{}, bool)

+ Set func(key string, object interface{}, expiration time.Duration)

+ SetDefault func(key string, object interface{})

+ type ICachePartition interface

+ PartitionName func() string

+ func NewPartition(partitionName string) ICachePartition

+ type IConfigFile interface

+ GetCustomConfig func() ICustomConfig

+ GetServerConfig func() *ServerConfig

+ type ICustomConfig interface

+ type IDB interface

+ Begin func() (*sql.Tx, error)

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ Ping func() error

+ Prepare func(query string) (*sql.Stmt, error)

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

+ QueryRow func(query string, args ...interface{}) *sql.Row

+ SetConnMaxLifetime func(d time.Duration)

+ SetMaxIdleConns func(n int)

+ SetMaxOpenConns func(n int)

+ Stats func() sql.DBStats

+ type IGlobalCache interface

+ func GetGlobalCache() IGlobalCache

+ type ILocalCache interface

+ func GetLocalCache() ILocalCache

+ func NewLocalCache(localDefaultExpiration time.Duration, localCleanupInterval time.Duration) ILocalCache

+ type IPartitionedCache interface

+ Add func(partition ICachePartition, key string, object interface{}, ...) error

+ AllItems func(partition ICachePartition) map[string]interface{}

+ Delete func(partition ICachePartition, key string)

+ Flush func(partition ICachePartition)

+ Get func(partition ICachePartition, key string) (interface{}, bool)

+ Partitions func() map[string]ICachePartition

+ Set func(partition ICachePartition, key string, object interface{}, ...)

+ SetDefault func(partition ICachePartition, key string, object interface{})

+ func GetPartitionedCache() IPartitionedCache

+ type IStringNormalizer interface

+ String func(str string) (result string, err error)

+ ToUpper func(str string) (result string, err error)

+ func NewStringNormalizer() IStringNormalizer

+ type ITokenResponse interface

+ GetExpirationInSeconds func() int

+ GetToken func() string

+ type JSONConfigFile struct

+ Config *ServerConfig

+ VostokInfo map[string]string

+ func (thisFile *JSONConfigFile) GetCustomConfig() ICustomConfig

+ func (thisFile *JSONConfigFile) GetServerConfig() *ServerConfig

+ type JSONResponse struct

+ VostokData interface{}

+ VostokHeader *JSONResponseHeader

+ type JSONResponseError struct

+ Code string

+ Message string

+ Title string

+ type JSONResponseHeader struct

+ AppName string

+ AppVersion string

+ Box string

+ CallName string

+ ResponseType string

+ VostokVersion string

+ type JSONResponseStatus struct

+ CGIURL string

+ Children []*responseStatusChildren

+ Memory *responseStatusMemory

+ NbRequests uint64

+ Port int

+ type JSONString string

+ type JSONTime time.Time

+ func (sTime JSONTime) MarshalJSON() ([]byte, error)

+ type JobConfig struct

+ Active bool

+ Description string

+ Params map[string]string

+ Schedule string

+ UID string

+ UseConfig bool

+ type JobWorker struct

+ func (thisWorker *JobWorker) Batcher() *Batcher

+ func (thisWorker *JobWorker) BeginDbTransaction() (*sql.Tx, error)

+ func (thisWorker *JobWorker) Exec(queryAsString string, values ...interface{}) (sql.Result, error)

+ func (thisWorker *JobWorker) GetAppName() string

+ func (thisWorker *JobWorker) GetAppPath() string

+ func (thisWorker *JobWorker) GetCustomConfig() ICustomConfig

+ func (thisWorker *JobWorker) GetDbName() string

+ func (thisWorker *JobWorker) GetDescription() string

+ func (thisWorker *JobWorker) GetLogger() *logrus.Logger

+ func (thisWorker *JobWorker) GetMode() AppMode

+ func (thisWorker *JobWorker) GetParentScope() LoggingScope

+ func (thisWorker *JobWorker) GetRoutineStats() (currentUse, maxParaUse, totalUse int)

+ func (thisWorker *JobWorker) GetScopeID() string

+ func (thisWorker *JobWorker) GetSecondaryDB(dbID string, check bool) (*sql.DB, error)

+ func (thisWorker *JobWorker) GetSecondaryDBx(dbID string, check bool) (*sqlx.DB, error)

+ func (thisWorker *JobWorker) GetSecondaryDbName(id string) string

+ func (thisWorker *JobWorker) GetSeparator() string

+ func (thisWorker *JobWorker) GetSignature() string

+ func (thisWorker *JobWorker) GetSqlLogThreshold() time.Duration

+ func (thisWorker *JobWorker) GetUniqueID(counterName string) (int, error)

+ func (thisWorker *JobWorker) GetVersion() string

+ func (thisWorker *JobWorker) GetVostokAppToken(appName string, appURL string, user string, password string, ...) (string, error)

+ func (thisWorker *JobWorker) GetWorkerID() int

+ func (thisWorker *JobWorker) GetWorkerUses() int

+ func (thisWorker *JobWorker) IsDBOpen() bool

+ func (thisWorker *JobWorker) IsHideFunctionName() bool

+ func (thisWorker *JobWorker) IsTestMode() bool

+ func (thisWorker *JobWorker) IsVerbose() bool

+ func (thisWorker *JobWorker) Log() LogEntry

+ func (thisWorker *JobWorker) LogF(skip int, fields logrus.Fields) LogEntry

+ func (thisWorker *JobWorker) NewBatchRoutineContext(scopeID string) IBatchRoutineContext

+ func (thisWorker *JobWorker) NewRoutine(scopeID string) Routine

+ func (thisWorker *JobWorker) QueryRow(queryAsString string, values ...interface{}) *sql.Row

+ func (thisWorker *JobWorker) QuerySQL(queryAsString string, values ...interface{}) (*sql.Rows, error)

+ type Lang string

+ const LangDE

+ const LangEN

+ const LangES

+ const LangFR

+ const LangIT

+ const LangNL

+ type LogEntry interface

+ Debug func(format string, args ...interface{})

+ Error func(format string, args ...interface{})

+ Fatal func(format string, args ...interface{})

+ Info func(format string, args ...interface{})

+ Panic func(format string, args ...interface{})

+ Trace func(format string, args ...interface{})

+ Warn func(format string, args ...interface{})

+ func NewEntry(scope LoggingScope, skip int, fields logrus.Fields) LogEntry

+ type LoggingScope interface

+ GetLogger func() *logrus.Logger

+ GetParentScope func() LoggingScope

+ GetScopeID func() string

+ GetSeparator func() string

+ GetSignature func() string

+ IsHideFunctionName func() bool

+ IsVerbose func() bool

+ Log func() LogEntry

+ LogF func(skip int, fields logrus.Fields) LogEntry

+ type OAuthAction string

+ type RegExpPattern struct

+ var VOSTOK_REGEXP_FLOAT *RegExpPattern

+ var VOSTOK_REGEXP_INT *RegExpPattern

+ var VOSTOK_REGEXP_IP *RegExpPattern

+ var VOSTOK_REGEXP_MD5 *RegExpPattern

+ var VOSTOK_REGEXP_NAME *RegExpPattern

+ var VOSTOK_REGEXP_TIMESTAMP *RegExpPattern

+ var VOSTOK_REGEXP_TIMESTAMP_LONG *RegExpPattern

+ var VOSTOK_REGEXP_TIMESTAMP_MEDIUM *RegExpPattern

+ var VOSTOK_REGEXP_TIMESTAMP_SHORT *RegExpPattern

+ var VOSTOK_REGEXP_TIMESTAMP_YEAR *RegExpPattern

+ var VOSTOK_REGEXP_UINT *RegExpPattern

+ func NewRegExpPattern(pPattern string) *RegExpPattern

+ func (sRegExpPattern *RegExpPattern) MatchString(pString string) bool

+ type Routine interface

+ Release func()

+ type RoutineOwner interface

+ type ServerConfig struct

+ AppName string

+ Application *applicationConfig

+ Box string

+ Custom ICustomConfig

+ Description string

+ Flags map[string]bool

+ Items map[string]string

+ Version string

+ func BuildConfig(pConfigFilePath string) (rConfig *ServerConfig, rErr error)

+ type SessionAuthAction string

+ const SessionAuthLOGIN

+ const SessionAuthLOGOUT

+ type StatelessAuthAction string

+ const StatelessAuthLOGIN

+ const StatelessAuthLOGOUT

+ type SuccessMessage struct

+ Message string

+ Title string

+ Valid bool

+ type Translation struct

+ Language Lang

+ Long string

+ Short string

+ type URL string

+ type UserInfo struct

+ IPAddress string

+ Permissions map[string]bool

+ UserID int

Other modules containing this package

bitbucket.org/oscaroscar/vostok/v6

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