minimal

Documentation

Index

• type Cfg
• type Dag
• type Minimal
  • func NewMinimal(cfg *Cfg) (*Minimal, error)
  • func (m *Minimal) FInit() error
  • func (m *Minimal) Init() error
  • func (m *Minimal) Process(dag Dag, msg *proto.Msg, opts ...Option) ([]byte, error)
• type Option
  • func WithKvs(kvs map[string]interface{}) Option

Types

type Cfg

type Cfg struct {
	Viper              *viper.Viper
	Logger             log.Logger
	GoNativeGenerators []schema.NewPlugin
}

type Dag

type Dag struct {
	Id    string
	Steps []string
}

type Minimal

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

func NewMinimal

func NewMinimal(cfg *Cfg) (*Minimal, error)

func (*Minimal) FInit

func (m *Minimal) FInit() error

func (*Minimal) Init

func (m *Minimal) Init() error

func (*Minimal) Process

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

type Option

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

func WithKvs

func WithKvs(kvs map[string]interface{}) Option