node

Documentation

Index

• type Msg
• type Node
  • func New(maxNodes int, etcd *clientv3.Client, logger *zap.Logger) (*Node, error)
  • func (n *Node) GetNodeNumber() error
  • func (n *Node) GetSession() error
  • func (n *Node) Start(johnCmd john.Cmd) error

Types

type Msg

type Msg struct {
	TS      time.Time
	Payload string
}

type Node

type Node struct {
	Log        *zap.SugaredLogger
	Number     int
	SessionID  string
	TotalNodes int
	Paths      struct {
		SessionID string
		Node      string
		Results   string
	}
	// contains filtered or unexported fields
}

func New

func New(maxNodes int, etcd *clientv3.Client, logger *zap.Logger) (*Node, error)

func (*Node) GetNodeNumber

func (n *Node) GetNodeNumber() error

func (*Node) GetSession

func (n *Node) GetSession() error

func (*Node) Start

func (n *Node) Start(johnCmd john.Cmd) error