nfs

Documentation

Index

• type Buffer
  • func (n *Buffer) BufferType() storage.CDNBufferType
  • func (n *Buffer) Connect() (*gonfs.Mount, *gonfs.Target, error)
  • func (n *Buffer) GetDriverName() string
  • func (n *Buffer) Init(ctx context.Context, cfg interface{}, bufferType storage.CDNBufferType) error
  • func (n *Buffer) ItemExists(ctx context.Context, m *gorpmapper.Mapper, db gorp.SqlExecutor, i sdk.CDNItem) (bool, error)
  • func (n *Buffer) NewReader(ctx context.Context, i sdk.CDNItemUnit) (io.ReadCloser, error)
  • func (n *Buffer) NewWriter(ctx context.Context, i sdk.CDNItemUnit) (io.WriteCloser, error)
  • func (n *Buffer) Remove(ctx context.Context, i sdk.CDNItemUnit) error
  • func (n *Buffer) ResyncWithDatabase(ctx context.Context, db gorp.SqlExecutor, t sdk.CDNItemType, dryRun bool)
  • func (n *Buffer) Size(_ sdk.CDNItemUnit) (int64, error)
  • func (n *Buffer) Status(_ context.Context) []sdk.MonitoringStatusLine
• type Reader
  • func (r *Reader) Close() error
  • func (r *Reader) Read(p []byte) (n int, err error)
• type Writer
  • func (w *Writer) Close() error
  • func (w *Writer) Write(p []byte) (n int, err error)

Types

type Buffer

type Buffer struct {
	storage.AbstractUnit
	encryption.NoConvergentEncryption
	// contains filtered or unexported fields
}

func (*Buffer) BufferType

func (n *Buffer) BufferType() storage.CDNBufferType

func (*Buffer) Connect

func (n *Buffer) Connect() (*gonfs.Mount, *gonfs.Target, error)

func (*Buffer) GetDriverName

func (n *Buffer) GetDriverName() string

func (*Buffer) Init

func (n *Buffer) Init(ctx context.Context, cfg interface{}, bufferType storage.CDNBufferType) error

func (*Buffer) ItemExists

func (n *Buffer) ItemExists(ctx context.Context, m *gorpmapper.Mapper, db gorp.SqlExecutor, i sdk.CDNItem) (bool, error)

func (*Buffer) NewReader

func (n *Buffer) NewReader(ctx context.Context, i sdk.CDNItemUnit) (io.ReadCloser, error)

func (*Buffer) NewWriter

func (n *Buffer) NewWriter(ctx context.Context, i sdk.CDNItemUnit) (io.WriteCloser, error)

func (*Buffer) Remove

func (n *Buffer) Remove(ctx context.Context, i sdk.CDNItemUnit) error

func (*Buffer) ResyncWithDatabase

func (n *Buffer) ResyncWithDatabase(ctx context.Context, db gorp.SqlExecutor, t sdk.CDNItemType, dryRun bool)

func (*Buffer) Size

func (n *Buffer) Size(_ sdk.CDNItemUnit) (int64, error)

func (*Buffer) Status

func (n *Buffer) Status(_ context.Context) []sdk.MonitoringStatusLine

type Reader

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

func (*Reader) Close

func (r *Reader) Close() error

func (*Reader) Read

func (r *Reader) Read(p []byte) (n int, err error)

type Writer

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

func (*Writer) Close

func (w *Writer) Close() error

func (*Writer) Write

func (w *Writer) Write(p []byte) (n int, err error)