rules

package
v0.0.0-...-b0bff92 Latest Latest
Warning

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

Go to latest
Published: Dec 7, 2021 License: AGPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

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