agentsobs

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)
	// contains filtered or unexported methods
}

type AgentTx interface {
	CloudAgent() CloudAgentTx
	// contains filtered or unexported methods
}

type CloudAgentReporter interface {
	RegisterFunc(func(ts time.Time, tx CloudAgentTx) bool)
	Tx(func(tx CloudAgentTx))
	TxAt(time.Time, func(tx CloudAgentTx))
	WithAgent(name string) AgentReporter
	WithDeferredAgent() (AgentReporter, KeyResolver)
	// contains filtered or unexported methods
}

type CloudAgentTx interface {
	Project() ProjectTx
	// contains filtered or unexported methods
}

type JobKind string

type JobReporter interface {
	RegisterFunc(func(ts time.Time, tx JobTx) bool)
	Tx(func(tx JobTx))
	TxAt(time.Time, func(tx JobTx))
	// contains filtered or unexported methods
}

type JobStatus string

type JobTx interface {
	Worker() WorkerTx
	// contains filtered or unexported methods
}

type KeyResolver interface {
	Resolve(string)
	Reset()
}

type ProjectReporter interface {
	RegisterFunc(func(ts time.Time, tx ProjectTx) bool)
	Tx(func(tx ProjectTx))
	TxAt(time.Time, func(tx ProjectTx))
	WithCloudAgent(id string) CloudAgentReporter
	WithDeferredCloudAgent() (CloudAgentReporter, KeyResolver)
	// contains filtered or unexported methods
}

type ProjectTx interface {
	// contains filtered or unexported methods
}

type Reporter interface {
	WithProject(id string) ProjectReporter
	WithDeferredProject() (ProjectReporter, KeyResolver)
}

type Rollup string

type WorkerKind string

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)
	// contains filtered or unexported methods
}

type WorkerState string

type WorkerStatus string

type WorkerTx interface {
	Agent() AgentTx
	// contains filtered or unexported methods
}