cachingreader

Documentation

Index

• type ObjectServer
  • func NewObjectServer(baseDir string, maxCachedBytes uint64, objectServerAddress string, ...) (*ObjectServer, error)
  • func (objSrv *ObjectServer) FetchObjects(hashes []hash.Hash) error
  • func (objSrv *ObjectServer) GetObjects(hashes []hash.Hash) (objectserver.ObjectsReader, error)
  • func (objSrv *ObjectServer) GetStats() Stats
  • func (objSrv *ObjectServer) LinkObject(filename string, hashVal hash.Hash) (bool, error)
  • func (objSrv *ObjectServer) WriteHtml(writer io.Writer)
• type Stats

Types

type ObjectServer

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

func NewObjectServer

func NewObjectServer(baseDir string, maxCachedBytes uint64,
	objectServerAddress string, logger log.DebugLogger) (*ObjectServer, error)

func (*ObjectServer) FetchObjects

func (objSrv *ObjectServer) FetchObjects(hashes []hash.Hash) error

func (*ObjectServer) GetObjects

func (objSrv *ObjectServer) GetObjects(hashes []hash.Hash) (
	objectserver.ObjectsReader, error)

func (*ObjectServer) GetStats

func (objSrv *ObjectServer) GetStats() Stats

func (*ObjectServer) LinkObject

func (objSrv *ObjectServer) LinkObject(filename string,
	hashVal hash.Hash) (bool, error)

func (*ObjectServer) WriteHtml

func (objSrv *ObjectServer) WriteHtml(writer io.Writer)

type Stats

type Stats struct {
	CachedBytes      uint64 // Includes LruBytes.
	DownloadingBytes uint64 // Objects being downloaded and cached.
	LruBytes         uint64 // Cached but not in-use objects.

}