pool

Documentation

Index

• type Closer
• type Option
  • func WithContext(ctx context.Context) Option
  • func WithDownload(fn transferFn) Option
  • func WithMaxSize(max int) Option
  • func WithUpload(fn transferFn) Option
• type WorkerPool
  • func NewPool(config *ssh.ClientConfig, ipPort string, opts ...Option) *WorkerPool
  • func (p *WorkerPool) Close()
  • func (p *WorkerPool) DownloadFile(src, dest string)
  • func (p *WorkerPool) UploadFile(src, dest string)
  • func (p *WorkerPool) Wait() error

Types

type Closer

type Closer interface {
	Close() error
}

type Option

type Option func(wp *WorkerPool)

func WithContext

func WithContext(ctx context.Context) Option

func WithDownload

func WithDownload(fn transferFn) Option

func WithMaxSize

func WithMaxSize(max int) Option

func WithUpload

func WithUpload(fn transferFn) Option

type WorkerPool

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

func NewPool

func NewPool(config *ssh.ClientConfig, ipPort string, opts ...Option) *WorkerPool

NewPool creates a new pool of connections and starts GC. If no configuration is specified (nil), defaults values are used.

func (*WorkerPool) Close

func (p *WorkerPool) Close()

func (*WorkerPool) DownloadFile

func (p *WorkerPool) DownloadFile(src, dest string)

func (*WorkerPool) UploadFile

func (p *WorkerPool) UploadFile(src, dest string)

func (*WorkerPool) Wait

func (p *WorkerPool) Wait() error