boltrouter

Nov 28, 2023

Changes in this version

type Config

+ AwsIgnoreAuthHeaderRegion bool

Sep 20, 2023

Changes in this version

+ const AwsCloudPlatform

+ const GcpCloudPlatform

+ const UndefinedCloudPlatform

+ var CloudPlatformStrToTypeMap map[string]CloudPlatformType = map[string]CloudPlatformType

+ var CloudPlatformTypeToStrMap map[CloudPlatformType]string = map[CloudPlatformType]string

+ var InitialRequestTargetMap = map[InitialRequestTargetType]string

type BoltRequest

+ Gcp *http.Request

+ type CloudPlatformType uint8

type Config

+ CloudPlatform CloudPlatformType

+ GcpReplicasEnabled bool

+ type ErrUnknownCloudPlatform error

+ type InitialRequestTargetType uint8

+ const InitialRequestTargetBolt

+ const InitialRequestTargetFallback

+ const InitialRequestTargetUndefined

Aug 24, 2023

Changes in this version

+ var DefaultConfig = Config

type BoltRouter

+ func (br *BoltRouter) IsOffline(endpoint string) bool

+ func (br *BoltRouter) MaybeMarkOffline(url *url.URL, err error)

type Config

+ CrunchTrafficSplit CrunchTrafficSplitType

+ NoFallback404 bool

+ type CrunchTrafficSplitType string

+ const CrunchTrafficSplitByObjectKeyHash

+ const CrunchTrafficSplitByRandomRequest

Aug 14, 2023

Changes in this version

+ var ErrPanicDuringAwsRequest = errors.New("panic occurred during AWS request")

+ var ErrPanicDuringBoltRequest = errors.New("panic occurred during Bolt request")

type BoltRouter

+ func (br *BoltRouter) DoRequest(logger *zap.Logger, boltReq *BoltRequest) (*http.Response, bool, *BoltRequestAnalytics, error)

Aug 11, 2023

Changes in this version

+ type BoltRequestAnalytics struct

+ AwsRequestDuration time.Duration

+ AwsRequestResponseStatusCode int

+ BoltRequestDuration time.Duration

+ BoltRequestResponseStatusCode int

+ BoltRequestUrl string

+ InitialRequestTarget string

+ InitialRequestTargetReason string

+ Method string

+ ObjectKey string

+ RequestBodySize int

Aug 9, 2023

Changes in this version

+ func LogAnalytics(logger *zap.Logger, boltReq *BoltRequest, duration time.Duration, ...)

Jul 25, 2023

Changes in this version

type Config

+ BoltEndpointOverride string

Jul 20, 2023

Changes in this version

+ const BoltInfoRefreshInterval

+ type BoltInfo map[string]interface

type BoltRouter

+ func (br *BoltRouter) GetCleanerStatus() (bool, error)

+ func (br *BoltRouter) RefreshBoltInfo(ctx context.Context) error

+ func (br *BoltRouter) RefreshBoltInfoPeriodically(ctx context.Context)

+ func (br *BoltRouter) SelectInitialRequestTarget() (target string, reason string, err error)

type BoltVars

+ BoltInfo AtomicVar[BoltInfo]

Jun 14, 2023

Changes in this version

type Config

+ func NewConfig() Config

Jun 12, 2023

Changes in this version

+ func CopyReqBody(src *http.Request, dest *http.Request)

+ func CopyRespBody(resp *http.Response) io.ReadCloser

Jun 6, 2023

Changes in this version

type BoltRouter

+ func (br *BoltRouter) RefreshAWSCredentialsPeriodically(ctx context.Context, logger *zap.Logger)

type SourceBucket

+ Bucket string

+ Region string

+ Style s3RequestStyle

Apr 25, 2023

Changes in this version

+ func StatusCodeIs2xx(statusCode int) bool

Mar 27, 2023

Changes in this version

+ type AtomicVar struct

+ func (v *AtomicVar[T]) Get() T

+ func (v *AtomicVar[T]) Set(x T)

+ func (v *AtomicVar[T]) String() string

+ type BoltEndpointsMap map[string][]string

+ type BoltRequest struct

+ Aws *http.Request

+ Bolt *http.Request

+ type BoltRouter struct

+ func NewBoltRouter(ctx context.Context, logger *zap.Logger, cfg Config) (*BoltRouter, error)

+ func (br *BoltRouter) DoBoltRequest(logger *zap.Logger, boltReq *BoltRequest) (*http.Response, error)

+ func (br *BoltRouter) NewBoltRequest(ctx context.Context, req *http.Request) (*BoltRequest, error)

+ func (br *BoltRouter) RefreshEndpoints(ctx context.Context) error

+ func (br *BoltRouter) RefreshEndpointsPeriodically(ctx context.Context)

+ func (br *BoltRouter) SelectBoltEndpoint(ctx context.Context, reqMethod string) (*url.URL, error)

+ type BoltVars struct

+ AuthBucket AtomicVar[string]

+ BoltCustomDomain AtomicVar[string]

+ BoltEndpoints AtomicVar[BoltEndpointsMap]

+ BoltHostname AtomicVar[string]

+ HttpReadMethodTypes AtomicVar[[]string]

+ QuicksilverURL AtomicVar[string]

+ ReadOrderEndpoints AtomicVar[[]string]

+ Region AtomicVar[string]

+ UserAgentPrefix AtomicVar[string]

+ WriteOrderEndpoints AtomicVar[[]string]

+ ZoneId AtomicVar[string]

+ func GetBoltVars(logger *zap.Logger) (*BoltVars, error)

+ func (bv *BoltVars) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ type Config struct

+ Failover bool

+ Local bool

+ Passthrough bool

+ type SourceBucket struct