controller

Documentation

Index

• Variables
• type BackendError
  • func (b *BackendError) Error() string
• type Controller
  • func NewController(name string, factory types.BackendFactory, frontend types.Frontend) *Controller
  • func (c *Controller) AddReplica(address string) error
  • func (c *Controller) Close() error
  • func (c *Controller) ListReplicas() []types.Replica
  • func (c *Controller) ReadAt(b []byte, off int64) (int, error)
  • func (c *Controller) RemoveReplica(address string) error
  • func (c *Controller) Revert(name string) error
  • func (c *Controller) SetReplicaMode(address string, mode types.Mode) error
  • func (c *Controller) Shutdown() error
  • func (c *Controller) Size() (int64, error)
  • func (c *Controller) Snapshot(name string) (string, error)
  • func (c *Controller) Start(addresses ...string) error
  • func (c *Controller) WriteAt(b []byte, off int64) (int, error)
• type MultiWriterAt
  • func (m *MultiWriterAt) WriteAt(p []byte, off int64) (n int, err error)
• type MultiWriterError
  • func (m *MultiWriterError) Error() string

Variables

var (
	ErrNoBackend = errors.New("No backend available")
)

Types

type BackendError

type BackendError struct {
	Errors map[string]error
}

func (*BackendError) Error

func (b *BackendError) Error() string

type Controller

type Controller struct {
	sync.RWMutex
	Name string
	// contains filtered or unexported fields
}

func NewController

func NewController(name string, factory types.BackendFactory, frontend types.Frontend) *Controller

func (*Controller) AddReplica

func (c *Controller) AddReplica(address string) error

func (*Controller) Close

func (c *Controller) Close() error

func (*Controller) ListReplicas

func (c *Controller) ListReplicas() []types.Replica

func (*Controller) ReadAt

func (c *Controller) ReadAt(b []byte, off int64) (int, error)

func (*Controller) RemoveReplica

func (c *Controller) RemoveReplica(address string) error

func (*Controller) Revert

func (c *Controller) Revert(name string) error

func (*Controller) SetReplicaMode

func (c *Controller) SetReplicaMode(address string, mode types.Mode) error

func (*Controller) Shutdown

func (c *Controller) Shutdown() error

func (*Controller) Size

func (c *Controller) Size() (int64, error)

func (*Controller) Snapshot

func (c *Controller) Snapshot(name string) (string, error)

func (*Controller) Start

func (c *Controller) Start(addresses ...string) error

func (*Controller) WriteAt

func (c *Controller) WriteAt(b []byte, off int64) (int, error)

type MultiWriterAt

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

func (*MultiWriterAt) WriteAt

func (m *MultiWriterAt) WriteAt(p []byte, off int64) (n int, err error)

type MultiWriterError

type MultiWriterError struct {
	Writers []io.WriterAt
	Errors  []error
}

func (*MultiWriterError) Error

func (m *MultiWriterError) Error() string