source

package

Go to main page

Versions in this module

v1

v1.10.0

Mar 13, 2026

v1.9.5

Mar 11, 2026

v1.9.4

Mar 11, 2026

Changes in this version

type LocalOption

+ func WithVolumeUUID(uuid string) LocalOption

type LocalSource

+ func (s *LocalSource) VolumeLabel() string

+ func (s *LocalSource) VolumeUUID() string

v1.9.3

Mar 8, 2026

Changes in this version

type GDriveOption

+ func WithSkipNativeFiles() GDriveOption

v1.9.2

Mar 7, 2026

v1.9.1

Mar 7, 2026

v1.9.0

Mar 6, 2026

v1.8.0

Mar 5, 2026

Changes in this version

+ func ParseExcludeFile(path string) ([]string, error)

+ type ChangeType string

+ const ChangeDelete

+ const ChangeUpsert

+ type ExcludeMatcher struct

+ func NewExcludeMatcher(patterns []string) *ExcludeMatcher

+ func (m *ExcludeMatcher) Empty() bool

+ func (m *ExcludeMatcher) Excludes(relPath string, isDir bool) bool

+ type FileChange struct

+ Meta core.FileMeta

+ Type ChangeType

+ type GDriveChangeSource struct

+ func NewGDriveChangeSource(ctx context.Context, opts ...GDriveOption) (*GDriveChangeSource, error)

+ func (s *GDriveChangeSource) GetStartPageToken() (string, error)

+ func (s *GDriveChangeSource) Info() core.SourceInfo

+ func (s *GDriveChangeSource) WalkChanges(ctx context.Context, token string, callback func(FileChange) error) (string, error)

+ type GDriveOption func(*gDriveOptions)

+ func WithAccountEmail(email string) GDriveOption

+ func WithCredsPath(path string) GDriveOption

+ func WithDriveID(id string) GDriveOption

+ func WithGDriveExcludePatterns(patterns []string) GDriveOption

+ func WithHTTPClient(client *http.Client) GDriveOption

+ func WithRootFolderID(id string) GDriveOption

+ func WithTokenPath(path string) GDriveOption

+ type GDriveSource struct

+ func NewGDriveSource(ctx context.Context, opts ...GDriveOption) (*GDriveSource, error)

+ func (s *GDriveSource) GetFileStream(fileID string) (io.ReadCloser, error)

+ func (s *GDriveSource) Info() core.SourceInfo

+ func (s *GDriveSource) Size(ctx context.Context) (*SourceSize, error)

+ func (s *GDriveSource) Walk(ctx context.Context, callback func(core.FileMeta) error) error

+ type IncrementalSource interface

+ GetStartPageToken func() (string, error)

+ WalkChanges func(ctx context.Context, token string, callback func(FileChange) error) (newToken string, err error)

+ type LocalOption func(*localOptions)

+ func WithLocalExcludePatterns(patterns []string) LocalOption

+ type LocalSource struct

+ func NewLocalSource(rootPath string, opts ...LocalOption) *LocalSource

+ func (s *LocalSource) GetFileStream(fileID string) (io.ReadCloser, error)

+ func (s *LocalSource) Info() core.SourceInfo

+ func (s *LocalSource) Size(ctx context.Context) (*SourceSize, error)

+ func (s *LocalSource) Walk(ctx context.Context, callback func(core.FileMeta) error) error

+ type OneDriveChangeSource struct

+ func NewOneDriveChangeSource(ctx context.Context, opts ...OneDriveOption) (*OneDriveChangeSource, error)

+ func (s *OneDriveChangeSource) GetStartPageToken() (string, error)

+ func (s *OneDriveChangeSource) Info() core.SourceInfo

+ func (s *OneDriveChangeSource) WalkChanges(ctx context.Context, token string, callback func(FileChange) error) (string, error)

+ type OneDriveOption func(*oneDriveOptions)

+ func WithOneDriveClientID(id string) OneDriveOption

+ func WithOneDriveExcludePatterns(patterns []string) OneDriveOption

+ func WithOneDriveTokenPath(path string) OneDriveOption

+ type OneDriveSource struct

+ func NewOneDriveSource(ctx context.Context, opts ...OneDriveOption) (*OneDriveSource, error)

+ func (s *OneDriveSource) GetFileStream(fileID string) (io.ReadCloser, error)

+ func (s *OneDriveSource) Info() core.SourceInfo

+ func (s *OneDriveSource) Size(ctx context.Context) (*SourceSize, error)

+ func (s *OneDriveSource) Walk(ctx context.Context, callback func(core.FileMeta) error) error

+ type SFTPOption func(*sftpOptions)

+ func WithSFTPExcludePatterns(patterns []string) SFTPOption

+ func WithSFTPSourceBasePath(basePath string) SFTPOption

+ func WithSFTPSourceClient(client *sftp.Client) SFTPOption

+ func WithSFTPSourceKey(keyPath string) SFTPOption

+ func WithSFTPSourcePassword(password string) SFTPOption

+ func WithSFTPSourcePort(port string) SFTPOption

+ func WithSFTPSourceUser(user string) SFTPOption

+ type SFTPSource struct

+ func NewSFTPSource(host string, opts ...SFTPOption) (*SFTPSource, error)

+ func (s *SFTPSource) Close() error

+ func (s *SFTPSource) GetFileStream(fileID string) (io.ReadCloser, error)

+ func (s *SFTPSource) Info() core.SourceInfo

+ func (s *SFTPSource) Size(ctx context.Context) (*SourceSize, error)

+ func (s *SFTPSource) Walk(ctx context.Context, callback func(core.FileMeta) error) error

+ type Source interface

+ GetFileStream func(fileID string) (io.ReadCloser, error)

+ Info func() core.SourceInfo

+ Size func(ctx context.Context) (*SourceSize, error)

+ Walk func(ctx context.Context, callback func(core.FileMeta) error) error

+ type SourceSize struct

+ Bytes int64

+ Files int64

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