client

Documentation

Index

• Variables
• func NextKey(key string) string
• type Blob
• type BlobStore
  • func NewBlobStore(serverAddr string) *BlobStore
  • func (bs *BlobStore) Enumerate(blobs chan<- string, start, end string, limit int) error
  • func (bs *BlobStore) Get(hash string) ([]byte, error)
  • func (bs *BlobStore) ProcessBlobs()
  • func (bs *BlobStore) Put(hash string, blob []byte) error
  • func (bs *BlobStore) SetAPIKey(apiKey string)
  • func (bs *BlobStore) Stat(hash string) (bool, error)
  • func (bs *BlobStore) WaitBlobs()
• type BlobsBuffer
  • func NewBlobsBuffer(bs *BlobStore) *BlobsBuffer
  • func (bb *BlobsBuffer) AddBlob(hash string, blob []byte) error
  • func (bb *BlobsBuffer) Close()
  • func (bb *BlobsBuffer) Upload() error
• type BlobsResp
• type KvStore
  • func NewKvStore(serverAddr string) *KvStore
  • func (kvs *KvStore) Get(key string, version int) (*response.KeyValue, error)
  • func (kvs *KvStore) Keys(start, end string, limit int) ([]*response.KeyValue, error)
  • func (kvs *KvStore) Put(key, value string, version int) (*response.KeyValue, error)
  • func (kvs *KvStore) Versions(key string, start, end, limit int) (*response.KeyValueVersions, error)
• type MultipartWriter
  • func NewMultipartWriter() *MultipartWriter
  • func (mpw *MultipartWriter) AddBlob(hash string, blob []byte) error
  • func (mpw *MultipartWriter) Close() error
  • func (mpw *MultipartWriter) FormDataContentType() string

Variables

var ErrBlobNotFound = errors.New("blob not found")

ErrBlobNotFound is returned from a get/stat request if the blob does not exist.

var ErrKeyNotFound = errors.New("key doest not exist")

Functions

func NextKey

func NextKey(key string) string

NextKey returns the next key for lexigraphical (key = NextKey(lastkey))

Types

type Blob

type Blob struct {
	Hash string
	Blob string
}

type BlobStore

type BlobStore struct {
	ServerAddr string
	// contains filtered or unexported fields
}

func NewBlobStore

func NewBlobStore(serverAddr string) *BlobStore

func (*BlobStore) Enumerate

func (bs *BlobStore) Enumerate(blobs chan<- string, start, end string, limit int) error

func (*BlobStore) Get

func (bs *BlobStore) Get(hash string) ([]byte, error)

Get fetch the given blob.

func (*BlobStore) ProcessBlobs

func (bs *BlobStore) ProcessBlobs()

func (*BlobStore) Put

func (bs *BlobStore) Put(hash string, blob []byte) error

func (*BlobStore) SetAPIKey

func (bs *BlobStore) SetAPIKey(apiKey string)

func (*BlobStore) Stat

func (bs *BlobStore) Stat(hash string) (bool, error)

Stat checks wether a blob exists or not.

func (*BlobStore) WaitBlobs

func (bs *BlobStore) WaitBlobs()

type BlobsBuffer

type BlobsBuffer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewBlobsBuffer

func NewBlobsBuffer(bs *BlobStore) *BlobsBuffer

func (*BlobsBuffer) AddBlob

func (bb *BlobsBuffer) AddBlob(hash string, blob []byte) error

func (*BlobsBuffer) Close

func (bb *BlobsBuffer) Close()

func (*BlobsBuffer) Upload

func (bb *BlobsBuffer) Upload() error

type BlobsResp

type BlobsResp struct {
	Blobs []string `json:"blobs"`
}

type KvStore

type KvStore struct {
	ServerAddr string
	// contains filtered or unexported fields
}

func NewKvStore

func NewKvStore(serverAddr string) *KvStore

func (*KvStore) Get

func (kvs *KvStore) Get(key string, version int) (*response.KeyValue, error)

func (*KvStore) Keys

func (kvs *KvStore) Keys(start, end string, limit int) ([]*response.KeyValue, error)

func (*KvStore) Put

func (kvs *KvStore) Put(key, value string, version int) (*response.KeyValue, error)

func (*KvStore) Versions

func (kvs *KvStore) Versions(key string, start, end, limit int) (*response.KeyValueVersions, error)

type MultipartWriter

type MultipartWriter struct {
	Buffer *bytes.Buffer
	Writer *multipart.Writer
	Blobs  int
}

func NewMultipartWriter

func NewMultipartWriter() *MultipartWriter

func (*MultipartWriter) AddBlob

func (mpw *MultipartWriter) AddBlob(hash string, blob []byte) error

func (*MultipartWriter) Close

func (mpw *MultipartWriter) Close() error

func (*MultipartWriter) FormDataContentType

func (mpw *MultipartWriter) FormDataContentType() string