sender

Documentation

Index

• Constants
• type FileData
  • func DecodeGobFileData(reader io.Reader) (*FileData, error)
  • func NewFileData(name string) *FileData
  • func (f *FileData) Content() []byte
  • func (f *FileData) Name() string
  • func (f *FileData) SetContent(content []byte)
  • func (f *FileData) Size() int
• type FileReader
  • func NewFileReader(path string) (*FileReader, error)
  • func (r FileReader) Delete(name string) error
  • func (r FileReader) ReadDir() ([]*FileData, error)
  • func (r FileReader) ReadFile(name string) (*FileData, error)
• type Sender
  • func NewSender(addr string, reader *FileReader) *Sender
  • func (s *Sender) Close() error
  • func (s *Sender) Open() error
  • func (s *Sender) Reconnect()
  • func (s *Sender) Run()
  • func (s *Sender) SendFiles() error
  • func (s *Sender) Stop()

Constants

const (
	ConnectTimeout    = 5
	KeepaliveInterval = 10
	FileCheckInterval = 5
	DataTimeout       = 5
)

Types

type FileData

type FileData struct {
	RawName    string
	RawContent []byte
}

func DecodeGobFileData

func DecodeGobFileData(reader io.Reader) (*FileData, error)

func NewFileData

func NewFileData(name string) *FileData

func (*FileData) Content

func (f *FileData) Content() []byte

func (*FileData) Name

func (f *FileData) Name() string

func (*FileData) SetContent

func (f *FileData) SetContent(content []byte)

func (*FileData) Size

func (f *FileData) Size() int

type FileReader

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

func NewFileReader

func NewFileReader(path string) (*FileReader, error)

func (FileReader) Delete

func (r FileReader) Delete(name string) error

func (FileReader) ReadDir

func (r FileReader) ReadDir() ([]*FileData, error)

func (FileReader) ReadFile

func (r FileReader) ReadFile(name string) (*FileData, error)

type Sender

type Sender struct {
	TlsConfig *tls.Config
	// contains filtered or unexported fields
}

func NewSender

func NewSender(addr string, reader *FileReader) *Sender

func (*Sender) Close

func (s *Sender) Close() error

func (*Sender) Open

func (s *Sender) Open() error

func (*Sender) Reconnect

func (s *Sender) Reconnect()

func (*Sender) Run

func (s *Sender) Run()

func (*Sender) SendFiles

func (s *Sender) SendFiles() error

func (*Sender) Stop

func (s *Sender) Stop()