mini

Documentation

Index

• type Cfg
• type Dag
• type Mini
  • func NewMinimal(fn func(cfg *Cfg)) (*Mini, error)
  • func (m *Mini) FInit() error
  • func (m *Mini) Init() error
  • func (m *Mini) Process(dag Dag, msg *proto.Msg, opts ...Opt) ([]byte, error)
• type Opt
  • func WithKv(k interface{}, v interface{}) Opt

Types

type Cfg

type Cfg struct {
	Viper  *viper.Viper
	Logger log.API
	Plugs  []schema.NewPlug
}

type Dag

type Dag struct {
	Id    string
	Steps []string
}

type Mini

type Mini struct {
	Plugs []schema.NewPlug
	// contains filtered or unexported fields
}

func NewMinimal

func NewMinimal(fn func(cfg *Cfg)) (*Mini, error)

func (*Mini) FInit

func (m *Mini) FInit() error

func (*Mini) Init

func (m *Mini) Init() error

func (*Mini) Process

func (m *Mini) Process(dag Dag, msg *proto.Msg, opts ...Opt) ([]byte, error)

type Opt

type Opt interface {
	// contains filtered or unexported methods
}

func WithKv

func WithKv(k interface{}, v interface{}) Opt