broker

Documentation

Overview

Package broker proxies requests from client, and routes to target nodes.

Index

• Constants
• func NewHTTPHandler(broker *Broker) http.Handler
• type Broker
  • func New(store kv.Store, specMgr *specmgr.SpecManager) *Broker
  • func (b *Broker) GetBlob(ctx context.Context, key blob.Key) (*blobio.OptBlob, error)
  • func (b *Broker) PutBlob(ctx context.Context, blob *blob.Blob) error
  • func (b *Broker) Shutdown()

Constants

const HTTPPathPrefix = "/"

Functions

func NewHTTPHandler

func NewHTTPHandler(broker *Broker) http.Handler

Types

type Broker

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

Broker broker is entry to access solidb

func New

func New(store kv.Store, specMgr *specmgr.SpecManager) *Broker

New create an broker instance

func (*Broker) GetBlob

func (b *Broker) GetBlob(ctx context.Context, key blob.Key) (*blobio.OptBlob, error)

GetBlob get blob by its key

func (*Broker) PutBlob

func (b *Broker) PutBlob(ctx context.Context, blob *blob.Blob) error

PutBlob store a blob

func (*Broker) Shutdown

func (b *Broker) Shutdown()

Shutdown stop all goroutines and wait for stopped