client

Documentation

Index

• type ControllerClient
  • func NewControllerClient(controller string) *ControllerClient
  • func (c *ControllerClient) CreateQuorumReplica(address string) (*rest.Replica, error)
  • func (c *ControllerClient) CreateReplica(address string) (*rest.Replica, error)
  • func (c *ControllerClient) DeleteReplica(address string) (*rest.Replica, error)
  • func (c *ControllerClient) DeleteSnapshot(name string) error
  • func (c *ControllerClient) GetReplica(address string) (*rest.Replica, error)
  • func (c *ControllerClient) GetVolume() (*rest.Volume, error)
  • func (c *ControllerClient) ListJournal(limit int) error
  • func (c *ControllerClient) ListReplicas() ([]rest.Replica, error)
  • func (c *ControllerClient) PrepareRebuild(address string) (*rest.PrepareRebuildOutput, error)
  • func (c *ControllerClient) Register(address string, revisionCount int64, replicaType string, upTime time.Duration, ...) error
  • func (c *ControllerClient) RevertSnapshot(snapshot string) error
  • func (c *ControllerClient) RevertVolume(name string) (*rest.Volume, error)
  • func (c *ControllerClient) SetLogging(lf util.LogToFile) error
  • func (c *ControllerClient) Snapshot(name string) (string, error)
  • func (c *ControllerClient) Start(replicas ...string) error
  • func (c *ControllerClient) UpdateReplica(replica rest.Replica) (rest.Replica, error)
  • func (c *ControllerClient) VerifyRebuildReplica(address string) error

Types

type ControllerClient

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

func NewControllerClient

func NewControllerClient(controller string) *ControllerClient

func (*ControllerClient) CreateQuorumReplica

func (c *ControllerClient) CreateQuorumReplica(address string) (*rest.Replica, error)

func (*ControllerClient) CreateReplica

func (c *ControllerClient) CreateReplica(address string) (*rest.Replica, error)

func (*ControllerClient) DeleteReplica

func (c *ControllerClient) DeleteReplica(address string) (*rest.Replica, error)

func (*ControllerClient) DeleteSnapshot

func (c *ControllerClient) DeleteSnapshot(name string) error

DeleteSnapshot ...

func (*ControllerClient) GetReplica

func (c *ControllerClient) GetReplica(address string) (*rest.Replica, error)

func (*ControllerClient) GetVolume

func (c *ControllerClient) GetVolume() (*rest.Volume, error)

func (*ControllerClient) ListJournal

func (c *ControllerClient) ListJournal(limit int) error

func (*ControllerClient) ListReplicas

func (c *ControllerClient) ListReplicas() ([]rest.Replica, error)

func (*ControllerClient) PrepareRebuild

func (c *ControllerClient) PrepareRebuild(address string) (*rest.PrepareRebuildOutput, error)

func (*ControllerClient) Register

func (c *ControllerClient) Register(address string, revisionCount int64, replicaType string, upTime time.Duration, state string) error

func (*ControllerClient) RevertSnapshot

func (c *ControllerClient) RevertSnapshot(snapshot string) error

func (*ControllerClient) RevertVolume

func (c *ControllerClient) RevertVolume(name string) (*rest.Volume, error)

func (*ControllerClient) SetLogging

func (c *ControllerClient) SetLogging(lf util.LogToFile) error

SetLogging ...

func (*ControllerClient) Snapshot

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

func (*ControllerClient) Start

func (c *ControllerClient) Start(replicas ...string) error

func (*ControllerClient) UpdateReplica

func (c *ControllerClient) UpdateReplica(replica rest.Replica) (rest.Replica, error)

func (*ControllerClient) VerifyRebuildReplica

func (c *ControllerClient) VerifyRebuildReplica(address string) error