PMM-7590 Jobs API (#702)

* Remove myself from CODEOWNERS

* PMM-7557: Add bucket name field (#691)

* PMM-7379 alert rule name edit (#692)

* Remove myself from CODEOWNERS

* PMM-7379 Add summary field to update request

* PMM-7379 Update comment

Co-authored-by: Alexey Palazhchenko <[email protected]>

* PMM-7590 Define some basic types for Jobs API

* PMM-7590 Fix deps

* PMM-7590 Update

* PMM-7337 add STT check intervals (#687)

* PMM-7337 add intervals in serverpb/server.proto

* PMM-7337 generate files

* Remove myself from CODEOWNERS

* PMM-7337 update generated file

* PMM-7337 fix comments

* PMM-7337 update generated code

* PMM-7337 fix name for standard interval

* PMM-7337 update generated code

* PMM-7337 fix comments

Co-authored-by: Alexey Palazhchenko <[email protected]>
Co-authored-by: Artem Gavrilov <[email protected]>

* PMM-7508 Add GetResources RPC to XtraDB API

* PMM-7508 Add GetResources RPC to XtraDB API

* PMM-7508 Add GetPSMDBClusterResources RPC to PSMDB API

* PMM-7119 Add field name to UpdateTemplateRequest (#663)

Co-authored-by: Alexey Palazhchenko <[email protected]>
Co-authored-by: Nurlan Moldomurov <[email protected]>

* PMM-7313 Updated RDS (#693)

* Remove myself from CODEOWNERS

* PMM-7313 Updated RDS

* PMM-7313 Added pg_statement to Add RDS request

* PMM-7313 Renamed PG RDS param

* PMM-7313 Updated RDS PG definitions

* PMM-7313 Removed pg_statmonitor from request

* PMM-7313 removed statmonitor from response

* PMM-7313 Updated deps

* Update descriptors (#700)

Co-authored-by: Alexey Palazhchenko <[email protected]>
Co-authored-by: Nurlan Moldomurov <[email protected]>

* PMM-7555 QAN PostgreSQL. (#697)

* PMM-7555 Gen.

* PMM-7555 Database in queryexample.

* Revert "PMM-7555 Database in queryexample."

This reverts commit 4c3e992.

* PMM-7555 Change order.

* PMM-7503 Add GetResources RPC to DBaaS Kubernetes API (#699)

* PMM-7503 Add GetResources RPC to DBaaS Kubernetes API

* PMM-7521 Alert templates pagination (#695)

* PMM-7521 Alert templates pagination

* PMM-7521 Add validation for page params

* PMM-7522 PageSize has to be greater than 0

* Merge

* PMM-7522 Notifications channels paging (#698)

* PMM-7590 Make Jobs API onle directional, add progress message

* PMM-7590 Refactoring

* PMM-7590 Update

* PMM-7590 Update

* PMM-7590 Update

* PMM-7590 Use go-sumtype for jobs API

* PMM-7590 Fix dependencies

* PMM-7590 Update

* PMM-7590 Add jobs to management API

* PMM-7590 Update

* PMM-7590 Update

* PMM-7590 Fix typos

* PMM-7590 Add timeout to echo job

* PMM-7590 Add fields to GetJobResponse

* PMM-7590 Refactoring

* PMM-7590 Move jobs api to separate package

* PMM-7590 Fix package name

* PMM-7590 Fix comments, add validation

* PMM-7590 Fix validation

* PMM-7590 Add error field to StartJobResponse

Co-authored-by: Alexey Palazhchenko <[email protected]>
Co-authored-by: Maksym <[email protected]>
Co-authored-by: Dávid Mikuš <[email protected]>
Co-authored-by: Nicola Lamacchia <[email protected]>
Co-authored-by: Tiago Mota Santos <[email protected]>
Co-authored-by: Alexey Palazhchenko <[email protected]>
Co-authored-by: Nurlan Moldomurov <[email protected]>
Co-authored-by: Carlos Salguero <[email protected]>
Co-authored-by: JiriCtvrtka <[email protected]>
Co-authored-by: Jan Prukner <[email protected]>
Co-authored-by: Tiago Mota Santos <[email protected]>

api/agentpb/agent.go

@@ -54,6 +54,12 @@ func (m *QANCollectRequest) AgentMessageRequestPayload() isAgentMessage_Payload
 func (m *ActionResultRequest) AgentMessageRequestPayload() isAgentMessage_Payload {
 	return &AgentMessage_ActionResult{ActionResult: m}
 }
+func (m *JobProgress) AgentMessageRequestPayload() isAgentMessage_Payload {
+	return &AgentMessage_JobProgress{JobProgress: m}
+}
+func (m *JobResult) AgentMessageRequestPayload() isAgentMessage_Payload {
+	return &AgentMessage_JobResult{JobResult: m}
+}
 
 // AgentMessage response payloads
 func (m *Pong) AgentMessageResponsePayload() isAgentMessage_Payload {
@@ -71,6 +77,21 @@ func (m *StopActionResponse) AgentMessageResponsePayload() isAgentMessage_Payloa
 func (m *CheckConnectionResponse) AgentMessageResponsePayload() isAgentMessage_Payload {
 	return &AgentMessage_CheckConnection{CheckConnection: m}
 }
+func (m *JobStatusResponse) AgentMessageResponsePayload() isAgentMessage_Payload {
+	return &AgentMessage_JobStatus{JobStatus: m}
+}
+func (m *StartJobResponse) AgentMessageResponsePayload() isAgentMessage_Payload {
+	return &AgentMessage_StartJob{StartJob: m}
+}
+func (m *StopJobResponse) AgentMessageResponsePayload() isAgentMessage_Payload {
+	return &AgentMessage_StopJob{StopJob: m}
+}
+func (m *JobProgress) AgentMessageResponsePayload() isAgentMessage_Payload {
+	return &AgentMessage_JobProgress{JobProgress: m}
+}
+func (m *JobResult) AgentMessageResponsePayload() isAgentMessage_Payload {
+	return &AgentMessage_JobResult{JobResult: m}
+}
 
 // ServerMessage response payloads
 func (m *Pong) ServerMessageResponsePayload() isServerMessage_Payload {
@@ -102,12 +123,25 @@ func (m *StopActionRequest) ServerMessageRequestPayload() isServerMessage_Payloa
 func (m *CheckConnectionRequest) ServerMessageRequestPayload() isServerMessage_Payload {
 	return &ServerMessage_CheckConnection{CheckConnection: m}
 }
+func (m *StartJobRequest) ServerMessageRequestPayload() isServerMessage_Payload {
+	return &ServerMessage_StartJob{StartJob: m}
+}
+func (m *StopJobRequest) ServerMessageRequestPayload() isServerMessage_Payload {
+	return &ServerMessage_StopJob{StopJob: m}
+}
+func (m *JobStatusRequest) ServerMessageRequestPayload() isServerMessage_Payload {
+	return &ServerMessage_JobStatus{JobStatus: m}
+}
 
 // in alphabetical order
 func (*ActionResultRequest) sealed()     {}
 func (*ActionResultResponse) sealed()    {}
 func (*CheckConnectionRequest) sealed()  {}
 func (*CheckConnectionResponse) sealed() {}
+func (*JobProgress) sealed()             {}
+func (*JobResult) sealed()               {}
+func (*JobStatusRequest) sealed()        {}
+func (*JobStatusResponse) sealed()       {}
 func (*Ping) sealed()                    {}
 func (*Pong) sealed()                    {}
 func (*QANCollectRequest) sealed()       {}
@@ -116,10 +150,14 @@ func (*SetStateRequest) sealed()         {}
 func (*SetStateResponse) sealed()        {}
 func (*StartActionRequest) sealed()      {}
 func (*StartActionResponse) sealed()     {}
+func (*StartJobRequest) sealed()         {}
+func (*StartJobResponse) sealed()        {}
 func (*StateChangedRequest) sealed()     {}
 func (*StateChangedResponse) sealed()    {}
 func (*StopActionRequest) sealed()       {}
 func (*StopActionResponse) sealed()      {}
+func (*StopJobRequest) sealed()          {}
+func (*StopJobResponse) sealed()         {}
 
 // check interfaces
 var (
@@ -135,6 +173,11 @@ var (
 	_ AgentResponsePayload = (*StartActionResponse)(nil)
 	_ AgentResponsePayload = (*StopActionResponse)(nil)
 	_ AgentResponsePayload = (*CheckConnectionResponse)(nil)
+	_ AgentResponsePayload = (*JobProgress)(nil)
+	_ AgentResponsePayload = (*JobResult)(nil)
+	_ AgentResponsePayload = (*StartJobResponse)(nil)
+	_ AgentResponsePayload = (*StopJobResponse)(nil)
+	_ AgentResponsePayload = (*JobStatusResponse)(nil)
 
 	// ServerMessage response payloads
 	_ ServerResponsePayload = (*Pong)(nil)
@@ -148,6 +191,9 @@ var (
 	_ ServerRequestPayload = (*StartActionRequest)(nil)
 	_ ServerRequestPayload = (*StopActionRequest)(nil)
 	_ ServerRequestPayload = (*CheckConnectionRequest)(nil)
+	_ ServerRequestPayload = (*StartJobRequest)(nil)
+	_ ServerRequestPayload = (*StopJobRequest)(nil)
+	_ ServerRequestPayload = (*JobStatusRequest)(nil)
 )
 
 //go-sumtype:decl AgentParams