kafkaconnect

type ConfigOut struct {
	ConnectorClass string `json:"connector.class,omitempty"`
	Name           string `json:"name"`
}

type ConfigurationSchemaOut struct {
	DefaultValue  string `json:"default_value"`
	DisplayName   string `json:"display_name"`
	Documentation string `json:"documentation"`
	Group         string `json:"group"`
	Importance    string `json:"importance"`
	Name          string `json:"name"`
	Order         int    `json:"order"`
	Required      bool   `json:"required"`
	Type          string `json:"type"`
	Width         string `json:"width"`
}

type ConnectorOut struct {
	Config ConfigOut `json:"config"`
	Name   string    `json:"name"`
	Plugin PluginOut `json:"plugin"`
	Tasks  []TaskOut `json:"tasks"`
}

type Handler interface {
	// ServiceKafkaConnectCreateConnector create a Kafka Connect connector
	// POST /project/{project}/service/{service_name}/connectors
	// https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaConnectCreateConnector
	ServiceKafkaConnectCreateConnector(ctx context.Context, project string, serviceName string, in *ServiceKafkaConnectCreateConnectorIn) (*ServiceKafkaConnectCreateConnectorOut, error)

	// ServiceKafkaConnectDeleteConnector delete Kafka Connect connector
	// DELETE /project/{project}/service/{service_name}/connectors/{connector_name}
	// https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaConnectDeleteConnector
	ServiceKafkaConnectDeleteConnector(ctx context.Context, project string, serviceName string, connectorName string) error

	// ServiceKafkaConnectEditConnector edit Kafka Connect connector
	// PUT /project/{project}/service/{service_name}/connectors/{connector_name}
	// https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaConnectEditConnector
	ServiceKafkaConnectEditConnector(ctx context.Context, project string, serviceName string, connectorName string, in *ServiceKafkaConnectEditConnectorIn) (*ServiceKafkaConnectEditConnectorOut, error)

	// ServiceKafkaConnectGetAvailableConnectors get available Kafka Connect connectors
	// GET /project/{project}/service/{service_name}/available-connectors
	// https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaConnectGetAvailableConnectors
	ServiceKafkaConnectGetAvailableConnectors(ctx context.Context, project string, serviceName string) ([]PluginOut, error)

	// ServiceKafkaConnectGetConnectorConfiguration get Kafka Connect connector configuration schema
	// GET /project/{project}/service/{service_name}/connector-plugins/{connector_name}/configuration
	// https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaConnectGetConnectorConfiguration
	ServiceKafkaConnectGetConnectorConfiguration(ctx context.Context, project string, serviceName string, connectorName string) ([]ConfigurationSchemaOut, error)

	// ServiceKafkaConnectGetConnectorStatus get a Kafka Connect Connector status
	// GET /project/{project}/service/{service_name}/connectors/{connector_name}/status
	// https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaConnectGetConnectorStatus
	ServiceKafkaConnectGetConnectorStatus(ctx context.Context, project string, serviceName string, connectorName string) (*ServiceKafkaConnectGetConnectorStatusOut, error)

	// ServiceKafkaConnectList lists Kafka connectors
	// GET /project/{project}/service/{service_name}/connectors
	// https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaConnectList
	ServiceKafkaConnectList(ctx context.Context, project string, serviceName string) ([]ConnectorOut, error)

	// ServiceKafkaConnectPauseConnector pause a Kafka Connect Connector
	// POST /project/{project}/service/{service_name}/connectors/{connector_name}/pause
	// https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaConnectPauseConnector
	ServiceKafkaConnectPauseConnector(ctx context.Context, project string, serviceName string, connectorName string) error

	// ServiceKafkaConnectRestartConnector restart a Kafka Connect Connector
	// POST /project/{project}/service/{service_name}/connectors/{connector_name}/restart
	// https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaConnectRestartConnector
	ServiceKafkaConnectRestartConnector(ctx context.Context, project string, serviceName string, connectorName string) error

	// ServiceKafkaConnectRestartConnectorTask restart a Kafka Connect Connector task
	// POST /project/{project}/service/{service_name}/connectors/{connector_name}/tasks/{task_id}/restart
	// https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaConnectRestartConnectorTask
	ServiceKafkaConnectRestartConnectorTask(ctx context.Context, project string, serviceName string, connectorName string, taskId string) error

	// ServiceKafkaConnectResumeConnector resume a Kafka Connect Connector
	// POST /project/{project}/service/{service_name}/connectors/{connector_name}/resume
	// https://api.aiven.io/doc/#tag/Service:_Kafka/operation/ServiceKafkaConnectResumeConnector
	ServiceKafkaConnectResumeConnector(ctx context.Context, project string, serviceName string, connectorName string) error
}

type KafkaConnectHandler struct {
	// contains filtered or unexported fields
}

type PluginOut struct {
	Author      string `json:"author"`
	Class       string `json:"class"`
	DocUrl      string `json:"docURL"`
	Preview     *bool  `json:"preview,omitempty"`
	PreviewInfo string `json:"preview_info,omitempty"`
	Title       string `json:"title"`
	Type        string `json:"type"`
	Version     string `json:"version"`
}

type ServiceKafkaConnectCreateConnectorIn struct {
	ConnectorClass string `json:"connector.class,omitempty"`
	Name           string `json:"name"`
}

type ServiceKafkaConnectCreateConnectorOut struct {
	Config ConfigOut `json:"config"`
	Name   string    `json:"name"`
	Plugin PluginOut `json:"plugin"`
	Tasks  []TaskOut `json:"tasks"`
}

type ServiceKafkaConnectEditConnectorIn struct {
	ConnectorClass string `json:"connector.class,omitempty"`
	Name           string `json:"name"`
}

type ServiceKafkaConnectEditConnectorOut struct {
	Config ConfigOut `json:"config"`
	Name   string    `json:"name"`
	Plugin PluginOut `json:"plugin"`
	Tasks  []TaskOut `json:"tasks"`
}

type ServiceKafkaConnectGetConnectorStatusOut struct {
	State string       `json:"state"`
	Tasks []TaskOutAlt `json:"tasks"`
}

type TaskOut struct {
	Connector string `json:"connector"`
	Task      int    `json:"task"`
}

type TaskOutAlt struct {
	Id    int    `json:"id"`
	State string `json:"state"`
	Trace string `json:"trace"`
}