remote_comms_facade

Documentation

Index

• type Facade
• type Factory
  • func NewFactory(logger logger.Logger, gopsexecClient *gpClient.Client, ...) Factory
• type Result
  • func (r *Result) AppendError(err error)
  • func (r *Result) AppendFeedback(feedback string)
  • func (r *Result) CombinedErrorLines() string
  • func (r *Result) CombinedFeedbackLines() string
  • func (r *Result) ErrorStrings() (errStrs []string)
• type StartedDetails
  • func (s *StartedDetails) Wait() *Result

Types

type Facade

type Facade interface {
	Ping() error
	ConfirmVersionMatch(version string) error

	GetTempDir() (string, error)
	GetOsType() (osvisitors.OsType, error)

	// Start() (*StartedDetails, error)
	StartDetached(workingDir string, commandLine ...string) (*StartedDetails, error)

	CheckPathsAreInSync(logger logger.Logger, localPath, remotePath string) (bool, error)

	Upload(localPath, remotePath string) error
	DownloadDir(remotePath, localPath string) error

	ReadFileContent(remotePath string) ([]byte, error)
	UploadFileContent(remotePath string, content []byte) error

	Stats(remotePath string) (*dtos.StatsDto, error)
	Copy(srcRemotePath, destRemotePath string) error
	Symlink(srcRemotePath, destRemoteSymlinkPath string) error
	Move(oldRemotePath, newRemotePath string) error

	Delete(remotePath string) error
}

type Factory

type Factory interface {
	NewFacade(hostDetails host_details.HostDetails) Facade
}

Factory will create instances of Facade

func NewFactory

func NewFactory(logger logger.Logger, gopsexecClient *gpClient.Client, filepathSummaryService filepath_summary.Service) Factory

NewFactory creates a new Factory instance

type Result

type Result struct {
	FeedbackLines []string
	Errors        []error
}

func (*Result) AppendError

func (r *Result) AppendError(err error)

func (*Result) AppendFeedback

func (r *Result) AppendFeedback(feedback string)

func (*Result) CombinedErrorLines

func (r *Result) CombinedErrorLines() string

func (*Result) CombinedFeedbackLines

func (r *Result) CombinedFeedbackLines() string

func (*Result) ErrorStrings

func (r *Result) ErrorStrings() (errStrs []string)

type StartedDetails

type StartedDetails struct {
	Pid          int
	FeedbackChan <-chan string
	ErrorChan    <-chan error
}

func (*StartedDetails) Wait

func (s *StartedDetails) Wait() *Result