api

type Client struct {
	// The endpoint of the server conforming to this interface, with scheme,
	// https://api.deepmap.com for example. This can contain a path relative
	// to the server, such as https://api.deepmap.com/dev-test, and all the
	// paths in the swagger spec will be appended to the server.
	Server string

	// Doer for performing requests, typically a *http.Client with any
	// customized settings, such as certificate chains.
	Client HttpRequestDoer

	// A list of callbacks for modifying requests which are generated before sending over
	// the network.
	RequestEditors []RequestEditorFn
}

type ClientInterface interface {
	// ServerInfo request
	ServerInfo(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListLoggers request
	ListLoggers(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetLogger request
	GetLogger(ctx context.Context, logger string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// SetLevelWithBody request with any body
	SetLevelWithBody(ctx context.Context, logger string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	SetLevel(ctx context.Context, logger string, body SetLevelJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListConnectorPlugins request
	ListConnectorPlugins(ctx context.Context, params *ListConnectorPluginsParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetConnectorConfigDef request
	GetConnectorConfigDef(ctx context.Context, pluginName string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ValidateConfigsWithBody request with any body
	ValidateConfigsWithBody(ctx context.Context, pluginName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	ValidateConfigs(ctx context.Context, pluginName string, body ValidateConfigsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListConnectors request
	ListConnectors(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CreateConnectorWithBody request with any body
	CreateConnectorWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	CreateConnector(ctx context.Context, body CreateConnectorJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DestroyConnector request
	DestroyConnector(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetConnector request
	GetConnector(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetConnectorConfig request
	GetConnectorConfig(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// PutConnectorConfigWithBody request with any body
	PutConnectorConfigWithBody(ctx context.Context, connector string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	PutConnectorConfig(ctx context.Context, connector string, body PutConnectorConfigJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetOffsets request
	GetOffsets(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// PauseConnector request
	PauseConnector(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// RestartConnector request
	RestartConnector(ctx context.Context, connector string, params *RestartConnectorParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ResumeConnector request
	ResumeConnector(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetConnectorStatus request
	GetConnectorStatus(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// StopConnector request
	StopConnector(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetTaskConfigs request
	GetTaskConfigs(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetTasksConfig request
	GetTasksConfig(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// RestartTask request
	RestartTask(ctx context.Context, connector string, task int32, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetTaskStatus request
	GetTaskStatus(ctx context.Context, connector string, task int32, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetConnectorActiveTopics request
	GetConnectorActiveTopics(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ResetConnectorActiveTopics request
	ResetConnectorActiveTopics(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)
}

type ClientOption func(*Client) error

type ClientWithResponses struct {
	ClientInterface
}

type ClientWithResponsesInterface interface {
	// ServerInfoWithResponse request
	ServerInfoWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ServerInfoResponse, error)

	// ListLoggersWithResponse request
	ListLoggersWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListLoggersResponse, error)

	// GetLoggerWithResponse request
	GetLoggerWithResponse(ctx context.Context, logger string, reqEditors ...RequestEditorFn) (*GetLoggerResponse, error)

	// SetLevelWithBodyWithResponse request with any body
	SetLevelWithBodyWithResponse(ctx context.Context, logger string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SetLevelResponse, error)

	SetLevelWithResponse(ctx context.Context, logger string, body SetLevelJSONRequestBody, reqEditors ...RequestEditorFn) (*SetLevelResponse, error)

	// ListConnectorPluginsWithResponse request
	ListConnectorPluginsWithResponse(ctx context.Context, params *ListConnectorPluginsParams, reqEditors ...RequestEditorFn) (*ListConnectorPluginsResponse, error)

	// GetConnectorConfigDefWithResponse request
	GetConnectorConfigDefWithResponse(ctx context.Context, pluginName string, reqEditors ...RequestEditorFn) (*GetConnectorConfigDefResponse, error)

	// ValidateConfigsWithBodyWithResponse request with any body
	ValidateConfigsWithBodyWithResponse(ctx context.Context, pluginName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ValidateConfigsResponse, error)

	ValidateConfigsWithResponse(ctx context.Context, pluginName string, body ValidateConfigsJSONRequestBody, reqEditors ...RequestEditorFn) (*ValidateConfigsResponse, error)

	// ListConnectorsWithResponse request
	ListConnectorsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListConnectorsResponse, error)

	// CreateConnectorWithBodyWithResponse request with any body
	CreateConnectorWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CreateConnectorResponse, error)

	CreateConnectorWithResponse(ctx context.Context, body CreateConnectorJSONRequestBody, reqEditors ...RequestEditorFn) (*CreateConnectorResponse, error)

	// DestroyConnectorWithResponse request
	DestroyConnectorWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*DestroyConnectorResponse, error)

	// GetConnectorWithResponse request
	GetConnectorWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorResponse, error)

	// GetConnectorConfigWithResponse request
	GetConnectorConfigWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorConfigResponse, error)

	// PutConnectorConfigWithBodyWithResponse request with any body
	PutConnectorConfigWithBodyWithResponse(ctx context.Context, connector string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutConnectorConfigResponse, error)

	PutConnectorConfigWithResponse(ctx context.Context, connector string, body PutConnectorConfigJSONRequestBody, reqEditors ...RequestEditorFn) (*PutConnectorConfigResponse, error)

	// GetOffsetsWithResponse request
	GetOffsetsWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetOffsetsResponse, error)

	// PauseConnectorWithResponse request
	PauseConnectorWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*PauseConnectorResponse, error)

	// RestartConnectorWithResponse request
	RestartConnectorWithResponse(ctx context.Context, connector string, params *RestartConnectorParams, reqEditors ...RequestEditorFn) (*RestartConnectorResponse, error)

	// ResumeConnectorWithResponse request
	ResumeConnectorWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*ResumeConnectorResponse, error)

	// GetConnectorStatusWithResponse request
	GetConnectorStatusWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorStatusResponse, error)

	// StopConnectorWithResponse request
	StopConnectorWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*StopConnectorResponse, error)

	// GetTaskConfigsWithResponse request
	GetTaskConfigsWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetTaskConfigsResponse, error)

	// GetTasksConfigWithResponse request
	GetTasksConfigWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetTasksConfigResponse, error)

	// RestartTaskWithResponse request
	RestartTaskWithResponse(ctx context.Context, connector string, task int32, reqEditors ...RequestEditorFn) (*RestartTaskResponse, error)

	// GetTaskStatusWithResponse request
	GetTaskStatusWithResponse(ctx context.Context, connector string, task int32, reqEditors ...RequestEditorFn) (*GetTaskStatusResponse, error)

	// GetConnectorActiveTopicsWithResponse request
	GetConnectorActiveTopicsWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorActiveTopicsResponse, error)

	// ResetConnectorActiveTopicsWithResponse request
	ResetConnectorActiveTopicsWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*ResetConnectorActiveTopicsResponse, error)
}

type ConfigInfo struct {
	Definition *ConfigKeyInfo   `json:"definition,omitempty"`
	Value      *ConfigValueInfo `json:"value,omitempty"`
}

type ConfigInfos struct {
	Configs    *[]ConfigInfo `json:"configs,omitempty"`
	ErrorCount *int32        `json:"error_count,omitempty"`
	Groups     *[]string     `json:"groups,omitempty"`
	Name       *string       `json:"name,omitempty"`
}

type ConfigKeyInfo struct {
	DefaultValue  *string   `json:"default_value,omitempty"`
	Dependents    *[]string `json:"dependents,omitempty"`
	DisplayName   *string   `json:"display_name,omitempty"`
	Documentation *string   `json:"documentation,omitempty"`
	Group         *string   `json:"group,omitempty"`
	Importance    *string   `json:"importance,omitempty"`
	Name          *string   `json:"name,omitempty"`
	Order         *int32    `json:"order,omitempty"`
	OrderInGroup  *int32    `json:"order_in_group,omitempty"`
	Required      *bool     `json:"required,omitempty"`
	Type          *string   `json:"type,omitempty"`
	Width         *string   `json:"width,omitempty"`
}

type ConfigValueInfo struct {
	Errors            *[]string `json:"errors,omitempty"`
	Name              *string   `json:"name,omitempty"`
	RecommendedValues *[]string `json:"recommended_values,omitempty"`
	Value             *string   `json:"value,omitempty"`
	Visible           *bool     `json:"visible,omitempty"`
}

type ConnectorInfo struct {
	Config *map[string]string `json:"config,omitempty"`
	Name   *string            `json:"name,omitempty"`
	Tasks  *[]ConnectorTaskId `json:"tasks,omitempty"`
	Type   *ConnectorInfoType `json:"type,omitempty"`
}

type ConnectorInfoType string

type ConnectorOffset struct {
	Offset    *map[string]map[string]interface{} `json:"offset,omitempty"`
	Partition *map[string]map[string]interface{} `json:"partition,omitempty"`
}

type ConnectorOffsets struct {
	Offsets *[]ConnectorOffset `json:"offsets,omitempty"`
}

type ConnectorState struct {
	Msg      *string `json:"msg,omitempty"`
	State    *string `json:"state,omitempty"`
	Trace    *string `json:"trace,omitempty"`
	WorkerId *string `json:"worker_id,omitempty"`
}

type ConnectorStateInfo struct {
	Connector *ConnectorState         `json:"connector,omitempty"`
	Name      *string                 `json:"name,omitempty"`
	Tasks     *[]TaskState            `json:"tasks,omitempty"`
	Type      *ConnectorStateInfoType `json:"type,omitempty"`
}

type ConnectorStateInfoType string

type ConnectorTaskId struct {
	Connector *string `json:"connector,omitempty"`
	Task      *int32  `json:"task,omitempty"`
}

type CreateConnectorJSONRequestBody = CreateConnectorRequest

type CreateConnectorRequest struct {
	Config *map[string]string `json:"config,omitempty"`
	Name   *string            `json:"name,omitempty"`
}

type CreateConnectorResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type DestroyConnectorResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type GetConnectorActiveTopicsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type GetConnectorConfigDefResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSONDefault  *[]ConfigKeyInfo
}

type GetConnectorConfigResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSONDefault  *map[string]string
}

type GetConnectorResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSONDefault  *ConnectorInfo
}

type GetConnectorStatusResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSONDefault  *ConnectorStateInfo
}

type GetLoggerResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type GetOffsetsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSONDefault  *ConnectorOffsets
}

type GetTaskConfigsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSONDefault  *[]TaskInfo
}

type GetTaskStatusResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSONDefault  *TaskState
}

type GetTasksConfigResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSONDefault  *map[string]map[string]string
}

type HttpRequestDoer interface {
	Do(req *http.Request) (*http.Response, error)
}

type ListConnectorPluginsParams struct {
	// ConnectorsOnly Whether to list only connectors instead of all plugins
	ConnectorsOnly *bool `form:"connectorsOnly,omitempty" json:"connectorsOnly,omitempty"`
}

type ListConnectorPluginsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSONDefault  *[]PluginInfo
}

type ListConnectorsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type ListLoggersResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type PauseConnectorResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type PluginInfo struct {
	Class   *string `json:"class,omitempty"`
	Type    *string `json:"type,omitempty"`
	Version *string `json:"version,omitempty"`
}

type PutConnectorConfigJSONBody map[string]string

type PutConnectorConfigJSONRequestBody PutConnectorConfigJSONBody

type PutConnectorConfigResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type RequestEditorFn func(ctx context.Context, req *http.Request) error

type ResetConnectorActiveTopicsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type RestartConnectorParams struct {
	// IncludeTasks Whether to also restart tasks
	IncludeTasks *bool `form:"includeTasks,omitempty" json:"includeTasks,omitempty"`

	// OnlyFailed Whether to only restart failed tasks/connectors
	OnlyFailed *bool `form:"onlyFailed,omitempty" json:"onlyFailed,omitempty"`
}

type RestartConnectorResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type RestartTaskResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type ResumeConnectorResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type ServerInfo struct {
	Commit         *string `json:"commit,omitempty"`
	KafkaClusterId *string `json:"kafka_cluster_id,omitempty"`
	Version        *string `json:"version,omitempty"`
}

type ServerInfoResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSONDefault  *ServerInfo
}

type SetLevelJSONBody map[string]string

type SetLevelJSONRequestBody SetLevelJSONBody

type SetLevelResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type StopConnectorResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type TaskInfo struct {
	Config *map[string]string `json:"config,omitempty"`
	Id     *ConnectorTaskId   `json:"id,omitempty"`
}

type TaskState struct {
	Id       *int32  `json:"id,omitempty"`
	Msg      *string `json:"msg,omitempty"`
	State    *string `json:"state,omitempty"`
	Trace    *string `json:"trace,omitempty"`
	WorkerId *string `json:"worker_id,omitempty"`
}

type ValidateConfigsJSONBody map[string]string

type ValidateConfigsJSONRequestBody ValidateConfigsJSONBody

type ValidateConfigsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSONDefault  *ConfigInfos
}