filersink

package
v0.0.0-...-0b345dd Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 6, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

README

How replication works
======

All metadata changes within current cluster would be notified to a message queue.

If the meta data change is from other clusters, this metadata would change would not be notified to the message queue.

So active<=>active replication is possible.


All metadata changes would be published as metadata changes.
So all mounts listening for metadata changes will get updated.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FilerSink

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

func (*FilerSink) AdjustedUrl

func (fs *FilerSink) AdjustedUrl(location *filer_pb.Location) string

func (*FilerSink) CreateEntry

func (fs *FilerSink) CreateEntry(key string, entry *filer_pb.Entry, signatures []int32) error

func (*FilerSink) DeleteEntry

func (fs *FilerSink) DeleteEntry(key string, isDirectory, deleteIncludeChunks bool, signatures []int32) error

func (*FilerSink) DoInitialize

func (fs *FilerSink) DoInitialize(address, grpcAddress string, dir string,
	replication string, collection string, ttlSec int, diskType string, grpcDialOption grpc.DialOption, writeChunkByFiler bool) (err error)

func (*FilerSink) GetName

func (fs *FilerSink) GetName() string

func (*FilerSink) GetSinkToDirectory

func (fs *FilerSink) GetSinkToDirectory() string

func (*FilerSink) Initialize

func (fs *FilerSink) Initialize(configuration util.Configuration, prefix string) error

func (*FilerSink) IsIncremental

func (fs *FilerSink) IsIncremental() bool

func (*FilerSink) SetSourceFiler

func (fs *FilerSink) SetSourceFiler(s *source.FilerSource)

func (*FilerSink) UpdateEntry

func (fs *FilerSink) UpdateEntry(key string, oldEntry *filer_pb.Entry, newParentPath string, newEntry *filer_pb.Entry, deleteIncludeChunks bool, signatures []int32) (foundExistingEntry bool, err error)

func (*FilerSink) WithFilerClient

func (fs *FilerSink) WithFilerClient(streamingMode bool, fn func(filer_pb.SeaweedFilerClient) error) error

Jump to

Keyboard shortcuts

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