followers

Documentation

Index

• func Setup(ctx context.Context, ch chan worker.Message, urls []*url.URL) error
• type Listener
  • func (l *Listener) Run()
• type Process
  • func Dial(ctx context.Context, loc *url.URL) (*Process, error)

Functions

func Setup

func Setup(ctx context.Context, ch chan worker.Message, urls []*url.URL) error

Types

type Listener

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

func (*Listener) Run

func (l *Listener) Run()

type Process

type Process struct {
	Location *url.URL
	Comm     *commpipe.Pipe
	Session  *ssh.Session
}

func Dial

func Dial(ctx context.Context, loc *url.URL) (*Process, error)