nodestorage

Documentation

Index

• Constants
• Variables
• type Config
• type DeletionStorage
  • func OpenDeletionStorage(rootPath string) (ds DeletionStorage, err error)
• type NodeStorage
  • func New() NodeStorage
• type SpaceStatus

Constants

const CName = spacestorage.CName

Variables

var (
	ErrUnknownSpaceId = errors.New("unknown space id")
	ErrNoLastRecordId = errors.New("no last record id")
)

var (
	ErrLocked         = errors.New("space storage locked")
	ErrSpaceIdIsEmpty = errors.New("space id is empty")
)

Types

type Config

type Config struct {
	Path string `yaml:"path"`
}

type DeletionStorage

type DeletionStorage interface {
	SpaceStatus(spaceId string) (status SpaceStatus, err error)
	SetSpaceStatus(spaceId string, status SpaceStatus) (err error)
	LastRecordId() (id string, err error)
	SetLastRecordId(id string) (err error)
	Close() (err error)
}

func OpenDeletionStorage

func OpenDeletionStorage(rootPath string) (ds DeletionStorage, err error)

type NodeStorage

type NodeStorage interface {
	spacestorage.SpaceStorageProvider
	DeletionStorage() DeletionStorage
	SpaceStorage(spaceId string) (spacestorage.SpaceStorage, error)
	TryLockAndDo(spaceId string, do func() error) (err error)
	AllSpaceIds() (ids []string, err error)
	OnDeleteStorage(onDelete func(ctx context.Context, spaceId string))
	OnWriteHash(onWrite func(ctx context.Context, spaceId, hash string))
	OnWriteOldHash(onWrite func(ctx context.Context, spaceId, hash string))
	StoreDir(spaceId string) (path string)
	DeleteSpaceStorage(ctx context.Context, spaceId string) error
}

func New

func New() NodeStorage

type SpaceStatus

type SpaceStatus int

const (
	SpaceStatusOk SpaceStatus = iota
	SpaceStatusRemove
)