Documentation
¶
Index ¶
- func ConfigurationSchemaTypeChoices() []string
- func ImportanceTypeChoices() []string
- func PluginTypeChoices() []string
- func ServiceKafkaConnectConnectorStateTypeChoices() []string
- func TaskStateTypeChoices() []string
- func WidthTypeChoices() []string
- type ConfigOut
- type ConfigurationSchemaOut
- type ConfigurationSchemaType
- type ConnectorOut
- type Handler
- type ImportanceType
- type KafkaConnectHandler
- func (h *KafkaConnectHandler) ServiceKafkaConnectCreateConnector(ctx context.Context, project string, serviceName string, ...) (*ServiceKafkaConnectCreateConnectorOut, error)
- func (h *KafkaConnectHandler) ServiceKafkaConnectDeleteConnector(ctx context.Context, project string, serviceName string, connectorName string) error
- func (h *KafkaConnectHandler) ServiceKafkaConnectEditConnector(ctx context.Context, project string, serviceName string, connectorName string, ...) (*ServiceKafkaConnectEditConnectorOut, error)
- func (h *KafkaConnectHandler) ServiceKafkaConnectGetAvailableConnectors(ctx context.Context, project string, serviceName string) ([]PluginOut, error)
- func (h *KafkaConnectHandler) ServiceKafkaConnectGetConnectorConfiguration(ctx context.Context, project string, serviceName string, connectorName string) ([]ConfigurationSchemaOut, error)
- func (h *KafkaConnectHandler) ServiceKafkaConnectGetConnectorStatus(ctx context.Context, project string, serviceName string, connectorName string) (*ServiceKafkaConnectGetConnectorStatusOut, error)
- func (h *KafkaConnectHandler) ServiceKafkaConnectList(ctx context.Context, project string, serviceName string) ([]ConnectorOut, error)
- func (h *KafkaConnectHandler) ServiceKafkaConnectPauseConnector(ctx context.Context, project string, serviceName string, connectorName string) error
- func (h *KafkaConnectHandler) ServiceKafkaConnectRestartConnector(ctx context.Context, project string, serviceName string, connectorName string) error
- func (h *KafkaConnectHandler) ServiceKafkaConnectRestartConnectorTask(ctx context.Context, project string, serviceName string, connectorName string, ...) error
- func (h *KafkaConnectHandler) ServiceKafkaConnectResumeConnector(ctx context.Context, project string, serviceName string, connectorName string) error
- type PluginOut
- type PluginType
- type ServiceKafkaConnectConnectorStateType
- type ServiceKafkaConnectCreateConnectorIn
- type ServiceKafkaConnectCreateConnectorOut
- type ServiceKafkaConnectEditConnectorIn
- type ServiceKafkaConnectEditConnectorOut
- type ServiceKafkaConnectGetConnectorStatusOut
- type TaskOut
- type TaskOutAlt
- type TaskStateType
- type WidthType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConfigurationSchemaTypeChoices ¶ added in v0.3.0
func ConfigurationSchemaTypeChoices() []string
func ImportanceTypeChoices ¶ added in v0.3.0
func ImportanceTypeChoices() []string
func PluginTypeChoices ¶ added in v0.3.0
func PluginTypeChoices() []string
func ServiceKafkaConnectConnectorStateTypeChoices ¶ added in v0.3.0
func ServiceKafkaConnectConnectorStateTypeChoices() []string
func TaskStateTypeChoices ¶ added in v0.3.0
func TaskStateTypeChoices() []string
func WidthTypeChoices ¶ added in v0.3.0
func WidthTypeChoices() []string
Types ¶
type ConfigurationSchemaOut ¶
type ConfigurationSchemaOut struct { DefaultValue string `json:"default_value"` DisplayName string `json:"display_name"` Documentation string `json:"documentation"` Group string `json:"group"` Importance ImportanceType `json:"importance"` Name string `json:"name"` Order int `json:"order"` Required bool `json:"required"` Type ConfigurationSchemaType `json:"type"` Width WidthType `json:"width"` }
type ConfigurationSchemaType ¶ added in v0.3.0
type ConfigurationSchemaType string
const ( ConfigurationSchemaTypeString ConfigurationSchemaType = "STRING" ConfigurationSchemaTypeInt ConfigurationSchemaType = "INT" ConfigurationSchemaTypeShort ConfigurationSchemaType = "SHORT" ConfigurationSchemaTypeLong ConfigurationSchemaType = "LONG" ConfigurationSchemaTypeDouble ConfigurationSchemaType = "DOUBLE" ConfigurationSchemaTypeBoolean ConfigurationSchemaType = "BOOLEAN" ConfigurationSchemaTypeList ConfigurationSchemaType = "LIST" ConfigurationSchemaTypeClass ConfigurationSchemaType = "CLASS" ConfigurationSchemaTypePassword ConfigurationSchemaType = "PASSWORD" )
type ConnectorOut ¶
type Handler ¶
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 ImportanceType ¶ added in v0.3.0
type ImportanceType string
const ( ImportanceTypeLow ImportanceType = "LOW" ImportanceTypeMedium ImportanceType = "MEDIUM" ImportanceTypeHigh ImportanceType = "HIGH" )
type KafkaConnectHandler ¶
type KafkaConnectHandler struct {
// contains filtered or unexported fields
}
func NewHandler ¶
func NewHandler(doer doer) KafkaConnectHandler
func (*KafkaConnectHandler) ServiceKafkaConnectCreateConnector ¶
func (h *KafkaConnectHandler) ServiceKafkaConnectCreateConnector(ctx context.Context, project string, serviceName string, in *ServiceKafkaConnectCreateConnectorIn) (*ServiceKafkaConnectCreateConnectorOut, error)
func (*KafkaConnectHandler) ServiceKafkaConnectDeleteConnector ¶
func (*KafkaConnectHandler) ServiceKafkaConnectEditConnector ¶
func (h *KafkaConnectHandler) ServiceKafkaConnectEditConnector(ctx context.Context, project string, serviceName string, connectorName string, in *ServiceKafkaConnectEditConnectorIn) (*ServiceKafkaConnectEditConnectorOut, error)
func (*KafkaConnectHandler) ServiceKafkaConnectGetAvailableConnectors ¶
func (*KafkaConnectHandler) ServiceKafkaConnectGetConnectorConfiguration ¶
func (h *KafkaConnectHandler) ServiceKafkaConnectGetConnectorConfiguration(ctx context.Context, project string, serviceName string, connectorName string) ([]ConfigurationSchemaOut, error)
func (*KafkaConnectHandler) ServiceKafkaConnectGetConnectorStatus ¶
func (h *KafkaConnectHandler) ServiceKafkaConnectGetConnectorStatus(ctx context.Context, project string, serviceName string, connectorName string) (*ServiceKafkaConnectGetConnectorStatusOut, error)
func (*KafkaConnectHandler) ServiceKafkaConnectList ¶
func (h *KafkaConnectHandler) ServiceKafkaConnectList(ctx context.Context, project string, serviceName string) ([]ConnectorOut, error)
func (*KafkaConnectHandler) ServiceKafkaConnectPauseConnector ¶
func (*KafkaConnectHandler) ServiceKafkaConnectRestartConnector ¶
func (*KafkaConnectHandler) ServiceKafkaConnectRestartConnectorTask ¶
func (*KafkaConnectHandler) ServiceKafkaConnectResumeConnector ¶
type PluginType ¶ added in v0.3.0
type PluginType string
const ( PluginTypeSink PluginType = "sink" PluginTypeSource PluginType = "source" PluginTypeUnknown PluginType = "unknown" )
type ServiceKafkaConnectConnectorStateType ¶ added in v0.3.0
type ServiceKafkaConnectConnectorStateType string
const ( ServiceKafkaConnectConnectorStateTypeFailed ServiceKafkaConnectConnectorStateType = "FAILED" ServiceKafkaConnectConnectorStateTypePaused ServiceKafkaConnectConnectorStateType = "PAUSED" ServiceKafkaConnectConnectorStateTypeRunning ServiceKafkaConnectConnectorStateType = "RUNNING" ServiceKafkaConnectConnectorStateTypeUnassigned ServiceKafkaConnectConnectorStateType = "UNASSIGNED" )
type ServiceKafkaConnectGetConnectorStatusOut ¶
type ServiceKafkaConnectGetConnectorStatusOut struct { State ServiceKafkaConnectConnectorStateType `json:"state"` Tasks []TaskOutAlt `json:"tasks"` }
type TaskOutAlt ¶
type TaskOutAlt struct { Id int `json:"id"` State TaskStateType `json:"state"` Trace string `json:"trace"` }
type TaskStateType ¶ added in v0.3.0
type TaskStateType string
const ( TaskStateTypeFailed TaskStateType = "FAILED" TaskStateTypePaused TaskStateType = "PAUSED" TaskStateTypeRunning TaskStateType = "RUNNING" TaskStateTypeUnassigned TaskStateType = "UNASSIGNED" )
Click to show internal directories.
Click to hide internal directories.