coordinator

package

v0.3.0 Latest Latest Go to latest Published: Aug 4, 2021 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/suborbital/atmo

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Coordinator
- func New(appSource appsource.AppSource, options *options.Options) *Coordinator

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrMissingFQFN = errors.New("callableFn missing FQFN")

View Source

var ErrSequenceRunErr = errors.New("sequence resulted in a RunErr")

ErrSequenceRunErr is returned when the sequence returned due to a Runnable's RunErr

Functions ¶

This section is empty.

Types ¶

type Coordinator ¶

type Coordinator struct {
	App appsource.AppSource
	// contains filtered or unexported fields
}

Coordinator is a type that is responsible for covnerting the directive into usable Vektor handles by coordinating Reactr jobs and meshing when needed.

func New ¶

func New(appSource appsource.AppSource, options *options.Options) *Coordinator

New creates a coordinator

func (*Coordinator) CreateConnections ¶ added in v0.3.1

func (c *Coordinator) CreateConnections()

CreateConnections establishes all of the connections described in the directive

func (*Coordinator) SetSchedules ¶ added in v0.2.3

func (c *Coordinator) SetSchedules()

func (*Coordinator) SetupHandlers ¶ added in v0.3.1

func (c *Coordinator) SetupHandlers() *vk.Router

SetupHandlers configures all of the app's handlers and generates a Vektor Router for the app

func (*Coordinator) Start ¶ added in v0.2.3

func (c *Coordinator) Start() error

Start allows the Coordinator to bootstrap

func (*Coordinator) SyncAppState ¶ added in v0.2.3

func (c *Coordinator) SyncAppState()

Source Files ¶

View all Source files

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