rules

Documentation

Index

• type ManifoldsRule
  • func NewManifoldsRule(includeNested bool) *ManifoldsRule
  • func (r *ManifoldsRule) Run(name string, report Report) error
  • func (r *ManifoldsRule) Write(w io.Writer)
• type MongoRule
  • func NewMongoRule() *MongoRule
  • func (r *MongoRule) Run(name string, report Report) error
  • func (r *MongoRule) Write(w io.Writer)
• type NestedReport
• type PubsubReport
• type PubsubRule
  • func NewPubsubRule() *PubsubRule
  • func (r *PubsubRule) Run(name string, report Report) error
  • func (r *PubsubRule) Write(w io.Writer)
• type PubsubTarget
• type RaftReport
• type RaftRule
  • func NewRaftRule() *RaftRule
  • func (r *RaftRule) Run(name string, report Report) error
  • func (r *RaftRule) Write(w io.Writer)
• type Report
• type StartCountRule
  • func NewStartCountRule(includeNested bool, highestListNum int) *StartCountRule
  • func (r *StartCountRule) Run(name string, report Report) error
  • func (r *StartCountRule) Write(w io.Writer)
• type Worker
  • func (w Worker) UnmarshalReport(out interface{}) error

Types

type ManifoldsRule

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

func NewManifoldsRule

func NewManifoldsRule(includeNested bool) *ManifoldsRule

func (*ManifoldsRule) Run

func (r *ManifoldsRule) Run(name string, report Report) error

func (*ManifoldsRule) Write

func (r *ManifoldsRule) Write(w io.Writer)

type MongoRule

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

func NewMongoRule

func NewMongoRule() *MongoRule

func (*MongoRule) Run

func (r *MongoRule) Run(name string, report Report) error

func (*MongoRule) Write

func (r *MongoRule) Write(w io.Writer)

type NestedReport

type NestedReport struct {
	Workers map[string]Worker `yaml:"workers"`
}

type PubsubReport

type PubsubReport struct {
	Targets map[string]PubsubTarget `yaml:"targets"`
}

type PubsubRule

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

func NewPubsubRule

func NewPubsubRule() *PubsubRule

func (*PubsubRule) Run

func (r *PubsubRule) Run(name string, report Report) error

func (*PubsubRule) Write

func (r *PubsubRule) Write(w io.Writer)

type PubsubTarget

type PubsubTarget struct {
	Status string
}

type RaftReport

type RaftReport struct {
	State string `yaml:"state"`
}

type RaftRule

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

func NewRaftRule

func NewRaftRule() *RaftRule

func (*RaftRule) Run

func (r *RaftRule) Run(name string, report Report) error

func (*RaftRule) Write

func (r *RaftRule) Write(w io.Writer)

type Report

type Report struct {
	Manifolds map[string]Worker `yaml:"manifolds"`
}

type StartCountRule

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

func NewStartCountRule

func NewStartCountRule(includeNested bool, highestListNum int) *StartCountRule

func (*StartCountRule) Run

func (r *StartCountRule) Run(name string, report Report) error

func (*StartCountRule) Write

func (r *StartCountRule) Write(w io.Writer)

type Worker

type Worker struct {
	Inputs     []string    `yaml:"inputs"`
	Report     interface{} `yaml:"report"`
	StartCount int         `yaml:"start-count"`
	Started    string      `yaml:"started"`
	State      string      `yaml:"state"`
}

func (Worker) UnmarshalReport

func (w Worker) UnmarshalReport(out interface{}) error