adminapi

package

Go to main page

Versions in this module

v0

v0.12.0

Jul 26, 2026

Changes in this version

+ type ClearDiskWeightNoContent struct

+ type ClearDiskWeightParams struct

+ Disk string

+ Node string

type Client

+ func (c *Client) ClearDiskWeight(ctx context.Context, params ClearDiskWeightParams) error

+ func (c *Client) ListDiskWeights(ctx context.Context) (*DiskWeightList, error)

+ func (c *Client) SetDiskWeight(ctx context.Context, request *SetDiskWeightRequest, params SetDiskWeightParams) (*DiskWeight, error)

+ type DiskWeight struct

+ Disk string

+ Drained OptBool

+ Node string

+ Reason OptString

+ Weight float64

+ func (s *DiskWeight) Decode(d *jx.Decoder) error

+ func (s *DiskWeight) Encode(e *jx.Encoder)

+ func (s *DiskWeight) GetDisk() string

+ func (s *DiskWeight) GetDrained() OptBool

+ func (s *DiskWeight) GetNode() string

+ func (s *DiskWeight) GetReason() OptString

+ func (s *DiskWeight) GetWeight() float64

+ func (s *DiskWeight) MarshalJSON() ([]byte, error)

+ func (s *DiskWeight) SetDisk(val string)

+ func (s *DiskWeight) SetDrained(val OptBool)

+ func (s *DiskWeight) SetNode(val string)

+ func (s *DiskWeight) SetReason(val OptString)

+ func (s *DiskWeight) SetWeight(val float64)

+ func (s *DiskWeight) UnmarshalJSON(data []byte) error

+ func (s *DiskWeight) Validate() error

+ type DiskWeightList struct

+ Overrides []DiskWeight

+ func (s *DiskWeightList) Decode(d *jx.Decoder) error

+ func (s *DiskWeightList) Encode(e *jx.Encoder)

+ func (s *DiskWeightList) GetOverrides() []DiskWeight

+ func (s *DiskWeightList) MarshalJSON() ([]byte, error)

+ func (s *DiskWeightList) SetOverrides(val []DiskWeight)

+ func (s *DiskWeightList) UnmarshalJSON(data []byte) error

+ func (s *DiskWeightList) Validate() error

type Handler

+ ClearDiskWeight func(ctx context.Context, params ClearDiskWeightParams) error

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

+ SetDiskWeight func(ctx context.Context, req *SetDiskWeightRequest, params SetDiskWeightParams) (*DiskWeight, error)

type Invoker

+ ClearDiskWeight func(ctx context.Context, params ClearDiskWeightParams) error

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

+ SetDiskWeight func(ctx context.Context, request *SetDiskWeightRequest, params SetDiskWeightParams) (*DiskWeight, error)

type OperationName

+ const ClearDiskWeightOperation

+ const ListDiskWeightsOperation

+ const SetDiskWeightOperation

+ type SetDiskWeightParams struct

+ Disk string

+ Node string

+ type SetDiskWeightRequest struct

+ Reason OptString

+ Weight float64

+ func (s *SetDiskWeightRequest) Decode(d *jx.Decoder) error

+ func (s *SetDiskWeightRequest) Encode(e *jx.Encoder)

+ func (s *SetDiskWeightRequest) GetReason() OptString

+ func (s *SetDiskWeightRequest) GetWeight() float64

+ func (s *SetDiskWeightRequest) MarshalJSON() ([]byte, error)

+ func (s *SetDiskWeightRequest) SetReason(val OptString)

+ func (s *SetDiskWeightRequest) SetWeight(val float64)

+ func (s *SetDiskWeightRequest) UnmarshalJSON(data []byte) error

+ func (s *SetDiskWeightRequest) Validate() error

type UnimplementedHandler

+ func (UnimplementedHandler) ClearDiskWeight(ctx context.Context, params ClearDiskWeightParams) error

+ func (UnimplementedHandler) ListDiskWeights(ctx context.Context) (r *DiskWeightList, _ error)

+ func (UnimplementedHandler) SetDiskWeight(ctx context.Context, req *SetDiskWeightRequest, params SetDiskWeightParams) (r *DiskWeight, _ error)

v0.11.0

Jul 26, 2026

Changes in this version

+ type BucketUsage struct

+ Bucket string

+ Bytes int64

+ Counted OptDateTime

+ Objects int64

+ Updated OptDateTime

+ func (s *BucketUsage) Decode(d *jx.Decoder) error

+ func (s *BucketUsage) Encode(e *jx.Encoder)

+ func (s *BucketUsage) GetBucket() string

+ func (s *BucketUsage) GetBytes() int64

+ func (s *BucketUsage) GetCounted() OptDateTime

+ func (s *BucketUsage) GetObjects() int64

+ func (s *BucketUsage) GetUpdated() OptDateTime

+ func (s *BucketUsage) MarshalJSON() ([]byte, error)

+ func (s *BucketUsage) SetBucket(val string)

+ func (s *BucketUsage) SetBytes(val int64)

+ func (s *BucketUsage) SetCounted(val OptDateTime)

+ func (s *BucketUsage) SetObjects(val int64)

+ func (s *BucketUsage) SetUpdated(val OptDateTime)

+ func (s *BucketUsage) UnmarshalJSON(data []byte) error

+ type BucketUsageList struct

+ Buckets []BucketUsage

+ Bytes OptInt64

+ Objects OptInt64

+ func (s *BucketUsageList) Decode(d *jx.Decoder) error

+ func (s *BucketUsageList) Encode(e *jx.Encoder)

+ func (s *BucketUsageList) GetBuckets() []BucketUsage

+ func (s *BucketUsageList) GetBytes() OptInt64

+ func (s *BucketUsageList) GetObjects() OptInt64

+ func (s *BucketUsageList) MarshalJSON() ([]byte, error)

+ func (s *BucketUsageList) SetBuckets(val []BucketUsage)

+ func (s *BucketUsageList) SetBytes(val OptInt64)

+ func (s *BucketUsageList) SetObjects(val OptInt64)

+ func (s *BucketUsageList) UnmarshalJSON(data []byte) error

+ func (s *BucketUsageList) Validate() error

type Client

+ func (c *Client) GetBucketUsage(ctx context.Context) (*BucketUsageList, error)

type ClusterDisk

+ Bytes OptInt64

+ Fragments OptInt64

+ func (s *ClusterDisk) GetBytes() OptInt64

+ func (s *ClusterDisk) GetFragments() OptInt64

+ func (s *ClusterDisk) SetBytes(val OptInt64)

+ func (s *ClusterDisk) SetFragments(val OptInt64)

type Handler

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

type Invoker

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

type OperationName

+ const GetBucketUsageOperation

type UnimplementedHandler

+ func (UnimplementedHandler) GetBucketUsage(ctx context.Context) (r *BucketUsageList, _ error)

v0.10.0

Jul 26, 2026

Changes in this version

type ClusterDisk

+ DataError OptString

+ HasData OptBool

+ func (s *ClusterDisk) GetDataError() OptString

+ func (s *ClusterDisk) GetHasData() OptBool

+ func (s *ClusterDisk) SetDataError(val OptString)

+ func (s *ClusterDisk) SetHasData(val OptBool)

+ type OptBool struct

+ Set bool

+ Value bool

+ func NewOptBool(v bool) OptBool

+ func (o *OptBool) Decode(d *jx.Decoder) error

+ func (o *OptBool) Reset()

+ func (o *OptBool) SetTo(v bool)

+ func (o OptBool) Encode(e *jx.Encoder)

+ func (o OptBool) Get() (v bool, ok bool)

+ func (o OptBool) IsSet() bool

+ func (o OptBool) Or(d bool) bool

+ func (s *OptBool) UnmarshalJSON(data []byte) error

+ func (s OptBool) MarshalJSON() ([]byte, error)

v0.9.0

Jul 25, 2026

Changes in this version

type Client

+ func (c *Client) ApplyMigrations(ctx context.Context) (*MigrationStatus, error)

+ func (c *Client) GetMigrationStatus(ctx context.Context) (*MigrationStatus, error)

type ClusterNode

+ Live OptClusterNodeLive

+ LiveError OptString

+ func (s *ClusterNode) GetLive() OptClusterNodeLive

+ func (s *ClusterNode) GetLiveError() OptString

+ func (s *ClusterNode) SetLive(val OptClusterNodeLive)

+ func (s *ClusterNode) SetLiveError(val OptString)

+ type ClusterNodeLive struct

+ ConvertedObjects int64

+ CorruptReplicas int64

+ EcUnverified bool

+ RebalanceError OptString

+ RebalanceFailed int

+ RebalanceObjects int

+ RebalanceRelocated int

+ RebalanceState RebalanceState

+ RebuiltFragments int64

+ RepairQueueDepth int

+ SchemaVersion OptInt

+ ScrubFailed int64

+ ScrubObjects int64

+ ScrubPasses int64

+ ScrubRepaired int64

+ SweptStale int64

+ UptimeSeconds OptFloat64

+ Version OptString

+ func (s *ClusterNodeLive) Decode(d *jx.Decoder) error

+ func (s *ClusterNodeLive) Encode(e *jx.Encoder)

+ func (s *ClusterNodeLive) GetConvertedObjects() int64

+ func (s *ClusterNodeLive) GetCorruptReplicas() int64

+ func (s *ClusterNodeLive) GetEcUnverified() bool

+ func (s *ClusterNodeLive) GetRebalanceError() OptString

+ func (s *ClusterNodeLive) GetRebalanceFailed() int

+ func (s *ClusterNodeLive) GetRebalanceObjects() int

+ func (s *ClusterNodeLive) GetRebalanceRelocated() int

+ func (s *ClusterNodeLive) GetRebalanceState() RebalanceState

+ func (s *ClusterNodeLive) GetRebuiltFragments() int64

+ func (s *ClusterNodeLive) GetRepairQueueDepth() int

+ func (s *ClusterNodeLive) GetSchemaVersion() OptInt

+ func (s *ClusterNodeLive) GetScrubFailed() int64

+ func (s *ClusterNodeLive) GetScrubObjects() int64

+ func (s *ClusterNodeLive) GetScrubPasses() int64

+ func (s *ClusterNodeLive) GetScrubRepaired() int64

+ func (s *ClusterNodeLive) GetSweptStale() int64

+ func (s *ClusterNodeLive) GetUptimeSeconds() OptFloat64

+ func (s *ClusterNodeLive) GetVersion() OptString

+ func (s *ClusterNodeLive) MarshalJSON() ([]byte, error)

+ func (s *ClusterNodeLive) SetConvertedObjects(val int64)

+ func (s *ClusterNodeLive) SetCorruptReplicas(val int64)

+ func (s *ClusterNodeLive) SetEcUnverified(val bool)

+ func (s *ClusterNodeLive) SetRebalanceError(val OptString)

+ func (s *ClusterNodeLive) SetRebalanceFailed(val int)

+ func (s *ClusterNodeLive) SetRebalanceObjects(val int)

+ func (s *ClusterNodeLive) SetRebalanceRelocated(val int)

+ func (s *ClusterNodeLive) SetRebalanceState(val RebalanceState)

+ func (s *ClusterNodeLive) SetRebuiltFragments(val int64)

+ func (s *ClusterNodeLive) SetRepairQueueDepth(val int)

+ func (s *ClusterNodeLive) SetSchemaVersion(val OptInt)

+ func (s *ClusterNodeLive) SetScrubFailed(val int64)

+ func (s *ClusterNodeLive) SetScrubObjects(val int64)

+ func (s *ClusterNodeLive) SetScrubPasses(val int64)

+ func (s *ClusterNodeLive) SetScrubRepaired(val int64)

+ func (s *ClusterNodeLive) SetSweptStale(val int64)

+ func (s *ClusterNodeLive) SetUptimeSeconds(val OptFloat64)

+ func (s *ClusterNodeLive) SetVersion(val OptString)

+ func (s *ClusterNodeLive) UnmarshalJSON(data []byte) error

+ func (s *ClusterNodeLive) Validate() error

type ClusterStatus

+ NodesNotReporting int

+ NodesReporting int

+ RepairQueueDepth int

+ func (s *ClusterStatus) GetNodesNotReporting() int

+ func (s *ClusterStatus) GetNodesReporting() int

+ func (s *ClusterStatus) GetRepairQueueDepth() int

+ func (s *ClusterStatus) SetNodesNotReporting(val int)

+ func (s *ClusterStatus) SetNodesReporting(val int)

+ func (s *ClusterStatus) SetRepairQueueDepth(val int)

type Handler

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

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

type Invoker

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

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

+ type Migration struct

+ Description string

+ Version int

+ func (s *Migration) Decode(d *jx.Decoder) error

+ func (s *Migration) Encode(e *jx.Encoder)

+ func (s *Migration) GetDescription() string

+ func (s *Migration) GetVersion() int

+ func (s *Migration) MarshalJSON() ([]byte, error)

+ func (s *Migration) SetDescription(val string)

+ func (s *Migration) SetVersion(val int)

+ func (s *Migration) UnmarshalJSON(data []byte) error

+ type MigrationStatus struct

+ BinarySchemaVersion int

+ ClusterSchemaVersion int

+ LastApplied []int

+ LastError OptString

+ Pending []Migration

+ Running bool

+ State ClusterState

+ UpToDate bool

+ func (s *MigrationStatus) Decode(d *jx.Decoder) error

+ func (s *MigrationStatus) Encode(e *jx.Encoder)

+ func (s *MigrationStatus) GetBinarySchemaVersion() int

+ func (s *MigrationStatus) GetClusterSchemaVersion() int

+ func (s *MigrationStatus) GetLastApplied() []int

+ func (s *MigrationStatus) GetLastError() OptString

+ func (s *MigrationStatus) GetPending() []Migration

+ func (s *MigrationStatus) GetRunning() bool

+ func (s *MigrationStatus) GetState() ClusterState

+ func (s *MigrationStatus) GetUpToDate() bool

+ func (s *MigrationStatus) MarshalJSON() ([]byte, error)

+ func (s *MigrationStatus) SetBinarySchemaVersion(val int)

+ func (s *MigrationStatus) SetClusterSchemaVersion(val int)

+ func (s *MigrationStatus) SetLastApplied(val []int)

+ func (s *MigrationStatus) SetLastError(val OptString)

+ func (s *MigrationStatus) SetPending(val []Migration)

+ func (s *MigrationStatus) SetRunning(val bool)

+ func (s *MigrationStatus) SetState(val ClusterState)

+ func (s *MigrationStatus) SetUpToDate(val bool)

+ func (s *MigrationStatus) UnmarshalJSON(data []byte) error

+ func (s *MigrationStatus) Validate() error

type OperationName

+ const ApplyMigrationsOperation

+ const GetMigrationStatusOperation

+ type OptClusterNodeLive struct

+ Set bool

+ Value ClusterNodeLive

+ func NewOptClusterNodeLive(v ClusterNodeLive) OptClusterNodeLive

+ func (o *OptClusterNodeLive) Decode(d *jx.Decoder) error

+ func (o *OptClusterNodeLive) Reset()

+ func (o *OptClusterNodeLive) SetTo(v ClusterNodeLive)

+ func (o OptClusterNodeLive) Encode(e *jx.Encoder)

+ func (o OptClusterNodeLive) Get() (v ClusterNodeLive, ok bool)

+ func (o OptClusterNodeLive) IsSet() bool

+ func (o OptClusterNodeLive) Or(d ClusterNodeLive) ClusterNodeLive

+ func (s *OptClusterNodeLive) UnmarshalJSON(data []byte) error

+ func (s OptClusterNodeLive) MarshalJSON() ([]byte, error)

+ type OptInt struct

+ Set bool

+ Value int

+ func NewOptInt(v int) OptInt

+ func (o *OptInt) Decode(d *jx.Decoder) error

+ func (o *OptInt) Reset()

+ func (o *OptInt) SetTo(v int)

+ func (o OptInt) Encode(e *jx.Encoder)

+ func (o OptInt) Get() (v int, ok bool)

+ func (o OptInt) IsSet() bool

+ func (o OptInt) Or(d int) int

+ func (s *OptInt) UnmarshalJSON(data []byte) error

+ func (s OptInt) MarshalJSON() ([]byte, error)

type UnimplementedHandler

+ func (UnimplementedHandler) ApplyMigrations(ctx context.Context) (r *MigrationStatus, _ error)

+ func (UnimplementedHandler) GetMigrationStatus(ctx context.Context) (r *MigrationStatus, _ error)

v0.8.0

Jul 24, 2026

Changes in this version

type Client

+ func (c *Client) GetPublicReadBuckets(ctx context.Context) (*PublicReadBuckets, error)

+ func (c *Client) SetPublicReadBuckets(ctx context.Context, request *SetPublicReadBucketsRequest) (*PublicReadBuckets, error)

type Handler

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

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

type Invoker

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

+ SetPublicReadBuckets func(ctx context.Context, request *SetPublicReadBucketsRequest) (*PublicReadBuckets, error)

type OperationName

+ const GetPublicReadBucketsOperation

+ const SetPublicReadBucketsOperation

+ type PublicReadBuckets struct

+ Buckets []string

+ func (s *PublicReadBuckets) Decode(d *jx.Decoder) error

+ func (s *PublicReadBuckets) Encode(e *jx.Encoder)

+ func (s *PublicReadBuckets) GetBuckets() []string

+ func (s *PublicReadBuckets) MarshalJSON() ([]byte, error)

+ func (s *PublicReadBuckets) SetBuckets(val []string)

+ func (s *PublicReadBuckets) UnmarshalJSON(data []byte) error

+ func (s *PublicReadBuckets) Validate() error

+ type SetPublicReadBucketsRequest struct

+ Buckets []string

+ func (s *SetPublicReadBucketsRequest) Decode(d *jx.Decoder) error

+ func (s *SetPublicReadBucketsRequest) Encode(e *jx.Encoder)

+ func (s *SetPublicReadBucketsRequest) GetBuckets() []string

+ func (s *SetPublicReadBucketsRequest) MarshalJSON() ([]byte, error)

+ func (s *SetPublicReadBucketsRequest) SetBuckets(val []string)

+ func (s *SetPublicReadBucketsRequest) UnmarshalJSON(data []byte) error

+ func (s *SetPublicReadBucketsRequest) Validate() error

type UnimplementedHandler

+ func (UnimplementedHandler) GetPublicReadBuckets(ctx context.Context) (r *PublicReadBuckets, _ error)

+ func (UnimplementedHandler) SetPublicReadBuckets(ctx context.Context, req *SetPublicReadBucketsRequest) (r *PublicReadBuckets, _ error)

v0.7.0

Jul 24, 2026

Changes in this version

+ type BucketScheme struct

+ Bucket string

+ ClusterDefault string

+ IsDefault bool

+ Override OptString

+ Scheme string

+ func (s *BucketScheme) Decode(d *jx.Decoder) error

+ func (s *BucketScheme) Encode(e *jx.Encoder)

+ func (s *BucketScheme) GetBucket() string

+ func (s *BucketScheme) GetClusterDefault() string

+ func (s *BucketScheme) GetIsDefault() bool

+ func (s *BucketScheme) GetOverride() OptString

+ func (s *BucketScheme) GetScheme() string

+ func (s *BucketScheme) MarshalJSON() ([]byte, error)

+ func (s *BucketScheme) SetBucket(val string)

+ func (s *BucketScheme) SetClusterDefault(val string)

+ func (s *BucketScheme) SetIsDefault(val bool)

+ func (s *BucketScheme) SetOverride(val OptString)

+ func (s *BucketScheme) SetScheme(val string)

+ func (s *BucketScheme) UnmarshalJSON(data []byte) error

type Client

+ func (c *Client) GetBucketScheme(ctx context.Context, params GetBucketSchemeParams) (*BucketScheme, error)

+ func (c *Client) SetBucketScheme(ctx context.Context, request *SetBucketSchemeRequest, ...) (*BucketScheme, error)

+ type GetBucketSchemeParams struct

+ Bucket string

type Handler

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

+ SetBucketScheme func(ctx context.Context, req *SetBucketSchemeRequest, params SetBucketSchemeParams) (*BucketScheme, error)

type Invoker

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

+ SetBucketScheme func(ctx context.Context, request *SetBucketSchemeRequest, ...) (*BucketScheme, error)

type OperationName

+ const GetBucketSchemeOperation

+ const SetBucketSchemeOperation

+ type SetBucketSchemeParams struct

+ Bucket string

+ type SetBucketSchemeRequest struct

+ Scheme OptString

+ func (s *SetBucketSchemeRequest) Decode(d *jx.Decoder) error

+ func (s *SetBucketSchemeRequest) Encode(e *jx.Encoder)

+ func (s *SetBucketSchemeRequest) GetScheme() OptString

+ func (s *SetBucketSchemeRequest) MarshalJSON() ([]byte, error)

+ func (s *SetBucketSchemeRequest) SetScheme(val OptString)

+ func (s *SetBucketSchemeRequest) UnmarshalJSON(data []byte) error

type UnimplementedHandler

+ func (UnimplementedHandler) GetBucketScheme(ctx context.Context, params GetBucketSchemeParams) (r *BucketScheme, _ error)

+ func (UnimplementedHandler) SetBucketScheme(ctx context.Context, req *SetBucketSchemeRequest, params SetBucketSchemeParams) (r *BucketScheme, _ error)

v0.6.0

Jul 24, 2026

Changes in this version

+ func WithServerURL(ctx context.Context, u *url.URL) context.Context

+ type AccessKey struct

+ AccessKey string

+ CreatedAt OptDateTime

+ Grants []Grant

+ Source Source

+ func (s *AccessKey) Decode(d *jx.Decoder) error

+ func (s *AccessKey) Encode(e *jx.Encoder)

+ func (s *AccessKey) GetAccessKey() string

+ func (s *AccessKey) GetCreatedAt() OptDateTime

+ func (s *AccessKey) GetGrants() []Grant

+ func (s *AccessKey) GetSource() Source

+ func (s *AccessKey) MarshalJSON() ([]byte, error)

+ func (s *AccessKey) SetAccessKey(val string)

+ func (s *AccessKey) SetCreatedAt(val OptDateTime)

+ func (s *AccessKey) SetGrants(val []Grant)

+ func (s *AccessKey) SetSource(val Source)

+ func (s *AccessKey) UnmarshalJSON(data []byte) error

+ func (s *AccessKey) Validate() error

+ type AccessKeyList struct

+ Keys []AccessKey

+ func (s *AccessKeyList) Decode(d *jx.Decoder) error

+ func (s *AccessKeyList) Encode(e *jx.Encoder)

+ func (s *AccessKeyList) GetKeys() []AccessKey

+ func (s *AccessKeyList) MarshalJSON() ([]byte, error)

+ func (s *AccessKeyList) SetKeys(val []AccessKey)

+ func (s *AccessKeyList) UnmarshalJSON(data []byte) error

+ func (s *AccessKeyList) Validate() error

+ type Client struct

+ func NewClient(serverURL string, opts ...ClientOption) (*Client, error)

+ func (c *Client) ControlRebalance(ctx context.Context, request *RebalanceControlRequest) (*RebalanceStatus, error)

+ func (c *Client) CreateAccessKey(ctx context.Context, request *CreateAccessKeyRequest) (*CreatedAccessKey, error)

+ func (c *Client) DeleteAccessKey(ctx context.Context, params DeleteAccessKeyParams) error

+ func (c *Client) GetClusterStatus(ctx context.Context) (*ClusterStatus, error)

+ func (c *Client) GetInfo(ctx context.Context) (*InstanceInfo, error)

+ func (c *Client) GetRebalanceStatus(ctx context.Context) (*RebalanceStatus, error)

+ func (c *Client) ListAccessKeys(ctx context.Context) (*AccessKeyList, error)

+ func (c *Client) ReloadConfig(ctx context.Context) (*ReloadResult, error)

+ type ClientOption interface

+ func WithClient(client ht.Client) ClientOption

+ type ClusterDisk struct

+ FreeBytes OptInt64

+ Fullness OptFloat64

+ ID string

+ TotalBytes OptInt64

+ Weight float64

+ func (s *ClusterDisk) Decode(d *jx.Decoder) error

+ func (s *ClusterDisk) Encode(e *jx.Encoder)

+ func (s *ClusterDisk) GetFreeBytes() OptInt64

+ func (s *ClusterDisk) GetFullness() OptFloat64

+ func (s *ClusterDisk) GetID() string

+ func (s *ClusterDisk) GetTotalBytes() OptInt64

+ func (s *ClusterDisk) GetWeight() float64

+ func (s *ClusterDisk) MarshalJSON() ([]byte, error)

+ func (s *ClusterDisk) SetFreeBytes(val OptInt64)

+ func (s *ClusterDisk) SetFullness(val OptFloat64)

+ func (s *ClusterDisk) SetID(val string)

+ func (s *ClusterDisk) SetTotalBytes(val OptInt64)

+ func (s *ClusterDisk) SetWeight(val float64)

+ func (s *ClusterDisk) UnmarshalJSON(data []byte) error

+ func (s *ClusterDisk) Validate() error

+ type ClusterNode struct

+ Addr OptString

+ Disks []ClusterDisk

+ ID string

+ Rack OptString

+ func (s *ClusterNode) Decode(d *jx.Decoder) error

+ func (s *ClusterNode) Encode(e *jx.Encoder)

+ func (s *ClusterNode) GetAddr() OptString

+ func (s *ClusterNode) GetDisks() []ClusterDisk

+ func (s *ClusterNode) GetID() string

+ func (s *ClusterNode) GetRack() OptString

+ func (s *ClusterNode) MarshalJSON() ([]byte, error)

+ func (s *ClusterNode) SetAddr(val OptString)

+ func (s *ClusterNode) SetDisks(val []ClusterDisk)

+ func (s *ClusterNode) SetID(val string)

+ func (s *ClusterNode) SetRack(val OptString)

+ func (s *ClusterNode) UnmarshalJSON(data []byte) error

+ func (s *ClusterNode) Validate() error

+ type ClusterState string

+ const ClusterStateDisabled

+ const ClusterStateOk

+ func (ClusterState) AllValues() []ClusterState

+ func (s *ClusterState) Decode(d *jx.Decoder) error

+ func (s *ClusterState) UnmarshalJSON(data []byte) error

+ func (s *ClusterState) UnmarshalText(data []byte) error

+ func (s ClusterState) Encode(e *jx.Encoder)

+ func (s ClusterState) MarshalJSON() ([]byte, error)

+ func (s ClusterState) MarshalText() ([]byte, error)

+ func (s ClusterState) Validate() error

+ type ClusterStatus struct

+ BinarySchemaVersion int

+ DiskCount int

+ FreeBytes int64

+ NodeCount int

+ Nodes []ClusterNode

+ PlacementSkew float64

+ RebalanceCursorBucket OptString

+ RebalanceCursorKey OptString

+ RebalanceRunning bool

+ SchemaVersion int

+ State ClusterState

+ TotalBytes int64

+ func (s *ClusterStatus) Decode(d *jx.Decoder) error

+ func (s *ClusterStatus) Encode(e *jx.Encoder)

+ func (s *ClusterStatus) GetBinarySchemaVersion() int

+ func (s *ClusterStatus) GetDiskCount() int

+ func (s *ClusterStatus) GetFreeBytes() int64

+ func (s *ClusterStatus) GetNodeCount() int

+ func (s *ClusterStatus) GetNodes() []ClusterNode

+ func (s *ClusterStatus) GetPlacementSkew() float64

+ func (s *ClusterStatus) GetRebalanceCursorBucket() OptString

+ func (s *ClusterStatus) GetRebalanceCursorKey() OptString

+ func (s *ClusterStatus) GetRebalanceRunning() bool

+ func (s *ClusterStatus) GetSchemaVersion() int

+ func (s *ClusterStatus) GetState() ClusterState

+ func (s *ClusterStatus) GetTotalBytes() int64

+ func (s *ClusterStatus) MarshalJSON() ([]byte, error)

+ func (s *ClusterStatus) SetBinarySchemaVersion(val int)

+ func (s *ClusterStatus) SetDiskCount(val int)

+ func (s *ClusterStatus) SetFreeBytes(val int64)

+ func (s *ClusterStatus) SetNodeCount(val int)

+ func (s *ClusterStatus) SetNodes(val []ClusterNode)

+ func (s *ClusterStatus) SetPlacementSkew(val float64)

+ func (s *ClusterStatus) SetRebalanceCursorBucket(val OptString)

+ func (s *ClusterStatus) SetRebalanceCursorKey(val OptString)

+ func (s *ClusterStatus) SetRebalanceRunning(val bool)

+ func (s *ClusterStatus) SetSchemaVersion(val int)

+ func (s *ClusterStatus) SetState(val ClusterState)

+ func (s *ClusterStatus) SetTotalBytes(val int64)

+ func (s *ClusterStatus) UnmarshalJSON(data []byte) error

+ func (s *ClusterStatus) Validate() error

+ type CreateAccessKeyRequest struct

+ AccessKey OptString

+ Grants []Grant

+ SecretKey OptString

+ func (s *CreateAccessKeyRequest) Decode(d *jx.Decoder) error

+ func (s *CreateAccessKeyRequest) Encode(e *jx.Encoder)

+ func (s *CreateAccessKeyRequest) GetAccessKey() OptString

+ func (s *CreateAccessKeyRequest) GetGrants() []Grant

+ func (s *CreateAccessKeyRequest) GetSecretKey() OptString

+ func (s *CreateAccessKeyRequest) MarshalJSON() ([]byte, error)

+ func (s *CreateAccessKeyRequest) SetAccessKey(val OptString)

+ func (s *CreateAccessKeyRequest) SetGrants(val []Grant)

+ func (s *CreateAccessKeyRequest) SetSecretKey(val OptString)

+ func (s *CreateAccessKeyRequest) UnmarshalJSON(data []byte) error

+ func (s *CreateAccessKeyRequest) Validate() error

+ type CreatedAccessKey struct

+ AccessKey string

+ CreatedAt time.Time

+ Grants []Grant

+ SecretKey string

+ func (s *CreatedAccessKey) Decode(d *jx.Decoder) error

+ func (s *CreatedAccessKey) Encode(e *jx.Encoder)

+ func (s *CreatedAccessKey) GetAccessKey() string

+ func (s *CreatedAccessKey) GetCreatedAt() time.Time

+ func (s *CreatedAccessKey) GetGrants() []Grant

+ func (s *CreatedAccessKey) GetSecretKey() string

+ func (s *CreatedAccessKey) MarshalJSON() ([]byte, error)

+ func (s *CreatedAccessKey) SetAccessKey(val string)

+ func (s *CreatedAccessKey) SetCreatedAt(val time.Time)

+ func (s *CreatedAccessKey) SetGrants(val []Grant)

+ func (s *CreatedAccessKey) SetSecretKey(val string)

+ func (s *CreatedAccessKey) UnmarshalJSON(data []byte) error

+ func (s *CreatedAccessKey) Validate() error

+ type DeleteAccessKeyNoContent struct

+ type DeleteAccessKeyParams struct

+ AccessKey string

+ type Error struct

+ ErrorMessage string

+ func (s *Error) Decode(d *jx.Decoder) error

+ func (s *Error) Encode(e *jx.Encoder)

+ func (s *Error) GetErrorMessage() string

+ func (s *Error) MarshalJSON() ([]byte, error)

+ func (s *Error) SetErrorMessage(val string)

+ func (s *Error) UnmarshalJSON(data []byte) error

+ type ErrorHandler = ogenerrors.ErrorHandler

+ type ErrorStatusCode struct

+ Response Error

+ StatusCode int

+ func (s *ErrorStatusCode) Error() string

+ func (s *ErrorStatusCode) GetResponse() Error

+ func (s *ErrorStatusCode) GetStatusCode() int

+ func (s *ErrorStatusCode) SetResponse(val Error)

+ func (s *ErrorStatusCode) SetStatusCode(val int)

+ type Grant struct

+ Bucket string

+ Permission Permission

+ func (s *Grant) Decode(d *jx.Decoder) error

+ func (s *Grant) Encode(e *jx.Encoder)

+ func (s *Grant) GetBucket() string

+ func (s *Grant) GetPermission() Permission

+ func (s *Grant) MarshalJSON() ([]byte, error)

+ func (s *Grant) SetBucket(val string)

+ func (s *Grant) SetPermission(val Permission)

+ func (s *Grant) UnmarshalJSON(data []byte) error

+ func (s *Grant) Validate() error

+ type Handler interface

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

+ CreateAccessKey func(ctx context.Context, req *CreateAccessKeyRequest) (*CreatedAccessKey, error)

+ DeleteAccessKey func(ctx context.Context, params DeleteAccessKeyParams) error

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

+ GetInfo func(ctx context.Context) (*InstanceInfo, error)

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

+ ListAccessKeys func(ctx context.Context) (*AccessKeyList, error)

+ NewError func(ctx context.Context, err error) *ErrorStatusCode

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

+ type InstanceInfo struct

+ Arch string

+ AuthEnabled bool

+ Commit string

+ ConfigRevision OptString

+ GoVersion string

+ Os string

+ StartTime time.Time

+ UptimeSeconds float64

+ Version string

+ func (s *InstanceInfo) Decode(d *jx.Decoder) error

+ func (s *InstanceInfo) Encode(e *jx.Encoder)

+ func (s *InstanceInfo) GetArch() string

+ func (s *InstanceInfo) GetAuthEnabled() bool

+ func (s *InstanceInfo) GetCommit() string

+ func (s *InstanceInfo) GetConfigRevision() OptString

+ func (s *InstanceInfo) GetGoVersion() string

+ func (s *InstanceInfo) GetOs() string

+ func (s *InstanceInfo) GetStartTime() time.Time

+ func (s *InstanceInfo) GetUptimeSeconds() float64

+ func (s *InstanceInfo) GetVersion() string

+ func (s *InstanceInfo) MarshalJSON() ([]byte, error)

+ func (s *InstanceInfo) SetArch(val string)

+ func (s *InstanceInfo) SetAuthEnabled(val bool)

+ func (s *InstanceInfo) SetCommit(val string)

+ func (s *InstanceInfo) SetConfigRevision(val OptString)

+ func (s *InstanceInfo) SetGoVersion(val string)

+ func (s *InstanceInfo) SetOs(val string)

+ func (s *InstanceInfo) SetStartTime(val time.Time)

+ func (s *InstanceInfo) SetUptimeSeconds(val float64)

+ func (s *InstanceInfo) SetVersion(val string)

+ func (s *InstanceInfo) UnmarshalJSON(data []byte) error

+ func (s *InstanceInfo) Validate() error

+ type Invoker interface

+ ControlRebalance func(ctx context.Context, request *RebalanceControlRequest) (*RebalanceStatus, error)

+ CreateAccessKey func(ctx context.Context, request *CreateAccessKeyRequest) (*CreatedAccessKey, error)

+ DeleteAccessKey func(ctx context.Context, params DeleteAccessKeyParams) error

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

+ GetInfo func(ctx context.Context) (*InstanceInfo, error)

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

+ ListAccessKeys func(ctx context.Context) (*AccessKeyList, error)

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

+ type Labeler struct

+ func LabelerFromContext(ctx context.Context) (*Labeler, bool)

+ func (l *Labeler) Add(attrs ...attribute.KeyValue)

+ func (l *Labeler) AttributeSet() attribute.Set

+ type Middleware = middleware.Middleware

+ type OperationName = string

+ const ControlRebalanceOperation

+ const CreateAccessKeyOperation

+ const DeleteAccessKeyOperation

+ const GetClusterStatusOperation

+ const GetInfoOperation

+ const GetRebalanceStatusOperation

+ const ListAccessKeysOperation

+ const ReloadConfigOperation

+ type OptDateTime struct

+ Set bool

+ Value time.Time

+ func NewOptDateTime(v time.Time) OptDateTime

+ func (o *OptDateTime) Decode(d *jx.Decoder, format func(*jx.Decoder) (time.Time, error)) error

+ func (o *OptDateTime) Reset()

+ func (o *OptDateTime) SetTo(v time.Time)

+ func (o OptDateTime) Encode(e *jx.Encoder, format func(*jx.Encoder, time.Time))

+ func (o OptDateTime) Get() (v time.Time, ok bool)

+ func (o OptDateTime) IsSet() bool

+ func (o OptDateTime) Or(d time.Time) time.Time

+ func (s *OptDateTime) UnmarshalJSON(data []byte) error

+ func (s OptDateTime) MarshalJSON() ([]byte, error)

+ type OptFloat64 struct

+ Set bool

+ Value float64

+ func NewOptFloat64(v float64) OptFloat64

+ func (o *OptFloat64) Decode(d *jx.Decoder) error

+ func (o *OptFloat64) Reset()

+ func (o *OptFloat64) SetTo(v float64)

+ func (o OptFloat64) Encode(e *jx.Encoder)

+ func (o OptFloat64) Get() (v float64, ok bool)

+ func (o OptFloat64) IsSet() bool

+ func (o OptFloat64) Or(d float64) float64

+ func (s *OptFloat64) UnmarshalJSON(data []byte) error

+ func (s OptFloat64) MarshalJSON() ([]byte, error)

+ type OptInt64 struct

+ Set bool

+ Value int64

+ func NewOptInt64(v int64) OptInt64

+ func (o *OptInt64) Decode(d *jx.Decoder) error

+ func (o *OptInt64) Reset()

+ func (o *OptInt64) SetTo(v int64)

+ func (o OptInt64) Encode(e *jx.Encoder)

+ func (o OptInt64) Get() (v int64, ok bool)

+ func (o OptInt64) IsSet() bool

+ func (o OptInt64) Or(d int64) int64

+ func (s *OptInt64) UnmarshalJSON(data []byte) error

+ func (s OptInt64) MarshalJSON() ([]byte, error)

+ type OptString struct

+ Set bool

+ Value string

+ func NewOptString(v string) OptString

+ func (o *OptString) Decode(d *jx.Decoder) error

+ func (o *OptString) Reset()

+ func (o *OptString) SetTo(v string)

+ func (o OptString) Encode(e *jx.Encoder)

+ func (o OptString) Get() (v string, ok bool)

+ func (o OptString) IsSet() bool

+ func (o OptString) Or(d string) string

+ func (s *OptString) UnmarshalJSON(data []byte) error

+ func (s OptString) MarshalJSON() ([]byte, error)

+ type Option interface

+ func WithAttributes(attributes ...attribute.KeyValue) Option

+ func WithMeterProvider(provider metric.MeterProvider) Option

+ func WithTracerProvider(provider trace.TracerProvider) Option

+ type Permission string

+ const PermissionAdmin

+ const PermissionRead

+ const PermissionWrite

+ func (Permission) AllValues() []Permission

+ func (s *Permission) Decode(d *jx.Decoder) error

+ func (s *Permission) UnmarshalJSON(data []byte) error

+ func (s *Permission) UnmarshalText(data []byte) error

+ func (s Permission) Encode(e *jx.Encoder)

+ func (s Permission) MarshalJSON() ([]byte, error)

+ func (s Permission) MarshalText() ([]byte, error)

+ func (s Permission) Validate() error

+ type RebalanceAction string

+ const RebalanceActionPause

+ const RebalanceActionResume

+ const RebalanceActionStart

+ func (RebalanceAction) AllValues() []RebalanceAction

+ func (s *RebalanceAction) Decode(d *jx.Decoder) error

+ func (s *RebalanceAction) UnmarshalJSON(data []byte) error

+ func (s *RebalanceAction) UnmarshalText(data []byte) error

+ func (s RebalanceAction) Encode(e *jx.Encoder)

+ func (s RebalanceAction) MarshalJSON() ([]byte, error)

+ func (s RebalanceAction) MarshalText() ([]byte, error)

+ func (s RebalanceAction) Validate() error

+ type RebalanceControlRequest struct

+ Action RebalanceAction

+ func (s *RebalanceControlRequest) Decode(d *jx.Decoder) error

+ func (s *RebalanceControlRequest) Encode(e *jx.Encoder)

+ func (s *RebalanceControlRequest) GetAction() RebalanceAction

+ func (s *RebalanceControlRequest) MarshalJSON() ([]byte, error)

+ func (s *RebalanceControlRequest) SetAction(val RebalanceAction)

+ func (s *RebalanceControlRequest) UnmarshalJSON(data []byte) error

+ func (s *RebalanceControlRequest) Validate() error

+ type RebalanceState string

+ const RebalanceStateDisabled

+ const RebalanceStateDone

+ const RebalanceStateFailed

+ const RebalanceStateIdle

+ const RebalanceStatePaused

+ const RebalanceStateRunning

+ const RebalanceStateWaiting

+ func (RebalanceState) AllValues() []RebalanceState

+ func (s *RebalanceState) Decode(d *jx.Decoder) error

+ func (s *RebalanceState) UnmarshalJSON(data []byte) error

+ func (s *RebalanceState) UnmarshalText(data []byte) error

+ func (s RebalanceState) Encode(e *jx.Encoder)

+ func (s RebalanceState) MarshalJSON() ([]byte, error)

+ func (s RebalanceState) MarshalText() ([]byte, error)

+ func (s RebalanceState) Validate() error

+ type RebalanceStatus struct

+ CursorBucket OptString

+ CursorKey OptString

+ ErrorMessage OptString

+ Failed int

+ FinishedAt OptDateTime

+ Objects int

+ Relocated int

+ RepairQueueDepth int

+ StartedAt OptDateTime

+ State RebalanceState

+ func (s *RebalanceStatus) Decode(d *jx.Decoder) error

+ func (s *RebalanceStatus) Encode(e *jx.Encoder)

+ func (s *RebalanceStatus) GetCursorBucket() OptString

+ func (s *RebalanceStatus) GetCursorKey() OptString

+ func (s *RebalanceStatus) GetErrorMessage() OptString

+ func (s *RebalanceStatus) GetFailed() int

+ func (s *RebalanceStatus) GetFinishedAt() OptDateTime

+ func (s *RebalanceStatus) GetObjects() int

+ func (s *RebalanceStatus) GetRelocated() int

+ func (s *RebalanceStatus) GetRepairQueueDepth() int

+ func (s *RebalanceStatus) GetStartedAt() OptDateTime

+ func (s *RebalanceStatus) GetState() RebalanceState

+ func (s *RebalanceStatus) MarshalJSON() ([]byte, error)

+ func (s *RebalanceStatus) SetCursorBucket(val OptString)

+ func (s *RebalanceStatus) SetCursorKey(val OptString)

+ func (s *RebalanceStatus) SetErrorMessage(val OptString)

+ func (s *RebalanceStatus) SetFailed(val int)

+ func (s *RebalanceStatus) SetFinishedAt(val OptDateTime)

+ func (s *RebalanceStatus) SetObjects(val int)

+ func (s *RebalanceStatus) SetRelocated(val int)

+ func (s *RebalanceStatus) SetRepairQueueDepth(val int)

+ func (s *RebalanceStatus) SetStartedAt(val OptDateTime)

+ func (s *RebalanceStatus) SetState(val RebalanceState)

+ func (s *RebalanceStatus) UnmarshalJSON(data []byte) error

+ func (s *RebalanceStatus) Validate() error

+ type ReloadResult struct

+ ConfigRevision OptString

+ Reloaded []string

+ func (s *ReloadResult) Decode(d *jx.Decoder) error

+ func (s *ReloadResult) Encode(e *jx.Encoder)

+ func (s *ReloadResult) GetConfigRevision() OptString

+ func (s *ReloadResult) GetReloaded() []string

+ func (s *ReloadResult) MarshalJSON() ([]byte, error)

+ func (s *ReloadResult) SetConfigRevision(val OptString)

+ func (s *ReloadResult) SetReloaded(val []string)

+ func (s *ReloadResult) UnmarshalJSON(data []byte) error

+ func (s *ReloadResult) Validate() error

+ type Route struct

+ func (r Route) Args() []string

+ func (r Route) Name() string

+ func (r Route) OperationGroup() string

+ func (r Route) OperationID() string

+ func (r Route) PathPattern() string

+ func (r Route) Summary() string

+ type Server struct

+ func NewServer(h Handler, opts ...ServerOption) (*Server, error)

+ func (s *Server) FindPath(method string, u *url.URL) (r Route, _ bool)

+ func (s *Server) FindRoute(method, path string) (Route, bool)

+ func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type ServerOption interface

+ func WithErrorHandler(h ErrorHandler) ServerOption

+ func WithMaxMultipartMemory(max int64) ServerOption

+ func WithMethodNotAllowed(methodNotAllowed func(w http.ResponseWriter, r *http.Request, allowed string)) ServerOption

+ func WithMiddleware(m ...Middleware) ServerOption

+ func WithNotFound(notFound http.HandlerFunc) ServerOption

+ func WithPathPrefix(prefix string) ServerOption

+ type Source string

+ const SourceConfig

+ const SourceManaged

+ func (Source) AllValues() []Source

+ func (s *Source) Decode(d *jx.Decoder) error

+ func (s *Source) UnmarshalJSON(data []byte) error

+ func (s *Source) UnmarshalText(data []byte) error

+ func (s Source) Encode(e *jx.Encoder)

+ func (s Source) MarshalJSON() ([]byte, error)

+ func (s Source) MarshalText() ([]byte, error)

+ func (s Source) Validate() error

+ type UnimplementedHandler struct

+ func (UnimplementedHandler) ControlRebalance(ctx context.Context, req *RebalanceControlRequest) (r *RebalanceStatus, _ error)

+ func (UnimplementedHandler) CreateAccessKey(ctx context.Context, req *CreateAccessKeyRequest) (r *CreatedAccessKey, _ error)

+ func (UnimplementedHandler) DeleteAccessKey(ctx context.Context, params DeleteAccessKeyParams) error

+ func (UnimplementedHandler) GetClusterStatus(ctx context.Context) (r *ClusterStatus, _ error)

+ func (UnimplementedHandler) GetInfo(ctx context.Context) (r *InstanceInfo, _ error)

+ func (UnimplementedHandler) GetRebalanceStatus(ctx context.Context) (r *RebalanceStatus, _ error)

+ func (UnimplementedHandler) ListAccessKeys(ctx context.Context) (r *AccessKeyList, _ error)

+ func (UnimplementedHandler) NewError(ctx context.Context, err error) (r *ErrorStatusCode)

+ func (UnimplementedHandler) ReloadConfig(ctx context.Context) (r *ReloadResult, _ error)

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