silo

package

v0.0.0-...-8ab07fe Latest Latest Go to latest Published: Nov 2, 2020 License: AGPL-3.0 Imports: 11 Imported by: 0

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

This section is empty.

This section is empty.

This section is empty.

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

Silo is the running instance of gambaru

func NewSilo() *Silo

NewSilo creates a new silo

func (silo *Silo) AddInputQueue(processorID uuid.UUID, queueID uuid.UUID) error

AddInputQueue attaches an Input Queue to a processor

func (silo *Silo) AddOutputQueue(processorID uuid.UUID, queueID uuid.UUID) error

AddOutputQueue attaches an Output Queue to a processor

func (silo *Silo) CreateProcessor(processor interface_processor.ProcessorInterface, processorID uuid.UUID, config *flow_model.Config) uuid.UUID

CreateProcessor returns the id of a created Processor

func (silo *Silo) CreateQueue(queue interface_queue.QueueInterface, queueID uuid.UUID) uuid.UUID

CreateQueue returns an id of a created Queue

func (silo *Silo) ExportProcessors() (flow_model.Processors, error)

func (silo *Silo) ExportQueues() (map[uuid.UUID]*actor.PID, error)

func (silo *Silo) GetRegisteredProcessor(processorTypeName string) interface_processor.ProcessorInterface

GetRegisteredProcessor returns a registered type of processor

func (silo *Silo) GetRegisteredQueue(queueTypeName string) interface_queue.QueueInterface

GetRegisteredQueue returns a registered type of queue

func (silo *Silo) Start() error

Start commences all the configured processors

func (silo *Silo) Stop()

Stop stops all the configured processors