batch

package
v0.0.0-...-7aac2a2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 12, 2026 License: AGPL-3.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ReplicationWorkersWait = "replication_workers_wait"
	KeyRotationWorkersWait = "keyrotation_workers_wait"
	ExpirationWorkersWait  = "expiration_workers_wait"

	EnvReplicationWorkersWait   = "MINIO_BATCH_REPLICATION_WORKERS_WAIT"
	EnvKeyRotationWorkersWait   = "MINIO_BATCH_KEYROTATION_WORKERS_WAIT"
	EnvKeyExpirationWorkersWait = "MINIO_BATCH_EXPIRATION_WORKERS_WAIT"
)

Batch job environment variables

Variables

View Source 
var DefaultKVS = config.KVS{
	config.KV{
		Key:   ReplicationWorkersWait,
		Value: "0ms",
	},
	config.KV{
		Key:   KeyRotationWorkersWait,
		Value: "0ms",
	},
	config.KV{
		Key:   ExpirationWorkersWait,
		Value: "0ms",
	},
}

DefaultKVS - default KV config for batch job settings

View Source 
var (

	// Help provides help for config values
	Help = config.HelpKVS{
		config.HelpKV{
			Key:         ReplicationWorkersWait,
			Description: `maximum sleep duration between objects to slow down batch replication operation` + defaultHelpPostfix(ReplicationWorkersWait),
			Optional:    true,
			Type:        "duration",
		},
		config.HelpKV{
			Key:         KeyRotationWorkersWait,
			Description: `maximum sleep duration between objects to slow down batch keyrotation operation` + defaultHelpPostfix(KeyRotationWorkersWait),
			Optional:    true,
			Type:        "duration",
		},
		config.HelpKV{
			Key:         ExpirationWorkersWait,
			Description: "maximum sleep duration between objects to slow down batch expiration operation" + defaultHelpPostfix(ExpirationWorkersWait),
			Optional:    true,
			Type:        "duration",
		},
	}
)

Help template for batch feature.

Functions

This section is empty.

Types

type Config 

type Config struct {
	ReplicationWorkersWait time.Duration `json:"replicationWorkersWait"`
	KeyRotationWorkersWait time.Duration `json:"keyRotationWorkersWait"`
	ExpirationWorkersWait  time.Duration `json:"expirationWorkersWait"`
}

Config represents the batch job settings.

func LookupConfig 

func LookupConfig(kvs config.KVS) (cfg Config, err error)

LookupConfig - lookup config and override with valid environment settings if any.

func (Config) Clone 

func (opts Config) Clone() Config

Clone returns a copy of Config value

func (Config) ExpirationWait 

func (opts Config) ExpirationWait() time.Duration

ExpirationWait returns the duration for which a batch expiration worker would wait before working on next object.

func (Config) KeyRotationWait 

func (opts Config) KeyRotationWait() time.Duration

KeyRotationWait returns the duration for which a batch key-rotation worker would wait before working on next object.

func (Config) ReplicationWait 

func (opts Config) ReplicationWait() time.Duration

ReplicationWait returns the duration for which a batch replication worker would wait before working on next object.

func (*Config) Update 

func (opts *Config) Update(nopts Config)

Update updates opts with nopts

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.