persist

Documentation

Index

• type BadgerPersistence
  • func NewBadger(c *PersistenceConfig) BadgerPersistence
  • func (b BadgerPersistence) Close()
  • func (b BadgerPersistence) GetOwner(name string) (o *remote.Owner, err error)
  • func (b BadgerPersistence) GetOwners() (owners []*remote.Owner, err error)
  • func (b BadgerPersistence) GetRepoOutcome(r *remote.RepoT) (outcome *remote.Outcome, err error)
  • func (b BadgerPersistence) GetRepos(withOutcome func(outcome *remote.Outcome) (matching bool)) (repos []*remote.RepoT, err error)
  • func (b BadgerPersistence) GetStateLeafs() (state PersistentState, err error)
  • func (b BadgerPersistence) PutCurrentLeaf(leaf remote.Leaf, changeState func(st *PersistentState, l remote.Leaf)) (state PersistentState, err error)
  • func (b BadgerPersistence) PutOwner(o *remote.Owner) (err error)
  • func (b BadgerPersistence) PutRepoOutcome(r *remote.RepoT, outcome *remote.Outcome) (err error)
  • func (b BadgerPersistence) SetGenesis(leaf remote.Leaf) (err error)
• type ErrKeyNotFound
• type PersistenceConfig
• type PersistenceProvider
• type PersistentState
  • func (ps PersistentState) IsGenesis() bool
  • func (ps PersistentState) String() string
• type RetrospectiveProvider

Types

type BadgerPersistence

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

func NewBadger

func NewBadger(c *PersistenceConfig) BadgerPersistence

func (BadgerPersistence) Close

func (b BadgerPersistence) Close()

func (BadgerPersistence) GetOwner

func (b BadgerPersistence) GetOwner(name string) (o *remote.Owner, err error)

func (BadgerPersistence) GetOwners

func (b BadgerPersistence) GetOwners() (owners []*remote.Owner, err error)

func (BadgerPersistence) GetRepoOutcome

func (b BadgerPersistence) GetRepoOutcome(r *remote.RepoT) (outcome *remote.Outcome, err error)

func (BadgerPersistence) GetRepos

func (b BadgerPersistence) GetRepos(withOutcome func(outcome *remote.Outcome) (matching bool)) (repos []*remote.RepoT, err error)

func (BadgerPersistence) GetStateLeafs

func (b BadgerPersistence) GetStateLeafs() (state PersistentState, err error)

func (BadgerPersistence) PutCurrentLeaf

func (b BadgerPersistence) PutCurrentLeaf(leaf remote.Leaf, changeState func(st *PersistentState, l remote.Leaf)) (state PersistentState, err error)

func (BadgerPersistence) PutOwner

func (b BadgerPersistence) PutOwner(o *remote.Owner) (err error)

func (BadgerPersistence) PutRepoOutcome

func (b BadgerPersistence) PutRepoOutcome(r *remote.RepoT, outcome *remote.Outcome) (err error)

func (BadgerPersistence) SetGenesis

func (b BadgerPersistence) SetGenesis(leaf remote.Leaf) (err error)

type ErrKeyNotFound

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

type PersistenceConfig

type PersistenceConfig struct {
	Name     string // eg. bolt, kf, POST
	Endpoint string // eg. path/to/database or HTTP endpoint
}

type PersistenceProvider

type PersistenceProvider interface {
	PutRepoOutcome(r *remote.RepoT, outcome *remote.Outcome) error
	GetRepoOutcome(r *remote.RepoT) (outcome *remote.Outcome, err error)

	PutOwner(o *remote.Owner) error
	GetOwner(name string) (owner *remote.Owner, err error)
	GetOwners() (owners []*remote.Owner, err error)

	GetRepos(withOutcome func(outcome *remote.Outcome) (matching bool)) (repos []*remote.RepoT, err error)

	SetGenesis(leaf remote.Leaf) error
	PutCurrentLeaf(leaf remote.Leaf, updater func(st *PersistentState, l remote.Leaf)) (state PersistentState, err error)
	GetStateLeafs() (state PersistentState, err error)

	Close()
}

type PersistentState

type PersistentState struct {
	Genesis  remote.Leaf
	Last     remote.Leaf
	Current  remote.Leaf
	Distance int
	Steps    int64 // ha
}

func (PersistentState) IsGenesis

func (ps PersistentState) IsGenesis() bool

func (PersistentState) String

func (ps PersistentState) String() string

type RetrospectiveProvider

type RetrospectiveProvider interface {
	GetOutcomes(outcome remote.Outcome) (repos []*remote.RepoT, err error)
	Close()
}