gostr

package
v0.0.1 Latest Latest
Warning

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

Go to latest
Published: Jun 6, 2022 License: Apache-2.0, Apache-2.0 Imports: 2 Imported by: 0

README

gostr

Simple Streaming Framework in Go

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Register

func Register(n Node) error

Types

type Node

type Node interface {
	Id() string
	Depends() []string
	Attach(ch chan<- Value, param Parameters) error
	Start() // blocking, and recursively calls dependent Node.Start()
	Stop()
}

func Get

func Get(id string) (Node, error)

type Parameters

type Parameters interface{}

type Registry

type Registry interface {
	Register(n Node) error
	Get(id string) (Node, error)
}

type SimpleRegistry

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

func (*SimpleRegistry) Get

func (r *SimpleRegistry) Get(id string) (Node, error)

func (*SimpleRegistry) Register

func (r *SimpleRegistry) Register(n Node) error

type Value

type Value interface{}

Jump to

Keyboard shortcuts

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