osio

Apr 6, 2022

Changes in this version

+ type Client interface

+ Do func(*http.Request) (*http.Response, error)

Nov 4, 2021

Changes in this version

+ var StdLogger stdLogger

+ func WithLogger(logger Logger) interface

+ type Logger interface

+ Log func(key string, offset, length int64)

Sep 29, 2021

Changes in this version

type Adapter

+ func (a *Adapter) Size(key string) (int64, error)

type HTTPHandler

+ func (h *HTTPHandler) StreamAt(key string, off int64, n int64) (io.ReadCloser, int64, error)

+ type KeyStreamerAt interface

+ StreamAt func(key string, off int64, n int64) (io.ReadCloser, int64, error)

Aug 4, 2021

Changes in this version

+ func Retries(retries int) interface

+ type HTTPHandler struct

+ func HTTPHandle(ctx context.Context, opts ...HTTPOption) (*HTTPHandler, error)

+ func (h *HTTPHandler) ReadAt(url string, p []byte, off int64) (int, int64, error)

+ type HTTPOption func(o *HTTPHandler)

+ func HTTPBasicAuth(username, password string) HTTPOption

+ func HTTPClient(cl *http.Client) HTTPOption

+ func HTTPHeader(key, value string) HTTPOption

+ type S3Handler struct

+ func S3Handle(ctx context.Context, opts ...S3Option) (*S3Handler, error)

+ func (h *S3Handler) ReadAt(key string, p []byte, off int64) (int, int64, error)

+ type S3Option func(o *S3Handler)

+ func S3Client(cl *s3.Client) S3Option

+ func S3RequestPayer() S3Option

Jul 1, 2021

Changes in this version

type NamedOnceMutex

+ TryLock func(key interface{}) bool

May 6, 2021

Changes in this version

+ const DefaultBlockSize

+ const DefaultNumCachedBlocks

+ func BlockSize(blockSize string) interface

+ func NumCachedBlocks(n int) interface

+ func SizeCache(numEntries int) interface

+ func SplitRanges(splitRanges bool) interface

+ type Adapter struct

+ func NewAdapter(reader KeyReaderAt, opts ...AdapterOption) (*Adapter, error)

+ func (a *Adapter) ReadAt(key string, p []byte, off int64) (int, error)

+ func (a *Adapter) ReadAtMulti(key string, bufs [][]byte, offsets []int64) ([]int, error)

+ func (a *Adapter) Reader(key string) (*Reader, error)

+ type AdapterOption interface

+ func BlockCache(bc BlockCacher) AdapterOption

+ type BlockCacher interface

+ Add func(key string, blockID uint, data []byte)

+ Get func(key string, blockID uint) ([]byte, bool)

+ type GCSHandler struct

+ func GCSHandle(ctx context.Context, opts ...GCSOption) (*GCSHandler, error)

+ func (gcs *GCSHandler) ReadAt(key string, p []byte, off int64) (int, int64, error)

+ type GCSOption func(o *GCSHandler)

+ func GCSBillingProject(projectID string) GCSOption

+ func GCSClient(cl *storage.Client) GCSOption

+ type KeyReaderAt interface

+ ReadAt func(key string, p []byte, off int64) (int, int64, error)

+ type LRUCache struct

+ func NewLRUCache(numEntries int) (*LRUCache, error)

+ func (cg *LRUCache) Add(key string, id uint, data []byte)

+ func (cg *LRUCache) Get(key string, id uint) ([]byte, bool)

+ func (cg *LRUCache) Purge()

+ func (cg *LRUCache) PurgeKey(prefix string)

+ type NamedOnceMutex interface

+ Lock func(key interface{}) bool

+ Unlock func(key interface{})

+ type Reader struct

+ func (r *Reader) Read(buf []byte) (int, error)

+ func (r *Reader) ReadAt(buf []byte, off int64) (int, error)

+ func (r *Reader) ReadAtMulti(bufs [][]byte, offs []int64) ([]int, error)

+ func (r *Reader) Seek(off int64, nWhence int) (int64, error)

+ func (r *Reader) Size() int64