simulator

package
v0.0.0-...-c283e9f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 4, 2021 License: BSD-3-Clause Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DbInfo

type DbInfo struct {
	Config      *state.Config `json:"config"`
	Online      bool          `json:"online"`
	CurXLog     xlog.Position `json:"xlog"`
	XLogWaiting xlog.Position `json:"xlog_waiting,omitempty"`
}

func (*DbInfo) XLog

func (d *DbInfo) XLog() xlog.XLog

type DiscoverdInfo

type DiscoverdInfo struct {
	State *state.DiscoverdState `json:"state"`
	Peers []*discoverd.Instance `json:"peers"`
}

type PeerSimInfo

type PeerSimInfo struct {
	Peer *state.PeerInfo `json:"peer"`
	Db   *DbInfo         `json:"postgres"`
}

type Simulator

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

func New

func New(singleton bool, out io.Writer, logOut io.Writer) *Simulator

func (*Simulator) AddPeer

func (s *Simulator) AddPeer(args []string)

func (*Simulator) Bootstrap

func (s *Simulator) Bootstrap(args []string)

func (*Simulator) CatchUp

func (s *Simulator) CatchUp(args []string)

func (*Simulator) Close

func (s *Simulator) Close() error

func (*Simulator) Depose

func (s *Simulator) Depose(args []string)

func (*Simulator) Discoverd

func (s *Simulator) Discoverd(args []string)

func (*Simulator) Echo

func (s *Simulator) Echo(args []string)

func (*Simulator) Exit

func (s *Simulator) Exit(args []string)

func (*Simulator) Freeze

func (s *Simulator) Freeze(args []string)

func (*Simulator) Help

func (s *Simulator) Help(args []string)

func (*Simulator) Ident

func (s *Simulator) Ident(args []string)

func (*Simulator) LsPeers

func (s *Simulator) LsPeers(args []string)

func (*Simulator) Peer

func (s *Simulator) Peer(args []string)

func (*Simulator) Rebuild

func (s *Simulator) Rebuild(args []string)

func (*Simulator) RmPeer

func (s *Simulator) RmPeer(args []string)

func (*Simulator) RunCommand

func (s *Simulator) RunCommand(cmdline string)

func (*Simulator) SetClusterState

func (s *Simulator) SetClusterState(args []string)

func (*Simulator) StartPeer

func (s *Simulator) StartPeer(args []string)

func (*Simulator) Unfreeze

func (s *Simulator) Unfreeze(args []string)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL