send

Documentation

Index

• func SendFiles(ctx context.Context, cfg *config.Config, filePaths []string, ...) error
• func SendToDevice(ctx context.Context, cfg *config.Config, device *model.Device, ...) error
• type IdleTimeoutReader
  • func NewIdleTimeoutReader(r io.ReadCloser, timeout time.Duration, cancel func()) *IdleTimeoutReader
  • func (tr *IdleTimeoutReader) Close() error
  • func (tr *IdleTimeoutReader) Read(p []byte) (int, error)

Functions

func SendFiles

func SendFiles(ctx context.Context, cfg *config.Config, filePaths []string, recipientAlias string, recipientPort int, logger *zap.SugaredLogger) error

SendFiles sends files or directories to a recipient.

func SendToDevice

func SendToDevice(ctx context.Context, cfg *config.Config, device *model.Device, filePaths []string, logger *zap.SugaredLogger) error

Types

type IdleTimeoutReader

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

IdleTimeoutReader wraps an io.ReadCloser and cancels the context if no data is read within the configured idle duration.

func NewIdleTimeoutReader

func NewIdleTimeoutReader(r io.ReadCloser, timeout time.Duration, cancel func()) *IdleTimeoutReader

NewIdleTimeoutReader creates an IdleTimeoutReader.

func (*IdleTimeoutReader) Close

func (tr *IdleTimeoutReader) Close() error

func (*IdleTimeoutReader) Read

func (tr *IdleTimeoutReader) Read(p []byte) (int, error)