poll

Documentation

Index

• type Config
• type Poller
  • func New(snapshot map[string]time.Time, ctx context.Context, config *Config, ...) (Poller, error)
• type Update

Types

type Config

type Config struct {
	// Directory for downloaded files
	TempDir string

	// True to only show commands w/o executing them
	DryRun bool

	// URL:port of the sftp server to poll
	HostPort string

	// ssh configuration
	Ssh *ssh.ClientConfig
}

type Poller

type Poller interface {
	io.Closer
	Updates() <-chan *Update
}

func New

func New(snapshot map[string]time.Time, ctx context.Context, config *Config, remoteRoot string) (Poller, error)

type Update

type Update struct {
	Path      string
	Timestamp time.Time
}

Update represents either a poller downloaded artefact, or describes a remote file entry