engine

Documentation

Index

• Variables
• func RegisterObjectEngine(name string, newEngine ObjectEngineConstructor)
• type Object
• type ObjectEngine
• type ObjectEngineConstructor
  • func FindEngine(name string) (ObjectEngineConstructor, error)

Variables

var (
	ErrEngineNotFound = errors.New("object engine not found")
)

Functions

func RegisterObjectEngine

func RegisterObjectEngine(name string, newEngine ObjectEngineConstructor)

Types

type Object

type Object interface {
	Exists() bool

	Quarantine() error

	Metadata() map[string]string

	ContentLength() int64

	CopyRange(io.Writer, int64, int64) (int64, error)

	Copy(...io.Writer) (int64, error)

	SetData(size int64) (io.Writer, error)

	Commit(metadata map[string]string) error

	CommitMeta(metadata map[string]string) error

	Delete(metadata map[string]string) error

	Close() error

	Repr() string
}

type ObjectEngine

type ObjectEngine interface {
	New(vars map[string]string, needData bool) (Object, error)

	GetHashes(device, partition string, recalculate []string) (map[string]string, error)

	Close() error
}

type ObjectEngineConstructor

type ObjectEngineConstructor func(conf.Config, *conf.Policy, *flag.FlagSet, *sync.WaitGroup) (ObjectEngine, error)

func FindEngine

func FindEngine(name string) (ObjectEngineConstructor, error)