index

Documentation

Index

• Constants
• Variables
• type CidEntries
  • func (ce *CidEntries) Release()
• type FileInfo
• type GroupInfo
• type Index
  • func New() Index
• type Key
• type SpaceInfo

Constants

const CName = "filenode.index"

Variables

var (
	ErrCidsNotExist = errors.New("cids not exist")
)

Types

type CidEntries

type CidEntries struct {
	// contains filtered or unexported fields
}

func (*CidEntries) Release

func (ce *CidEntries) Release()

type FileInfo

type FileInfo struct {
	BytesUsage uint64
	CidsCount  uint64
}

type GroupInfo

type GroupInfo struct {
	BytesUsage uint64
	CidsCount  uint64
	SpaceIds   []string
}

type Index

type Index interface {
	FileBind(ctx context.Context, key Key, fileId string, cidEntries *CidEntries) (err error)
	FileUnbind(ctx context.Context, kye Key, fileIds ...string) (err error)
	FileInfo(ctx context.Context, key Key, fileIds ...string) (fileInfo []FileInfo, err error)

	GroupInfo(ctx context.Context, groupId string) (info GroupInfo, err error)
	SpaceInfo(ctx context.Context, key Key) (info SpaceInfo, err error)

	BlocksGetNonExistent(ctx context.Context, bs []blocks.Block) (nonExistent []blocks.Block, err error)
	BlocksLock(ctx context.Context, bs []blocks.Block) (unlock func(), err error)
	BlocksAdd(ctx context.Context, bs []blocks.Block) (err error)

	CidExists(ctx context.Context, c cid.Cid) (ok bool, err error)
	CidEntries(ctx context.Context, cids []cid.Cid) (entries *CidEntries, err error)
	CidEntriesByBlocks(ctx context.Context, bs []blocks.Block) (entries *CidEntries, err error)
	CidExistsInSpace(ctx context.Context, k Key, cids []cid.Cid) (exists []cid.Cid, err error)

	Migrate(ctx context.Context, key Key) error

	SpaceDelete(ctx context.Context, key Key) (ok bool, err error)
	app.ComponentRunnable
}

func New

func New() Index

type Key

type Key struct {
	GroupId string
	SpaceId string
}

type SpaceInfo

type SpaceInfo struct {
	BytesUsage uint64
	CidsCount  uint64
	FileCount  uint32
}