ogcore

type Action func(ctx context.Context, state State) error

type Cloneable interface {
	Node
	Clone() Cloneable
}

type Cluster interface {
	Join(nodes []Node)
}

type EventNode interface {
	Node
	AttachBus(bus *eventd.EventBus[State])
}

type EventTrace struct {
	NodeName  string
	Event     string
	Timestamp time.Time
}

type Factories struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Initializeable interface {
	Init(params map[string]any) error
}

type Nameable interface {
	Name() string

	SetName(name string)
}

type Node interface {
	Run(ctx context.Context, state State) error
}

type State interface {
	Get(key any) (any, bool)
	Set(key any, val any)
	Update(key any, updateFunc func(val any) any)
}

type Tracker struct {
	StartTime time.Time
	TraceData []EventTrace
}

type Transactional interface {
	Node
	Commit()
	Rollback()
}

type Wrapper interface {
	Wrap(node Node)
}