bookkeeping

Documentation

Index

• func NewPlugin(endpoint string) integration.Plugin
• type BookkeepingWrapper
  • func Instance() *BookkeepingWrapper
  • func (bk *BookkeepingWrapper) CreateEnvironment(envId string, createdAt time.Time, status string, statusMessage string) error
  • func (bk *BookkeepingWrapper) CreateFlp(name string, hostName string, runNumber int32) error
  • func (bk *BookkeepingWrapper) CreateLog(text string, title string, runNumbers string, parentLogId int32) error
  • func (bk *BookkeepingWrapper) CreateRun(activityId string, nDetectors int, nEpns int, nFlps int, runNumber int32, ...) error
  • func (bk *BookkeepingWrapper) GetLogs()
  • func (bk *BookkeepingWrapper) GetRuns()
  • func (bk *BookkeepingWrapper) UpdateEnvironment(envId string, toredownAt time.Time, status string, statusMessage string) error
  • func (bk *BookkeepingWrapper) UpdateFlp(name string, runNumber int32, nSubtimeframes int32, nEquipmentBytes int32, ...) error
  • func (bk *BookkeepingWrapper) UpdateRun(runNumber int32, runResult string, timeO2Start string, timeO2End string, ...) error
• type Plugin
  • func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{})
  • func (p *Plugin) Destroy() error
  • func (p *Plugin) GetConnectionState() string
  • func (p *Plugin) GetData(environmentIds []uid.ID) string
  • func (p *Plugin) GetEndpoint() string
  • func (p *Plugin) GetName() string
  • func (p *Plugin) GetPrettyName() string
  • func (p *Plugin) Init(instanceId string) error
  • func (p *Plugin) ObjectStack(_ map[string]string) (stack map[string]interface{})

Functions

func NewPlugin

func NewPlugin(endpoint string) integration.Plugin

Types

type BookkeepingWrapper

type BookkeepingWrapper struct{}

func Instance

func Instance() *BookkeepingWrapper

func (*BookkeepingWrapper) CreateEnvironment

func (bk *BookkeepingWrapper) CreateEnvironment(envId string, createdAt time.Time, status string, statusMessage string) error

func (*BookkeepingWrapper) CreateFlp

func (bk *BookkeepingWrapper) CreateFlp(name string, hostName string, runNumber int32) error

func (*BookkeepingWrapper) CreateLog

func (bk *BookkeepingWrapper) CreateLog(text string, title string, runNumbers string, parentLogId int32) error

func (*BookkeepingWrapper) CreateRun

func (bk *BookkeepingWrapper) CreateRun(activityId string, nDetectors int, nEpns int, nFlps int, runNumber int32, runType runtype.RunType, ddFlp bool, dcs bool, epn bool, epnTopology string, odcTopologyFullname string, detectors string) error

func (*BookkeepingWrapper) GetLogs

func (bk *BookkeepingWrapper) GetLogs()

func (*BookkeepingWrapper) GetRuns

func (bk *BookkeepingWrapper) GetRuns()

func (*BookkeepingWrapper) UpdateEnvironment

func (bk *BookkeepingWrapper) UpdateEnvironment(envId string, toredownAt time.Time, status string, statusMessage string) error

func (*BookkeepingWrapper) UpdateFlp

func (bk *BookkeepingWrapper) UpdateFlp(name string, runNumber int32, nSubtimeframes int32, nEquipmentBytes int32, nRecordingBytes int32, nFairMQBytes int32) error

func (*BookkeepingWrapper) UpdateRun

func (bk *BookkeepingWrapper) UpdateRun(runNumber int32, runResult string, timeO2Start string, timeO2End string, timeTrgStart string, timeTrgEnd string, trg string, pdpConfig string, pdpTopology string, tfbMode string, lhcPeriod string, odcTopologyFullname string, pdpParameters string, pdpBeam string, readoutUri string) error

type Plugin

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

func (*Plugin) CallStack

func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{})

func (*Plugin) Destroy

func (p *Plugin) Destroy() error

func (*Plugin) GetConnectionState

func (p *Plugin) GetConnectionState() string

func (*Plugin) GetData

func (p *Plugin) GetData(environmentIds []uid.ID) string

func (*Plugin) GetEndpoint

func (p *Plugin) GetEndpoint() string

func (*Plugin) GetName

func (p *Plugin) GetName() string

func (*Plugin) GetPrettyName

func (p *Plugin) GetPrettyName() string

func (*Plugin) Init

func (p *Plugin) Init(instanceId string) error

func (*Plugin) ObjectStack

func (p *Plugin) ObjectStack(_ map[string]string) (stack map[string]interface{})