trial

Documentation

Index

• Variables
• type Manager
  • func (m *Manager) CreateRule(ruleDef string) (string, error)
  • func (m *Manager) StartRule(ruleId string) error
  • func (m *Manager) StopRule(ruleId string)
• type Run
• type RunDef

Variables

var TrialManager = &Manager{
	runs: make(map[string]Run),
}

TrialManager Manager Initialized in the binder

Types

type Manager

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

Manager In memory manager for all trial rules

func (*Manager) CreateRule

func (m *Manager) CreateRule(ruleDef string) (string, error)

func (*Manager) StartRule

func (m *Manager) StartRule(ruleId string) error

func (*Manager) StopRule

func (m *Manager) StopRule(ruleId string)

type Run

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

type RunDef

type RunDef struct {
	Id        string                    `json:"id"`
	Sql       string                    `json:"sql"`
	Mock      map[string]map[string]any `json:"mockSource"`
	SinkProps map[string]any            `json:"sinkProps"`
	// contains filtered or unexported fields
}