sync

package

v0.1.18 Latest Latest Go to latest Published: Apr 29, 2024 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Filecoin-Titan/titan

Links

Open Source Insights

Documentation ¶

Index ¶

type DataSync
- func NewDataSync(sync Sync) *DataSync
- func (ds *DataSync) CompareBucketHashes(ctx context.Context, hashes map[uint32]string) ([]uint32, error)
- func (ds *DataSync) CompareTopHash(ctx context.Context, topHash string) (bool, error)
type Sync

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DataSync ¶

type DataSync struct {
	Sync
}

DataSync represents a data synchronizer, which implements the Sync interface

func NewDataSync ¶

func NewDataSync(sync Sync) *DataSync

NewDataSync creates a new instance of DataSync

func (*DataSync) CompareBucketHashes ¶

func (ds *DataSync) CompareBucketHashes(ctx context.Context, hashes map[uint32]string) ([]uint32, error)

CompareBucketHashes groups assets in a bucket and compares individual bucket checksums

func (*DataSync) CompareTopHash ¶

func (ds *DataSync) CompareTopHash(ctx context.Context, topHash string) (bool, error)

CompareTopHash compares the local top hash with the given hash

type Sync ¶

type Sync interface {
	// GetTopHash returns the local top checksum
	GetTopHash(ctx context.Context) (string, error)
	// GetBucketHashes returns local checksums of all buckets
	GetBucketHashes(ctx context.Context) (map[uint32]string, error)
	// GetAssetsOfBucket retrieves assets of a bucket either from local or remote storage
	GetAssetsOfBucket(ctx context.Context, bucketNumber uint32, isRemote bool) ([]cid.Cid, error)
	DeleteAsset(root cid.Cid) error
	AddLostAsset(root cid.Cid) error
}

Sync defines the synchronization interface

Source Files ¶

View all Source files

data_sync.go

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