sftp

Documentation

Index

• type SFTPImporter
  • func NewSFTPImporter(name string, loader *config.OptionLoader) (*SFTPImporter, error)
  • func (si *SFTPImporter) Name() string
  • func (si *SFTPImporter) Start(ctx context.Context) error
  • func (si *SFTPImporter) Stop() error

Types

type SFTPImporter

type SFTPImporter struct {
	Logger nacelle.Logger `service:"logger"`
	API    *api.Client    `service:"api"`
	// contains filtered or unexported fields
}

func NewSFTPImporter

func NewSFTPImporter(name string, loader *config.OptionLoader) (*SFTPImporter, error)

func (*SFTPImporter) Name

func (si *SFTPImporter) Name() string

func (*SFTPImporter) Start

func (si *SFTPImporter) Start(ctx context.Context) error

func (*SFTPImporter) Stop

func (si *SFTPImporter) Stop() error