bus

func (*DataPubSubEndpoint) GetReaderOn ¶

func (d *DataPubSubEndpoint) GetReaderOn(ctx context.Context, path string, node tree.N) (out io.ReadCloser, err error)

func (*DataPubSubEndpoint) GetWriterOn ¶

func (d *DataPubSubEndpoint) GetWriterOn(cancel context.Context, path string, targetSize int64, node tree.N) (out io.WriteCloser, writeDone chan bool, writeErr chan error, err error)

func (*PubSubEndpoint) CreateMetadata ¶

func (e *PubSubEndpoint) CreateMetadata(ctx context.Context, node tree.N, namespace string, jsonValue string) error

CreateMetadata add a metadata to the node

func (*PubSubEndpoint) CreateNode ¶

func (e *PubSubEndpoint) CreateNode(ctx context.Context, node tree.N, updateIfExists bool) (err error)

func (*PubSubEndpoint) DeleteMetadata ¶

func (e *PubSubEndpoint) DeleteMetadata(ctx context.Context, node tree.N, namespace string) error

DeleteMetadata deletes a metadata by namespace

func (*PubSubEndpoint) DeleteNode ¶

func (e *PubSubEndpoint) DeleteNode(ctx context.Context, path string) (err error)

func (*PubSubEndpoint) FinishSession ¶

func (e *PubSubEndpoint) FinishSession(ctx context.Context, sessionUuid string) error

func (*PubSubEndpoint) FlushSession ¶

func (e *PubSubEndpoint) FlushSession(ctx context.Context, sessionUuid string) error

func (*PubSubEndpoint) GetEndpointInfo ¶

func (e *PubSubEndpoint) GetEndpointInfo() model.EndpointInfo

func (*PubSubEndpoint) LoadNode ¶

func (e *PubSubEndpoint) LoadNode(ctx context.Context, path string, extendedStats ...bool) (node tree.N, err error)

LoadNode loads a given node by its path from this endpoint Redeclare it to disambiguate LoadNode from PathSyncSource & PathSyncTarget

func (*PubSubEndpoint) MoveNode ¶

func (e *PubSubEndpoint) MoveNode(ctx context.Context, oldPath string, newPath string) (err error)

func (*PubSubEndpoint) ProvidesMetadataNamespaces ¶

func (e *PubSubEndpoint) ProvidesMetadataNamespaces() ([]glob.Glob, bool)

ProvidesMetadataNamespaces implements model.MetadataProvider interface

func (*PubSubEndpoint) Shutdown ¶

func (e *PubSubEndpoint) Shutdown() (err error)

func (*PubSubEndpoint) StartSession ¶

func (e *PubSubEndpoint) StartSession(ctx context.Context, rootNode tree.N, silent bool) (string, error)

func (*PubSubEndpoint) UpdateMetadata ¶

func (e *PubSubEndpoint) UpdateMetadata(ctx context.Context, node tree.N, namespace string, jsonValue string) error

UpdateMetadata updates an existing metadata value

func (*PubSubEndpoint) Watch ¶

func (e *PubSubEndpoint) Watch(ctx context.Context, recursivePath string) (*model.WatchObject, error)

Watch sets up an event watcher on the nodes