package
3.0.0-20221117134721-e033f95963cb
Repository: https://github.com/ricardo-ch/go-kafka-connect.git
Documentation: pkg.go.dev

# Functions

NewClient generates a new client.

# Structs

ConnectorRequest is generic request used when interacting with connector endpoint.
ConnectorResponse is generic response when interacting with connector endpoint.
CreateConnectorRequest is request used for creating connector.
EmptyResponse is response returned by multiple endpoint when only StatusCode matter.
ErrorResponse is generic error returned by kafka connect.
GetAllConnectorsResponse is request used to get list of available connectors.
GetAllTasksResponse is response to get all tasks of a specific endpoint.
GetConnectorConfigResponse is response returned by GetConfig endpoint.
GetConnectorStatusResponse is response returned by GetStatus endpoint.
MockBaseClient is an autogenerated mock type for the BaseClient type.
MockHighLevelClient is an autogenerated mock type for the HighLevelClient type.
TaskDetails is detail of a specific task on a specific endpoint.
TaskID identify a task and its connector.
TaskRequest is generic request when interacting with task endpoint.
TaskStatus define task status.
TaskStatusResponse is response returned by get task status endpoint.

# Interfaces

BaseClient implement the kafka-connect contract as a client handle retries on 409 response.
HighLevelClient support all function of kafka-connect API + some more features.