generate schema for cloud-agents

Author: yoonsio

observability/agentsobs/gen_reporter.go

@@ -0,0 +1,91 @@
+// Code generated; DO NOT EDIT.
+
+package agentsobs
+
+import (
+	"time"
+)
+
+const Version_JDTUL28 = true
+
+type KeyResolver interface {
+	Resolve(string)
+	Reset()
+}
+
+type Reporter interface {
+	WithProject(id string) ProjectReporter
+	WithDeferredProject() (ProjectReporter, KeyResolver)
+}
+
+type ProjectReporter interface {
+	RegisterFunc(func(ts time.Time, tx ProjectTx) bool)
+	Tx(func(tx ProjectTx))
+	TxAt(time.Time, func(tx ProjectTx))
+	WithAgent(name string) AgentReporter
+	WithDeferredAgent() (AgentReporter, KeyResolver)
+}
+
+type ProjectTx interface{}
+
+type AgentReporter interface {
+	RegisterFunc(func(ts time.Time, tx AgentTx) bool)
+	Tx(func(tx AgentTx))
+	TxAt(time.Time, func(tx AgentTx))
+	WithWorker(id string) WorkerReporter
+	WithDeferredWorker() (WorkerReporter, KeyResolver)
+}
+
+type AgentTx interface{}
+
+type WorkerReporter interface {
+	RegisterFunc(func(ts time.Time, tx WorkerTx) bool)
+	Tx(func(tx WorkerTx))
+	TxAt(time.Time, func(tx WorkerTx))
+	WithJob(id string) JobReporter
+	WithDeferredJob() (JobReporter, KeyResolver)
+	ReportMem(v float32)
+	ReportCPU(v float32)
+	ReportLoad(v float32)
+	ReportStatus(v WorkerStatus)
+	ReportRegion(v string)
+	ReportVersion(v string)
+	ReportStartedAt(v time.Time)
+	ReportJobsCurrent(v uint16)
+	ReportKind(v AgentKind)
+}
+
+type WorkerTx interface {
+	ReportMem(v float32)
+	ReportCPU(v float32)
+	ReportLoad(v float32)
+	ReportStatus(v WorkerStatus)
+	ReportRegion(v string)
+	ReportVersion(v string)
+	ReportStartedAt(v time.Time)
+	ReportJobsCurrent(v uint16)
+	ReportKind(v AgentKind)
+}
+
+type JobReporter interface {
+	RegisterFunc(func(ts time.Time, tx JobTx) bool)
+	Tx(func(tx JobTx))
+	TxAt(time.Time, func(tx JobTx))
+	ReportRoomSessionID(v string)
+	ReportKind(v JobKind)
+	ReportStatus(v JobStatus)
+	ReportDuration(v uint32)
+	ReportDispatchedAt(v time.Time)
+	ReportJoinedAt(v time.Time)
+	ReportCompletedAt(v time.Time)
+}
+
+type JobTx interface {
+	ReportRoomSessionID(v string)
+	ReportKind(v JobKind)
+	ReportStatus(v JobStatus)
+	ReportDuration(v uint32)
+	ReportDispatchedAt(v time.Time)
+	ReportJoinedAt(v time.Time)
+	ReportCompletedAt(v time.Time)
+}

observability/agentsobs/gen_reporter_noop.go

@@ -0,0 +1,108 @@
+// Code generated; DO NOT EDIT.
+
+package agentsobs
+
+import (
+	"time"
+)
+
+var (
+	_ Reporter        = (*noopReporter)(nil)
+	_ ProjectReporter = (*noopProjectReporter)(nil)
+	_ AgentReporter   = (*noopAgentReporter)(nil)
+	_ WorkerReporter  = (*noopWorkerReporter)(nil)
+	_ JobReporter     = (*noopJobReporter)(nil)
+)
+
+type noopKeyResolver struct{}
+
+func (noopKeyResolver) Resolve(string) {}
+func (noopKeyResolver) Reset()         {}
+
+type noopReporter struct{}
+
+func NewNoopReporter() Reporter {
+	return &noopReporter{}
+}
+
+func (r *noopReporter) WithProject(id string) ProjectReporter {
+	return &noopProjectReporter{}
+}
+
+func (r *noopReporter) WithDeferredProject() (ProjectReporter, KeyResolver) {
+	return &noopProjectReporter{}, noopKeyResolver{}
+}
+
+type noopProjectReporter struct{}
+
+func NewNoopProjectReporter() ProjectReporter {
+	return &noopProjectReporter{}
+}
+
+func (r *noopProjectReporter) RegisterFunc(f func(ts time.Time, tx ProjectTx) bool) {}
+func (r *noopProjectReporter) Tx(f func(ProjectTx))                                 {}
+func (r *noopProjectReporter) TxAt(ts time.Time, f func(ProjectTx))                 {}
+func (r *noopProjectReporter) WithAgent(name string) AgentReporter {
+	return &noopAgentReporter{}
+}
+func (r *noopProjectReporter) WithDeferredAgent() (AgentReporter, KeyResolver) {
+	return &noopAgentReporter{}, noopKeyResolver{}
+}
+
+type noopAgentReporter struct{}
+
+func NewNoopAgentReporter() AgentReporter {
+	return &noopAgentReporter{}
+}
+
+func (r *noopAgentReporter) RegisterFunc(f func(ts time.Time, tx AgentTx) bool) {}
+func (r *noopAgentReporter) Tx(f func(AgentTx))                                 {}
+func (r *noopAgentReporter) TxAt(ts time.Time, f func(AgentTx))                 {}
+func (r *noopAgentReporter) WithWorker(id string) WorkerReporter {
+	return &noopWorkerReporter{}
+}
+func (r *noopAgentReporter) WithDeferredWorker() (WorkerReporter, KeyResolver) {
+	return &noopWorkerReporter{}, noopKeyResolver{}
+}
+
+type noopWorkerReporter struct{}
+
+func NewNoopWorkerReporter() WorkerReporter {
+	return &noopWorkerReporter{}
+}
+
+func (r *noopWorkerReporter) RegisterFunc(f func(ts time.Time, tx WorkerTx) bool) {}
+func (r *noopWorkerReporter) Tx(f func(WorkerTx))                                 {}
+func (r *noopWorkerReporter) TxAt(ts time.Time, f func(WorkerTx))                 {}
+func (r *noopWorkerReporter) ReportMem(v float32)                                 {}
+func (r *noopWorkerReporter) ReportCPU(v float32)                                 {}
+func (r *noopWorkerReporter) ReportLoad(v float32)                                {}
+func (r *noopWorkerReporter) ReportStatus(v WorkerStatus)                         {}
+func (r *noopWorkerReporter) ReportRegion(v string)                               {}
+func (r *noopWorkerReporter) ReportVersion(v string)                              {}
+func (r *noopWorkerReporter) ReportStartedAt(v time.Time)                         {}
+func (r *noopWorkerReporter) ReportJobsCurrent(v uint16)                          {}
+func (r *noopWorkerReporter) ReportKind(v AgentKind)                              {}
+func (r *noopWorkerReporter) WithJob(id string) JobReporter {
+	return &noopJobReporter{}
+}
+func (r *noopWorkerReporter) WithDeferredJob() (JobReporter, KeyResolver) {
+	return &noopJobReporter{}, noopKeyResolver{}
+}
+
+type noopJobReporter struct{}
+
+func NewNoopJobReporter() JobReporter {
+	return &noopJobReporter{}
+}
+
+func (r *noopJobReporter) RegisterFunc(f func(ts time.Time, tx JobTx) bool) {}
+func (r *noopJobReporter) Tx(f func(JobTx))                                 {}
+func (r *noopJobReporter) TxAt(ts time.Time, f func(JobTx))                 {}
+func (r *noopJobReporter) ReportRoomSessionID(v string)                     {}
+func (r *noopJobReporter) ReportKind(v JobKind)                             {}
+func (r *noopJobReporter) ReportStatus(v JobStatus)                         {}
+func (r *noopJobReporter) ReportDuration(v uint32)                          {}
+func (r *noopJobReporter) ReportDispatchedAt(v time.Time)                   {}
+func (r *noopJobReporter) ReportJoinedAt(v time.Time)                       {}
+func (r *noopJobReporter) ReportCompletedAt(v time.Time)                    {}

observability/agentsobs/gen_source.go

@@ -0,0 +1,46 @@
+// Code generated; DO NOT EDIT.
+package agentsobs
+
+type WorkerStatus string
+
+const (
+	WorkerStatusUndefined WorkerStatus = ""
+	WorkerStatusAvailable WorkerStatus = "available"
+	WorkerStatusFull      WorkerStatus = "full"
+)
+
+type AgentKind string
+
+const (
+	AgentKindUndefined AgentKind = ""
+	AgentKindCloud     AgentKind = "cloud"
+	AgentKindSelfhost  AgentKind = "selfhost"
+)
+
+type JobKind string
+
+const (
+	JobKindUndefined   JobKind = ""
+	JobKindRoom        JobKind = "room"
+	JobKindPublisher   JobKind = "publisher"
+	JobKindParticipant JobKind = "participant"
+)
+
+type JobStatus string
+
+const (
+	JobStatusUndefined JobStatus = ""
+	JobStatusPending   JobStatus = "pending"
+	JobStatusRunning   JobStatus = "running"
+	JobStatusSuccess   JobStatus = "success"
+	JobStatusFailed    JobStatus = "failed"
+)
+
+type Rollup string
+
+const (
+	RollupUndefined    Rollup = ""
+	RollupWorker       Rollup = "worker"
+	RollupWorkerSeries Rollup = "worker_series"
+	RollupJob          Rollup = "job"
+)