endpoint

package

v0.9.4 Latest Latest Go to latest Published: Feb 6, 2023 License: GPL-3.0 Imports: 27 Imported by: 2

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/pydio/cells-sync

Links

Open Source Insights

Documentation ¶

Overview ¶

Package endpoint provides some specific factories to provide Endpoints to the sync library

Index ¶

func DefaultDirForURI(uri string) string
func EndpointFromURI(uri string, otherUri string, browseOnly ...bool) (ep model.Endpoint, e error)
func NewSnapshotFactory(configPath string, left model.Endpoint, right model.Endpoint) model.SnapshotFactory
type PatchStore
- func NewPatchStore(folderPath string, source model.Endpoint, target model.Endpoint) (*PatchStore, error)
type SnapshotFactory

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DefaultDirForURI ¶ added in v0.8.0

func DefaultDirForURI(uri string) string

DefaultDirForURI tries to find a default directory to display to user when they choose a specific endpoint. Currently only used for FS, returning ${HOMEDIR}/Cells

func EndpointFromURI ¶

func EndpointFromURI(uri string, otherUri string, browseOnly ...bool) (ep model.Endpoint, e error)

EndpointFromURI parse an URI string to instantiate a proper Endpoint

func NewSnapshotFactory ¶

func NewSnapshotFactory(configPath string, left model.Endpoint, right model.Endpoint) model.SnapshotFactory

NewSnapshotFactory opens a new SnapshotFactory.

Types ¶

type PatchStore ¶

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

PatchStore is a persistence layer for storing patches. It is based on BoltDB

func NewPatchStore ¶

func NewPatchStore(folderPath string, source model.Endpoint, target model.Endpoint) (*PatchStore, error)

NewPatchStore opens a new PatchStore

func (*PatchStore) Load ¶

func (p *PatchStore) Load(offset, limit int) (patches []merger.Patch, e error)

Load list all patches

func (*PatchStore) PublishPatch ¶

func (p *PatchStore) PublishPatch(patch merger.Patch)

PublishPatch pushes patch to the persist queue

func (*PatchStore) Stop ¶

func (p *PatchStore) Stop()

Stop closes the DB.

func (*PatchStore) Store ¶

func (p *PatchStore) Store(patch merger.Patch)

Store pushes the patch to the DB.

type SnapshotFactory ¶

type SnapshotFactory struct {
	sync.Mutex
	// contains filtered or unexported fields
}

SnapshotFactory implements model.SnapshotProvider interface for persisting snapshots in a BoltDB.

func (*SnapshotFactory) Close ¶ added in v0.8.0

func (f *SnapshotFactory) Close(ctx context.Context) error

Close closes the BoltDB.

func (*SnapshotFactory) Load ¶

func (f *SnapshotFactory) Load(source model.PathSyncSource) (model.Snapshoter, error)

Load creates or loads an existing snapshot from within the application dir

func (*SnapshotFactory) Reset ¶

func (f *SnapshotFactory) Reset(ctx context.Context) error

Reset clears all snapshots (left and right)

Source Files ¶

View all Source files

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