Documentation
¶
Index ¶
- Constants
- Variables
- type BackendError
- type Controller
- func (c *Controller) AddReplica(address string) error
- func (c *Controller) Close() error
- func (c *Controller) Endpoint() string
- func (c *Controller) Frontend() string
- func (c *Controller) ListReplicas() []types.Replica
- func (c *Controller) PrepareRebuildReplica(address string) ([]string, error)
- 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, labels map[string]string) (string, error)
- func (c *Controller) Start(addresses ...string) error
- func (c *Controller) StartRestServer() error
- func (c *Controller) UpdatePort(newPort int) error
- func (c *Controller) VerifyRebuildReplica(address string) error
- func (c *Controller) WaitForShutdown() error
- func (c *Controller) WriteAt(b []byte, off int64) (int, error)
- type MultiWriterAt
- type MultiWriterError
Constants ¶
View Source
const ( RPCTimeout = 60 * time.Second LauncherBinary = "longhorn-engine-launcher" )
Variables ¶
View Source
var (
ErrNoBackend = errors.New("No backend available")
)
Functions ¶
This section is empty.
Types ¶
type BackendError ¶
func (*BackendError) Error ¶
func (b *BackendError) Error() string
type Controller ¶
type Controller struct {
sync.RWMutex
Name string
RestServer *http.Server
Broadcaster *broadcaster.Broadcaster
// contains filtered or unexported fields
}
func NewController ¶
func NewController(name string, factory types.BackendFactory, frontend types.Frontend, launcher, launcherID string) *Controller
func (*Controller) AddReplica ¶
func (c *Controller) AddReplica(address string) error
func (*Controller) Close ¶
func (c *Controller) Close() error
func (*Controller) Endpoint ¶ added in v0.3.0
func (c *Controller) Endpoint() string
func (*Controller) Frontend ¶ added in v0.3.0
func (c *Controller) Frontend() string
func (*Controller) ListReplicas ¶
func (c *Controller) ListReplicas() []types.Replica
func (*Controller) PrepareRebuildReplica ¶ added in v0.3.0
func (c *Controller) PrepareRebuildReplica(address string) ([]string, error)
func (*Controller) RemoveReplica ¶
func (c *Controller) RemoveReplica(address string) error
func (*Controller) Revert ¶ added in v0.2.0
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) Start ¶
func (c *Controller) Start(addresses ...string) error
func (*Controller) StartRestServer ¶ added in v0.3.0
func (c *Controller) StartRestServer() error
func (*Controller) UpdatePort ¶ added in v0.3.0
func (c *Controller) UpdatePort(newPort int) error
func (*Controller) VerifyRebuildReplica ¶ added in v0.3.0
func (c *Controller) VerifyRebuildReplica(address string) error
func (*Controller) WaitForShutdown ¶ added in v0.3.0
func (c *Controller) WaitForShutdown() error
type MultiWriterAt ¶
type MultiWriterAt struct {
// contains filtered or unexported fields
}
type MultiWriterError ¶
func (*MultiWriterError) Error ¶
func (m *MultiWriterError) Error() string
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.