Documentation
¶
Index ¶
- Variables
- func ContextWithExplicitFeatureFlags(ctx context.Context) context.Context
- func ContextWithFeatureFlag(ctx context.Context, flag FeatureFlag, enabled bool) context.Context
- func FromContext(ctx context.Context) map[FeatureFlag]bool
- func IncomingCtxWithFeatureFlag(ctx context.Context, flag FeatureFlag, enabled bool) context.Context
- func OutgoingCtxWithFeatureFlag(ctx context.Context, flag FeatureFlag, enabled bool) context.Context
- type FeatureFlag
Constants ¶
This section is empty.
Variables ¶
var ( // EnableAllFeatureFlagsEnvVar will cause Gitaly to treat all feature flags as // enabled in case its value is set to `true`. Only used for testing purposes. EnableAllFeatureFlagsEnvVar = "GITALY_TESTING_ENABLE_ALL_FEATURE_FLAGS" )
var FixRoutingWithAdditionalRepository = NewFeatureFlag( "fix_routing_with_additional_repository", "v16.0.0", "https://gitlab.com/gitlab-org/gitaly/-/issues/5134", false, )
FixRoutingWithAdditionalRepository fixes routing of repository-creating RPCs that have an additional repository set in their request that is to be rewritten. Previously, it could have happened that the new repository was routed to nodes that didn't have the additional repo. With the flag enabled, Praefect always routes repository-creating RPCs to the same node that the additional repository is assigned to.
var GeometricRepacking = NewFeatureFlag( "geometric_repacking", "v15.11.0", "https://gitlab.com/gitlab-org/gitaly/-/issues/5031", true, )
GeometricRepacking will start to use geometric repacking of objects in the context of repository maintenance.
var LocalrepoReadObjectCached = NewFeatureFlag( "localrepo_read_object_cached", "v15.7", "https://gitlab.com/gitlab-org/gitaly/-/issues/4662", false, )
LocalrepoReadObjectCached enables the use of the catfile cache for localrepo.ReadObject
var PackObjectsLimitingRemoteIP = NewFeatureFlag( "pack_objects_limiting_remote_ip", "v15.11.0", "https://gitlab.com/gitlab-org/gitaly/-/issues/4413", false, )
PackObjectsLimitingRemoteIP will enable a concurrency limiter for pack objects based off of the remote IP
var RunCommandsInCGroup = NewFeatureFlag( "run_cmds_in_cgroup", "v14.10.0", "https://gitlab.com/gitlab-org/gitaly/-/issues/4102", true, )
RunCommandsInCGroup allows all commands to be run within a cgroup
Functions ¶
func ContextWithExplicitFeatureFlags ¶
ContextWithExplicitFeatureFlags marks the context such that all feature flags which are checked must have been explicitly set in that context. If a feature flag wasn't set to an explicit value, then checking this feature flag will panic. This is not for use in production systems, but is intended for tests to verify that we test each feature flag properly.
func ContextWithFeatureFlag ¶
ContextWithFeatureFlag sets the feature flag in both the incoming and outgoing context.
func FromContext ¶
func FromContext(ctx context.Context) map[FeatureFlag]bool
FromContext returns the set of all feature flags defined in the context. This returns both feature flags that are currently defined by Gitaly, but may also return some that aren't defined by us in case they match the feature flag prefix but don't have a definition. This function also returns the state of the feature flag *as defined in the context*. This value may be overridden.
func IncomingCtxWithFeatureFlag ¶
func IncomingCtxWithFeatureFlag(ctx context.Context, flag FeatureFlag, enabled bool) context.Context
IncomingCtxWithFeatureFlag sets the feature flag for an incoming context. This is NOT meant for use in clients that transfer the context across process boundaries.
func OutgoingCtxWithFeatureFlag ¶
func OutgoingCtxWithFeatureFlag(ctx context.Context, flag FeatureFlag, enabled bool) context.Context
OutgoingCtxWithFeatureFlag sets the feature flag for an outgoing context.
Types ¶
type FeatureFlag ¶
type FeatureFlag struct {
// Name is the name of the feature flag.
Name string `json:"name"`
// OnByDefault is the default value if the feature flag is not explicitly set in
// the incoming context.
OnByDefault bool `json:"on_by_default"`
}
FeatureFlag gates the implementation of new or changed functionality.
func DefinedFlags ¶
func DefinedFlags() []FeatureFlag
DefinedFlags returns the set of feature flags that have been explicitly defined.
func FromMetadataKey ¶
func FromMetadataKey(metadataKey string) (FeatureFlag, error)
FromMetadataKey parses the given gRPC metadata key into a Gitaly feature flag and performs the necessary conversions. Returns an error in case the metadata does not refer to a feature flag.
This function tries to look up the default value via our set of flag definitions. In case the flag definition is unknown to Gitaly it assumes a default value of `false`.
func NewFeatureFlag ¶
func NewFeatureFlag(name, version, rolloutIssueURL string, onByDefault bool) FeatureFlag
NewFeatureFlag creates a new feature flag and adds it to the array of all existing feature flags. The name must be of the format `some_feature_flag`. Accepts a version and rollout issue URL as input that are not used for anything but only for the sake of linking to the feature flag rollout issue in the Gitaly project.
func (FeatureFlag) FormatWithValue ¶
func (ff FeatureFlag) FormatWithValue(enabled bool) string
FormatWithValue converts the feature flag into a string with the given state. Note that this function uses the feature flag name and not the raw metadata key as used in gRPC metadata.
func (FeatureFlag) IsDisabled ¶
func (ff FeatureFlag) IsDisabled(ctx context.Context) bool
IsDisabled determines whether the feature flag is disabled in the incoming context.
func (FeatureFlag) IsEnabled ¶
func (ff FeatureFlag) IsEnabled(ctx context.Context) bool
IsEnabled checks if the feature flag is enabled for the passed context. Only returns true if the metadata for the feature flag is set to "true"
func (FeatureFlag) MetadataKey ¶
func (ff FeatureFlag) MetadataKey() string
MetadataKey returns the key of the feature flag as it is present in the metadata map.
Source Files