Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/allegro/akubra
/ types & classes
Types & classes
174 in github.com/allegro/akubra
⨍
Functions
618
◇
Types & classes
174
↓ 2 callers
Interface
Node
Node is interface of call node
balancing/balance_breaker.go:60
↓ 1 callers
TypeAlias
AdditionalHeaders
AdditionalHeaders type fields in yaml configuration will parse list of special headers
httphandler/config/config.go:33
↓ 1 callers
TypeAlias
ContextKey
ContextKey is type for log related context keys
log/logger.go:15
TypeAlias
APIErrorCode
APIErrorCode type of error status.
storages/auth/s3_signer.go:17
Struct
AccessMessageData
AccessMessageData holds all important informations about http roundtrip
httphandler/log.go:13
Struct
Backend
Backend represents any storage in akubra cluster
storages/backend/backend.go:17
Interface
BackendError
BackendError interface helps logging inconsistencies
utils/utils.go:17
Struct
BackendError
BackendError is returned in Backend.RoundTrip if any
types/errors.go:10
Struct
BalancerPrioritySet
BalancerPrioritySet selects storage by priority and availability
balancing/balance_breaker.go:602
Struct
BasePicker
BasePicker contains common methods of pickers
storages/response_picker.go:11
Interface
Breaker
Breaker is interface of citcuit breaker
balancing/balance_breaker.go:286
Struct
BrimLogHook
BrimLogHook collects and sends sync events to brim api
log/brim_logger.go:17
Struct
BucketListResponseMergerTestSuite
storages/response_handler_test.go:119
Struct
CallMeter
CallMeter implements Node interface
balancing/balance_breaker.go:95
Struct
Client
Client keeps backend client configuration
httphandler/config/config.go:57
Struct
ClientTransportProperties
ClientTransportProperties details
transport/config/config.go:11
Struct
ClientTransportRules
ClientTransportRules properties
transport/config/config.go:29
Struct
ClientWrapper
ClientWrapper for consul api.Client
discovery/service.go:38
Interface
ClusterStorage
ClusterStorage is basic cluster storage interface
storages/storages.go:18
Struct
ClusterTestSuite
ClusterTestSuite setups cluster test suite
storages/shardclient_test.go:15
Struct
CommonPrefix
CommonPrefix container for prefix response.
storages/merger/s3datatypes/s3_datatypes_minio.go:43
TypeAlias
CommonPrefixes
CommonPrefixes is slice of CommonPrefix
storages/merger/s3datatypes/s3_datatypes_minio.go:273
Struct
CompiledRules
CompiledRules properties
transport/config/config.go:36
Struct
CompleteMultipartUploadResult
CompleteMultipartUploadResult contains information about a successfull multipart upload, after the object has been assembled
types/s3_types.go:7
Struct
Config
Config is watchdog type
watchdog/config.go:10
Struct
Config
Config defines metrics publication details
metrics/config.go:28
Struct
Config
Config contains processed YamlConfig data
config/config.go:44
Struct
ConsistencyRecord
ConsistencyRecord describes the state of an object in domain
watchdog/watchdog.go:30
Interface
ConsistencyRecordFactory
ConsistencyRecordFactory creates records from http requests
watchdog/watchdog.go:72
Struct
ConsistencyRecordFactoryMock
storages/request_dispatcher_test.go:329
Interface
ConsistencyWatchdog
ConsistencyWatchdog manages the ConsistencyRecords and DeleteMarkers
watchdog/watchdog.go:63
Interface
ConsistencyWatchdogFactory
ConsistencyWatchdogFactory creates ConsistencyWatchdogs
watchdog/config.go:17
Struct
ConsulClientWrapperMock
discovery/service_mock_test.go:16
Struct
Credentials
Credentials stores brim api credentials
log/brim_logger.go:11
Struct
CredentialsStore
CredentialsStore - gets a caches credentials from akubra-crdstore
crdstore/crdstore.go:34
Struct
CredentialsStore
CredentialsStore configuration
crdstore/config/config.go:9
Struct
CredentialsStoreData
CredentialsStoreData - stores single access-secret key pair with EOL(TTL)
crdstore/crdstoredata.go:11
TypeAlias
CredentialsStoreMap
CredentialsStoreMap - map of credentialsStores configurations
crdstore/config/config.go:17
Struct
CustomItemsTestNoEmpty
config/validator_test.go:26
Struct
CustomItemsTestUnique
config/validator_test.go:22
Struct
DBClientFactory
DBClientFactory constructs instances of DBClient
database/sql.go:15
Struct
DBConfig
DBConfig holds configuration for database logging
log/sql/connection.go:16
FuncType
Decorator
Decorator is http.RoundTripper interface wrapper
httphandler/roundtripper_decorators.go:16
Struct
DefaultConsistencyRecordFactory
DefaultConsistencyRecordFactory is a default implementation of ConsistencyRecordFactory
watchdog/watchdog.go:77
Struct
DefinitionError
DefinitionError properties for Transports
transport/transport.go:77
Struct
DeleteMarker
DeleteMarker indicates which ConsistencyRecords for a given object can be deleted
watchdog/watchdog.go:50
Struct
DeleteMarkerInfo
DeleteMarkerInfo container
storages/merger/s3datatypes/s3_datatypes_minio.go:145
TypeAlias
DeleteMarkerInfos
DeleteMarkerInfos is slice []DeleteMarkerInfo
storages/merger/s3datatypes/s3_datatypes_minio.go:221
Struct
ExecutionDelay
ExecutionDelay tells how to change the execution time of a record
watchdog/watchdog.go:57
Struct
Factory
Factory creates storages
storages/storages.go:67
Struct
Handler
Handler implements http.Handler interface
httphandler/httphandler.go:19
Struct
HealthWrapper
HealthWrapper for consul api.Health
discovery/service.go:23
Struct
HealthWrapperMock
discovery/service_mock_test.go:29
Struct
HumanSizeUnits
HumanSizeUnits type for max. payload body size in bytes
types/yaml.go:31
Struct
HumanSizeUnits
HumanSizeUnits type for max. payload body size in bytes
httphandler/config/config.go:71
Interface
IClient
IClient interface
discovery/service.go:33
Interface
IHealth
IHealth interface
discovery/service.go:18
Struct
InitiateMultipartUploadResult
InitiateMultipartUploadResult contains information about an initiated multipart
types/s3_types.go:16
Struct
Interval
Interval is time.Duration wrapper
metrics/config.go:9
Struct
Keys
Keys user credentials
storages/auth/s3_signer.go:86
Struct
ListBucketResult
ListBucketResult container for listObjects response.
storages/merger/s3datatypes/s3_datatypes_minio.go:75
Struct
ListBucketV2Result
ListBucketV2Result container for listObjects response version 2.
storages/merger/s3datatypes/s3_datatypes_minio.go:244
Struct
ListMultipartUploadsResult
ListMultipartUploadsResult decodes s3 multipart upload results
storages/merger/s3datatypes/s3_datatypes_minio.go:296
Struct
ListVersionsResult
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
Interface
Logger
Logger interface generalizes Logger implementations
log/logger.go:57
Struct
LoggerConfig
LoggerConfig holds oprions
log/logger.go:76
Struct
LoggerMock
transport/transport_matcher_test.go:19
Struct
LoggingConfig
LoggingConfig contains Loggers configuration
log/config/config.go:6
Struct
Matcher
Matcher mapping initialized Transports with http.RoundTripper by transport name
transport/transport.go:21
Struct
MeasuredStorage
MeasuredStorage coordinates metrics collection
balancing/balance_breaker.go:509
TypeAlias
Method
Method is the ConsistencyRecord type
watchdog/config.go:4
Struct
MockRoundTripper
balancing/balance_breaker_test.go:414
Struct
MockedRoundTripper
storages/multipart_setup_test.go:14
Struct
MultiClusterConfig
MultiClusterConfig defines region settings for multicluster
sharding/config/config.go:10
Struct
MultiPartRoundTripper
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
Interface
NamedShardClient
NamedShardClient interface
storages/shardclient.go:15
Struct
NodeBreaker
NodeBreaker is implementation of Breaker interface
balancing/balance_breaker.go:307
Struct
ObjectInfo
ObjectInfo container for object metadata.
storages/merger/s3datatypes/s3_datatypes_minio.go:10
TypeAlias
ObjectInfos
ObjectInfos is slice of ObjectInfo
storages/merger/s3datatypes/s3_datatypes_minio.go:52
Struct
ObjectMultipartInfo
ObjectMultipartInfo container for multipart object metadata.
storages/merger/s3datatypes/s3_datatypes_minio.go:313
Struct
ObjectResponsePicker
ObjectResponsePicker chooses first successful or one of failure response from chan of `BackendResponse`s
storages/response_picker.go:70
Struct
ParsedAuthorizationHeader
ParsedAuthorizationHeader holds the parsed "Authorization" header content
storages/auth/s3_signer.go:39
Struct
PlainTextFormatter
PlainTextFormatter implements raw message formatting
log/logger.go:113
Struct
Policies
Policies region configuration
regions/config/config.go:10
Struct
Policy
Policy defines region cluster
regions/config/config.go:4
Struct
RegionConfig
RegionConfig region configuration
sharding/config/config.go:18
Struct
Regions
Regions container for multiclusters
regions/regions.go:19
Struct
ReplicationClient
ReplicationClient is multiple endpoints client
storages/replicator.go:19
Struct
Request
Request encapsulates the http requests along with the watchdog-data
storages/request_dispatcher.go:130
Struct
RequestDispatcher
RequestDispatcher passes requests and responses to matching replicators and response pickers
storages/request_dispatcher.go:17
FuncType
RequestHandler
func(*http.Request) (*http.Response, error)
storages/replicator_test.go:169
Interface
Resetter
Resetter interface
types/interfaces.go:6
Struct
Resolver
Resolver for discovery service
discovery/resolver.go:17
Struct
Response
Response helps handle responses
storages/backend/backend.go:63
Struct
ResponseTimeBalancer
ResponseTimeBalancer proxies calls to balancing nodes
balancing/balance_breaker.go:18
Struct
RingFactory
RingFactory produces clients ShardsRing
sharding/sharding.go:14
Struct
SQLConsistencyRecord
SQLConsistencyRecord is a SQL representation of ConsistencyRecord
watchdog/sql.go:38
Struct
SQLWatchdog
SQLWatchdog is a type of ConsistencyWatchdog that uses a SQL database
watchdog/sql.go:30
Struct
SQLWatchdogFactory
SQLWatchdogFactory creates instances of SQLWatchdog
watchdog/sql.go:25
Struct
Server
Server struct handles basic http server parameters
httphandler/config/config.go:16
next →
1–100 of 174, ranked by callers