Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

lib

package

Go to main page

Versions in this module

v0

v0.2.1

Sep 10, 2022

v0.2.0

Sep 1, 2022

v0.1.1

Oct 15, 2021

Changes in this version

+ type Histogram struct

+ BucketShift uint32

+ Histogram string

+ TscRate uint64

type Iostat

+ BytesUnmapped uint64

type NameFmt

+ func (nf *NameFmt) ExpId(secNvmeName string) string

+ func (nf *NameFmt) PdId(pdBdevName string) string

+ func (nf *NameFmt) SecNvmeNameToBdevName(secNvmeName string) string

type OperationClient

+ func (oc *OperationClient) BdevGetHistogram(bdevName string) (*Histogram, error)

+ func (oc *OperationClient) BdevGetIostat(bdevName string) (*Iostat, error)

v0.1.0

Jul 10, 2021

v0.0.3

Jun 6, 2021

Changes in this version

+ const AllocLockTTL

+ const AllocMaxRetry

+ const CLUSTER_SIZE

+ const CLUSTER_SIZE_MB

+ const CnOldRevErrCode

+ const CnOutOfSyncErrCode

+ const CnSucceedCode

+ const CnSucceedMsg

+ const DefaultEtcdPrefix

+ const DefaultNqnPrefix

+ const DefaultSanpDescription

+ const DefaultSanpName

+ const DefaultVdaPrefix

+ const DnOldRevErrCode

+ const DnOutOfSyncErrCode

+ const DnSucceedCode

+ const DnSucceedMsg

+ const GrpcCacheInterval

+ const GrpcCacheStep

+ const GrpcCacheTTL

+ const MaxHashCode

+ const MaxReqId

+ const MonitorLeaseTimeout

+ const NVMF_MODULE_NUMBER

+ const PortalDefaultListLimit

+ const PortalDupResErrCode

+ const PortalInternalErrCode

+ const PortalInvalidParamCode

+ const PortalJsonToMessageErrCode

+ const PortalMaxListLimit

+ const PortalMessageToByteErrCode

+ const PortalResBusyErrCode

+ const PortalResRevErrCode

+ const PortalSucceedCode

+ const PortalSucceedMsg

+ const PortalUnknownKeyTypeCode

+ const PortalUnknownResErrCode

+ const ResNoInfoMsg

+ const ResUninitMsg

+ const SPDK_PAGE_SIZE

+ func DivCeil(x, y uint64) uint64

+ func GetReqId(ctx context.Context) string

+ func NewHexStrUuid() string

+ func NvmfSerialNumber(nqn string) string

+ func NvmfUuid(nqn string) (string, error)

+ func ResTimestamp() string

+ func RoundUp(x, y uint64) uint64

+ func SetReqId(ctx context.Context) context.Context

+ type Allocator struct

+ func NewAllocator(etcdCli *clientv3.Client, kf *KeyFmt, boundList []uint64) *Allocator

+ func (alloc *Allocator) AllocCn(ctx context.Context, cnCnt uint32) ([]*CnCand, error)

+ func (alloc *Allocator) AllocDnPd(ctx context.Context, vdCnt uint32, vdSize uint64, qos *BdevQos) ([]*DnPdCand, error)

+ type BdevQos struct

+ RMbytesPerSec uint64

+ RwIosPerSec uint64

+ RwMbytesPerSec uint64

+ WMbytesPerSec uint64

+ type CnCand struct

+ SockAddr string

+ type DnPdCand struct

+ PdName string

+ SockAddr string

+ type GrpcCache struct

+ func NewGrpcCache(ttl int64, step int, interval int) *GrpcCache

+ func (gc *GrpcCache) Close()

+ func (gc *GrpcCache) Get(sockAddr string) (*grpc.ClientConn, error)

+ type InvalidKeyError struct

+ func (e *InvalidKeyError) Error() string

+ type Iostat struct

+ ByetsUnampped uint64

+ BytesRead uint64

+ BytesWritten uint64

+ IoTime uint64

+ NumReadOps uint64

+ NumUnmapOps uint64

+ NumWriteOps uint64

+ QueueDepth uint64

+ QueueDepthPollingPeriod uint64

+ ReadLatencyTicks uint64

+ TickRate uint64

+ UnmapLatencyTicks uint64

+ WeightedIoTime uint64

+ WriteLatencyTicks uint64

+ type KeyFmt struct

+ func NewKeyFmt(prefix string) *KeyFmt

+ func (kf *KeyFmt) AllocLockPath() string

+ func (kf *KeyFmt) CnCapCntPrefix(cntlrCnt uint32) string

+ func (kf *KeyFmt) CnCapKey(cntlrCnt uint32, sockAddr string) string

+ func (kf *KeyFmt) CnCapPrefix() string

+ func (kf *KeyFmt) CnEntityKey(sockAddr string) string

+ func (kf *KeyFmt) CnEntityPrefix() string

+ func (kf *KeyFmt) CnErrKey(hashCode uint32, sockAddr string) string

+ func (kf *KeyFmt) CnErrPrefix() string

+ func (kf *KeyFmt) CnErrWithHash(hashCode uint32) string

+ func (kf *KeyFmt) CnListKey(hashCode uint32, sockAddr string) string

+ func (kf *KeyFmt) CnListPrefix() string

+ func (kf *KeyFmt) CnListWithHash(hashCode uint32) string

+ func (kf *KeyFmt) DaEntityKey(daName string) string

+ func (kf *KeyFmt) DaEntityPrefix() string

+ func (kf *KeyFmt) DaListKey(daName string) string

+ func (kf *KeyFmt) DaListPrefix() string

+ func (kf *KeyFmt) DecodeCnCapKey(key string) (uint32, string, error)

+ func (kf *KeyFmt) DecodeCnErrKey(key string) (uint32, string, error)

+ func (kf *KeyFmt) DecodeCnListKey(key string) (uint32, string, error)

+ func (kf *KeyFmt) DecodeDaListKey(key string) (string, error)

+ func (kf *KeyFmt) DecodeDnCapKey(key string) (uint64, string, string, error)

+ func (kf *KeyFmt) DecodeDnErrKey(key string) (uint32, string, error)

+ func (kf *KeyFmt) DecodeDnListKey(key string) (uint32, string, error)

+ func (kf *KeyFmt) DnCapKey(freeSize uint64, sockAddr string, pdName string) string

+ func (kf *KeyFmt) DnCapPrefix() string

+ func (kf *KeyFmt) DnCapSizePrefix(freeSize uint64) string

+ func (kf *KeyFmt) DnEntityKey(sockAddr string) string

+ func (kf *KeyFmt) DnEntityPrefix() string

+ func (kf *KeyFmt) DnErrKey(hashCode uint32, sockAddr string) string

+ func (kf *KeyFmt) DnErrPrefix() string

+ func (kf *KeyFmt) DnErrWithHash(hashCode uint32) string

+ func (kf *KeyFmt) DnListKey(hashCode uint32, sockAddr string) string

+ func (kf *KeyFmt) DnListPrefix() string

+ func (kf *KeyFmt) DnListWithHash(hashCode uint32) string

+ func (kf *KeyFmt) MonitorPrefix() string

+ type LisConf struct

+ AdrFam string

+ TrAddr string

+ TrSvcId string

+ TrType string

+ type LvsInfo struct

+ BlockSize uint64

+ ClusterSize uint64

+ FreeClusters uint64

+ TotalDataClusters uint64

+ type NameFmt struct

+ func NewNameFmt(vdaPrefix, nqnPrefix string) *NameFmt

+ func (nf *NameFmt) AggBdevName(daId string) string

+ func (nf *NameFmt) AggBdevPrefix() string

+ func (nf *NameFmt) BeLvolFullName(pdId, vdId string) string

+ func (nf *NameFmt) BeLvolName(vdId string) string

+ func (nf *NameFmt) BeLvolPrefix() string

+ func (nf *NameFmt) BeNqnName(vdId string) string

+ func (nf *NameFmt) BeNqnPrefix() string

+ func (nf *NameFmt) DaLvsName(daId string) string

+ func (nf *NameFmt) DaLvsPrefix() string

+ func (nf *NameFmt) ExpNqnName(daName, expName string) string

+ func (nf *NameFmt) ExpNqnPrefix() string

+ func (nf *NameFmt) FeBdevName(vdId string) string

+ func (nf *NameFmt) FeNqnName(cntlrId string) string

+ func (nf *NameFmt) FeNqnPrefix() string

+ func (nf *NameFmt) FeNvmeName(vdId string) string

+ func (nf *NameFmt) FeNvmePrefix() string

+ func (nf *NameFmt) GrpBdevName(grpId string) string

+ func (nf *NameFmt) GrpBdevPrefix() string

+ func (nf *NameFmt) PdBdevName(pdId string) string

+ func (nf *NameFmt) PdBdevPrefix() string

+ func (nf *NameFmt) PdLvsName(pdId string) string

+ func (nf *NameFmt) PdLvsPrefix() string

+ func (nf *NameFmt) Raid0BdevName(grpId string) string

+ func (nf *NameFmt) Raid0BdevPrefix() string

+ func (nf *NameFmt) SecBdevName(primCntlrId string) string

+ func (nf *NameFmt) SecNqnName(cntlrId string) string

+ func (nf *NameFmt) SecNqnPrefix() string

+ func (nf *NameFmt) SecNvmeName(primCntlrId string) string

+ func (nf *NameFmt) SecNvmePrefix() string

+ func (nf *NameFmt) SnapFullName(daId, snapId string) string

+ func (nf *NameFmt) SnapFullNamePrefix() string

+ func (nf *NameFmt) SnapName(snapId string) string

+ type OperationClient struct

+ func NewOperationClient(sc *SpdkClient) *OperationClient

+ func (oc *OperationClient) BdevGetIosat(bdevName string) (*Iostat, error)

+ func (oc *OperationClient) CreateAggBdev(aggBdevName string, grpBdevList []string) error

+ func (oc *OperationClient) CreateBeLvol(lvsName, lvolName string, size uint64, ...) error

+ func (oc *OperationClient) CreateBeNvmf(beNqnName, beLvolFullName, feNqnName string, lisConf *LisConf) error

+ func (oc *OperationClient) CreateDaLvs(daLvsName, aggBdevName string) error

+ func (oc *OperationClient) CreateExpPrimaryNvmf(expNqnName, snapFullName, initiatorNqn string, secNqnList []string, ...) error

+ func (oc *OperationClient) CreateExpSecNvmf(expNqnName, secBdevName, initiatorNqn string, lisConf *LisConf) error

+ func (oc *OperationClient) CreateFeNvme(feNvmeName, beNqnName, feNqnName string, lisConf *LisConf) error

+ func (oc *OperationClient) CreateGrpBdev(grpBdevName, raid0BdevName string) error

+ func (oc *OperationClient) CreatePdAio(name string, fileName string) error

+ func (oc *OperationClient) CreatePdLvs(pdLvsName, bdevName string) error

+ func (oc *OperationClient) CreatePdMalloc(name string, size uint64) error

+ func (oc *OperationClient) CreatePdNvme(name, realName, trAddr string) error

+ func (oc *OperationClient) CreateRaid0Bdev(raid0BdevName string, stripSizeKb uint32, feBdevList []string) error

+ func (oc *OperationClient) CreateSecNvme(secNvmeName, expNqnName, secNqnName string, lisConf *LisConf) error

+ func (oc *OperationClient) CreateSnap(daLvsName, snapName, oriName string, isClone bool, snapSize uint64) error

+ func (oc *OperationClient) DeleteAggBdev(name string) error

+ func (oc *OperationClient) DeleteBeLvol(name string) error

+ func (oc *OperationClient) DeleteBeNvmf(nqn string) error

+ func (oc *OperationClient) DeleteDaLvs(daLvsName string) error

+ func (oc *OperationClient) DeleteExpNvmf(nqn string) error

+ func (oc *OperationClient) DeleteFeNvme(feNvmeName string) error

+ func (oc *OperationClient) DeleteGrpBdev(name string) error

+ func (oc *OperationClient) DeletePdBdev(bdevName string) error

+ func (oc *OperationClient) DeletePdLvs(lvsName string) error

+ func (oc *OperationClient) DeleteRaid0Bdev(name string) error

+ func (oc *OperationClient) DeleteSecNvme(secNvmeName string) error

+ func (oc *OperationClient) DeleteSnap(name string) error

+ func (oc *OperationClient) EnableHistogram(bdevName string) error

+ func (oc *OperationClient) ExamineBdev(bdevName string) error

+ func (oc *OperationClient) GetAggBdevList(prefix string) ([]string, error)

+ func (oc *OperationClient) GetBeLvolList(prefix string) ([]string, error)

+ func (oc *OperationClient) GetBeNqnList(prefix string) ([]string, error)

+ func (oc *OperationClient) GetDaLvsList(prefix string) ([]string, error)

+ func (oc *OperationClient) GetExpNqnList(prefix string) ([]string, error)

+ func (oc *OperationClient) GetFeNvmeList(prefix string) ([]string, error)

+ func (oc *OperationClient) GetGrpBdevList(prefix string) ([]string, error)

+ func (oc *OperationClient) GetLvsInfo(lvsName string) (*LvsInfo, error)

+ func (oc *OperationClient) GetPdBdevList(prefix string) ([]string, error)

+ func (oc *OperationClient) GetPdLvsList(prefix string) ([]string, error)

+ func (oc *OperationClient) GetRaid0BdevList(prefix string) ([]string, error)

+ func (oc *OperationClient) GetSecNvmeList(prefix string) ([]string, error)

+ func (oc *OperationClient) GetSnapList(prefix string) ([]string, error)

+ func (oc *OperationClient) LoadBdevs() error

+ func (oc *OperationClient) LoadNvmfs() error

+ func (oc *OperationClient) WaitForLvs(daLvsName string) error

+ type SpdkClient struct

+ func NewSpdkClient(network, address string, timeout time.Duration) *SpdkClient

+ func (sc *SpdkClient) Invoke(method string, params interface{}, rsp interface{}) error

+ func (sc *SpdkClient) Stop()

+ type StmWrapper struct

+ func NewStmWrapper(etcdCli *clientv3.Client) *StmWrapper

+ func (sw *StmWrapper) RunStm(apply func(stm concurrency.STM) error, ctx context.Context, name string) error

+ type SyncupManager struct

+ func NewSyncupManager(kf *KeyFmt, sw *StmWrapper, gc *GrpcCache) *SyncupManager

+ func (sm *SyncupManager) SyncupCn(sockAddr string, ctx context.Context)

+ func (sm *SyncupManager) SyncupDn(sockAddr string, ctx context.Context)