storage

Documentation

Index

• Constants
• func InitLocalCache(config config.Bootstrap)
• type CacheNode
  • func NewMemCacheNode(needBig bool) CacheNode
• type Info
• type LocalCache
  • func NewLocalCache(s Storage) *LocalCache
  • func (c *LocalCache) CommitTemporaryNode(ctx context.Context, segID, idx int64, node CacheNode) error
  • func (c *LocalCache) OpenCacheNode(ctx context.Context, key, idx int64) (CacheNode, error)
  • func (c *LocalCache) OpenTemporaryNode(ctx context.Context, oid, off int64) (CacheNode, error)
• type Storage
  • func NewStorage(storageID, storageType string, cfg config.Storage) (s Storage, err error)

Constants

const (
	LocalStorage  = config.LocalStorage
	MemoryStorage = config.MemoryStorage
)

const (
	MinioStorage = config.MinioStorage
)

const (
	OSSStorage = config.OSSStorage
)

const (
	S3Storage = config.S3Storage
)

const (
	WebdavStorage = config.WebdavStorage
)

Functions

func InitLocalCache

func InitLocalCache(config config.Bootstrap)

Types

type CacheNode

type CacheNode interface {
	io.ReaderAt
	io.WriterAt
	io.Closer
	Size() int64
	// contains filtered or unexported methods
}

func NewMemCacheNode

func NewMemCacheNode(needBig bool) CacheNode

type Info

type Info struct {
	Key  string
	Size int64
}

type LocalCache

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

func NewLocalCache

func NewLocalCache(s Storage) *LocalCache

func (*LocalCache) CommitTemporaryNode

func (c *LocalCache) CommitTemporaryNode(ctx context.Context, segID, idx int64, node CacheNode) error

func (*LocalCache) OpenCacheNode

func (c *LocalCache) OpenCacheNode(ctx context.Context, key, idx int64) (CacheNode, error)

func (*LocalCache) OpenTemporaryNode

func (c *LocalCache) OpenTemporaryNode(ctx context.Context, oid, off int64) (CacheNode, error)

type Storage

type Storage interface {
	ID() string
	Get(ctx context.Context, key, idx int64) (io.ReadCloser, error)
	Put(ctx context.Context, key, idx int64, dataReader io.Reader) error
	Delete(ctx context.Context, key int64) error
	Head(ctx context.Context, key int64, idx int64) (Info, error)
}

func NewStorage

func NewStorage(storageID, storageType string, cfg config.Storage) (s Storage, err error)