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, timeO2End time.Time, timeTrgEnd time.Time) 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 string, timeO2Start time.Time, timeTrgStart time.Time, dd_flp bool, dcs bool, epn bool, epnTopology 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, timeO2End time.Time, timeTrgEnd time.Time) 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{})