mapstate

Documentation

Overview

Package mapstate implements the State interface for IPFS Cluster by using a map to keep track of the consensus-shared state.

Index

• Constants
• type MapState
  • func NewMapState() *MapState
  • func (st *MapState) Add(c api.Pin) error
  • func (st *MapState) Get(c *cid.Cid) api.Pin
  • func (st *MapState) GetVersion() int
  • func (st *MapState) Has(c *cid.Cid) bool
  • func (st *MapState) List() []api.Pin
  • func (st *MapState) Marshal() ([]byte, error)
  • func (st *MapState) Restore(r io.Reader) error
  • func (st *MapState) Rm(c *cid.Cid) error
  • func (st *MapState) Snapshot(w io.Writer) error
  • func (st *MapState) Unmarshal(bs []byte) error

Constants

const Version = 2

Version is the map state Version. States with old versions should perform an upgrade before.

Types

type MapState

type MapState struct {
	PinMap  map[string]api.PinSerial
	Version int
	// contains filtered or unexported fields
}

MapState is a very simple database to store the state of the system using a Go map. It is thread safe. It implements the State interface.

func NewMapState

func NewMapState() *MapState

NewMapState initializes the internal map and returns a new MapState object.

func (*MapState) Add

func (st *MapState) Add(c api.Pin) error

Add adds a Pin to the internal map.

func (*MapState) Get

func (st *MapState) Get(c *cid.Cid) api.Pin

Get returns Pin information for a CID.

func (*MapState) GetVersion

func (st *MapState) GetVersion() int

GetVersion returns the current version of this state object. It is not necessarily up to date

func (*MapState) Has

func (st *MapState) Has(c *cid.Cid) bool

Has returns true if the Cid belongs to the State.

func (*MapState) List

func (st *MapState) List() []api.Pin

List provides the list of tracked Pins.

func (*MapState) Marshal

func (st *MapState) Marshal() ([]byte, error)

Marshal encodes the state using msgpack

func (*MapState) Restore

func (st *MapState) Restore(r io.Reader) error

Restore restores a snapshot from the state's internal bytes. It should migrate the format if it is not compatible with the current version.

func (*MapState) Rm

func (st *MapState) Rm(c *cid.Cid) error

Rm removes a Cid from the internal map.

func (*MapState) Snapshot

func (st *MapState) Snapshot(w io.Writer) error

Snapshot dumps the MapState to the given writer, in pretty json format.

func (*MapState) Unmarshal

func (st *MapState) Unmarshal(bs []byte) error

Unmarshal decodes the state using msgpack. It first decodes just the version number. If this is not the current version the bytes are stored within the state's internal reader, which can be migrated to the current version in a later call to restore. Note: Out of date version is not an error