reflector

Apr 3, 2020

Changes in this version

+ var ErrBlobTooBig = errors.Base("blob must be at most %d bytes", maxBlobSize)

Aug 28, 2019

Changes in this version

+ func IsValidJSON(b []byte) bool

type Server

+ EnableBlocklist bool

+ type Stats struct

+ func NewStatLogger(name string, logger *log.Logger, logFreq time.Duration, parentGrp *stop.Group) *Stats

+ func (s *Stats) AddBlob()

+ func (s *Stats) AddError(e error) (shouldLog bool)

+ func (s *Stats) AddStream()

+ func (s *Stats) Shutdown()

+ func (s *Stats) Start()

+ type Summary struct

+ AlreadyStored int

+ Blob int

+ Err int

+ Sd int

+ Total int

+ type Uploader struct

+ func NewUploader(db *db.SQL, store *store.DBBackedS3Store, workers int, skipExistsCheck bool) *Uploader

+ func (u *Uploader) GetSummary() Summary

+ func (u *Uploader) Stop()

+ func (u *Uploader) Upload(dirOrFilePath string) error

Aug 28, 2018

Changes in this version

type Server

+ StatLogger *log.Logger

+ StatReportFrequency time.Duration

Aug 15, 2018

Changes in this version

+ func BlobHash(blob []byte) string

type Server

+ Timeout time.Duration

Aug 9, 2018

Changes in this version

+ const DefaultTimeout

Aug 7, 2018

Changes in this version

+ const DefaultPort

+ var ErrBlobExists = errors.Base("blob exists on server")

+ type Client struct

+ func (c *Client) Close() error

+ func (c *Client) Connect(address string) error

+ func (c *Client) SendBlob(blob []byte) error

+ type Server struct

+ func NewServer(store store.BlobStore) *Server

+ func (s *Server) Shutdown()

+ func (s *Server) Start(address string) error