cube

Documentation

Index

• type Config
• type Cube
  • func New(c *Config) *Cube
  • func (c *Cube) Initialize() error
  • func (c *Cube) IntegrateWith(name string, r Runnable)
  • func (c *Cube) Run(stop <-chan struct{})
• type Runnable

Types

type Config

type Config struct {
	EnablePprof bool
	PprofAddr   string
}

type Cube

type Cube struct {
	*Config

	RunnableComponents map[string]Runnable
}

func New

func New(c *Config) *Cube

func (*Cube) Initialize

func (c *Cube) Initialize() error

Initialize init all components of cube, block util initialization completed or error occurred.

func (*Cube) IntegrateWith

func (c *Cube) IntegrateWith(name string, r Runnable)

func (*Cube) Run

func (c *Cube) Run(stop <-chan struct{})

type Runnable

type Runnable interface {
	Run(stop <-chan struct{})
	Initialize() error
}

Runnable run components after initialized