dmplugin

type Action interface {
	// Update sends an action status update
	Update(offset, length, max int64) error
	// ID returns the action item's ID
	ID() uint64
	// Offset returns the current offset of the action item
	Offset() int64
	// Length returns the expected length of the action item's file
	Length() int64
	// Data returns a byte slice of the action item's data
	Data() []byte
	// PrimaryPath returns the action item's primary file path
	PrimaryPath() string

	// WritePath returns the action item's write path (e.g. for restores)
	WritePath() string

	// UUID returns the action item's file id
	UUID() string

	// Hash returns the action item's file id
	Hash() []byte

	// URL returns the action item's file id
	URL() string

	// SetUUID sets the action's file id
	SetUUID(id string)

	// SetHash sets the action's file id
	SetHash(hash []byte)

	// SetURL sets the action's file id
	SetURL(id string)

	// SetActualLength sets the action's actual file length
	SetActualLength(length int64)
}

type ActionHandler func(Action) error

type Archiver interface {
	Archive(Action) error
}

type Config struct {
	Mover      Mover
	NumThreads int
	ArchiveID  uint32
}

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

type Fataler interface {
	Fatal(args ...interface{})
	Fatalf(format string, args ...interface{})
}

type Mover interface {
	Start()
}

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

type Remover interface {
	Remove(Action) error
}

type Restorer interface {
	Restore(Action) error
}

type TestAction struct {
	ActualLength int
	Updates      int
	// contains filtered or unexported fields
}