client

type Broker struct {
	Conf *Conf
	// contains filtered or unexported fields
}

type Conf struct {
	Name string // The name assigned to this broker/client instance

	// Components
	Store        sts.FileSource          // The source of file objects from which to read (and delete)
	Cache        sts.FileCache           // The persistent cache of file metadata from the store
	Queue        sts.FileQueue           // The queue that takes files ready to send and chunks them up in its configured order
	Recoverer    sts.Recover             // The function that determines what chunks need to be sent first
	BuildPayload sts.PayloadFactory      // The function that creates a Payload instance
	Transmitter  sts.Transmit            // The transmission implementation
	TxRecoverer  sts.RecoverTransmission // The transmission recovery implementation
	Validator    sts.Validate            // The validation implementation
	Logger       sts.SendLogger          // The logger used to log completed files

	// Helpers
	Tagger  sts.Translate // Takes a file name and provides a tag name
	Renamer sts.Rename    // Takes a file and provides a new target file name

	// Options
	CacheAge     time.Duration    // How long to keep files in the cache after being sent
	ScanDelay    time.Duration    // How long to wait between scans of the store (0 means only once and we're done)
	Threads      int              // How many go routines for sending data
	PayloadSize  units.Base2Bytes // How large a single transmission payload should be (before any compression by the transmitter)
	StatPayload  bool             // Whether or not to record single-payload throughput stats
	StatInterval time.Duration    // How long to wait between logging transmission rate statistics
	PollDelay    time.Duration    // How long to wait before validating completed files after final transmission
	PollInterval time.Duration    // How long to wait between between validation requests
	PollAttempts int              // How many times to attempt validation for a single file before giving up
	Tags         []*FileTag       // Options for files of a particular pattern
	ErrorBackoff float64          // Multiplier for backoff time
}

type FileTag struct {
	Name        string // The name of the tag to be matched by the tagger
	InOrder     bool   // Whether or not the order files are received matters
	Delete      bool
	DeleteDelay time.Duration
}