utils

Oct 17, 2024

Changes in this version

+ func GetBizIDC() string

Sep 26, 2024

Changes in this version

type PathReplace

+ func (p *PathReplace) ObjectAPINameV3(objectAPIName string) *PathReplace

+ func (p *PathReplace) RecordIDStr(recordID string) *PathReplace

Sep 4, 2024

Changes in this version

+ func GetFunctionAPIIDFromCtx(ctx context.Context) string

Jun 28, 2024

Changes in this version

+ func GetExecuteIDFromCtx(ctx context.Context) string

+ func GetTenantTypeFromCtx(ctx context.Context) int64

+ func SetEventIDToCtx(ctx context.Context, eventID string) context.Context

Mar 30, 2024

Changes in this version

+ func GetEventID(ctx context.Context) string

+ func GetLegacyLoggerDisabledFromCtx(ctx context.Context) bool

+ func GetMeshDestReqTimeout(ctx context.Context) int64

+ type LogLimitOption struct

+ MaxLine int64

+ MaxLineLength int64

+ MaxSize int64

+ func GetLogLimitOption(ctx context.Context) LogLimitOption

+ type RuntimeOption struct

+ DisableLegacyLogger bool

+ LogLimitOption LogLimitOption

Dec 13, 2023

Changes in this version

+ func SetAPaaSPersistHeader(ctx context.Context, header http.Header)

Dec 4, 2023

retracted

Changes in this version

+ func CanOpenAPIRequestToLGW(ctx context.Context) bool

+ func EnableMesh() bool

+ func GetFaaSEnvIDFromCtx(ctx context.Context) string

+ func GetFaaSEnvTypeFromCtx(ctx context.Context) int64

+ func GetFaaSInfraDomainName() string

+ func GetFaaSInfraPSM(ctx context.Context) string

+ func GetFaaSInfraPSMFromEnv() (psm string, cluster string)

+ func GetFaaSPlatform() string

+ func GetInnerAPIPSMFromEnv() string

+ func GetLGWClusterFromEnv() string

+ func GetLGWPSMFromEnv() string

+ func GetOpenAPIDomainByConf(ctx context.Context) string

+ func GetOpenAPIDomainName() string

+ func GetOpenAPIPSMAndCluster(ctx context.Context) (psm string, cluster string)

+ func GetSDKConf(ctx context.Context) *structs.SDKConf

+ func GetSDKTransientConf(ctx context.Context) *structs.SDKTransientConf

+ func GetSocketAddr() string

+ func GetTraceHeader(ctx context.Context) map[string]string

+ func IsCloseMesh(ctx context.Context) bool

+ func IsExternalFaaS() bool

+ func IsRuntime(ctx context.Context) bool

+ func IsTmpUseOpenapi(ctx context.Context) bool

+ func IsTrueString(str string) bool

+ func OpenMesh(ctx context.Context) bool

+ func SetFaaSEnvIDCtx(ctx context.Context, envID string) context.Context

+ func SetFaaSEnvTypeCtx(ctx context.Context, envType int64) context.Context

+ func SetRuntimeType(ctx context.Context, runtimeType string) context.Context

+ func SetTmpUseOpenapiToCtx(ctx context.Context) context.Context

+ type RuntimeType string

+ const RuntimeTypeCloudDebug

+ const RuntimeTypeLocalDebug

+ const RuntimeTypeRuntime

+ func GetRuntimeType(ctx context.Context) RuntimeType

+ type UseOpenapiKey string

Oct 19, 2023

Changes in this version

+ func ErrorWrapper(body []byte, extra map[string]interface{}, err error) ([]byte, error)

+ func WriteUnauthFieldMapWithLock(ctx context.Context, objectAPIName string, recordID int64, ...)

Oct 9, 2023

Changes in this version

+ func GetGlobalAuthType() *string

Sep 15, 2023

Changes in this version

+ func GetFaaSLaneIDFromCtx(ctx context.Context) string

+ func SetFaaSLaneIDCtx(ctx context.Context, laneID string) context.Context

Aug 8, 2023

Changes in this version

+ func GetCurFunctionMetaConfFromCtx(ctx context.Context) *structs.FunctionMeta

+ func GetFuncAPINameFromCtx(ctx context.Context) string

+ func GetFunctionMetaConfFromCtx(ctx context.Context, apiName string) *structs.FunctionMeta

+ func GetParamUnauthFieldByKey(ctx context.Context, key string) (unauthFields interface{})

+ func GetParamUnauthFieldMapFromCtx(ctx context.Context) (keyToUnauthFields map[string]interface{})

+ func GetParamUnauthFieldRecordByKey(ctx context.Context, key string) (unauthFields []string)

+ func GetParamUnauthFieldRecordListByKey(ctx context.Context, key string) (unauthFieldsList [][]string)

+ func GetRecordID(record interface{}) int64

+ func GetRecordUnauthFieldByObject(ctx context.Context, objectAPIName string) (recordIDToUnauthFields map[int64][]string)

+ func GetRecordUnauthFieldByObjectAndRecordID(ctx context.Context, objectAPIName string, recordID int64) (unauthFields []string)

+ func ParseStrList(v interface{}) (strs []string)

+ func ParseStrsList(v interface{}) (strsList [][]string)

+ func SetFuncAPINameToCtx(ctx context.Context, funcAPIName string) context.Context

+ func SetFunctionMetaConfToCtx(ctx context.Context, metaConf map[string]string) context.Context

+ func SetRecordUnauthField(ctx context.Context, unauthFieldMap RecordUnauthField) context.Context

+ func SetUserAndMixAuthTypeToCtx(ctx context.Context, authType *string, isMix bool) context.Context

+ func SetUserAndMixAuthTypeToHeaders(ctx context.Context, headers map[string][]string, isMix bool) map[string][]string

+ func ToString(v interface{}) string

+ type RecordUnauthField = map[string]map[int64][]string

+ func GetRecordUnauthField(ctx context.Context) (objToRecordIDToUnauthFields RecordUnauthField)

Jul 12, 2023

Changes in this version

+ func GetAppInfoFromCtx(ctx context.Context) (*structs.AppInfo, error)

+ func GetEventInfoFromCtx(ctx context.Context) (*structs.EventInfo, error)

+ func SetAppInfoToCtx(ctx context.Context, appInfo *structs.AppInfo) context.Context

+ func SetEventInfoToCtx(ctx context.Context, appInfo *structs.EventInfo) context.Context

Jun 29, 2023

Changes in this version

+ const Console

+ const ISWebIDE

+ const Result

+ const System

+ const WebIDESource

+ func WebIDELevelInfo(level logrus.Level) string

+ type WebIDELogFormatter struct

+ func (m *WebIDELogFormatter) Format(entry *logrus.Entry) ([]byte, error)

May 16, 2023

Changes in this version

+ func SetUserAndAuthTypeToCtx(ctx context.Context, authType *string) context.Context

+ func SetUserAndAuthTypeToHeaders(ctx context.Context, headers map[string][]string) map[string][]string

Apr 19, 2023

Changes in this version

+ func GetAPaaSLaneFromCtx(ctx context.Context) string

+ func GetAPaaSPersistFaaSMapFromCtx(ctx context.Context) (res map[string]string)

+ func GetAPaaSPersistFaaSMapStr(ctx context.Context) string

+ func GetAPaaSPersistFaaSValueFromCtx(ctx context.Context, key string) string

+ func GetFaaSType(ctx context.Context) string

+ func IsMicroservice(ctx context.Context) bool

+ func SetAPaaSLaneToCtx(ctx context.Context, lane string) context.Context

+ func SetAPaaSPersistFaaSMapToCtx(ctx context.Context, aPaaSPersistFaaSMap map[string]string) context.Context

+ func WithAPaaSPersistFaaSValue(ctx context.Context, key, value string) context.Context

Jan 12, 2023

Changes in this version

+ func GetUserContextMap(ctx context.Context) (res map[string]interface{})

+ func SetUserContextMap(ctx context.Context, userCtxMap map[string]interface{}) context.Context

Nov 1, 2022

Changes in this version

+ func AesDecryptText(fieldID int64, realEncryptKey []byte, encryptedText string) (originText string, err error)

+ func BoolPtr(val bool) *bool

+ func BoolValueOfPtr(val *bool) bool

+ func Decode(input interface{}, output interface{}) error

+ func GetAGWDomain(ctx context.Context) string

+ func GetAGWDomainByConf(ctx context.Context) string

+ func GetApiTimeoutFromCtx(ctx context.Context) map[string]int64

+ func GetAppIDAndSecret() (string, string, error)

+ func GetBoe(ctx context.Context) string

+ func GetDebugTypeFromCtx(ctx context.Context) int

+ func GetDistributedMaskFromCtx(ctx context.Context) string

+ func GetEnv() string

+ func GetEnvBoeFromCtx(ctx context.Context) string

+ func GetEnvOrgID() string

+ func GetFaaSInfraDomain(ctx context.Context) string

+ func GetFunctionNameFromCtx(ctx context.Context) string

+ func GetInnerAPIPSM(ctx context.Context) string

+ func GetInnerAPIPSMFromCtx(ctx context.Context) string

+ func GetLogIDFromCtx(ctx context.Context) string

+ func GetLogIDFromExtra(extra map[string]interface{}) string

+ func GetLoopMaskFromCtx(ctx context.Context) []string

+ func GetNamespace() string

+ func GetNamespaceFromCtx(ctx context.Context) string

+ func GetOpenAPIDomain(ctx context.Context) string

+ func GetServiceID() string

+ func GetSourceTypeFromCtx(ctx context.Context) int

+ func GetTTEnvFromCtx(ctx context.Context) string

+ func GetTenantFromCtx(ctx context.Context) (*structs.Tenant, error)

+ func GetTenantIDFromCtx(ctx context.Context) int64

+ func GetTenantName() string

+ func GetTriggerTaskIDFromCtx(ctx context.Context) int64

+ func GetTriggerTypeFromCtx(ctx context.Context) string

+ func GetUserContext(ctx context.Context) (res structs.UserContext)

+ func GetUserIDFromCtx(ctx context.Context) int64

+ func Int64InInt64s(ns []int, n int) bool

+ func Int64Ptr(val int64) *int64

+ func Int64ValueOfPtr(p *int64, defaultVal int64) int64

+ func IntInInts(ns []int, n int) bool

+ func IntPtr(val int) *int

+ func IntValueOfPtr(p *int, defaultVal int) int

+ func InvokeFuncWithRetry(retryCount int, retryInterval time.Duration, f func() error) error

+ func IsDebug(ctx context.Context) bool

+ func IsLocalDebug(ctx context.Context) bool

+ func JsonMarshalBytes(val interface{}) ([]byte, error)

+ func JsonUnmarshalBytes(val []byte, addr interface{}) error

+ func LevelInfo(level logrus.Level) (string, int)

+ func NowMils() int64

+ func PrintLog(contents ...interface{})

+ func PtrToInt(p *int, defaultVal int) int

+ func SetApiTimeoutMethodToCtx(ctx context.Context, method string) context.Context

+ func SetApiTimeoutToCtx(ctx context.Context, timeout map[string]int64) context.Context

+ func SetDebugTypeToCtx(ctx context.Context, debugType int) context.Context

+ func SetDistributedMaskToCtx(ctx context.Context, mask string) context.Context

+ func SetEnvBoeToCtx(ctx context.Context, boe string) context.Context

+ func SetFunctionNameToCtx(ctx context.Context, functionName string) context.Context

+ func SetInnerAPIPSMToCtx(ctx context.Context, psm string) context.Context

+ func SetKEnvToCtx(ctx context.Context, kEnv string) context.Context

+ func SetKEnvToCtxForRPC(ctx context.Context) context.Context

+ func SetLogIDToCtx(ctx context.Context, logID string) context.Context

+ func SetLoopMaskToCtx(ctx context.Context, mask []string) context.Context

+ func SetSourceTypeToCtx(ctx context.Context, sourceType int) context.Context

+ func SetTTEnvToCtx(ctx context.Context, ttEnv string) context.Context

+ func SetTenantToCtx(ctx context.Context, tenant *structs.Tenant) context.Context

+ func SetTriggerTaskIDToCtx(ctx context.Context, taskID int64) context.Context

+ func SetTriggerTypeToCtx(ctx context.Context, triggerType string) context.Context

+ func SetUserContext(ctx context.Context, userCtx structs.UserContext) context.Context

+ func SetUserIDToCtx(ctx context.Context, userID int64) context.Context

+ func StrInStrs(strs []string, str string) bool

+ func StringPtr(val string) *string

+ func StringValueOfPtr(p *string, defaultVal string) string

+ func TimeMils(t time.Time) int64

+ type ConsoleLogger struct

+ func GetConsoleLogger(logIDs ...string) *ConsoleLogger

+ func (c *ConsoleLogger) Errorf(format string, args ...interface{})

+ func (c *ConsoleLogger) Infof(format string, args ...interface{})

+ func (c *ConsoleLogger) Result(format string, args ...interface{})

+ func (c *ConsoleLogger) Warnf(format string, args ...interface{})

+ type LogFormatter struct

+ func (m *LogFormatter) Format(entry *logrus.Entry) ([]byte, error)

+ type PathReplace struct

+ func NewPathReplace(path string) *PathReplace

+ func (p *PathReplace) APIName(APIName string) *PathReplace

+ func (p *PathReplace) ExecutionID(instanceID int64) *PathReplace

+ func (p *PathReplace) FieldAPIName(fieldAPIName string) *PathReplace

+ func (p *PathReplace) FileID(fileID string) *PathReplace

+ func (p *PathReplace) FunctionAPIName(functionAPIName string) *PathReplace

+ func (p *PathReplace) Namespace(namespace string) *PathReplace

+ func (p *PathReplace) ObjectAPIName(objectAPIName string) *PathReplace

+ func (p *PathReplace) Path() string

+ func (p *PathReplace) RecordID(recordID int64) *PathReplace