Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

ograph

package module

Go to main page

Versions in this module

v0

v0.8.2

May 3, 2025

Changes in this version

type Element

+ WrapperAlias map[string]string

+ func (e *Element) WrapByAlias(wrapper string, alias string) *Element

v0.8.1

Mar 19, 2025

v0.8.0

Mar 16, 2025

v0.7.0

Feb 9, 2025

Changes in this version

+ type BaseEventNode struct

+ func (node *BaseEventNode) AttachBus(bus *eventd.EventBus[ogcore.State])

type Element

+ Priority int

+ func (e *Element) GetPriority() int

+ func (e *Element) SetPriority(priority int) *Element

type Pipeline

+ func (pipeline *Pipeline) AsyncRun(ctx context.Context, state ogcore.State) (pause, continueRun func(), wait func() error)

+ func (pipeline *Pipeline) Subscribe(callback eventd.CallBack[ogcore.State], ops ...eventd.Op) (cancel func(), err error)

v0.6.1

Dec 28, 2024

v0.6.0

Dec 21, 2024

Changes in this version

+ var Branch = func(elements ...*Element) Op

+ var ErrFactoryNotFound error = errors.New("factory not found")

+ var ErrSingletonNotSet error = errors.New("single node not set")

+ var Rely = func(dependencies ...*Element) Op

+ var Then = func(nextElements ...*Element) Op

+ func LoadPrivateState[SK ~string, SV any](state ogcore.State, key string) SV

+ func LoadState[SV any](state ogcore.State, key string) SV

+ func SavePrivateState[SK ~string](state ogcore.State, key string, val any, overwrite bool)

+ func SaveState(state ogcore.State, key string, val any, overwrite bool)

+ func UpdatePrivateState[SK ~string, SV any](state ogcore.State, key string, updateFunc func(oldVal SV) (val SV)) error

+ func UpdateState[SV any](state ogcore.State, key string, updateFunc func(oldVal SV) (val SV)) error

+ type BaseCluster struct

+ Group []ogcore.Node

+ NodeMap map[string]ogcore.Node

+ func (cluster *BaseCluster) Join(nodes []ogcore.Node)

+ func (cluster BaseCluster) Run(ctx context.Context, state ogcore.State) error

+ type BaseNode struct

+ Action ogcore.Action

+ func (node *BaseNode) Name() string

+ func (node *BaseNode) SetName(name string)

+ func (node BaseNode) Run(ctx context.Context, state ogcore.State) error

+ type BaseState struct

+ func NewState() *BaseState

+ func (state *BaseState) Get(key any) (any, bool)

+ func (state *BaseState) Set(key any, val any)

+ func (state *BaseState) Update(key any, updateFunc func(val any) any)

+ type BaseWrapper struct

+ func (wrapper *BaseWrapper) Wrap(node ogcore.Node)

+ func (wrapper BaseWrapper) Run(ctx context.Context, state ogcore.State) error

+ type Builder struct

+ Factories *ogcore.Factories

+ func (builder *Builder) RegisterFactory(name string, factory func() ogcore.Node) *Builder

+ func (builder *Builder) RegisterPrototype(name string, prototype ogcore.Cloneable) *Builder

+ type Element struct

+ DefaultImpl string

+ FactoryName string

+ Name string

+ ParamsMap map[string]any

+ PrivateFactory func() ogcore.Node

+ Singleton ogcore.Node

+ SubElements []*Element

+ Virtual bool

+ Wrappers []string

+ func NewElement(name string) *Element

+ func (e *Element) Apply(options ...ElementOption) *Element

+ func (e *Element) AsVirtual() *Element

+ func (e *Element) Params(key string, val any) *Element

+ func (e *Element) SetVirtual(isVirtual bool) *Element

+ func (e *Element) UseFactory(name string, subElements ...*Element) *Element

+ func (e *Element) UseFn(fn func() error) *Element

+ func (e *Element) UseNode(node ogcore.Node) *Element

+ func (e *Element) UsePrivateFactory(factory func() ogcore.Node, subElements ...*Element) *Element

+ func (e *Element) Wrap(wrappers ...string) *Element

+ type ElementOption func(e *Element)

+ type FuncNode struct

+ RunFunc func(ctx context.Context, state ogcore.State) error

+ func NewFuncNode(runFunc func(ctx context.Context, state ogcore.State) error) *FuncNode

+ func (node *FuncNode) Run(ctx context.Context, state ogcore.State) error

+ type Op func(pipeline *Pipeline, element *Element)

+ type PGraph = internal.Graph[*Element]

+ type Pipeline struct

+ DisablePool bool

+ EnableMonitor bool

+ Interrupts iter.Seq[string]

+ ParallelismLimit int

+ SlowThreshold time.Duration

+ func NewPipeline() *Pipeline

+ func (pipeline *Pipeline) Check() error

+ func (pipeline *Pipeline) DumpDOT() ([]byte, error)

+ func (pipeline *Pipeline) DumpGraph() ([]byte, error)

+ func (pipeline *Pipeline) ForEachElem(op func(e *Element)) *Pipeline

+ func (pipeline *Pipeline) LoadGraph(data []byte) error

+ func (pipeline *Pipeline) Register(e *Element, ops ...Op) *Pipeline

+ func (pipeline *Pipeline) ResetPool()

+ func (pipeline *Pipeline) Run(ctx context.Context, state ogcore.State) error

+ func (pipeline *Pipeline) SetPoolCache(size int, warmup bool) error