storage

type IndexFile struct {
	Temporary bool
	MapIdx    int32
	ReduceIdx int32
	Body      *[]KeyValue
}

type KeyValue struct {
	Key   string
	Value string
}

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

type Persister interface {
	Init() (err error)
	Destroy() (err error)
	RetrieveMRIdx(path string) (mIdx int32, rIdx int32)
	Writable(file IndexFile) (path string, err error)
	Commit(file IndexFile) (path string, err error)
	Readable(file IndexFile) (path string, err error)
	Request(file IndexFile) (path string, err error)
	Abort(file IndexFile) (err error)
	Delete(file IndexFile) (err error)
}

type S3Config struct {
	Endpoint          string `json:"endpoint"`
	AccessKeyID       string `json:"access_key_id"`
	SecretAccessKeyID string `json:"secret_access_key_id"`
	UseSSL            bool   `json:"use_ssl"`
	Bucket            string `json:"bucket"`
	Root              string `json:"root"`
}

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