Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + func DispatchChangeLogsByPeriod(pruningPeriods []*pruningPeriod, changesChan chan *tree.ChangeLog, ...) ([]*pruningPeriod, error) + func ParseDuration(duration string) (d time.Duration, e error) + func PreparePeriods(startTime time.Time, periods []*tree.VersioningKeepPeriod) ([]*pruningPeriod, error) + func PruneAllWithMaxSize(periods []*pruningPeriod, maxSize int64) (toBeRemoved []*tree.ChangeLog, remaining []*tree.ChangeLog) + type BoltStore struct + DbPath string + DeleteOnClose bool + func NewBoltStore(fileName string, deleteOnClose ...bool) (*BoltStore, error) + func (b *BoltStore) Close() error + func (b *BoltStore) DeleteVersionsForNode(nodeUuid string, versions ...*tree.ChangeLog) error + func (b *BoltStore) GetLastVersion(nodeUuid string) (log *tree.ChangeLog, err error) + func (b *BoltStore) GetVersion(nodeUuid string, versionId string) (*tree.ChangeLog, error) + func (b *BoltStore) GetVersions(nodeUuid string) (chan *tree.ChangeLog, chan bool) + func (b *BoltStore) ListAllVersionedNodesUuids() (chan string, chan bool, chan error) + func (b *BoltStore) StoreVersion(nodeUuid string, log *tree.ChangeLog) error + type DAO interface + DeleteVersionsForNode func(nodeUuid string, versions ...*tree.ChangeLog) error + GetLastVersion func(nodeUuid string) (*tree.ChangeLog, error) + GetVersion func(nodeUuid string, versionId string) (*tree.ChangeLog, error) + GetVersions func(nodeUuid string) (chan *tree.ChangeLog, chan bool) + ListAllVersionedNodesUuids func() (chan string, chan bool, chan error) + StoreVersion func(nodeUuid string, log *tree.ChangeLog) error + type PruneVersionsAction struct + Handler views.Handler + Pool *views.ClientsPool + func (c *PruneVersionsAction) GetName() string + func (c *PruneVersionsAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error + func (c *PruneVersionsAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (jobs.ActionMessage, error) + type VersionAction struct + func (c *VersionAction) GetName() string + func (c *VersionAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error + func (c *VersionAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (jobs.ActionMessage, error) Incompatible versions in this module v2.0.6+incompatible Apr 23, 2020
Go to main page