setting

Documentation

Index

• type Bus
• type FermionsSetting
  • func (s *FermionsSetting) AddStart(starts []string)
  • func (s *FermionsSetting) AddWorkflow(workflowSpec model.Workflow)
  • func (s *FermionsSetting) Bus() Bus
  • func (s *FermionsSetting) LoadConfig(confPath string) error
  • func (s *FermionsSetting) ParseWorkflow(filePath string) error
  • func (s *FermionsSetting) Starts() map[string]bool
  • func (s *FermionsSetting) WorkflowSpecs() map[string]model.Workflow
• type Setting
  • func New() Setting

Types

type Bus

type Bus struct {
	Redis string
}

type FermionsSetting

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

func (*FermionsSetting) AddStart

func (s *FermionsSetting) AddStart(starts []string)

func (*FermionsSetting) AddWorkflow

func (s *FermionsSetting) AddWorkflow(workflowSpec model.Workflow)

func (*FermionsSetting) Bus

func (s *FermionsSetting) Bus() Bus

func (*FermionsSetting) LoadConfig

func (s *FermionsSetting) LoadConfig(confPath string) error

func (*FermionsSetting) ParseWorkflow

func (s *FermionsSetting) ParseWorkflow(filePath string) error

func (*FermionsSetting) Starts

func (s *FermionsSetting) Starts() map[string]bool

func (*FermionsSetting) WorkflowSpecs

func (s *FermionsSetting) WorkflowSpecs() map[string]model.Workflow

type Setting

type Setting interface {
	Bus() Bus
	WorkflowSpecs() map[string]model.Workflow
	Starts() map[string]bool
}

func New

func New() Setting