From 88d5221325e13bdc145308506312f68b10eb677c Mon Sep 17 00:00:00 2001 From: GitHub Date: Fri, 20 Feb 2026 03:45:08 +0000 Subject: [PATCH] chore(update): bump openapi schema (2026-02-20) --- client_mock.go | 16 +++++++-------- handler/kafkaconnect/kafkaconnect.go | 30 +++++++++++++++++++--------- 2 files changed, 29 insertions(+), 17 deletions(-) diff --git a/client_mock.go b/client_mock.go index 7d9c8d7..65e1a66 100644 --- a/client_mock.go +++ b/client_mock.go @@ -18924,23 +18924,23 @@ func (_c *MockClient_ServiceKafkaConnectGetConnectorStatus_Call) RunAndReturn(ru } // ServiceKafkaConnectList provides a mock function for the type MockClient -func (_mock *MockClient) ServiceKafkaConnectList(ctx context.Context, project1 string, serviceName string) ([]kafkaconnect.ConnectorOut, error) { +func (_mock *MockClient) ServiceKafkaConnectList(ctx context.Context, project1 string, serviceName string) (*kafkaconnect.ServiceKafkaConnectListOut, error) { ret := _mock.Called(ctx, project1, serviceName) if len(ret) == 0 { panic("no return value specified for ServiceKafkaConnectList") } - var r0 []kafkaconnect.ConnectorOut + var r0 *kafkaconnect.ServiceKafkaConnectListOut var r1 error - if returnFunc, ok := ret.Get(0).(func(context.Context, string, string) ([]kafkaconnect.ConnectorOut, error)); ok { + if returnFunc, ok := ret.Get(0).(func(context.Context, string, string) (*kafkaconnect.ServiceKafkaConnectListOut, error)); ok { return returnFunc(ctx, project1, serviceName) } - if returnFunc, ok := ret.Get(0).(func(context.Context, string, string) []kafkaconnect.ConnectorOut); ok { + if returnFunc, ok := ret.Get(0).(func(context.Context, string, string) *kafkaconnect.ServiceKafkaConnectListOut); ok { r0 = returnFunc(ctx, project1, serviceName) } else { if ret.Get(0) != nil { - r0 = ret.Get(0).([]kafkaconnect.ConnectorOut) + r0 = ret.Get(0).(*kafkaconnect.ServiceKafkaConnectListOut) } } if returnFunc, ok := ret.Get(1).(func(context.Context, string, string) error); ok { @@ -18987,12 +18987,12 @@ func (_c *MockClient_ServiceKafkaConnectList_Call) Run(run func(ctx context.Cont return _c } -func (_c *MockClient_ServiceKafkaConnectList_Call) Return(connectorOuts []kafkaconnect.ConnectorOut, err error) *MockClient_ServiceKafkaConnectList_Call { - _c.Call.Return(connectorOuts, err) +func (_c *MockClient_ServiceKafkaConnectList_Call) Return(serviceKafkaConnectListOut *kafkaconnect.ServiceKafkaConnectListOut, err error) *MockClient_ServiceKafkaConnectList_Call { + _c.Call.Return(serviceKafkaConnectListOut, err) return _c } -func (_c *MockClient_ServiceKafkaConnectList_Call) RunAndReturn(run func(ctx context.Context, project1 string, serviceName string) ([]kafkaconnect.ConnectorOut, error)) *MockClient_ServiceKafkaConnectList_Call { +func (_c *MockClient_ServiceKafkaConnectList_Call) RunAndReturn(run func(ctx context.Context, project1 string, serviceName string) (*kafkaconnect.ServiceKafkaConnectListOut, error)) *MockClient_ServiceKafkaConnectList_Call { _c.Call.Return(run) return _c } diff --git a/handler/kafkaconnect/kafkaconnect.go b/handler/kafkaconnect/kafkaconnect.go index e449e31..cc5c8e6 100644 --- a/handler/kafkaconnect/kafkaconnect.go +++ b/handler/kafkaconnect/kafkaconnect.go @@ -50,7 +50,7 @@ type Handler interface { // GET /v1/project/{project}/service/{service_name}/connectors // https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaConnectList // Required roles or permissions: service:data:write - ServiceKafkaConnectList(ctx context.Context, project string, serviceName string) ([]ConnectorOut, error) + ServiceKafkaConnectList(ctx context.Context, project string, serviceName string) (*ServiceKafkaConnectListOut, error) // ServiceKafkaConnectPauseConnector pause a Kafka Connect Connector // POST /v1/project/{project}/service/{service_name}/connectors/{connector_name}/pause @@ -160,18 +160,18 @@ func (h *KafkaConnectHandler) ServiceKafkaConnectGetConnectorStatus(ctx context. } return &out.Status, nil } -func (h *KafkaConnectHandler) ServiceKafkaConnectList(ctx context.Context, project string, serviceName string) ([]ConnectorOut, error) { +func (h *KafkaConnectHandler) ServiceKafkaConnectList(ctx context.Context, project string, serviceName string) (*ServiceKafkaConnectListOut, error) { path := fmt.Sprintf("/v1/project/%s/service/%s/connectors", url.PathEscape(project), url.PathEscape(serviceName)) b, err := h.doer.Do(ctx, "ServiceKafkaConnectList", "GET", path, nil) if err != nil { return nil, err } - out := new(serviceKafkaConnectListOut) + out := new(ServiceKafkaConnectListOut) err = json.Unmarshal(b, out) if err != nil { return nil, err } - return out.Connectors, nil + return out, nil } func (h *KafkaConnectHandler) ServiceKafkaConnectPauseConnector(ctx context.Context, project string, serviceName string, connectorName string) error { path := fmt.Sprintf("/v1/project/%s/service/%s/connectors/%s/pause", url.PathEscape(project), url.PathEscape(serviceName), url.PathEscape(connectorName)) @@ -199,6 +199,12 @@ type AvailableVersionOut struct { NeedsMaintenance *bool `json:"needs_maintenance,omitempty"` // Using this version requires a maintenance update. Version *string `json:"version,omitempty"` // Connector version number } + +// ConfigOut Connector configuration parameters +type ConfigOut struct { + ConnectorClass string `json:"connector.class"` // The Java class for the connector + Name string `json:"name"` // Unique name for the connector +} type ConfigurationSchemaOut struct { DefaultValue string `json:"default_value"` // Default value to be set if field omitted in configuration DisplayName string `json:"display_name"` // Human friendly name of the field @@ -235,6 +241,11 @@ type ConnectorOut struct { Plugin PluginOut `json:"plugin"` // Kafka Connector plugin information Tasks []TaskOut `json:"tasks"` // List of tasks of a connector } +type FailedConnectorOut struct { + Config ConfigOut `json:"config"` // Connector configuration parameters + Error string `json:"error"` // Error message explaining why the connector failed to load + Name string `json:"name"` // Connector name +} type ImportanceType string const ( @@ -324,6 +335,12 @@ type ServiceKafkaConnectGetConnectorStatusTaskOut struct { State TaskStateType `json:"state"` // Current status of the task Trace string `json:"trace"` // Task error information } + +// ServiceKafkaConnectListOut ServiceKafkaConnectListResponse +type ServiceKafkaConnectListOut struct { + Connectors []ConnectorOut `json:"connectors"` // List of active Kafka Connect connectors + FailedConnectors []FailedConnectorOut `json:"failed_connectors,omitempty"` // List of connectors that failed plugin resolution +} type TaskOut struct { Connector string `json:"connector"` // Related connector name Task int `json:"task"` // Task id / number @@ -379,8 +396,3 @@ type serviceKafkaConnectGetConnectorConfigurationOut struct { type serviceKafkaConnectGetConnectorStatusOut struct { Status ServiceKafkaConnectGetConnectorStatusOut `json:"status"` // Connector status information } - -// serviceKafkaConnectListOut ServiceKafkaConnectListResponse -type serviceKafkaConnectListOut struct { - Connectors []ConnectorOut `json:"connectors"` // List of active Kafka Connect connectors -}