kvhttp

Documentation

Index

• func NewController(addr api.WarehouseLocation) (warehouse.BlobstoreController, error)
• type Controller
  • func (whCtrl Controller) OpenReader(wareID api.WareID) (io.ReadCloser, error)
  • func (whCtrl Controller) OpenWriter() (warehouse.BlobstoreWriteController, error)

Functions

func NewController

func NewController(addr api.WarehouseLocation) (warehouse.BlobstoreController, error)

Initialize a new warehouse controller that operates on a local filesystem.

May return errors of category:

• `rio.ErrUsage` -- for unsupported addressses
• `rio.ErrWarehouseUnavailable` -- if the warehouse doesn't exist

Types

type Controller

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

func (Controller) OpenReader

func (whCtrl Controller) OpenReader(wareID api.WareID) (io.ReadCloser, error)

func (Controller) OpenWriter

func (whCtrl Controller) OpenWriter() (warehouse.BlobstoreWriteController, error)