sync

Documentation

Index

• Constants
• func CopyToContainer(Kubectl *kubernetes.Clientset, Pod *k8sv1.Pod, Container *k8sv1.Container, ...) error
• type FileInformation
• type ParsingError
  • func (p ParsingError) Error() string
• type SyncConfig
  • func (s *SyncConfig) Logf(format string, args ...interface{})
  • func (s *SyncConfig) Logln(line interface{})
  • func (s *SyncConfig) Start()
  • func (s *SyncConfig) Stop()

Constants

const EndAck string = "DONE"

const ErrorAck string = "ERROR"

const IsDirectory uint64 = 040000

const IsRegularFile uint64 = 0100000

const IsSymbolicLink uint64 = 0120000

const StartAck string = "START"

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 or file to a container path

Types

type FileInformation

type FileInformation struct {
	Name        string // %n
	Size        int64  // %s
	Mtime       int64  // %Y
	IsDirectory bool   // parseHex(%f) & S_IFDIR
}

type ParsingError

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

func (ParsingError) Error

func (p ParsingError) Error() string

type SyncConfig

type SyncConfig struct {
	Kubectl      *kubernetes.Clientset
	Pod          *k8sv1.Pod
	Container    *k8sv1.Container
	WatchPath    string
	DestPath     string
	ExcludePaths []string
	// contains filtered or unexported fields
}

func (*SyncConfig) Logf

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

func (*SyncConfig) Logln

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

func (*SyncConfig) Start

func (s *SyncConfig) Start()

Starts a new sync instance

func (*SyncConfig) Stop

func (s *SyncConfig) Stop()