util

package

Go to main page

Versions in this module

v1

v1.42.0

Mar 28, 2022

Changes in this version

+ const EelObserver

+ const HTTPHandle

+ const HTTPHandleDuration

+ const HTTPHostKey

+ const HTTPMethodKey

+ const HTTPRequest

+ const HTTPRequestDuration

+ const HTTPRouteKey

+ const HTTPStatusCodeKey

+ const HTTPURLKey

+ const HandlerKey

+ const MessageLatency

+ const MessageProcess

+ const MessageProcessDuration

+ const MessageResponseDuration

+ const TopicKey

+ func End(ctx Context, attrs map[string]string, err error)

+ func Record(ctx Context, metric string, attrs map[string]string, val int)

+ func RegisterObserver(ctx Context, o Observer)

+ func UpdateContext(ctx Context, conf *EelSettings, tenantId string, updateVal bool)

type Context

+ func Start(ctx Context, trace string, attrs map[string]string) Context

+ type Observer interface

+ End func(ctx Context, attrs map[string]string, err error)

+ Record func(ctx Context, metric string, attrs map[string]string, val int)

+ Start func(ctx Context, trace string, attrs map[string]string) Context

v1.41.0

Jun 2, 2021

Changes in this version

+ const EelRequestQuery

+ func ExtractAppId(tenant string, allowPartner bool) string

+ func ExtractPartnerId(tenant string, allowPartner bool, defaultPartner string) string

type EelSettings

+ DefaultPartner string

v1.40.0

May 10, 2021

Changes in this version

+ const EelPartnerId

+ const LogPartnerId

type EelSettings

+ AllowPartner bool

+ HttpPartnerHeader string

v1.39.0

Dec 4, 2020

v1.38.0

Nov 16, 2020

v1.37.0

Mar 9, 2020

v1.36.0

Nov 25, 2019

v1.35.0

Nov 4, 2019

v1.34.0

Oct 17, 2019

v1.33.0

Sep 23, 2019

v1.32.0

Aug 9, 2019

v1.31.0

Jul 19, 2019

v1.30.0

Jun 7, 2019

v1.29.0

May 17, 2019

Changes in this version

+ const EelCache

+ const EelTenantIds

+ const LogTenantId

+ var StatusNoWorkerPool = map[string]interface

type EelSettings

+ Brokers string

+ ElementsAuth string

v1.8.1

Apr 19, 2017

Changes in this version

+ const DefaultConfigFolder

+ const Eel1MinStats

+ const Eel1hrStats

+ const Eel24hrStats

+ const Eel5MinStats

+ const EelConfig

+ const EelConfigFile

+ const EelCustomProperties

+ const EelDispatcher

+ const EelDuplicateChecker

+ const EelErrors

+ const EelFile

+ const EelHandlerConfig

+ const EelHandlerFactory

+ const EelHttpClient

+ const EelHttpTransport

+ const EelNamedTransformations

+ const EelPathWhiteList

+ const EelRequestHeader

+ const EelRetryService

+ const EelStartTime

+ const EelSyncPath

+ const EelTenantId

+ const EelTotalStats

+ const EelTraceLogger

+ const L_DebugLevel

+ const L_ErrorLevel

+ const L_InfoLevel

+ const L_MetricLevel

+ const L_NilLevel

+ const L_WarnLevel

+ const M_Dims

+ const M_Metric

+ const M_Namespace

+ const M_Unit

+ const M_Val

+ var AppId = "eel"

+ var BasePath = ""

+ var ConfigPath = ""

+ var EnvName = "default"

+ var Gctx Context

+ var HandlerPath = ""

+ var HandlerPaths = []string

+ var HttpStatusTooManyRequests = 429

+ var InstanceName = "localhost"

+ var LogLevel = L_InfoLevel

+ var Mutex = &sync.RWMutex

+ var Once sync.Once

+ var StatusAlreadySubscribed = map[string]interface

+ var StatusDuplicateEliminated = map[string]interface

+ var StatusEmptyBody = map[string]interface

+ var StatusHttpPostRequired = map[string]interface

+ var StatusInvalidJson = map[string]interface

+ var StatusNotEvenSubscribed = map[string]interface

+ var StatusProcessed = map[string]interface

+ var StatusProcessedDummy = map[string]interface

+ var StatusQueueFull = map[string]interface

+ var StatusRequestTooLarge = map[string]interface

+ var StatusUnknownTopic = map[string]interface

+ func AddError(ctx Context, err error)

+ func AddLatencyLog(ctx Context, stats *ServiceStats, key string)

+ func ClearErrors(ctx Context)

+ func DeepEquals(a, b interface{}) bool

+ func GetCustomProperties(ctx Context) map[string]interface

+ func GetErrors(ctx Context) []error

+ func GetHttpClient(ctx Context) *http.Client

+ func GetResponse(ctx Context, errTmpl map[string]interface{}) []byte

+ func GetTenantId(ctx Context) string

+ func HitEndpoint(ctx Context, url string, payload string, verb string, ...) (string, int, error)

+ func InitGctx(logLevel string)

+ func InitHttpTransport(ctx Context)

+ func InitHttpTransportWithDial(ctx Context, dial func(network, addr string) (net.Conn, error))

+ func NewUUID() (string, error)

+ func SetDefaultRetrier(retrier Retrier)

+ func ToFlatString(v interface{}) string

+ type Context interface

+ AddConfigValue func(key interface{}, value interface{})

+ AddLogValue func(key interface{}, value interface{})

+ AddValue func(key interface{}, value interface{})

+ ConfigValue func(key interface{}) interface{}

+ DisableLogging func()

+ EnableLogging func()

+ HandlePanic func()

+ Id func() string

+ Log func() Logger

+ LogValue func(key interface{}) interface{}

+ SetId func(id string)

+ SubContext func() Context

+ Value func(key interface{}) interface{}

+ WrapPanicHttpHandler func(func(http.ResponseWriter, *http.Request)) http.HandlerFunc

+ func NewDefaultContext(level string) Context

+ type DefaultContext struct

+ func (c *DefaultContext) AddConfigValue(key interface{}, value interface{})

+ func (c *DefaultContext) AddLogValue(key interface{}, value interface{})

+ func (c *DefaultContext) AddValue(key interface{}, value interface{})

+ func (c *DefaultContext) ConfigValue(key interface{}) interface{}

+ func (c *DefaultContext) DisableLogging()

+ func (c *DefaultContext) EnableLogging()

+ func (c *DefaultContext) HandlePanic()

+ func (c *DefaultContext) Id() string

+ func (c *DefaultContext) Log() Logger

+ func (c *DefaultContext) LogValue(key interface{}) interface{}

+ func (c *DefaultContext) SetId(id string)

+ func (c *DefaultContext) SubContext() Context

+ func (c *DefaultContext) Value(key interface{}) interface{}

+ func (c *DefaultContext) WrapPanicHttpHandler(fn func(w http.ResponseWriter, r *http.Request)) http.HandlerFunc

+ type DefaultLogWriter struct

+ func NewDefaultLogWriter() *DefaultLogWriter

+ type DefaultLogger struct

+ func NewDefaultLogger(ctx *DefaultContext, level string) *DefaultLogger

+ func (l *DefaultLogger) Debug(args ...interface{})

+ func (l *DefaultLogger) Error(args ...interface{})

+ func (l *DefaultLogger) Info(args ...interface{})

+ func (l *DefaultLogger) Metric(statKey interface{}, args ...interface{})

+ func (l *DefaultLogger) RuntimeLogLoop(interval time.Duration, iterations int)

+ func (l *DefaultLogger) Warn(args ...interface{})

+ type DefaultRetrier struct

+ func (*DefaultRetrier) Retry(ctx Context, url string, payload string, verb string, ...) (string, int, error)

+ func (d *DefaultRetrier) RetryEndpoint(ctx Context, url string, payload string, verb string, ...) (string, int, error)

+ type DuplicateChecker interface

+ GetTtl func() int

+ IsDuplicate func(Context, []byte) bool

+ func NewLocalInMemoryDupChecker(ttl int, size int) DuplicateChecker

+ type EelDebugLogParams struct

+ IdPath string

+ IdWhiteList map[string]string

+ Lock sync.RWMutex

+ LogParams map[string]string

+ RefreshSec int

+ WhiteListTable string

+ func GetDebugLogParams(ctx Context) *EelDebugLogParams

+ type EelSettings struct

+ ActionTopics []string

+ AppName string

+ BackoffMethod string

+ CloseIdleConnectionIntervalSec int

+ CloseIdleConnectionsStarted bool

+ CustomProperties map[string]interface{}

+ DebugLogParams *EelDebugLogParams

+ DuplicateTimeout int

+ EelWebhook string

+ ElementsPublishEndpoint string

+ ElementsWebhookEndpoint string

+ Endpoint interface{}

+ EventTopics []string

+ FunctionalMonitoringPort int

+ HandlerConfigPath string

+ HttpDebugHeader string

+ HttpTenantHeader string

+ HttpTimeout time.Duration

+ HttpTransactionHeader string

+ InitialBackoff time.Duration

+ InitialDelay time.Duration

+ LogParams map[string]string

+ LogStats bool

+ MaxAttempts int

+ MaxIdleConnsPerHost int

+ MaxMessageSize int64

+ MessageQueueDepth int

+ MessageQueueTimeout int

+ Misc map[string]interface{}

+ Name string

+ Organization string

+ Pad time.Duration

+ ResponseHeaderTimeout time.Duration

+ RetryQueues []string

+ RetryServiceAvailable bool

+ SendCloudWatchMetrics bool

+ TopicPath string

+ TraceLogParams *EelTraceLogParams

+ UseRetryQueue bool

+ Version string

+ WorkerPoolSize int

+ func GetConfig(ctx Context) *EelSettings

+ func GetConfigFromFile(ctx Context) *EelSettings

+ type EelTraceLogParams struct

+ Active bool

+ FileName string

+ LogIncoming bool

+ LogOutgoing bool

+ LogParams map[string]string

+ type LocalInMemoryDupChecker struct

+ func (d *LocalInMemoryDupChecker) GetTtl() int

+ func (d *LocalInMemoryDupChecker) IsDuplicate(ctx Context, payload []byte) bool

+ type Logger interface

+ Debug func(args ...interface{})

+ Error func(args ...interface{})

+ Info func(args ...interface{})

+ Metric func(statKey interface{}, args ...interface{})

+ RuntimeLogLoop func(interval time.Duration, iterations int)

+ Warn func(args ...interface{})

+ type NetworkError struct

+ Endpoint string

+ Message string

+ Status int

+ func (e NetworkError) Error() string

+ type ParseError struct

+ Message string

+ func (e ParseError) Error() string

+ type Retrier interface

+ Retry func(Context, string, string, string, map[string]string, map[string]string, ...) (string, int, error)

+ RetryEndpoint func(Context, string, string, string, map[string]string, map[string]string) (string, int, error)

+ func GetRetrier(ctx Context) Retrier

+ type RuntimeError struct

+ Function string

+ Message string

+ Params []string

+ func (e RuntimeError) Error() string

+ type ServiceStats struct

+ ErrorCount uint64

+ InCount uint64

+ OutCount uint64

+ TotalBytesIn uint64

+ TotalBytesOut uint64

+ TotalTimeExternal uint64

+ TotalTimeInternal uint64

+ func (stats *ServiceStats) Add(src *ServiceStats) *ServiceStats

+ func (stats *ServiceStats) Clone() *ServiceStats

+ func (stats *ServiceStats) IncBytesIn(size int)

+ func (stats *ServiceStats) IncBytesOut(size int)

+ func (stats *ServiceStats) IncErrors()

+ func (stats *ServiceStats) IncInCount()

+ func (stats *ServiceStats) IncOutCount()

+ func (stats *ServiceStats) IncTimeExternal(nanos int64)

+ func (stats *ServiceStats) IncTimeInternal(nanos int64)

+ func (stats *ServiceStats) Reset()

+ func (stats *ServiceStats) StatsLoop(ctx Context, interval time.Duration, iterations int, label string, ...)

+ func (stats *ServiceStats) Subtract(src *ServiceStats) *ServiceStats

+ type SyntaxError struct

+ Function string

+ Message string

+ Params []string

+ func (e SyntaxError) Error() string

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