adminhandler

package

Go to main page

Versions in this module

v0

v0.12.0

Jul 26, 2026

Changes in this version

type AdminAPI

+ func (a *AdminAPI) ClearDiskWeight(ctx context.Context, params adminapi.ClearDiskWeightParams) error

+ func (a *AdminAPI) ListDiskWeights(ctx context.Context) (*adminapi.DiskWeightList, error)

+ func (a *AdminAPI) SetDiskWeight(ctx context.Context, req *adminapi.SetDiskWeightRequest, ...) (*adminapi.DiskWeight, error)

+ type DiskWeight struct

+ Disk string

+ Node string

+ Reason string

+ Weight float64

+ func (d DiskWeight) Drained() bool

+ type DiskWeightStore interface

+ ClearDiskWeight func(ctx context.Context, node, disk string) error

+ ListDiskWeights func(ctx context.Context) ([]DiskWeight, error)

+ SetDiskWeight func(ctx context.Context, node, disk string, weight float64, reason string) error

type Options

+ DiskWeights DiskWeightStore

v0.11.0

Jul 26, 2026

Changes in this version

type AdminAPI

+ func (a *AdminAPI) GetBucketUsage(ctx context.Context) (*adminapi.BucketUsageList, error)

+ type BucketUsage struct

+ Bucket string

+ Bytes int64

+ Counted time.Time

+ Objects int64

+ Updated time.Time

+ type BucketUsageSource interface

+ BucketUsage func(ctx context.Context) ([]BucketUsage, error)

type NodeDisk

+ Bytes int64

+ Counted bool

+ Fragments int64

type Options

+ BucketUsage BucketUsageSource

v0.10.0

Jul 26, 2026

Changes in this version

+ type NodeDisk struct

+ Err string

+ HasData bool

+ ID string

type NodeLive

+ Disks []NodeDisk

v0.9.0

Jul 25, 2026

Changes in this version

+ var ErrMigrationConflict = errors.New("migration conflict")

type AdminAPI

+ func (a *AdminAPI) ApplyMigrations(ctx context.Context) (*adminapi.MigrationStatus, error)

+ func (a *AdminAPI) GetMigrationStatus(ctx context.Context) (*adminapi.MigrationStatus, error)

type ClusterNode

+ Live *NodeLive

+ LiveError string

+ type Migration struct

+ Description string

+ Version int

+ type MigrationControl interface

+ Apply func(ctx context.Context) (MigrationStatus, error)

+ Status func(ctx context.Context) (MigrationStatus, error)

+ type MigrationStatus struct

+ BinaryVersion int

+ ClusterVersion int

+ LastApplied []int

+ LastErr string

+ Pending []Migration

+ Running bool

+ type NodeLive struct

+ Converted int64

+ CorruptReplicas int64

+ ECUnverified bool

+ RebalanceErr string

+ RebalanceFailed int

+ RebalanceObjects int

+ RebalanceRelocated int

+ RebalanceState RebalanceState

+ RebuiltFragments int64

+ RepairQueueDepth int

+ SchemaVersion int

+ ScrubFailed int64

+ ScrubObjects int64

+ ScrubPasses int64

+ ScrubRepaired int64

+ SweptStale int64

+ UptimeSeconds float64

+ Version string

type Options

+ Migrations MigrationControl

v0.8.0

Jul 24, 2026

Changes in this version

+ var ErrPublicReadRejected = errors.New("public-read bucket list rejected")

type AdminAPI

+ func (a *AdminAPI) GetPublicReadBuckets(ctx context.Context) (*adminapi.PublicReadBuckets, error)

+ func (a *AdminAPI) SetPublicReadBuckets(ctx context.Context, req *adminapi.SetPublicReadBucketsRequest) (*adminapi.PublicReadBuckets, error)

+ type CredentialManager interface

+ Create func(in auth.CreateInput) (*auth.Created, error)

+ Delete func(accessKey string) error

+ List func() []auth.KeyInfo

type Options

+ PublicRead PublicReadStore

+ type PublicReadStore interface

+ PublicReadBuckets func(ctx context.Context) ([]string, error)

+ SetPublicReadBuckets func(ctx context.Context, buckets []string) error

v0.7.0

Jul 24, 2026

Changes in this version

+ var ErrBucketNotFound = errors.New("bucket not found")

+ var ErrSchemeRejected = errors.New("scheme rejected")

type AdminAPI

+ func (a *AdminAPI) GetBucketScheme(ctx context.Context, params adminapi.GetBucketSchemeParams) (*adminapi.BucketScheme, error)

+ func (a *AdminAPI) SetBucketScheme(ctx context.Context, req *adminapi.SetBucketSchemeRequest, ...) (*adminapi.BucketScheme, error)

+ type BucketSchemeStore interface

+ SchemeOverride func(ctx context.Context, bucket string) (string, error)

+ SetScheme func(ctx context.Context, bucket, scheme string) error

type Options

+ BucketSchemes BucketSchemeStore

+ ClusterDefaultScheme string

v0.6.0

Jul 24, 2026

Changes in this version

type AdminAPI

+ func (a *AdminAPI) GetClusterStatus(ctx context.Context) (*adminapi.ClusterStatus, error)

+ func (a *AdminAPI) ReloadConfig(ctx context.Context) (*adminapi.ReloadResult, error)

+ type ClusterDisk struct

+ FreeBytes uint64

+ ID string

+ TotalBytes uint64

+ Weight float64

+ type ClusterNode struct

+ Addr string

+ Disks []ClusterDisk

+ ID string

+ Rack string

+ type ClusterStatus struct

+ BinarySchemaVersion int

+ Cursor string

+ Nodes []ClusterNode

+ RebalanceCursorBucket string

+ RebalanceRunning bool

+ SchemaVersion int

+ type ClusterStatusSource interface

+ ClusterStatus func(ctx context.Context) (ClusterStatus, error)

type Options

+ ClusterStatus ClusterStatusSource

+ ConfigRevision func() string

+ Reloader Reloader

+ type ReloadResult struct

+ ConfigRevision string

+ Reloaded []string

+ type Reloader interface

+ Reload func(ctx context.Context) (ReloadResult, error)

v0.5.0

Jul 24, 2026

Changes in this version

+ var ErrRebalanceConflict = errors.New("invalid rebalance transition")

+ func UIMiddleware() func(http.Handler) http.Handler

+ type AdminAPI struct

+ func NewAdminAPI(opts Options) *AdminAPI

+ func (a *AdminAPI) ControlRebalance(ctx context.Context, req *adminapi.RebalanceControlRequest) (*adminapi.RebalanceStatus, error)

+ func (a *AdminAPI) CreateAccessKey(_ context.Context, req *adminapi.CreateAccessKeyRequest) (*adminapi.CreatedAccessKey, error)

+ func (a *AdminAPI) DeleteAccessKey(_ context.Context, params adminapi.DeleteAccessKeyParams) error

+ func (a *AdminAPI) GetInfo(_ context.Context) (*adminapi.InstanceInfo, error)

+ func (a *AdminAPI) GetRebalanceStatus(ctx context.Context) (*adminapi.RebalanceStatus, error)

+ func (a *AdminAPI) ListAccessKeys(_ context.Context) (*adminapi.AccessKeyList, error)

+ func (a *AdminAPI) NewError(_ context.Context, err error) *adminapi.ErrorStatusCode

+ type BuildInfo struct

+ Commit string

+ Version string

+ type Options struct

+ AuthEnabled bool

+ Build BuildInfo

+ Manager *auth.Manager

+ Rebalance RebalanceControl

+ StartTime time.Time

+ type RebalanceControl interface

+ Pause func(ctx context.Context) error

+ Resume func(ctx context.Context) error

+ Start func(ctx context.Context) error

+ Status func(ctx context.Context) RebalanceStatus

+ type RebalanceState string

+ const RebalanceDone

+ const RebalanceFailed

+ const RebalanceIdle

+ const RebalancePaused

+ const RebalanceRunning

+ const RebalanceWaiting

+ type RebalanceStatus struct

+ CursorBucket string

+ CursorKey string

+ Err string

+ Failed int

+ FinishedAt time.Time

+ Objects int

+ Relocated int

+ RepairQueueDepth int

+ StartedAt time.Time

+ State RebalanceState

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL