rpc

package

v0.0.0-...-2c3af24 Latest Latest Go to latest Published: Jan 5, 2022 License: BSD-3-Clause Imports: 15 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/SpeckiJ/Hochwasser

Links

Open Source Insights

Documentation ¶

Index ¶

func RunREPL(f Fluter)
type FlutAck
type FlutStatus
type Fluter
type Hevring
- func ConnectHevring(ránAddress string, stop chan bool, wg *sync.WaitGroup) *Hevring
type Rán
- func SummonRán(address string, stopChan chan bool, wg *sync.WaitGroup) *Rán
- func (r *Rán) SetTask(t pixelflut.FlutTask)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func RunREPL ¶

func RunREPL(f Fluter)

RunREPL starts reading os.Stdin for commands to apply to the given Fluter

Types ¶

type FlutAck ¶

type FlutAck struct{ Ok bool }

type FlutStatus ¶

type FlutStatus struct {
	*pixelflut.Performance
	Ok      bool
	Fluting bool
}

type Fluter ¶

type Fluter interface {
	// contains filtered or unexported methods
}

Fluter implements flut operations that can be triggered via a REPL

type Hevring ¶

type Hevring struct {
	PreviewPath string
	// contains filtered or unexported fields
}

func ConnectHevring ¶

func ConnectHevring(ránAddress string, stop chan bool, wg *sync.WaitGroup) *Hevring

func (*Hevring) Die ¶

func (h *Hevring) Die(x int, reply *FlutAck) error

func (*Hevring) Flut ¶

func (h *Hevring) Flut(task pixelflut.FlutTask, reply *FlutAck) error

func (*Hevring) Status ¶

func (h *Hevring) Status(metrics bool, reply *FlutStatus) error

func (*Hevring) Stop ¶

func (h *Hevring) Stop(x int, reply *FlutAck) error

type Rán ¶

type Rán struct {
	// contains filtered or unexported fields
}

Rán represents the RPC hub, used to coordinate `Hevring` clients. Implements `Fluter`

func SummonRán ¶

func SummonRán(address string, stopChan chan bool, wg *sync.WaitGroup) *Rán

SummonRán sets up the RPC master, accepting connections at addres (":1234") Connects calls methods on each client's rpc provider, killing all clients when stopChan is closed.

func (*Rán) SetTask ¶

func (r *Rán) SetTask(t pixelflut.FlutTask)

SetTask assigns a pixelflut.FlutTask to Rán, distributing it to all clients

Source Files ¶

View all Source files

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