From 2c69433588e2223d8d106cecb4c55486d3651efa Mon Sep 17 00:00:00 2001
From: "Frederick F. Kautz IV" <fkautz@alumni.cmu.edu>
Date: Wed, 18 Mar 2015 14:27:10 -0700
Subject: [PATCH] Adding interfaces for donut driver

---
 pkg/storage/donut/donut.go       | 45 ++++++++++++++++++++++++++++++
 pkg/storage/donut/donutdriver.go | 48 ++++++++++++++++++++++++++++++++
 2 files changed, 93 insertions(+)
 create mode 100644 pkg/storage/donut/donut.go
 create mode 100644 pkg/storage/donut/donutdriver.go

diff --git a/pkg/storage/donut/donut.go b/pkg/storage/donut/donut.go
new file mode 100644
index 000000000..3ea14d0d2
--- /dev/null
+++ b/pkg/storage/donut/donut.go
@@ -0,0 +1,45 @@
+package donut
+
+import "io"
+
+// INTERFACES
+
+// Donut interface
+type Donut interface {
+	CreateBucket(bucket string) error
+	GetBuckets() ([]string, error)
+	GetObject(bucket, object string) (io.ReadCloser, error)
+	GetObjectMetadata(bucket, object string) (map[string]string, error)
+	GetObjectWriter(bucket, object string) (ObjectWriter, error)
+}
+
+// Bucket is an interface for managing buckets
+type Bucket interface {
+	GetObject(object string) (io.Reader, error)
+	GetObjectMetadata(object string) (map[string]string, error)
+	GetObjectWriter(object string) (ObjectWriter, error)
+	GetObjects() ([]string, error)
+}
+
+// Disk is an interface for managing disks
+type Disk interface {
+	GetBuckets(object string) ([]string, error)
+}
+
+// ObjectWriter is an interface for writing new objects
+type ObjectWriter interface {
+	Write([]byte) error
+	Close() error
+	CloseWithError(error) error
+
+	SetMetadata(map[string]string)
+	GetMetadata() map[string]string
+}
+
+// InternalObjectWriter is an interface for use internally to donut
+type InternalObjectWriter interface {
+	ObjectWriter
+
+	SetDonutMetadata(map[string]string)
+	GetDonutMetadata() map[string]string
+}
diff --git a/pkg/storage/donut/donutdriver.go b/pkg/storage/donut/donutdriver.go
new file mode 100644
index 000000000..98bb3fd42
--- /dev/null
+++ b/pkg/storage/donut/donutdriver.go
@@ -0,0 +1,48 @@
+package donut
+
+import (
+	"errors"
+	"io"
+)
+
+type donutDriver struct {
+	buckets map[string]Bucket
+	disks   map[string]Disk
+}
+
+// NewDonutDriver instantiates a donut driver for use in object storage
+func NewDonutDriver() Donut {
+	return donutDriver{
+		buckets: make(map[string]Bucket),
+		disks:   make(map[string]Disk),
+	}
+}
+
+func notImplemented() error {
+	return errors.New("Not Implemented")
+}
+
+// CreateBucket creates a bucket
+func (driver donutDriver) CreateBucket(bucket string) error {
+	return notImplemented()
+}
+
+// GetBuckets returns a list of buckets
+func (driver donutDriver) GetBuckets() ([]string, error) {
+	return nil, notImplemented()
+}
+
+// GetObject returns an object
+func (driver donutDriver) GetObject(bucket, object string) (io.ReadCloser, error) {
+	return nil, notImplemented()
+}
+
+// GetObjectMetadata returns object metadata
+func (driver donutDriver) GetObjectMetadata(bucket, object string) (map[string]string, error) {
+	return nil, notImplemented()
+}
+
+// GetObjectWriter returns a writer for creating a new object.
+func (driver donutDriver) GetObjectWriter(bucket, object string) (ObjectWriter, error) {
+	return nil, notImplemented()
+}