Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

blob

package

Go to main page

Versions in this module

v1

v1.1.3-rc-with-build

Dec 9, 2021

v1.1.3-rc

Dec 9, 2021

v1.1.2-rc

Nov 25, 2021

v1.1.1

Nov 12, 2021

Changes in this version

+ const DefaultConcurrency

v1.1.1-rc

Nov 12, 2021

v0

v0.2.22

May 12, 2021

v0.2.21

Mar 16, 2021

v0.2.20

Feb 20, 2021

Changes in this version

+ const BgSaveInterval

+ const CacheItemsPerBlob

+ const DefaultConcurency

+ const MaxCacheBlockSize

+ const ReqIDHeader

type Index

+ func (idx *Index) GetCachedReader(folder storage.Folder, s Section) (io.ReadCloser, error)

+ func (idx *Index) SaveDelayed()

type Section

+ BlockSize uint64

type Server

+ func (bs *Server) AcquireLock() (*flock.Flock, error)

v0.2.19

Nov 30, 2020

v0.2.18

Nov 6, 2020

v0.2.17

Aug 14, 2020

Changes in this version

+ const BlockAll

+ const BlockCommitted

+ const BlockLatest

+ const BlockListTag

+ const BlockUncommitted

+ const IndexFileName

+ const ProxyStartTimeout

+ var ErrBadRequest = errors.New("invalid request")

+ var ErrNoLease = errors.New("no lease")

+ var ErrNotFound = errors.New("object not found")

+ func NewSkipReader(r io.Reader, offset uint64) io.Reader

+ func SerializeBlocklistXML(bl *XBlockListOut) ([]byte, error)

+ type Block struct

+ CommittedRev uint

+ CommittedSize uint64

+ ID string

+ Offset uint64

+ UploadedRev uint

+ UploadedSize uint64

+ type DebugResponseWriter struct

+ func (drw *DebugResponseWriter) Header() http.Header

+ func (drw *DebugResponseWriter) Write(b []byte) (int, error)

+ func (drw *DebugResponseWriter) WriteHeader(s int)

+ type Index struct

+ Blocks []*Block

+ Size uint64

+ func NewIndex(f storage.Folder) *Index

+ func (idx *Index) Clear() []string

+ func (idx *Index) GetBlockList(ltype string) *XBlockListOut

+ func (idx *Index) GetSections(rangeMin, rangeMax uint64) []Section

+ func (idx *Index) Load() error

+ func (idx *Index) PutBlock(id string, size uint64) string

+ func (idx *Index) PutBlockList(xblocklist *XBlockListIn) ([]string, error)

+ func (idx *Index) Save() error

+ type Lease struct

+ End time.Time

+ ID string

+ type Section struct

+ Limit uint64

+ Offset uint64

+ Path string

+ type Server struct

+ func NewServer(folder storage.Folder) (*Server, error)

+ func (bs *Server) HandleAcquireLease(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) HandleBlob(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) HandleBlobDelete(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) HandleBlobGet(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) HandleBlobHead(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) HandleBlobPut(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) HandleBlock(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) HandleBlockList(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) HandleBlockListGet(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) HandleBlockListPut(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) HandleBlockPut(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) HandleChangeLease(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) HandleLease(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) HandleReleaseLease(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) HandleRenewLease(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) Run(ctx context.Context) error

+ func (bs *Server) RunBackground(ctx context.Context, cancel context.CancelFunc) error

+ func (bs *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) ServeHTTP2(w http.ResponseWriter, req *http.Request)

+ func (bs *Server) Shutdown() error

+ func (bs *Server) WaitReady(ctx context.Context, timeout time.Duration) error

+ type SkipReader struct

+ func (r *SkipReader) Read(s []byte) (int, error)

+ type XBlockIn struct

+ ID string

+ Mode string

+ func (b *XBlockIn) MarshalXML(e *xml.Encoder, start xml.StartElement) error

+ func (b *XBlockIn) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error

+ type XBlockListIn struct

+ Blocks []XBlockIn

+ func ParseBlocklistXML(data []byte) (*XBlockListIn, error)

+ func (bl *XBlockListIn) MarshalXML(e *xml.Encoder, start xml.StartElement) error

+ func (bl *XBlockListIn) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error

+ type XBlockListOut struct

+ CommittedBlocks struct{ ... }

+ UncommittedBlocks struct{ ... }

+ XMLName xml.Name

+ type XBlockOut struct

+ Name string

+ Size uint64

+ XMLName xml.Name