Documentation ¶
Index ¶
- func InferSelfIPv4(ipv4 string, nic string) (uint32, error)
- func Init(f *FlagSet)
- func ResolveHostList(config string, nic string) (plan.HostList, error)
- func ResolvePeerList(localhostIPv4 uint32, port uint16, config string) (plan.PeerList, error)
- func SimpleRun(ctx context.Context, selfIPv4 uint32, pl plan.PeerList, j job.Job, ...)
- func WatchRun(ctx context.Context, self plan.PeerID, runners plan.PeerList, ch chan Stage, ...)
- type FlagSet
- type Handler
- type HostSpec
- type PeerSpec
- type PeerSpecList
- type Stage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ResolvePeerList ¶
Types ¶
type FlagSet ¶
type FlagSet struct { ConfigServer string ClusterSize int HostList string PeerList string User string PortRange plan.PortRange Self string Timeout time.Duration VerboseLog bool NIC string AllowNVLink bool Strategy kb.Strategy Port int DebugPort int Watch bool Keep bool InitVersion int Logfile string LogDir string Quiet bool Prog string Args []string }
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
func NewHandler ¶
func (*Handler) Handle ¶
func (h *Handler) Handle(conn connection.Connection) (int, error)
type HostSpec ¶
func ParseHostList ¶
type PeerSpec ¶
func ParsePeerSpec ¶
type PeerSpecList ¶
type PeerSpecList []PeerSpec
func ParsePeerSpecList ¶
func ParsePeerSpecList(config string) (PeerSpecList, error)
func (PeerSpecList) Eq ¶
func (l PeerSpecList) Eq(r PeerSpecList) bool
func (PeerSpecList) String ¶
func (l PeerSpecList) String() string
Source Files ¶
Click to show internal directories.
Click to hide internal directories.