apc

package

Go to main page

Versions in this module

v1

v1.3.25

Oct 6, 2024

v1.3.24

Sep 27, 2024

Changes in this version

+ const ActDisableBackend

+ const ActEcClose

+ const ActEcOpen

+ const ActEnableBackend

+ const ActMountpathFSHC

+ const ActMountpathRescan

+ const ActSelfRemove

+ const HT

+ const HdrActiveEC

+ const LoadX509

+ const LsNoDirs

+ const QparamValidateCksum

+ const RemAIS

+ const WhatBackends

+ const WhatCertificate

+ const WhatDiskRWUtilCap

+ var URLPathCluBendDisable = urlpath(Version, Cluster, ActDisableBackend)

+ var URLPathCluBendEnable = urlpath(Version, Cluster, ActEnableBackend)

+ var URLPathCluX509 = urlpath(Version, Cluster, LoadX509)

+ var URLPathDaeBendDisable = urlpath(Version, Daemon, ActDisableBackend)

+ var URLPathDaeBendEnable = urlpath(Version, Daemon, ActEnableBackend)

+ var URLPathDaeX509 = urlpath(Version, Daemon, LoadX509)

type ArchiveMsg

+ BaseNameOnly bool

type PrefetchMsg

+ NumWorkers int

+ type TCOMsg struct

+ ContinueOnError bool

+ NumWorkers int

+ TxnUUID string

v1.3.23

May 27, 2024

Changes in this version

+ const HdrInvID

+ const HdrInvName

+ const HdrInventory

+ const NilValue

+ const QparamArchmode

+ const QparamArchregx

+ const QparamBinfoWithOrWithoutRemote

+ const QparamMpathLabel

+ const WhatNodeStatsAndStatusV322

+ const WhatNodeStatsV322

type LsoMsg

+ Header http.Header

v1.3.22

Feb 25, 2024

Changes in this version

+ const AceObjUpdate

+ const ActBlobDl

+ const ActRotateLogs

+ const EntryVerChanged

+ const EntryVerRemoved

+ const EnvReadHeaderTimeout

+ const HdrBlobChunk

+ const HdrBlobDownload

+ const HdrBlobWorkers

+ const LsVerChanged

+ const MaxPageSizeAIS

+ const MaxPageSizeAWS

+ const MaxPageSizeAzure

+ const MaxPageSizeGCP

+ const QparamLatestVer

+ const QparamSync

+ const ReadHeaderTimeout

+ const UList

+ func PropToHeader(prop string) string

+ func Ptr[T any](v T) *T

+ type BlobMsg struct

+ ChunkSize int64

+ FullSize int64

+ LatestVer bool

+ NumWorkers int

+ func (msg *BlobMsg) FromHeader(hdr http.Header) error

type CopyBckMsg

+ LatestVer bool

+ Sync bool

+ type PrefetchMsg struct

+ BlobThreshold int64

+ ContinueOnError bool

+ LatestVer bool

+ type PromoteArgs struct

+ DaemonID string

+ DeleteSrc bool

+ ObjName string

+ OverwriteDst bool

+ Recursive bool

+ SrcFQN string

+ SrcIsNotFshare bool

v1.3.21

Nov 5, 2023

Changes in this version

+ const ActQuery

+ const GetPropsNameSize

+ const HdrCallerIsPrimary

+ const HdrCallerSmapVer

+ const LsBckPresent

+ const LsMissing

+ const QparamBsummRemote

+ func Bool(v bool) *bool

+ func Duration(v time.Duration) *time.Duration

+ func Int(v int) *int

+ func Int64(v int64) *int64

+ func String(v string) *string

type AccessAttrs

+ func AccAttrs(v AccessAttrs) *AccessAttrs

type BsummCtrlMsg

+ DontAddRemote bool

type LsoMsg

+ func (lsmsg *LsoMsg) ClearFlag(flag uint64)

type WritePolicy

+ func WPolicy(v WritePolicy) *WritePolicy

v1.3.20

Sep 12, 2023

v1.3.19

Aug 29, 2023

Changes in this version

+ const ActDsort

+ const HdrS3Profile

+ const QparamAllLogs

+ const QparamDontHeadRemote

v1.3.18

Jul 9, 2023

Changes in this version

+ const ActCleanupMarkers

+ const ActDecommissionCluster

+ const ActRmNodeUnsafe

+ const ActShutdownCluster

+ const ActStopGFN

+ const ArchAppend

+ const ArchAppendIfExist

+ const EntryIsArchive

+ const HdrPutApndArchFlags

+ const PriStop

+ const QparamCountRemoteObjs

+ const WhatNodeConfig

+ var URLPathVotePriStop = urlpath(Version, Vote, PriStop)

type ActMsg

+ func (msg *ActMsg) StringEx() string

+ type ArchiveMsg struct

+ AppendIfExists bool

+ ArchName string

+ ContinueOnError bool

+ FromBckName string

+ InclSrcBname bool

+ Mime string

+ TxnUUID string

+ type BsummCtrlMsg struct

+ BckPresent bool

+ Fast bool

+ ObjCached bool

+ Prefix string

+ UUID string

+ type BsummResult struct

+ IsBckPresent bool

+ ObjCount struct{ ... }

+ ObjSize struct{ ... }

+ TotalSize struct{ ... }

+ UsedPct uint64

+ type ListRange struct

+ ObjNames []string

+ Template string

+ func (lrm *ListRange) HasTemplate() bool

+ func (lrm *ListRange) IsList() bool

+ type TCObjsMsg struct

+ ContinueOnError bool

+ TxnUUID string

v1.3.17

Apr 10, 2023

v1.3.16

Mar 31, 2023

Changes in this version

+ const ActResetStats

+ const ETLMetrics

+ const EntryIsDir

+ const FltPresentCluster

+ const LocationPropSepa

+ const LsNameSize

+ const LsNoRecursion

+ const LsPropsSepa

+ const NodeDecommission

+ const NodeMaintenance

+ const QparamETLName

+ const QparamJobID

+ const QparamLogOff

+ const QparamLogSev

+ const QparamOnlyActive

+ const RemAisDefunct

+ const WhatAllRunningXacts

+ const WhatAllXactStatus

+ const WhatBMD

+ const WhatClusterConfig

+ const WhatConfig

+ const WhatDiskStats

+ const WhatICBundle

+ const WhatLog

+ const WhatMetricNames

+ const WhatMountpaths

+ const WhatNodeStats

+ const WhatNodeStatsAndStatus

+ const WhatOneXactStatus

+ const WhatQueryXactStats

+ const WhatRemoteAIS

+ const WhatSmap

+ const WhatSmapVote

+ const WhatSnode

+ const WhatSysInfo

+ const WhatTargetIPs

+ const WhatXactStats

+ var GetPropsDefaultAIS = []string

+ var GetPropsDefaultCloud = []string

+ func IsCloudProvider(p string) bool

+ func IsRemoteProvider(p string) bool

+ type ActMsg struct

+ Action string

+ Name string

+ Value any

+ func (msg *ActMsg) String() string

type CopyBckMsg

+ Prepend string

type LsoMsg

+ func (lsmsg *LsoMsg) WantOnlyName() bool

+ type MemCPUInfo struct

+ LoadAvg sys.LoadAvg

+ MemAvail uint64

+ MemUsed uint64

+ PctCPUUsed float64

+ PctMemUsed float64

+ func GetMemCPU() MemCPUInfo

+ type Transform struct

+ Name string

+ Timeout cos.Duration

v1.3.15

Nov 13, 2022

v1.3.13

Nov 9, 2022

v1.3.12

Nov 7, 2022

Changes in this version

+ const AIS

+ const AISScheme

+ const AWS

+ const AZScheme

+ const Abort

+ const AccessAll

+ const AccessCluster

+ const AccessNone

+ const AccessRO

+ const AccessRW

+ const AceAPPEND

+ const AceAdmin

+ const AceBckHEAD

+ const AceBckSetACL

+ const AceCreateBucket

+ const AceDestroyBucket

+ const AceDisconnectedBackend

+ const AceGET

+ const AceListBuckets

+ const AceMax

+ const AceMoveBucket

+ const AceObjDELETE

+ const AceObjHEAD

+ const AceObjLIST

+ const AceObjMOVE

+ const AcePATCH

+ const AcePUT

+ const AcePromote

+ const AceShowCluster

+ const ActAbort

+ const ActAddRemoteBck

+ const ActAdminJoinProxy

+ const ActAdminJoinTarget

+ const ActArchive

+ const ActAttachRemAis

+ const ActBegin

+ const ActCallbackRmFromSmap

+ const ActCommit

+ const ActCopyBck

+ const ActCopyObjects

+ const ActCreateBck

+ const ActDecommission

+ const ActDecommissionNode

+ const ActDeleteObjects

+ const ActDestroyBck

+ const ActDetachRemAis

+ const ActDownload

+ const ActECEncode

+ const ActECGet

+ const ActECPut

+ const ActECRespond

+ const ActETLBck

+ const ActETLInline

+ const ActETLObjects

+ const ActElection

+ const ActEvictObjects

+ const ActEvictRemoteBck

+ const ActInvalListCache

+ const ActKeepaliveUpdate

+ const ActLRU

+ const ActList

+ const ActListenToNotif

+ const ActLoadLomCache

+ const ActMakeNCopies

+ const ActMergeOwnershipTbl

+ const ActMountpathAttach

+ const ActMountpathDetach

+ const ActMountpathDisable

+ const ActMountpathEnable

+ const ActMoveBck

+ const ActNewPrimary

+ const ActPrefetchObjects

+ const ActPromote

+ const ActPutCopies

+ const ActRebalance

+ const ActRegGlobalXaction

+ const ActRenameObject

+ const ActResetBprops

+ const ActResetConfig

+ const ActResilver

+ const ActResyncBprops

+ const ActSelfJoinProxy

+ const ActSelfJoinTarget

+ const ActSendOwnershipTbl

+ const ActSetBprops

+ const ActSetConfig

+ const ActShutdown

+ const ActShutdownNode

+ const ActStartGFN

+ const ActStartMaintenance

+ const ActStopMaintenance

+ const ActStoreCleanup

+ const ActSummaryBck

+ const ActTransient

+ const ActXactStart

+ const ActXactStop

+ const AdminJoin

+ const AllProviders

+ const AllowAllAccess

+ const AllowReadOnlyAccess

+ const AllowReadWriteAccess

+ const AppendOp

+ const AuthenticationTypeBearer

+ const Azure

+ const BckObjnameSeparator

+ const BckProviderSeparator

+ const Buckets

+ const CallbackRmSelf

+ const Cluster

+ const Clusters

+ const CompressAlways

+ const CompressNever

+ const Daemon

+ const DefaultPageSizeAIS

+ const DefaultPageSizeCloud

+ const DefaultScheme

+ const DefaultTimeout

+ const DeploymentDev

+ const DeploymentK8s

+ const Discard

+ const Download

+ const EC

+ const ETL

+ const ETLHealth

+ const ETLInfo

+ const ETLInitCode

+ const ETLInitSpec

+ const ETLList

+ const ETLLogs

+ const ETLObject

+ const ETLStart

+ const ETLStop

+ const EntryInArch

+ const EntryIsCached

+ const EntryStatusBits

+ const EntryStatusMask

+ const Finished

+ const FinishedAck

+ const FltExists

+ const FltExistsNoProps

+ const FltExistsOutside

+ const FltPresent

+ const FltPresentAnywhere

+ const FltPresentNoProps

+ const FlushOp

+ const GCP

+ const GSScheme

+ const GetPropsAtime

+ const GetPropsCached

+ const GetPropsChecksum

+ const GetPropsCopies

+ const GetPropsCustom

+ const GetPropsEC

+ const GetPropsLocation

+ const GetPropsName

+ const GetPropsSize

+ const GetPropsStatus

+ const GetPropsVersion

+ const GetWhatBMD

+ const GetWhatClusterConfig

+ const GetWhatConfig

+ const GetWhatDaemonStatus

+ const GetWhatDiskStats

+ const GetWhatICBundle

+ const GetWhatLog

+ const GetWhatMountpaths

+ const GetWhatQueryXactStats

+ const GetWhatRemoteAIS

+ const GetWhatSmap

+ const GetWhatSmapVote

+ const GetWhatSnode

+ const GetWhatStats

+ const GetWhatSysInfo

+ const GetWhatTargetIPs

+ const GetWhatXactStats

+ const GetWhatXactStatus

+ const HDFS

+ const HTTP

+ const HdrAppendHandle

+ const HdrArchmime

+ const HdrArchpath

+ const HdrAuthorization

+ const HdrBackendProvider

+ const HdrBucketCreated

+ const HdrBucketProps

+ const HdrBucketSumm

+ const HdrBucketVerEnabled

+ const HdrCallerID

+ const HdrCallerName

+ const HdrCallerSmapVersion

+ const HdrClusterUptime

+ const HdrCompress

+ const HdrError

+ const HdrHandle

+ const HdrNodeID

+ const HdrNodeURL

+ const HdrNodeUptime

+ const HdrObjAtime

+ const HdrObjCksumType

+ const HdrObjCksumVal

+ const HdrObjCustomMD

+ const HdrObjVersion

+ const HdrOrigURLBck

+ const HdrPromoteNamesHash

+ const HdrPromoteNamesNum

+ const HdrRemAisAlias

+ const HdrRemAisURL

+ const HdrRemAisUUID

+ const HdrRemoteOffline

+ const HdrS3Endpoint

+ const HdrS3Region

+ const HdrSessID

+ const HdrT2TPutterID

+ const HdrXactionID

+ const HeaderPrefix

+ const Health

+ const IC

+ const Init

+ const Keepalive

+ const LZ4Compression

+ const List

+ const LocIsCopy

+ const LocIsCopyMissingObj

+ const LocMisplacedMountpath

+ const LocMisplacedNode

+ const LocOK

+ const LogErr

+ const LogInfo

+ const LogWarn

+ const LongTimeout

+ const LsAll

+ const LsArchDir

+ const LsDeleted

+ const LsDontAddRemote

+ const LsDontHeadRemote

+ const LsNameOnly

+ const LsObjCached

+ const LsTryHeadRemote

+ const LsWantOnlyRemoteProps

+ const Metasync

+ const Metrics

+ const Mountpaths

+ const MsgStream

+ const Next

+ const Notifs

+ const NsNamePrefix

+ const NsUUIDPrefix

+ const ObjStream

+ const Objects

+ const Peek

+ const Progress

+ const PropBackendBck

+ const PropBackendBckName

+ const PropBackendBckProvider

+ const PropBucketAccessAttrs

+ const PropBucketCreated

+ const PropBucketVerEnabled

+ const PropsLocationSepa

+ const Proxy

+ const QparamActNoXact

+ const QparamAppendHandle

+ const QparamAppendType

+ const QparamArchmime

+ const QparamArchpath

+ const QparamAskPrimary

+ const QparamBckTo

+ const QparamClusterInfo

+ const QparamConfirmFshare

+ const QparamDontAddRemote

+ const QparamDontResilver

+ const QparamFltPresence

+ const QparamForce

+ const QparamHealthReadiness

+ const QparamHostTimeout

+ const QparamIsGFNRequest

+ const QparamKeepRemote

+ const QparamNamespace

+ const QparamNetwTimeout

+ const QparamNewCustom

+ const QparamNonElectable

+ const QparamNotifyMe

+ const QparamOWT

+ const QparamOrigURL

+ const QparamPrepare

+ const QparamPrimaryCandidate

+ const QparamPrimaryReadyReb

+ const QparamProps

+ const QparamProvider

+ const QparamProxyID

+ const QparamRebData

+ const QparamRebStatus

+ const QparamRegex

+ const QparamSev

+ const QparamSilent

+ const QparamSkipVC

+ const QparamTaskAction

+ const QparamTotalCompressedSize

+ const QparamTotalInputShardsExtracted

+ const QparamTotalUncompressedSize

+ const QparamUUID

+ const QparamUnixTime

+ const QparamWaitMetasync

+ const QparamWhat

+ const Rebalance

+ const Records

+ const Remove

+ const Reverse

+ const Roles

+ const S3

+ const S3Scheme

+ const SelfJoin

+ const Shards

+ const Sort

+ const Start

+ const Stop

+ const SyncSmap

+ const Target

+ const TaskResult

+ const TaskStart

+ const TaskStatus

+ const Tokens

+ const Txn

+ const UseListObjsCache

+ const Users

+ const Version

+ const Vote

+ const VoteInit

+ const Voteres

+ const WorkerOwner

+ const WriteDefault

+ const WriteDelayed

+ const WriteImmediate

+ const WriteNever

+ const Xactions

+ var ErrETLMissingUUID = errors.New("ETL UUID can't be empty")

+ var GetPropsAll = append(GetPropsDefault, GetPropsVersion, GetPropsCached, GetPropsStatus, ...)

+ var GetPropsDefault = []string

+ var GetPropsMinimal = []string

+ var Providers = cos.NewStrSet(AIS, GCP, AWS, Azure, HDFS, HTTP)

+ var SupportedCompression = []string

+ var SupportedWritePolicy = []string

+ var URLPathBuckets = urlpath(Version, Buckets)

+ var URLPathClu = urlpath(Version, Cluster)

+ var URLPathCluAttach = urlpath(Version, Cluster, ActAttachRemAis)

+ var URLPathCluAutoReg = urlpath(Version, Cluster, SelfJoin)

+ var URLPathCluDaemon = urlpath(Version, Cluster, Daemon)

+ var URLPathCluDetach = urlpath(Version, Cluster, ActDetachRemAis)

+ var URLPathCluKalive = urlpath(Version, Cluster, Keepalive)

+ var URLPathCluProxy = urlpath(Version, Cluster, Proxy)

+ var URLPathCluSetConf = urlpath(Version, Cluster, ActSetConfig)

+ var URLPathCluUserReg = urlpath(Version, Cluster, AdminJoin)

+ var URLPathClusters = urlpath(Version, Clusters)

+ var URLPathDae = urlpath(Version, Daemon)

+ var URLPathDaeAdminJoin = urlpath(Version, Daemon, AdminJoin)

+ var URLPathDaeProxy = urlpath(Version, Daemon, Proxy)

+ var URLPathDaeRmSelf = urlpath(Version, Daemon, CallbackRmSelf)

+ var URLPathDaeSetConf = urlpath(Version, Daemon, ActSetConfig)

+ var URLPathDownload = urlpath(Version, Download)

+ var URLPathDownloadAbort = urlpath(Version, Download, Abort)

+ var URLPathDownloadRemove = urlpath(Version, Download, Remove)

+ var URLPathEC = urlpath(Version, EC)

+ var URLPathETL = urlpath(Version, ETL)

+ var URLPathETLObject = urlpath(Version, ETL, ETLObject)

+ var URLPathHealth = urlpath(Version, Health)

+ var URLPathIC = urlpath(Version, IC)

+ var URLPathMetasync = urlpath(Version, Metasync)

+ var URLPathNotifs = urlpath(Version, Notifs)

+ var URLPathObjects = urlpath(Version, Objects)

+ var URLPathRebalance = urlpath(Version, Rebalance)

+ var URLPathReverse = urlpath(Version, Reverse)

+ var URLPathReverseDae = urlpath(Version, Reverse, Daemon)

+ var URLPathRoles = urlpath(Version, Roles)

+ var URLPathS3 = urlpath(S3)

+ var URLPathTokens = urlpath(Version, Tokens)

+ var URLPathTxn = urlpath(Version, Txn)

+ var URLPathUsers = urlpath(Version, Users)

+ var URLPathVote = urlpath(Version, Vote)

+ var URLPathVoteInit = urlpath(Version, Vote, Init)

+ var URLPathVoteProxy = urlpath(Version, Vote, Proxy)

+ var URLPathVoteVoteres = urlpath(Version, Vote, Voteres)

+ var URLPathXactions = urlpath(Version, Xactions)

+ var URLPathdSort = urlpath(Version, Sort)

+ var URLPathdSortAbort = urlpath(Version, Sort, Abort)

+ var URLPathdSortAck = urlpath(Version, Sort, FinishedAck)

+ var URLPathdSortInit = urlpath(Version, Sort, Init)

+ var URLPathdSortList = urlpath(Version, Sort, List)

+ var URLPathdSortMetrics = urlpath(Version, Sort, Metrics)

+ var URLPathdSortRecords = urlpath(Version, Sort, Records)

+ var URLPathdSortRemove = urlpath(Version, Sort, Remove)

+ var URLPathdSortShards = urlpath(Version, Sort, Shards)

+ var URLPathdSortStart = urlpath(Version, Sort, Start)

+ func AccessOp(access AccessAttrs) string

+ func DisplayProvider(p string) string

+ func IsFltNoProps(v int) bool

+ func IsFltPresent(v int) bool

+ func IsProvider(p string) bool

+ func IsValidCompression(c string) bool

+ func NormalizeProvider(p string) string

+ func SupportedPermissions() []string

+ func ToScheme(p string) string

+ type AccessAttrs uint64

+ func StrToAccess(accessStr string) (access AccessAttrs, err error)

+ func (a AccessAttrs) Describe() string

+ func (a AccessAttrs) Has(perms AccessAttrs) bool

+ func (a AccessAttrs) String() string

+ type ActValRmNode struct

+ DaemonID string

+ KeepInitialConfig bool

+ NoShutdown bool

+ RmUserData bool

+ SkipRebalance bool

+ type ActionMsg struct

+ Action string

+ Name string

+ Value any

+ func (msg *ActionMsg) String() string

+ type CapacityInfo struct

+ PctUsed float64

+ Total uint64

+ Used uint64

+ type ClusterSysInfo struct

+ Proxy map[string]*cos.MemCPUInfo

+ Target map[string]*TSysInfo

+ type ClusterSysInfoRaw struct

+ Proxy cos.JSONRawMsgs

+ Target cos.JSONRawMsgs

+ type CopyBckMsg struct

+ DryRun bool

+ Force bool

+ Prefix string

+ type JoinNodeResult struct

+ DaemonID string

+ RebalanceID string

+ type LsoMsg struct

+ ContinuationToken string

+ Flags uint64

+ PageSize uint

+ Prefix string

+ Props string

+ SID string

+ StartAfter string

+ TimeFormat string

+ UUID string

+ func (lsmsg *LsoMsg) AddProps(propNames ...string)

+ func (lsmsg *LsoMsg) Clone() *LsoMsg

+ func (lsmsg *LsoMsg) IsFlagSet(flags uint64) bool

+ func (lsmsg *LsoMsg) PropsSet() (s cos.StrSet)

+ func (lsmsg *LsoMsg) SetFlag(flag uint64)

+ func (lsmsg *LsoMsg) WantOnlyRemoteProps() bool

+ func (lsmsg *LsoMsg) WantProp(propName string) bool

+ type MountpathList struct

+ Available []string

+ Disabled []string

+ WaitingDD []string

+ type TCBMsg struct

+ Ext cos.StrKVs

+ ID string

+ RequestTimeout cos.Duration

+ func (msg *TCBMsg) ToName(name string) string

+ func (msg *TCBMsg) Validate() error

+ type TSysInfo struct

+ type URLPath struct

+ L []string

+ S string

+ func (u URLPath) Join(words ...string) string

+ type WritePolicy string

+ func (wp WritePolicy) IsImmediate() bool

+ func (wp WritePolicy) Validate() (err error)

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