nodestorage

Documentation

Index

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

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 ChangeSizeStats

type ChangeSizeStats struct {
	MaxLen int     `json:"maxLen"`
	P95    float64 `json:"p95"`
	Avg    float64 `json:"avg"`
	Median float64 `json:"median"`
	Total  int     `json:"total"`
}

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))
	StoreDir(spaceId string) (path string)
	DeleteSpaceStorage(ctx context.Context, spaceId string) error
}

func New

func New() NodeStorage

type NodeStorageStats

type NodeStorageStats interface {
	GetSpaceStats(treeTop int) (SpaceStats, error)
}

type SpaceStats

type SpaceStats struct {
	ObjectsCount        int             `json:"objectsCount,omitempty"`
	DeletedObjectsCount int             `json:"deletedObjectsCount"`
	ChangesCount        int             `json:"changesCount"`
	ChangeSize          ChangeSizeStats `json:"changeSizeStats,omitempty"`
	TreeStats           []TreeStat      `json:"treeStats,omitempty"`
	// contains filtered or unexported fields
}

type SpaceStatus

type SpaceStatus int

const (
	SpaceStatusOk SpaceStatus = iota
	SpaceStatusRemove
)

type TreeStat

type TreeStat struct {
	Id             string `json:"id"`
	ChangesCount   int    `json:"changesCount"`
	SnapshotsCount int    `json:"snapshotsCount"`
	ChangesSumSize int    `json:"payloadSize"`
}