torus

package module

Go to main page

Versions in this module

v0

v0.1.2

Sep 15, 2016

Changes in this version

type Config

+ TLS *tls.Config

v0.1.1

Jun 16, 2016

Changes in this version

+ var ErrLeaseNotFound = errors.New("torus: lease not found")

type MetadataService

+ RenewLease func(int64) error

v0.1.1-fish

Jul 24, 2016

v0.1.0

Jun 1, 2016

Changes in this version

+ var BlockLog = capnslog.NewPackageLogger("github.com/coreos/torus", "blocklog")

+ var Version string

+ func InitMDS(name string, cfg Config, gmd GlobalMetadata, ringType RingType) error

+ func MkdirsFor(dir string) error

+ func RegisterMetadataInit(name string, newFunc InitMDSFunc)

+ func RegisterMetadataWipe(name string, newFunc WipeMDSFunc)

+ func WipeMDS(name string, cfg Config) error

type BlockRef

+ func (b BlockRef) ToBytesBuf(buf []byte)

type BlockStore

+ WriteBuf func(ctx context.Context, b BlockRef) ([]byte, error)

type Blockset

+ String func() string

type File

+ ReadOnly bool

+ func (f *File) SyncBlocks() error

+ func (f *File) SyncINode(ctx context.Context) (INodeRef, error)

type INodeRef

+ func (i INodeRef) Equals(x INodeRef) bool

+ type InitMDSFunc func(cfg Config, gmd GlobalMetadata, ringType RingType) error

+ type WipeMDSFunc func(cfg Config) error

type WriteLevel

+ func ParseWriteLevel(s string) (wl WriteLevel, err error)

v0.0.1

Apr 27, 2016

Changes in this version

+ const BlockRefByteSize

+ const CtxReadLevel

+ const CtxWriteLevel

+ const INodeRefByteSize

+ const VolumeIDByteSize

+ const VolumeMax

+ var ErrAgain = errors.New("agro: interrupted, try again")

+ var ErrBlockNotExist = errors.New("agro: block doesn't exist")

+ var ErrBlockUnavailable = errors.New("agro: block cannot be retrieved")

+ var ErrClosed = errors.New("agro: store is closed")

+ var ErrCompareFailed = errors.New("agro: compare failed")

+ var ErrExists = errors.New("agro: already exists")

+ var ErrINodeUnavailable = errors.New("agro: inode cannot be retrieved")

+ var ErrInvalid = errors.New("agro: invalid operation")

+ var ErrIsSymlink = errors.New("agro: is symlink")

+ var ErrLocked = errors.New("agro: locked")

+ var ErrNoGlobalMetadata = errors.New("agro: no global metadata available at mds")

+ var ErrNoPeer = errors.New("agro: no such peer")

+ var ErrNonSequentialRing = errors.New("agro: non-sequential ring")

+ var ErrNotDir = errors.New("agro: not a directory")

+ var ErrNotExist = errors.New("agro: doesn't exist")

+ var ErrNotSupported = errors.New("agro: not supported")

+ var ErrOutOfSpace = errors.New("agro: out of space on block store")

+ var ErrWrongVolumeType = errors.New("agro: wrong volume type")

+ func MarshalBlocksetToProto(bs Blockset) ([]*models.BlockLayer, error)

+ func Mkfs(name string, cfg Config, gmd GlobalMetadata, ringType RingType) error

+ func RegisterBlockStore(name string, newFunc NewBlockStoreFunc)

+ func RegisterMetadataService(name string, newFunc CreateMetadataServiceFunc)

+ func RegisterMkfs(name string, newFunc MkfsFunc)

+ func RegisterSetRing(name string, newFunc SetRingFunc)

+ func SetRing(name string, cfg Config, r Ring) error

+ type BlockIterator interface

+ BlockRef func() BlockRef

+ Close func() error

+ Err func() error

+ Next func() bool

+ type BlockLayer struct

+ Kind BlockLayerKind

+ Options string

+ type BlockLayerKind int

+ type BlockLayerSpec []BlockLayer

+ type BlockRef struct

+ Index IndexID

+ func BlockFromProto(p *models.BlockRef) BlockRef

+ func BlockRefFromBytes(b []byte) BlockRef

+ func ZeroBlock() BlockRef

+ func (b *BlockRef) SetBlockType(t BlockType)

+ func (b BlockRef) BlockType() BlockType

+ func (b BlockRef) HasINode(i INodeRef, t BlockType) bool

+ func (b BlockRef) IsZero() bool

+ func (b BlockRef) String() string

+ func (b BlockRef) ToBytes() []byte

+ func (b BlockRef) ToProto() *models.BlockRef

+ type BlockStore interface

+ BlockIterator func() BlockIterator

+ BlockSize func() uint64

+ DeleteBlock func(ctx context.Context, b BlockRef) error

+ GetBlock func(ctx context.Context, b BlockRef) ([]byte, error)

+ HasBlock func(ctx context.Context, b BlockRef) (bool, error)

+ NumBlocks func() uint64

+ UsedBlocks func() uint64

+ WriteBlock func(ctx context.Context, b BlockRef, data []byte) error

+ func CreateBlockStore(kind string, name string, cfg Config, gmd GlobalMetadata) (BlockStore, error)

+ type BlockType uint16

+ const TypeBlock

+ const TypeINode

+ type Blockset interface

+ GetAllBlockRefs func() []BlockRef

+ GetBlock func(ctx context.Context, i int) ([]byte, error)

+ GetLiveINodes func() *roaring.Bitmap

+ GetSubBlockset func() Blockset

+ Kind func() uint32

+ Length func() int

+ Marshal func() ([]byte, error)

+ PutBlock func(ctx context.Context, inode INodeRef, i int, b []byte) error

+ Trim func(from, to int) error

+ Truncate func(lastIndex int, blocksize uint64) error

+ Unmarshal func(data []byte) error

+ type Config struct

+ DataDir string

+ MetadataAddress string

+ ReadCacheSize uint64

+ ReadLevel ReadLevel

+ StorageSize uint64

+ WriteLevel WriteLevel

+ type CreateMetadataServiceFunc func(cfg Config) (MetadataService, error)

+ type DebugMetadataService interface

+ DumpMetadata func(io.Writer) error

+ type File struct

+ func (f *File) Close() error

+ func (f *File) Read(b []byte) (n int, err error)

+ func (f *File) ReadAt(b []byte, off int64) (n int, ferr error)

+ func (f *File) Replaces() uint64

+ func (f *File) Seek(offset int64, whence int) (int64, error)

+ func (f *File) Size() uint64

+ func (f *File) SyncAllWrites() (INodeRef, error)

+ func (f *File) Trim(offset, length int64) error

+ func (f *File) Truncate(size int64) error

+ func (f *File) Write(b []byte) (n int, err error)

+ func (f *File) WriteAt(b []byte, off int64) (n int, err error)

+ func (f *File) WriteOpen() bool

+ type GlobalMetadata struct

+ BlockSize uint64

+ DefaultBlockSpec BlockLayerSpec

+ INodeReplication int

+ type INodeID uint64

+ type INodeIterator struct

+ func (i *INodeIterator) Close() error

+ func (i *INodeIterator) Err() error

+ func (i *INodeIterator) INodeRef() INodeRef

+ func (i *INodeIterator) Next() bool

+ type INodeRef struct

+ INode INodeID

+ func INodeFromProto(p *models.INodeRef) INodeRef

+ func INodeRefFromBytes(b []byte) INodeRef

+ func NewINodeRef(vol VolumeID, i INodeID) INodeRef

+ func ZeroINode() INodeRef

+ func (i INodeRef) String() string

+ func (i INodeRef) ToBytes() []byte

+ func (i INodeRef) ToProto() *models.INodeRef

+ func (i INodeRef) Volume() VolumeID

+ type INodeStore struct

+ func NewINodeStore(bs BlockStore) *INodeStore

+ func (b *INodeStore) Close() error

+ func (b *INodeStore) DeleteINode(ctx context.Context, i INodeRef) error

+ func (b *INodeStore) Flush() error

+ func (b *INodeStore) GetINode(ctx context.Context, i INodeRef) (*models.INode, error)

+ func (b *INodeStore) INodeIterator() *INodeIterator

+ func (b *INodeStore) WriteINode(ctx context.Context, i INodeRef, inode *models.INode) error

+ type IndexID uint64

+ type MetadataKind int

+ const EtcdMetadata

+ const TempMetadata

+ type MetadataService interface

+ Close func() error

+ CommitINodeIndex func(VolumeID) (INodeID, error)

+ GetINodeIndex func(VolumeID) (INodeID, error)

+ GetLease func() (int64, error)

+ GetPeers func() (PeerInfoList, error)

+ GetRing func() (Ring, error)

+ GetVolume func(volume string) (*models.Volume, error)

+ GetVolumes func() ([]*models.Volume, error)

+ GlobalMetadata func() (GlobalMetadata, error)

+ Kind func() MetadataKind

+ NewVolumeID func() (VolumeID, error)

+ RegisterPeer func(lease int64, pi *models.PeerInfo) error

+ SetRing func(ring Ring) error

+ SubscribeNewRings func(chan Ring)

+ UUID func() string

+ UnsubscribeNewRings func(chan Ring)

+ WithContext func(ctx context.Context) MetadataService

+ func CreateMetadataService(name string, cfg Config) (MetadataService, error)

+ type MkfsFunc func(cfg Config, gmd GlobalMetadata, ringType RingType) error

+ type ModifyableRing interface

+ ChangeReplication func(r int)

+ type NewBlockStoreFunc func(string, Config, GlobalMetadata) (BlockStore, error)

+ type PeerInfoList []*models.PeerInfo

+ func (pi PeerInfoList) AndNot(b PeerList) PeerInfoList

+ func (pi PeerInfoList) GetWeights() map[string]int

+ func (pi PeerInfoList) HasUUID(uuid string) bool

+ func (pi PeerInfoList) Intersect(b PeerInfoList) PeerInfoList

+ func (pi PeerInfoList) PeerList() PeerList

+ func (pi PeerInfoList) UUIDAt(uuid string) int

+ func (pi PeerInfoList) Union(b PeerInfoList) PeerInfoList

+ type PeerList []string

+ func (pl PeerList) AndNot(b PeerList) PeerList

+ func (pl PeerList) Has(uuid string) bool

+ func (pl PeerList) IndexAt(uuid string) int

+ func (pl PeerList) Intersect(b PeerList) PeerList

+ func (pl PeerList) Union(b PeerList) PeerList

+ type PeerPermutation struct

+ Peers PeerList

+ Replication int

+ type ReadLevel int

+ const ReadBlock

+ const ReadSequential

+ const ReadSpread

+ type Ring interface

+ Describe func() string

+ GetPeers func(key BlockRef) (PeerPermutation, error)

+ Marshal func() ([]byte, error)

+ Members func() PeerList

+ Type func() RingType

+ Version func() int

+ type RingAdder interface

+ AddPeers func(PeerInfoList, ...RingModification) (Ring, error)

+ type RingModification interface

+ ModifyRing func(ModifyableRing)

+ type RingRemover interface

+ RemovePeers func(PeerList, ...RingModification) (Ring, error)

+ type RingType int

+ type Server struct

+ Blocks BlockStore

+ Cfg Config

+ INodes *INodeStore

+ MDS MetadataService

+ ReplicationOpen bool

+ func NewMemoryServer() *Server

+ func NewServer(cfg Config, metadataServiceKind, blockStoreKind string) (*Server, error)

+ func NewServerByImpl(cfg Config, mds MetadataService, blocks BlockStore) (*Server, error)

+ func (s *Server) AddTimeoutCallback(f func(uuid string))

+ func (s *Server) BeginHeartbeat(addr string, listen bool) error

+ func (s *Server) Close() error

+ func (s *Server) CreateFile(volume *models.Volume, inode *models.INode, blocks Blockset) (*File, error)

+ func (s *Server) Debug(w io.Writer) error

+ func (s *Server) ExtendContext(ctx context.Context) context.Context

+ func (s *Server) GetPeerMap() map[string]*models.PeerInfo

+ func (s *Server) Lease() int64

+ func (s *Server) UpdatePeerMap() map[string]*models.PeerInfo

+ func (s *Server) UpdateRebalanceInfo(ri *models.RebalanceInfo)

+ type SetRingFunc func(cfg Config, r Ring) error

+ type Store interface

+ Close func() error

+ Flush func() error

+ Kind func() string

+ type VolumeID uint64

+ func (v VolumeID) ToBytes() []byte

+ type WriteLevel int

+ const WriteAll

+ const WriteLocal

+ const WriteOne

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