datastore

Feb 17, 2020

Changes in this version

type JobState

+ const JobStateDead

+ const JobStateFailed

type MemoryDatastore

+ func (md *MemoryDatastore) IncrReplJobAttempts(jobID uint64) error

+ func (md *MemoryDatastore) UpdateReplJobState(jobID uint64, newState JobState) error

type ReplJob

+ Attempts int

type ReplJobsDatastore

+ IncrReplJobAttempts func(jobID uint64) error

+ UpdateReplJobState func(jobID uint64, newState JobState) error

Feb 6, 2020

Changes in this version

type MemoryDatastore

+ func (md *MemoryDatastore) GetSecondaries(virtualStorage string) ([]models.Node, error)

type ReplJob

+ RelativePath string

type ReplicasDatastore

+ GetSecondaries func(virtualStorage string) ([]models.Node, error)

Jan 29, 2020

Changes in this version

+ var ErrNoPrimaryForStorage = errors.New("no primary for storage")

Jan 16, 2020

Changes in this version

+ func Migrate(conf config.Config) (int, error)

Dec 16, 2019

Changes in this version

+ func CheckPostgresVersion(conf config.Config) error

Nov 25, 2019

Changes in this version

+ var ErrInvalidReplTarget = errors.New("targetStorage repository fails preconditions for replication")

+ var ErrPrimaryNotSet = errors.New("primary is not set")

+ var ErrReplicasMissing = errors.New("repository missing secondary replicas")

+ type ChangeType int

+ const DeleteRepo

+ const UpdateRepo

+ type Datastore interface

+ type JobState uint8

+ const JobStateCancelled

+ const JobStateComplete

+ const JobStateInProgress

+ const JobStatePending

+ const JobStateReady

+ type MemoryDatastore struct

+ func NewInMemory(cfg config.Config) *MemoryDatastore

+ func (md *MemoryDatastore) AddReplica(relativePath string, storageNodeID int) error

+ func (md *MemoryDatastore) CreateReplicaReplJobs(relativePath string, change ChangeType) ([]uint64, error)

+ func (md *MemoryDatastore) GetJobs(state JobState, targetNodeID int, count int) ([]ReplJob, error)

+ func (md *MemoryDatastore) GetPrimary(relativePath string) (*models.Node, error)

+ func (md *MemoryDatastore) GetReplicas(relativePath string) ([]models.Node, error)

+ func (md *MemoryDatastore) GetRepository(relativePath string) (*models.Repository, error)

+ func (md *MemoryDatastore) GetStorageNode(nodeID int) (models.Node, error)

+ func (md *MemoryDatastore) GetStorageNodes() ([]models.Node, error)

+ func (md *MemoryDatastore) PickAPrimary() (*models.Node, error)

+ func (md *MemoryDatastore) RemoveReplica(relativePath string, storageNodeID int) error

+ func (md *MemoryDatastore) SetPrimary(relativePath string, storageNodeID int) error

+ func (md *MemoryDatastore) UpdateReplJob(jobID uint64, newState JobState) error

+ type ReplJob struct

+ Change ChangeType

+ ID uint64

+ Repository models.Repository

+ SourceNode models.Node

+ State JobState

+ TargetNode models.Node

+ type ReplJobsDatastore interface

+ CreateReplicaReplJobs func(relativePath string, change ChangeType) ([]uint64, error)

+ GetJobs func(flag JobState, nodeID int, count int) ([]ReplJob, error)

+ UpdateReplJob func(jobID uint64, newState JobState) error

+ type ReplicasDatastore interface

+ AddReplica func(relativePath string, storageNodeID int) error

+ GetPrimary func(relativePath string) (*models.Node, error)

+ GetReplicas func(relativePath string) ([]models.Node, error)

+ GetRepository func(relativePath string) (*models.Repository, error)

+ GetStorageNode func(nodeID int) (models.Node, error)

+ GetStorageNodes func() ([]models.Node, error)

+ PickAPrimary func() (*models.Node, error)

+ RemoveReplica func(relativePath string, storageNodeID int) error

+ SetPrimary func(relativePath string, storageNodeID int) error