MCPcopy Index your code

hub / github.com/allegro/akubra / types & classes

Types & classes174 in github.com/allegro/akubra

↓ 2 callersInterfaceNode
Node is interface of call node
balancing/balance_breaker.go:60
↓ 1 callersTypeAliasAdditionalHeaders
AdditionalHeaders type fields in yaml configuration will parse list of special headers
httphandler/config/config.go:33
↓ 1 callersTypeAliasContextKey
ContextKey is type for log related context keys
log/logger.go:15
TypeAliasAPIErrorCode
APIErrorCode type of error status.
storages/auth/s3_signer.go:17
StructAccessMessageData
AccessMessageData holds all important informations about http roundtrip
httphandler/log.go:13
StructBackend
Backend represents any storage in akubra cluster
storages/backend/backend.go:17
InterfaceBackendError
BackendError interface helps logging inconsistencies
utils/utils.go:17
StructBackendError
BackendError is returned in Backend.RoundTrip if any
types/errors.go:10
StructBalancerPrioritySet
BalancerPrioritySet selects storage by priority and availability
balancing/balance_breaker.go:602
StructBasePicker
BasePicker contains common methods of pickers
storages/response_picker.go:11
InterfaceBreaker
Breaker is interface of citcuit breaker
balancing/balance_breaker.go:286
StructBrimLogHook
BrimLogHook collects and sends sync events to brim api
log/brim_logger.go:17
StructBucketListResponseMergerTestSuite
storages/response_handler_test.go:119
StructCallMeter
CallMeter implements Node interface
balancing/balance_breaker.go:95
StructClient
Client keeps backend client configuration
httphandler/config/config.go:57
StructClientTransportProperties
ClientTransportProperties details
transport/config/config.go:11
StructClientTransportRules
ClientTransportRules properties
transport/config/config.go:29
StructClientWrapper
ClientWrapper for consul api.Client
discovery/service.go:38
InterfaceClusterStorage
ClusterStorage is basic cluster storage interface
storages/storages.go:18
StructClusterTestSuite
ClusterTestSuite setups cluster test suite
storages/shardclient_test.go:15
StructCommonPrefix
CommonPrefix container for prefix response.
storages/merger/s3datatypes/s3_datatypes_minio.go:43
TypeAliasCommonPrefixes
CommonPrefixes is slice of CommonPrefix
storages/merger/s3datatypes/s3_datatypes_minio.go:273
StructCompiledRules
CompiledRules properties
transport/config/config.go:36
StructCompleteMultipartUploadResult
CompleteMultipartUploadResult contains information about a successfull multipart upload, after the object has been assembled
types/s3_types.go:7
StructConfig
Config is watchdog type
watchdog/config.go:10
StructConfig
Config defines metrics publication details
metrics/config.go:28
StructConfig
Config contains processed YamlConfig data
config/config.go:44
StructConsistencyRecord
ConsistencyRecord describes the state of an object in domain
watchdog/watchdog.go:30
InterfaceConsistencyRecordFactory
ConsistencyRecordFactory creates records from http requests
watchdog/watchdog.go:72
StructConsistencyRecordFactoryMock
storages/request_dispatcher_test.go:329
InterfaceConsistencyWatchdog
ConsistencyWatchdog manages the ConsistencyRecords and DeleteMarkers
watchdog/watchdog.go:63
InterfaceConsistencyWatchdogFactory
ConsistencyWatchdogFactory creates ConsistencyWatchdogs
watchdog/config.go:17
StructConsulClientWrapperMock
discovery/service_mock_test.go:16
StructCredentials
Credentials stores brim api credentials
log/brim_logger.go:11
StructCredentialsStore
CredentialsStore - gets a caches credentials from akubra-crdstore
crdstore/crdstore.go:34
StructCredentialsStore
CredentialsStore configuration
crdstore/config/config.go:9
StructCredentialsStoreData
CredentialsStoreData - stores single access-secret key pair with EOL(TTL)
crdstore/crdstoredata.go:11
TypeAliasCredentialsStoreMap
CredentialsStoreMap - map of credentialsStores configurations
crdstore/config/config.go:17
StructCustomItemsTestNoEmpty
config/validator_test.go:26
StructCustomItemsTestUnique
config/validator_test.go:22
StructDBClientFactory
DBClientFactory constructs instances of DBClient
database/sql.go:15
StructDBConfig
DBConfig holds configuration for database logging
log/sql/connection.go:16
FuncTypeDecorator
Decorator is http.RoundTripper interface wrapper
httphandler/roundtripper_decorators.go:16
StructDefaultConsistencyRecordFactory
DefaultConsistencyRecordFactory is a default implementation of ConsistencyRecordFactory
watchdog/watchdog.go:77
StructDefinitionError
DefinitionError properties for Transports
transport/transport.go:77
StructDeleteMarker
DeleteMarker indicates which ConsistencyRecords for a given object can be deleted
watchdog/watchdog.go:50
StructDeleteMarkerInfo
DeleteMarkerInfo container
storages/merger/s3datatypes/s3_datatypes_minio.go:145
TypeAliasDeleteMarkerInfos
DeleteMarkerInfos is slice []DeleteMarkerInfo
storages/merger/s3datatypes/s3_datatypes_minio.go:221
StructExecutionDelay
ExecutionDelay tells how to change the execution time of a record
watchdog/watchdog.go:57
StructFactory
Factory creates storages
storages/storages.go:67
StructHandler
Handler implements http.Handler interface
httphandler/httphandler.go:19
StructHealthWrapper
HealthWrapper for consul api.Health
discovery/service.go:23
StructHealthWrapperMock
discovery/service_mock_test.go:29
StructHumanSizeUnits
HumanSizeUnits type for max. payload body size in bytes
types/yaml.go:31
StructHumanSizeUnits
HumanSizeUnits type for max. payload body size in bytes
httphandler/config/config.go:71
InterfaceIClient
IClient interface
discovery/service.go:33
InterfaceIHealth
IHealth interface
discovery/service.go:18
StructInitiateMultipartUploadResult
InitiateMultipartUploadResult contains information about an initiated multipart
types/s3_types.go:16
StructInterval
Interval is time.Duration wrapper
metrics/config.go:9
StructKeys
Keys user credentials
storages/auth/s3_signer.go:86
StructListBucketResult
ListBucketResult container for listObjects response.
storages/merger/s3datatypes/s3_datatypes_minio.go:75
StructListBucketV2Result
ListBucketV2Result container for listObjects response version 2.
storages/merger/s3datatypes/s3_datatypes_minio.go:244
StructListMultipartUploadsResult
ListMultipartUploadsResult decodes s3 multipart upload results
storages/merger/s3datatypes/s3_datatypes_minio.go:296
StructListVersionsResult
ListVersionsResult container for Bucket Object versions response see: https://docs.aws.amazon.com/AmazonS3/latest/API/RESTBucketGETVersion.html
storages/merger/s3datatypes/s3_datatypes_minio.go:169
InterfaceLogger
Logger interface generalizes Logger implementations
log/logger.go:57
StructLoggerConfig
LoggerConfig holds oprions
log/logger.go:76
StructLoggerMock
transport/transport_matcher_test.go:19
StructLoggingConfig
LoggingConfig contains Loggers configuration
log/config/config.go:6
StructMatcher
Matcher mapping initialized Transports with http.RoundTripper by transport name
transport/transport.go:21
StructMeasuredStorage
MeasuredStorage coordinates metrics collection
balancing/balance_breaker.go:509
TypeAliasMethod
Method is the ConsistencyRecord type
watchdog/config.go:4
StructMockRoundTripper
balancing/balance_breaker_test.go:414
StructMockedRoundTripper
storages/multipart_setup_test.go:14
StructMultiClusterConfig
MultiClusterConfig defines region settings for multicluster
sharding/config/config.go:10
StructMultiPartRoundTripper
MultiPartRoundTripper handles the multipart upload. If multipart upload is detected, it delegates the request to the backend selected using the active
storages/multipart_round_tripper.go:24
InterfaceNamedShardClient
NamedShardClient interface
storages/shardclient.go:15
StructNodeBreaker
NodeBreaker is implementation of Breaker interface
balancing/balance_breaker.go:307
StructObjectInfo
ObjectInfo container for object metadata.
storages/merger/s3datatypes/s3_datatypes_minio.go:10
TypeAliasObjectInfos
ObjectInfos is slice of ObjectInfo
storages/merger/s3datatypes/s3_datatypes_minio.go:52
StructObjectMultipartInfo
ObjectMultipartInfo container for multipart object metadata.
storages/merger/s3datatypes/s3_datatypes_minio.go:313
StructObjectResponsePicker
ObjectResponsePicker chooses first successful or one of failure response from chan of `BackendResponse`s
storages/response_picker.go:70
StructParsedAuthorizationHeader
ParsedAuthorizationHeader holds the parsed "Authorization" header content
storages/auth/s3_signer.go:39
StructPlainTextFormatter
PlainTextFormatter implements raw message formatting
log/logger.go:113
StructPolicies
Policies region configuration
regions/config/config.go:10
StructPolicy
Policy defines region cluster
regions/config/config.go:4
StructRegionConfig
RegionConfig region configuration
sharding/config/config.go:18
StructRegions
Regions container for multiclusters
regions/regions.go:19
StructReplicationClient
ReplicationClient is multiple endpoints client
storages/replicator.go:19
StructRequest
Request encapsulates the http requests along with the watchdog-data
storages/request_dispatcher.go:130
StructRequestDispatcher
RequestDispatcher passes requests and responses to matching replicators and response pickers
storages/request_dispatcher.go:17
FuncTypeRequestHandler
func(*http.Request) (*http.Response, error)
storages/replicator_test.go:169
InterfaceResetter
Resetter interface
types/interfaces.go:6
StructResolver
Resolver for discovery service
discovery/resolver.go:17
StructResponse
Response helps handle responses
storages/backend/backend.go:63
StructResponseTimeBalancer
ResponseTimeBalancer proxies calls to balancing nodes
balancing/balance_breaker.go:18
StructRingFactory
RingFactory produces clients ShardsRing
sharding/sharding.go:14
StructSQLConsistencyRecord
SQLConsistencyRecord is a SQL representation of ConsistencyRecord
watchdog/sql.go:38
StructSQLWatchdog
SQLWatchdog is a type of ConsistencyWatchdog that uses a SQL database
watchdog/sql.go:30
StructSQLWatchdogFactory
SQLWatchdogFactory creates instances of SQLWatchdog
watchdog/sql.go:25
StructServer
Server struct handles basic http server parameters
httphandler/config/config.go:16
next →1–100 of 174, ranked by callers