replication

package

v0.0.11 Latest Latest Go to latest Published: Sep 22, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/datahop/ipfs-lite

Links

Open Source Insights

Documentation ¶

Index ¶

type Manager
- func New(ctx context.Context, cancel context.CancelFunc, r repo.Repo, h host.Host, ...) (*Manager, error)
type Metatag
type Syncer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Manager ¶

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

Manager handles replication

func New ¶

func New(
	ctx context.Context,
	cancel context.CancelFunc,
	r repo.Repo,
	h host.Host,
	dagSyncer crdt.DAGSyncer,
	st datastore.Batching,
	prefix string,
	topic string,
	broadcastInterval time.Duration,
	syncer Syncer,
) (*Manager, error)

New creates a new replication manager

func (*Manager) Close ¶

func (m *Manager) Close() error

Close the crdt store

func (*Manager) Delete ¶ added in v0.0.11

func (m *Manager) Delete(key datastore.Key) error

Delete removes the value for given `key`.

func (*Manager) FindTag ¶

func (m *Manager) FindTag(tag string) (*Metatag, error)

FindTag gets the meta info of a given tag from the store

func (*Manager) Get ¶

func (m *Manager) Get(key datastore.Key) ([]byte, error)

Get retrieves the object `value` named by `key`. Get will return ErrNotFound if the key is not mapped to a value.

func (*Manager) GetAllCids ¶

func (m *Manager) GetAllCids() ([]cid.Cid, error)

GetAllCids returns all the cids in the crdt store

func (*Manager) GetAllTags ¶

func (m *Manager) GetAllTags() ([]string, error)

GetAllTags returns all tags

func (*Manager) Has ¶

func (m *Manager) Has(key datastore.Key) (bool, error)

Has returns whether the `key` is mapped to a `value`. In some contexts, it may be much cheaper only to check for existence of a value, rather than retrieving the value itself. (e.g. HTTP HEAD). The default implementation is found in `GetBackedHas`.

func (*Manager) Index ¶ added in v0.0.11

func (m *Manager) Index() (map[string]*Metatag, error)

Index returns the tag-mata info as key:value

func (*Manager) Put ¶

func (m *Manager) Put(key datastore.Key, v []byte) error

Put stores the object `value` named by `key`.

func (*Manager) StartContentWatcher ¶

func (m *Manager) StartContentWatcher()

StartContentWatcher watches on incoming contents and gets content in datastore

func (*Manager) Tag ¶

func (m *Manager) Tag(tag string, meta *Metatag) error

Tag a given meta info in the store

type Metatag ¶ added in v0.0.11

type Metatag struct {
	Size      int64
	Type      string
	Name      string
	Hash      cid.Cid
	Timestamp int64
	Owner     peer.ID
}

Metatag keeps meta information of a content in the crdt store

type Syncer ¶

type Syncer interface {
	GetFile(context.Context, cid.Cid) (ufsio.ReadSeekCloser, error)
	FindProviders(context.Context, cid.Cid) []peer.ID
}

Syncer gets the file and finds file provider from the network

Source Files ¶

View all Source files

replication.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL