boltdb

package

v0.1.2 Latest Latest Go to latest Published: Feb 8, 2021 License: MPL-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func Factory(config map[string]interface{}) (state.State, error)

Factory is the factory method for the Boltdb backend

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

BoltDB is a boltdb state implementation

func (b *BoltDB) Apply(c *proto.Component) error

func (b *BoltDB) Close() error

Close implements the BoltDB interface

func (b *BoltDB) Finalize(id string) error

func (b *BoltDB) Get(name string) (*proto.Component, error)

func (b *BoltDB) GetTask(ctx context.Context) (*proto.ComponentTask, error)

func (b *BoltDB) LoadCluster(id string) (*proto.Cluster, error)

func (b *BoltDB) UpsertCluster(c *proto.Cluster) error

UpsertCluster implements the BoltDB interface

func (b *BoltDB) UpsertNode(n *proto.Node) error

UpsertNode implements the BoltDB interface

func (b *BoltDB) Wait(id string) chan struct{}