sync

Documentation

Index

• Constants
• func CopyToContainer(Kubectl *kubernetes.Clientset, Pod *k8sv1.Pod, Container *k8sv1.Container, ...) error
• type Symlink
  • func NewSymlink(upstream *upstream, symlinkPath, targetPath string, isDir bool) (*Symlink, error)
  • func (s *Symlink) Crawl() error
  • func (s *Symlink) Stop()
• type SyncConfig
  • func (s *SyncConfig) Error(err error)
  • func (s *SyncConfig) Logf(format string, args ...interface{})
  • func (s *SyncConfig) Logln(line interface{})
  • func (s *SyncConfig) Start() error
  • func (s *SyncConfig) Stop(fatalError error)

Constants

const EndAck string = "DONE"

EndAck signals to the user that the sync process is done

const ErrorAck string = "ERROR"

ErrorAck signals to the user that an error occurred

const IsDirectory uint64 = 040000

IsDirectory is a constant that can be used to determine whether a file is a folder

const IsRegularFile uint64 = 0100000

IsRegularFile is a constant that can be used to determine whether a file is a regular file

const IsSymbolicLink uint64 = 0120000

IsSymbolicLink is a constant that can be used to determine whether a file is a symbolic link

const StartAck string = "START"

StartAck signals to the user that the sync process is starting

Functions

func CopyToContainer

func CopyToContainer(Kubectl *kubernetes.Clientset, Pod *k8sv1.Pod, Container *k8sv1.Container, LocalPath, ContainerPath string, ExcludePaths []string) error

CopyToContainer copies a local folder to a container path

Types

type Symlink

type Symlink struct {
	SymlinkPath string
	TargetPath  string

	IsDir bool
	// contains filtered or unexported fields
}

Symlink holds information about a symlink

func NewSymlink

func NewSymlink(upstream *upstream, symlinkPath, targetPath string, isDir bool) (*Symlink, error)

NewSymlink creates a new symlink object

func (*Symlink) Crawl

func (s *Symlink) Crawl() error

Crawl resolves the symlink and sends an event for each file in the target path

func (*Symlink) Stop

func (s *Symlink) Stop()

Stop stops watching on the watching path

type SyncConfig

type SyncConfig struct {
	Kubectl              *kubernetes.Clientset
	Pod                  *k8sv1.Pod
	Container            *k8sv1.Container
	WatchPath            string
	DestPath             string
	ExcludePaths         []string
	DownloadExcludePaths []string
	UploadExcludePaths   []string
	UpstreamLimit        int64
	DownstreamLimit      int64
	Verbose              bool
	// contains filtered or unexported fields
}

SyncConfig holds the necessary information for the syncing process

func (*SyncConfig) Error

func (s *SyncConfig) Error(err error)

Error handles a sync error with context

func (*SyncConfig) Logf

func (s *SyncConfig) Logf(format string, args ...interface{})

Logf prints the given information to the synclog with context data

func (*SyncConfig) Logln

func (s *SyncConfig) Logln(line interface{})

Logln prints the given information to the synclog with context data

func (*SyncConfig) Start

func (s *SyncConfig) Start() error

Start starts a new sync instance

func (*SyncConfig) Stop

func (s *SyncConfig) Stop(fatalError error)

Stop stops the sync process