resourcemanager

Sep 26, 2023

Changes in this version

+ const NoopResourceManagerID

+ const RedisSetKeyPrefix

+ type BaseResourceConstraint struct

+ Value int64

+ func (brc *BaseResourceConstraint) IsAllowed(actualValue int64) bool

+ type BaseResourceManager interface

+ AllocateResource func(ctx context.Context, namespace pluginCore.ResourceNamespace, ...) (pluginCore.AllocationStatus, error)

+ GetID func() string

+ ReleaseResource func(ctx context.Context, namespace pluginCore.ResourceNamespace, ...) error

+ type Builder interface

+ BuildResourceManager func(ctx context.Context) (BaseResourceManager, error)

+ GetID func() string

+ GetResourceRegistrar func(namespacePrefix pluginCore.ResourceNamespace) pluginCore.ResourceRegistrar

+ func GetResourceManagerBuilderByType(ctx context.Context, managerType rmConfig.Type, scope promutils.Scope) (Builder, error)

+ type FullyQualifiedResourceConstraint struct

+ TargetedPrefixString string

+ Value int64

+ func (fqrc *FullyQualifiedResourceConstraint) IsAllowed(actualValue int64) bool

+ type Metrics interface

+ GetScope func() promutils.Scope

+ type NoopResourceManager struct

+ func (*NoopResourceManager) AllocateResource(ctx context.Context, namespace pluginCore.ResourceNamespace, ...) (pluginCore.AllocationStatus, error)

+ func (*NoopResourceManager) GetID() string

+ func (*NoopResourceManager) ReleaseResource(ctx context.Context, namespace pluginCore.ResourceNamespace, ...) error

+ type NoopResourceManagerBuilder struct

+ func (r *NoopResourceManagerBuilder) BuildResourceManager(ctx context.Context) (BaseResourceManager, error)

+ func (r *NoopResourceManagerBuilder) GetID() string

+ func (r *NoopResourceManagerBuilder) GetResourceRegistrar(namespacePrefix pluginCore.ResourceNamespace) pluginCore.ResourceRegistrar

+ func (r *NoopResourceManagerBuilder) RegisterResourceQuota(ctx context.Context, namespace pluginCore.ResourceNamespace, quota int) error

+ type Proxy struct

+ ExecutionIdentifier *core.TaskExecutionIdentifier

+ ResourceNamespacePrefix pluginCore.ResourceNamespace

+ ResourcePoolInfo map[string]*event.ResourcePoolInfo

+ func (p Proxy) AllocateResource(ctx context.Context, namespace pluginCore.ResourceNamespace, ...) (pluginCore.AllocationStatus, error)

+ func (p Proxy) ComposeResourceConstraint(spec pluginCore.ResourceConstraintsSpec) []FullyQualifiedResourceConstraint

+ func (p Proxy) GetResourcePoolInfo() []*event.ResourcePoolInfo

+ func (p Proxy) ReleaseResource(ctx context.Context, namespace pluginCore.ResourceNamespace, ...) error

+ type Redis struct

+ func (r *Redis) Ping() (string, error)

+ func (r *Redis) SAdd(key string, member interface{}) (int64, error)

+ func (r *Redis) SCard(key string) (int64, error)

+ func (r *Redis) SIsMember(key string, member interface{}) (bool, error)

+ func (r *Redis) SMembers(key string) ([]string, error)

+ func (r *Redis) SRem(key string, member interface{}) (int64, error)

+ type RedisClient interface

+ Ping func() (string, error)

+ SAdd func(string, interface{}) (int64, error)

+ SCard func(string) (int64, error)

+ SIsMember func(string, interface{}) (bool, error)

+ SMembers func(string) ([]string, error)

+ SRem func(string, interface{}) (int64, error)

+ func NewRedisClient(ctx context.Context, config config.RedisConfig) (RedisClient, error)

+ type RedisResourceManager struct

+ MetricsScope promutils.Scope

+ func (r *RedisResourceManager) AllocateResource(ctx context.Context, namespace pluginCore.ResourceNamespace, ...) (pluginCore.AllocationStatus, error)

+ func (r *RedisResourceManager) GetID() string

+ func (r *RedisResourceManager) ReleaseResource(ctx context.Context, namespace pluginCore.ResourceNamespace, ...) error

+ type RedisResourceManagerBuilder struct

+ MetricsScope promutils.Scope

+ func NewRedisResourceManagerBuilder(_ context.Context, client RedisClient, scope promutils.Scope) (*RedisResourceManagerBuilder, error)

+ func (r *RedisResourceManagerBuilder) BuildResourceManager(ctx context.Context) (BaseResourceManager, error)

+ func (r *RedisResourceManagerBuilder) GetID() string

+ func (r *RedisResourceManagerBuilder) GetResourceRegistrar(namespacePrefix pluginCore.ResourceNamespace) pluginCore.ResourceRegistrar

+ func (r *RedisResourceManagerBuilder) RegisterResourceQuota(ctx context.Context, namespace pluginCore.ResourceNamespace, quota int) error

+ type RedisResourceManagerMetrics struct

+ AllocatedTokensGauge prometheus.Gauge

+ ApproximateBackedUpLength prometheus.Gauge

+ RedisSizeCheckTime promutils.StopWatch

+ Scope promutils.Scope

+ func NewRedisResourceManagerMetrics(scope promutils.Scope) *RedisResourceManagerMetrics

+ func (rrmm RedisResourceManagerMetrics) GetScope() promutils.Scope

+ type Resource struct

+ type ResourceConstraint interface

+ IsAllowed func(int64) bool

+ type ResourceRegistrarProxy struct

+ ResourceNamespacePrefix pluginCore.ResourceNamespace

+ func (p ResourceRegistrarProxy) RegisterResourceQuota(ctx context.Context, namespace pluginCore.ResourceNamespace, quota int) error

+ type TaskResourceManager interface

+ GetResourcePoolInfo func() []*event.ResourcePoolInfo

+ func GetTaskResourceManager(r BaseResourceManager, resourceNamespacePrefix pluginCore.ResourceNamespace, ...) TaskResourceManager

+ type Token string

+ type TokenPrefix string

+ func ComposeTokenPrefix(id *core.TaskExecutionIdentifier) TokenPrefix