MCPcopy Create free account

hub / github.com/allegro/akubra / functions

Functions618 in github.com/allegro/akubra

⨍ Functions 618◇ Types & classes 174
↓ 63 callersMethodError
()
utils/utils.go:20
↓ 56 callersMethodPrintf
(format string, v ...interface{})
log/logger.go:67
↓ 54 callersMethodDebugf
(format string, v ...interface{})
log/logger.go:71
↓ 38 callersMethodGet
Get - Gets key from cache or from akubra-crdstore if TTL has expired
crdstore/crdstore.go:103
↓ 33 callersMethodAdd
(value float64, dateTime time.Time)
balancing/balance_breaker.go:167
↓ 30 callersMethodUnmarshal
Unmarshal - Unmarshal CredentialsStoreData to json
crdstore/crdstoredata.go:19
↓ 26 callersFunctionPrepareYamlConfig
( bodyMaxSize httpHandlerConfig.HumanSizeUnits, idleConnTimeoutInp time.Duration, responseHeaderTimeoutInp
config/config_test.go:358
↓ 23 callersMethodGet
(i int)
storages/merger/list.go:87
↓ 22 callersMethodValue
()
metrics/system_metrics.go:44
↓ 19 callersMethodLen
()
storages/merger/list.go:84
↓ 17 callersMethodString
()
storages/merger/s3datatypes/s3_datatypes_minio.go:38
↓ 16 callersMethodnow
()
balancing/balance_breaker_test.go:218
↓ 14 callersMethodPrintln
(v ...interface{})
log/logger.go:68
↓ 14 callersMethodShouldOpen
()
balancing/balance_breaker.go:288
↓ 13 callersMethodDiscardBody
DiscardBody drain and close response Body, so connections are properly closed
storages/backend/backend.go:71
↓ 12 callersMethodClose
()
sharding/shards_ring.go:77
↓ 12 callersMethodFatalf
(format string, v ...interface{})
log/logger.go:59
↓ 12 callersFunctionGetInstance
GetInstance - Get crdstore instance for endpoint
crdstore/crdstore.go:42
↓ 12 callersMethodString
String produces data in csv format with fields in following order: Method, Host, Path, UserAgent, StatusCode, Duration, RespErr)
httphandler/log.go:27
↓ 11 callersMethodTransportsEntryLogicalValidator
TransportsEntryLogicalValidator checks the correctness of "Transports" part of configuration file
config/validator.go:100
↓ 9 callersFunctionClear
Clear removes all metrics in Registry
metrics/metrics.go:25
↓ 9 callersFunctionInit
Init setups metrics publication
metrics/metrics.go:67
↓ 9 callersMethodprepareKey
(accessKey, backend string)
crdstore/crdstore.go:61
↓ 8 callersMethodDebug
(v ...interface{})
log/logger.go:70
↓ 8 callersMethodTimeSpent
()
balancing/balance_breaker.go:62
↓ 8 callersMethodUpdateTimeSpent
(time.Duration)
balancing/balance_breaker.go:65
↓ 7 callersMethodCalls
()
balancing/balance_breaker.go:61
↓ 7 callersMethodIsSuccessful
IsSuccessful returns true if no networ error occured and status code < 400
storages/backend/backend.go:103
↓ 7 callersMethodName
()
storages/shardclient.go:17
↓ 7 callersMethodRoundTrip
(req *http.Request)
httphandler/roundtripper_decorators.go:167
↓ 7 callersFunctionValidateConf
ValidateConf validate configuration from YAML file
config/config.go:89
↓ 7 callersMethodadvance
()
balancing/balance_breaker_test.go:224
↓ 7 callersFunctioncreateChanOfResponses
(successful ...bool)
storages/response_picker_test.go:120
↓ 6 callersFunctionDecorate
Decorate returns http.Roundtripper wraped with all passed decorators
httphandler/roundtripper_decorators.go:193
↓ 6 callersMethodDo
(request *Request)
storages/request_dispatcher.go:139
↓ 6 callersMethodElect
Elect elects node and calls it with args
balancing/balance_breaker.go:23
↓ 6 callersMethodFormat
Format implements logrus.Formatter interface
log/logger.go:116
↓ 6 callersMethodGetEndpoint
GetEndpoint by service name
discovery/service.go:55
↓ 6 callersMethodRecord
(duration time.Duration, success bool)
balancing/balance_breaker.go:287
↓ 6 callersMethodRegionsEntryLogicalValidator
RegionsEntryLogicalValidator checks the correctness of "Regions" part of configuration file
config/validator.go:87
↓ 6 callersMethodReqID
ReqID returns request id
storages/backend/backend.go:91
↓ 6 callersMethodToStringer
ToStringer returns slice of stringers
storages/merger/s3datatypes/s3_datatypes_minio.go:55
↓ 6 callersMethodWatchdogEntryLogicalValidator
WatchdogEntryLogicalValidator validates ConsistencyWatchdog's config depending on the types of watchdogs defined
config/validator.go:132
↓ 6 callersMethodappend
(obj ...fmt.Stringer)
storages/merger/list.go:72
↓ 6 callersFunctioncheckOpenFor
(t *testing.T, d time.Duration, breaker Breaker, timer *mockTimer)
balancing/balance_breaker_test.go:333
↓ 6 callersFunctionopenBreaker
(breaker Breaker)
balancing/balance_breaker_test.go:327
↓ 6 callersMethodsend
(out chan<- BackendResponse, bresp BackendResponse)
storages/response_picker.go:48
↓ 5 callersMethodDo
Do performs backend request
storages/multipart_round_tripper.go:66
↓ 5 callersMethodGetMostAvailable
GetMostAvailable returns balancer member
balancing/balance_breaker.go:607
↓ 5 callersMethodGetShard
(name string)
storages/storages.go:19
↓ 5 callersFunctionNewServices
NewServices constructor
discovery/service.go:96
↓ 5 callersMethodRoundTrip
(req *http.Request)
storages/replicator_test.go:189
↓ 5 callersFunctioncontents
(key ...string)
storages/response_handler_test.go:96
↓ 5 callersFunctioncreateDummyBackend
(handler RequestHandler)
storages/replicator_test.go:180
↓ 5 callersMethodfirst
(limit int)
storages/merger/list.go:89
↓ 5 callersFunctionmakeTestBreaker
()
balancing/balance_breaker_test.go:262
↓ 5 callersFunctionprefixes
(prefix ...string)
storages/response_handler_test.go:88
↓ 5 callersFunctionprepareErrors
prepareErrors
config/validator.go:182
↓ 4 callersMethodFromStringer
FromStringer returns asserted stringer slice to ObjectInfos
storages/merger/s3datatypes/s3_datatypes_minio.go:65
↓ 4 callersMethodPick
()
storages/request_dispatcher.go:125
↓ 4 callersMethodPick
Pick returns first successful response, discards others
storages/response_picker.go:81
↓ 4 callersMethodPrint
(v ...interface{})
log/logger.go:66
↓ 4 callersFunctionRequestHeaderContentTypeValidator
RequestHeaderContentTypeValidator for Content-Type header in request
config/validator.go:192
↓ 4 callersMethodReset
()
types/interfaces.go:7
↓ 4 callersMethodRoundTrip
RoundTrip performs round trip to target
regions/regions.go:42
↓ 4 callersMethodServeHTTP
(w http.ResponseWriter, req *http.Request)
httphandler/httphandler.go:26
↓ 4 callersMethodSetActive
(bool)
balancing/balance_breaker.go:64
↓ 4 callersMethodassignShardsRing
(domain string, shardRing sharding.ShardsRingAPI)
regions/regions.go:24
↓ 4 callersMethodcollectFailureResponse
(bresp BackendResponse)
storages/response_picker.go:29
↓ 4 callersMethodhasFailureResponse
()
storages/response_picker.go:44
↓ 4 callersMethodhasSuccessfulResponse
()
storages/response_picker.go:40
↓ 4 callersMethodindex
(now time.Time)
balancing/balance_breaker.go:242
↓ 4 callersFunctionnewCallMeterWithTimer
(retention, resolution time.Duration, now func() time.Time)
balancing/balance_breaker.go:86
↓ 4 callersFunctionnewReplicationClient
newReplicationClient returns ReplicationClient
storages/replicator.go:26
↓ 4 callersFunctionprepareConsulClientMock
(address string, port int, entitiesCount int)
discovery/service_mock_test.go:97
↓ 4 callersFunctionprepareTransportsForEntryLogicalValidatorTest
(maxIdleConns, maxIdleConnsPerHost int, idleConnTimeoutDuration, responseHeaderTimeoutDuration time.Duration)
config/validator_test.go:509
↓ 4 callersFunctionsendReq
(t *testing.T, srv *httptest.Server, method string, body io.Reader, rt http.RoundTripper)
httphandler/roundtripper_decorators_test.go:43
↓ 4 callersFunctiontestMultipartFlow
(statusCode int, xmlResponse string, record *watchdog.ConsistencyRecord, delta *watchdog.ExecutionDelay, mark
storages/multipart_round_tripper_test.go:136
↓ 3 callersMethodDispatch
(request *http.Request)
storages/request_dispatcher.go:13
↓ 3 callersFunctionHeadersSuplier
HeadersSuplier creates Decorator which adds headers to request and response
httphandler/roundtripper_decorators.go:102
↓ 3 callersMethodListenPortsLogicalValidator
ListenPortsLogicalValidator make sure that listen port and technical listen port are not equal
config/validator.go:118
↓ 3 callersFunctionNewLogger
NewLogger creates Logger
log/logger.go:161
↓ 3 callersMethodNewYamlConfigTest
NewYamlConfigTest tests func for updating fields values in tests cases
config/config_test.go:78
↓ 3 callersFunctionParseAuthorizationHeader
ParseAuthorizationHeader - extract S3 authorization header details
storages/auth/s3_signer.go:155
↓ 3 callersMethodPick
Pick returns first successful response, discard others
storages/response_picker.go:126
↓ 3 callersMethodRoundTrip
RoundTrip implements http.RoundTripper interface
storages/auth/s3_signer.go:108
↓ 3 callersMethodRoundTrip
(request *http.Request)
balancing/balance_breaker_test.go:418
↓ 3 callersMethodSelectTransportDefinition
SelectTransportDefinition returns transport instance by method, path and queryParams
transport/transport.go:27
↓ 3 callersMethodSend
(tup ...BackendResponse)
storages/response_handler_test.go:126
↓ 3 callersFunctionValidateConfigurationHTTPHandler
ValidateConfigurationHTTPHandler is used in technical HTTP endpoint for config file validation
config/config.go:116
↓ 3 callersFunctionassertIncludeHeaders
(t *testing.T, actual map[string][]string, required map[string]string)
httphandler/roundtripper_decorators_test.go:29
↓ 3 callersMethodcompileRule
compileRule
transport/config/config.go:55
↓ 3 callersMethodcompileRules
compileRules prepares precompiled regular expressions for rules
transport/config/config.go:70
↓ 3 callersFunctionexistAnyHostInInstance
(instance *url.URL, expectedHost1, expectedHost2 string)
discovery/service_mock_test.go:120
↓ 3 callersFunctionisSuccess
(response BackendResponse)
storages/response_handler.go:21
↓ 3 callersFunctionlogWriteHeaderErr
(err error, when string)
config/config.go:82
↓ 3 callersFunctionnewCallMeter
(retention, resolution time.Duration)
balancing/balance_breaker.go:77
↓ 3 callersFunctionnewLenLimitCounter
(retention int)
balancing/balance_breaker.go:395
↓ 3 callersMethodnewShard
(name string, storageNames []string, storages map[string]*StorageClient)
storages/shardclient.go:87
↓ 3 callersFunctionnewTimeHistogram
(retention, resolution time.Duration, now func() time.Time)
balancing/balance_breaker.go:194
next →1–100 of 618, ranked by callers