Versions in this module Expand all Collapse all v0 v0.1.1 Oct 11, 2023 v0.1.0 Oct 10, 2023 Changes in this version + func GetSwagger() (swagger *openapi3.T, err error) + func NewCreateConnectorRequest(server string, body CreateConnectorJSONRequestBody) (*http.Request, error) + func NewCreateConnectorRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error) + func NewDestroyConnectorRequest(server string, connector string) (*http.Request, error) + func NewGetConnectorActiveTopicsRequest(server string, connector string) (*http.Request, error) + func NewGetConnectorConfigDefRequest(server string, pluginName string) (*http.Request, error) + func NewGetConnectorConfigRequest(server string, connector string) (*http.Request, error) + func NewGetConnectorRequest(server string, connector string) (*http.Request, error) + func NewGetConnectorStatusRequest(server string, connector string) (*http.Request, error) + func NewGetLoggerRequest(server string, logger string) (*http.Request, error) + func NewGetOffsetsRequest(server string, connector string) (*http.Request, error) + func NewGetTaskConfigsRequest(server string, connector string) (*http.Request, error) + func NewGetTaskStatusRequest(server string, connector string, task int32) (*http.Request, error) + func NewGetTasksConfigRequest(server string, connector string) (*http.Request, error) + func NewListConnectorPluginsRequest(server string, params *ListConnectorPluginsParams) (*http.Request, error) + func NewListConnectorsRequest(server string) (*http.Request, error) + func NewListLoggersRequest(server string) (*http.Request, error) + func NewPauseConnectorRequest(server string, connector string) (*http.Request, error) + func NewPutConnectorConfigRequest(server string, connector string, body PutConnectorConfigJSONRequestBody) (*http.Request, error) + func NewPutConnectorConfigRequestWithBody(server string, connector string, contentType string, body io.Reader) (*http.Request, error) + func NewResetConnectorActiveTopicsRequest(server string, connector string) (*http.Request, error) + func NewRestartConnectorRequest(server string, connector string, params *RestartConnectorParams) (*http.Request, error) + func NewRestartTaskRequest(server string, connector string, task int32) (*http.Request, error) + func NewResumeConnectorRequest(server string, connector string) (*http.Request, error) + func NewServerInfoRequest(server string) (*http.Request, error) + func NewSetLevelRequest(server string, logger string, body SetLevelJSONRequestBody) (*http.Request, error) + func NewSetLevelRequestWithBody(server string, logger string, contentType string, body io.Reader) (*http.Request, error) + func NewStopConnectorRequest(server string, connector string) (*http.Request, error) + func NewValidateConfigsRequest(server string, pluginName string, body ValidateConfigsJSONRequestBody) (*http.Request, error) + func NewValidateConfigsRequestWithBody(server string, pluginName string, contentType string, body io.Reader) (*http.Request, error) + func PathToRawSpec(pathToFile string) map[string]func() ([]byte, error) + type Client struct + Client HttpRequestDoer + RequestEditors []RequestEditorFn + Server string + func NewClient(server string, opts ...ClientOption) (*Client, error) + func (c *Client) CreateConnector(ctx context.Context, body CreateConnectorJSONRequestBody, ...) (*http.Response, error) + func (c *Client) CreateConnectorWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error) + func (c *Client) DestroyConnector(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) GetConnector(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) GetConnectorActiveTopics(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) GetConnectorConfig(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) GetConnectorConfigDef(ctx context.Context, pluginName string, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) GetConnectorStatus(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) GetLogger(ctx context.Context, logger string, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) GetOffsets(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) GetTaskConfigs(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) GetTaskStatus(ctx context.Context, connector string, task int32, ...) (*http.Response, error) + func (c *Client) GetTasksConfig(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) ListConnectorPlugins(ctx context.Context, params *ListConnectorPluginsParams, ...) (*http.Response, error) + func (c *Client) ListConnectors(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) ListLoggers(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) PauseConnector(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) PutConnectorConfig(ctx context.Context, connector string, body PutConnectorConfigJSONRequestBody, ...) (*http.Response, error) + func (c *Client) PutConnectorConfigWithBody(ctx context.Context, connector string, contentType string, body io.Reader, ...) (*http.Response, error) + func (c *Client) ResetConnectorActiveTopics(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) RestartConnector(ctx context.Context, connector string, params *RestartConnectorParams, ...) (*http.Response, error) + func (c *Client) RestartTask(ctx context.Context, connector string, task int32, ...) (*http.Response, error) + func (c *Client) ResumeConnector(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) ServerInfo(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) SetLevel(ctx context.Context, logger string, body SetLevelJSONRequestBody, ...) (*http.Response, error) + func (c *Client) SetLevelWithBody(ctx context.Context, logger string, contentType string, body io.Reader, ...) (*http.Response, error) + func (c *Client) StopConnector(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + func (c *Client) ValidateConfigs(ctx context.Context, pluginName string, body ValidateConfigsJSONRequestBody, ...) (*http.Response, error) + func (c *Client) ValidateConfigsWithBody(ctx context.Context, pluginName string, contentType string, body io.Reader, ...) (*http.Response, error) + type ClientInterface interface + CreateConnector func(ctx context.Context, body CreateConnectorJSONRequestBody, ...) (*http.Response, error) + CreateConnectorWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error) + DestroyConnector func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + GetConnector func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + GetConnectorActiveTopics func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + GetConnectorConfig func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + GetConnectorConfigDef func(ctx context.Context, pluginName string, reqEditors ...RequestEditorFn) (*http.Response, error) + GetConnectorStatus func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + GetLogger func(ctx context.Context, logger string, reqEditors ...RequestEditorFn) (*http.Response, error) + GetOffsets func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + GetTaskConfigs func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + GetTaskStatus func(ctx context.Context, connector string, task int32, ...) (*http.Response, error) + GetTasksConfig func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + ListConnectorPlugins func(ctx context.Context, params *ListConnectorPluginsParams, ...) (*http.Response, error) + ListConnectors func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error) + ListLoggers func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error) + PauseConnector func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + PutConnectorConfig func(ctx context.Context, connector string, body PutConnectorConfigJSONRequestBody, ...) (*http.Response, error) + PutConnectorConfigWithBody func(ctx context.Context, connector string, contentType string, body io.Reader, ...) (*http.Response, error) + ResetConnectorActiveTopics func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + RestartConnector func(ctx context.Context, connector string, params *RestartConnectorParams, ...) (*http.Response, error) + RestartTask func(ctx context.Context, connector string, task int32, ...) (*http.Response, error) + ResumeConnector func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + ServerInfo func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error) + SetLevel func(ctx context.Context, logger string, body SetLevelJSONRequestBody, ...) (*http.Response, error) + SetLevelWithBody func(ctx context.Context, logger string, contentType string, body io.Reader, ...) (*http.Response, error) + StopConnector func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error) + ValidateConfigs func(ctx context.Context, pluginName string, body ValidateConfigsJSONRequestBody, ...) (*http.Response, error) + ValidateConfigsWithBody func(ctx context.Context, pluginName string, contentType string, body io.Reader, ...) (*http.Response, error) + type ClientOption func(*Client) error + func WithBaseURL(baseURL string) ClientOption + func WithHTTPClient(doer HttpRequestDoer) ClientOption + func WithRequestEditorFn(fn RequestEditorFn) ClientOption + type ClientWithResponses struct + func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, error) + func (c *ClientWithResponses) CreateConnectorWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*CreateConnectorResponse, error) + func (c *ClientWithResponses) CreateConnectorWithResponse(ctx context.Context, body CreateConnectorJSONRequestBody, ...) (*CreateConnectorResponse, error) + func (c *ClientWithResponses) DestroyConnectorWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*DestroyConnectorResponse, error) + func (c *ClientWithResponses) GetConnectorActiveTopicsWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorActiveTopicsResponse, error) + func (c *ClientWithResponses) GetConnectorConfigDefWithResponse(ctx context.Context, pluginName string, reqEditors ...RequestEditorFn) (*GetConnectorConfigDefResponse, error) + func (c *ClientWithResponses) GetConnectorConfigWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorConfigResponse, error) + func (c *ClientWithResponses) GetConnectorStatusWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorStatusResponse, error) + func (c *ClientWithResponses) GetConnectorWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorResponse, error) + func (c *ClientWithResponses) GetLoggerWithResponse(ctx context.Context, logger string, reqEditors ...RequestEditorFn) (*GetLoggerResponse, error) + func (c *ClientWithResponses) GetOffsetsWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetOffsetsResponse, error) + func (c *ClientWithResponses) GetTaskConfigsWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetTaskConfigsResponse, error) + func (c *ClientWithResponses) GetTaskStatusWithResponse(ctx context.Context, connector string, task int32, ...) (*GetTaskStatusResponse, error) + func (c *ClientWithResponses) GetTasksConfigWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetTasksConfigResponse, error) + func (c *ClientWithResponses) ListConnectorPluginsWithResponse(ctx context.Context, params *ListConnectorPluginsParams, ...) (*ListConnectorPluginsResponse, error) + func (c *ClientWithResponses) ListConnectorsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListConnectorsResponse, error) + func (c *ClientWithResponses) ListLoggersWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListLoggersResponse, error) + func (c *ClientWithResponses) PauseConnectorWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*PauseConnectorResponse, error) + func (c *ClientWithResponses) PutConnectorConfigWithBodyWithResponse(ctx context.Context, connector string, contentType string, body io.Reader, ...) (*PutConnectorConfigResponse, error) + func (c *ClientWithResponses) PutConnectorConfigWithResponse(ctx context.Context, connector string, body PutConnectorConfigJSONRequestBody, ...) (*PutConnectorConfigResponse, error) + func (c *ClientWithResponses) ResetConnectorActiveTopicsWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*ResetConnectorActiveTopicsResponse, error) + func (c *ClientWithResponses) RestartConnectorWithResponse(ctx context.Context, connector string, params *RestartConnectorParams, ...) (*RestartConnectorResponse, error) + func (c *ClientWithResponses) RestartTaskWithResponse(ctx context.Context, connector string, task int32, ...) (*RestartTaskResponse, error) + func (c *ClientWithResponses) ResumeConnectorWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*ResumeConnectorResponse, error) + func (c *ClientWithResponses) ServerInfoWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ServerInfoResponse, error) + func (c *ClientWithResponses) SetLevelWithBodyWithResponse(ctx context.Context, logger string, contentType string, body io.Reader, ...) (*SetLevelResponse, error) + func (c *ClientWithResponses) SetLevelWithResponse(ctx context.Context, logger string, body SetLevelJSONRequestBody, ...) (*SetLevelResponse, error) + func (c *ClientWithResponses) StopConnectorWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*StopConnectorResponse, error) + func (c *ClientWithResponses) ValidateConfigsWithBodyWithResponse(ctx context.Context, pluginName string, contentType string, body io.Reader, ...) (*ValidateConfigsResponse, error) + func (c *ClientWithResponses) ValidateConfigsWithResponse(ctx context.Context, pluginName string, body ValidateConfigsJSONRequestBody, ...) (*ValidateConfigsResponse, error) + type ClientWithResponsesInterface interface + CreateConnectorWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*CreateConnectorResponse, error) + CreateConnectorWithResponse func(ctx context.Context, body CreateConnectorJSONRequestBody, ...) (*CreateConnectorResponse, error) + DestroyConnectorWithResponse func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*DestroyConnectorResponse, error) + GetConnectorActiveTopicsWithResponse func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorActiveTopicsResponse, error) + GetConnectorConfigDefWithResponse func(ctx context.Context, pluginName string, reqEditors ...RequestEditorFn) (*GetConnectorConfigDefResponse, error) + GetConnectorConfigWithResponse func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorConfigResponse, error) + GetConnectorStatusWithResponse func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorStatusResponse, error) + GetConnectorWithResponse func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorResponse, error) + GetLoggerWithResponse func(ctx context.Context, logger string, reqEditors ...RequestEditorFn) (*GetLoggerResponse, error) + GetOffsetsWithResponse func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetOffsetsResponse, error) + GetTaskConfigsWithResponse func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetTaskConfigsResponse, error) + GetTaskStatusWithResponse func(ctx context.Context, connector string, task int32, ...) (*GetTaskStatusResponse, error) + GetTasksConfigWithResponse func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetTasksConfigResponse, error) + ListConnectorPluginsWithResponse func(ctx context.Context, params *ListConnectorPluginsParams, ...) (*ListConnectorPluginsResponse, error) + ListConnectorsWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*ListConnectorsResponse, error) + ListLoggersWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*ListLoggersResponse, error) + PauseConnectorWithResponse func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*PauseConnectorResponse, error) + PutConnectorConfigWithBodyWithResponse func(ctx context.Context, connector string, contentType string, body io.Reader, ...) (*PutConnectorConfigResponse, error) + PutConnectorConfigWithResponse func(ctx context.Context, connector string, body PutConnectorConfigJSONRequestBody, ...) (*PutConnectorConfigResponse, error) + ResetConnectorActiveTopicsWithResponse func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*ResetConnectorActiveTopicsResponse, error) + RestartConnectorWithResponse func(ctx context.Context, connector string, params *RestartConnectorParams, ...) (*RestartConnectorResponse, error) + RestartTaskWithResponse func(ctx context.Context, connector string, task int32, ...) (*RestartTaskResponse, error) + ResumeConnectorWithResponse func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*ResumeConnectorResponse, error) + ServerInfoWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*ServerInfoResponse, error) + SetLevelWithBodyWithResponse func(ctx context.Context, logger string, contentType string, body io.Reader, ...) (*SetLevelResponse, error) + SetLevelWithResponse func(ctx context.Context, logger string, body SetLevelJSONRequestBody, ...) (*SetLevelResponse, error) + StopConnectorWithResponse func(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*StopConnectorResponse, error) + ValidateConfigsWithBodyWithResponse func(ctx context.Context, pluginName string, contentType string, body io.Reader, ...) (*ValidateConfigsResponse, error) + ValidateConfigsWithResponse func(ctx context.Context, pluginName string, body ValidateConfigsJSONRequestBody, ...) (*ValidateConfigsResponse, error) + type ConfigInfo struct + Definition *ConfigKeyInfo + Value *ConfigValueInfo + type ConfigInfos struct + Configs *[]ConfigInfo + ErrorCount *int32 + Groups *[]string + Name *string + type ConfigKeyInfo struct + DefaultValue *string + Dependents *[]string + DisplayName *string + Documentation *string + Group *string + Importance *string + Name *string + Order *int32 + OrderInGroup *int32 + Required *bool + Type *string + Width *string + type ConfigValueInfo struct + Errors *[]string + Name *string + RecommendedValues *[]string + Value *string + Visible *bool + type ConnectorInfo struct + Config *map[string]string + Name *string + Tasks *[]ConnectorTaskId + Type *ConnectorInfoType + type ConnectorInfoType string + const ConnectorInfoTypeSink + const ConnectorInfoTypeSource + const ConnectorInfoTypeUnknown + type ConnectorOffset struct + Offset *map[string]map[string]interface{} + Partition *map[string]map[string]interface{} + type ConnectorOffsets struct + Offsets *[]ConnectorOffset + type ConnectorState struct + Msg *string + State *string + Trace *string + WorkerId *string + type ConnectorStateInfo struct + Connector *ConnectorState + Name *string + Tasks *[]TaskState + Type *ConnectorStateInfoType + type ConnectorStateInfoType string + const ConnectorStateInfoTypeSink + const ConnectorStateInfoTypeSource + const ConnectorStateInfoTypeUnknown + type ConnectorTaskId struct + Connector *string + Task *int32 + type CreateConnectorJSONRequestBody = CreateConnectorRequest + type CreateConnectorRequest struct + Config *map[string]string + Name *string + type CreateConnectorResponse struct + Body []byte + HTTPResponse *http.Response + func ParseCreateConnectorResponse(rsp *http.Response) (*CreateConnectorResponse, error) + func (r CreateConnectorResponse) Status() string + func (r CreateConnectorResponse) StatusCode() int + type DestroyConnectorResponse struct + Body []byte + HTTPResponse *http.Response + func ParseDestroyConnectorResponse(rsp *http.Response) (*DestroyConnectorResponse, error) + func (r DestroyConnectorResponse) Status() string + func (r DestroyConnectorResponse) StatusCode() int + type GetConnectorActiveTopicsResponse struct + Body []byte + HTTPResponse *http.Response + func ParseGetConnectorActiveTopicsResponse(rsp *http.Response) (*GetConnectorActiveTopicsResponse, error) + func (r GetConnectorActiveTopicsResponse) Status() string + func (r GetConnectorActiveTopicsResponse) StatusCode() int + type GetConnectorConfigDefResponse struct + Body []byte + HTTPResponse *http.Response + JSONDefault *[]ConfigKeyInfo + func ParseGetConnectorConfigDefResponse(rsp *http.Response) (*GetConnectorConfigDefResponse, error) + func (r GetConnectorConfigDefResponse) Status() string + func (r GetConnectorConfigDefResponse) StatusCode() int + type GetConnectorConfigResponse struct + Body []byte + HTTPResponse *http.Response + JSONDefault *map[string]string + func ParseGetConnectorConfigResponse(rsp *http.Response) (*GetConnectorConfigResponse, error) + func (r GetConnectorConfigResponse) Status() string + func (r GetConnectorConfigResponse) StatusCode() int + type GetConnectorResponse struct + Body []byte + HTTPResponse *http.Response + JSONDefault *ConnectorInfo + func ParseGetConnectorResponse(rsp *http.Response) (*GetConnectorResponse, error) + func (r GetConnectorResponse) Status() string + func (r GetConnectorResponse) StatusCode() int + type GetConnectorStatusResponse struct + Body []byte + HTTPResponse *http.Response + JSONDefault *ConnectorStateInfo + func ParseGetConnectorStatusResponse(rsp *http.Response) (*GetConnectorStatusResponse, error) + func (r GetConnectorStatusResponse) Status() string + func (r GetConnectorStatusResponse) StatusCode() int + type GetLoggerResponse struct + Body []byte + HTTPResponse *http.Response + func ParseGetLoggerResponse(rsp *http.Response) (*GetLoggerResponse, error) + func (r GetLoggerResponse) Status() string + func (r GetLoggerResponse) StatusCode() int + type GetOffsetsResponse struct + Body []byte + HTTPResponse *http.Response + JSONDefault *ConnectorOffsets + func ParseGetOffsetsResponse(rsp *http.Response) (*GetOffsetsResponse, error) + func (r GetOffsetsResponse) Status() string + func (r GetOffsetsResponse) StatusCode() int + type GetTaskConfigsResponse struct + Body []byte + HTTPResponse *http.Response + JSONDefault *[]TaskInfo + func ParseGetTaskConfigsResponse(rsp *http.Response) (*GetTaskConfigsResponse, error) + func (r GetTaskConfigsResponse) Status() string + func (r GetTaskConfigsResponse) StatusCode() int + type GetTaskStatusResponse struct + Body []byte + HTTPResponse *http.Response + JSONDefault *TaskState + func ParseGetTaskStatusResponse(rsp *http.Response) (*GetTaskStatusResponse, error) + func (r GetTaskStatusResponse) Status() string + func (r GetTaskStatusResponse) StatusCode() int + type GetTasksConfigResponse struct + Body []byte + HTTPResponse *http.Response + JSONDefault *map[string]map[string]string + func ParseGetTasksConfigResponse(rsp *http.Response) (*GetTasksConfigResponse, error) + func (r GetTasksConfigResponse) Status() string + func (r GetTasksConfigResponse) StatusCode() int + type HttpRequestDoer interface + Do func(req *http.Request) (*http.Response, error) + type ListConnectorPluginsParams struct + ConnectorsOnly *bool + type ListConnectorPluginsResponse struct + Body []byte + HTTPResponse *http.Response + JSONDefault *[]PluginInfo + func ParseListConnectorPluginsResponse(rsp *http.Response) (*ListConnectorPluginsResponse, error) + func (r ListConnectorPluginsResponse) Status() string + func (r ListConnectorPluginsResponse) StatusCode() int + type ListConnectorsResponse struct + Body []byte + HTTPResponse *http.Response + func ParseListConnectorsResponse(rsp *http.Response) (*ListConnectorsResponse, error) + func (r ListConnectorsResponse) Status() string + func (r ListConnectorsResponse) StatusCode() int + type ListLoggersResponse struct + Body []byte + HTTPResponse *http.Response + func ParseListLoggersResponse(rsp *http.Response) (*ListLoggersResponse, error) + func (r ListLoggersResponse) Status() string + func (r ListLoggersResponse) StatusCode() int + type PauseConnectorResponse struct + Body []byte + HTTPResponse *http.Response + func ParsePauseConnectorResponse(rsp *http.Response) (*PauseConnectorResponse, error) + func (r PauseConnectorResponse) Status() string + func (r PauseConnectorResponse) StatusCode() int + type PluginInfo struct + Class *string + Type *string + Version *string + type PutConnectorConfigJSONBody map[string]string + type PutConnectorConfigJSONRequestBody PutConnectorConfigJSONBody + type PutConnectorConfigResponse struct + Body []byte + HTTPResponse *http.Response + func ParsePutConnectorConfigResponse(rsp *http.Response) (*PutConnectorConfigResponse, error) + func (r PutConnectorConfigResponse) Status() string + func (r PutConnectorConfigResponse) StatusCode() int + type RequestEditorFn func(ctx context.Context, req *http.Request) error + type ResetConnectorActiveTopicsResponse struct + Body []byte + HTTPResponse *http.Response + func ParseResetConnectorActiveTopicsResponse(rsp *http.Response) (*ResetConnectorActiveTopicsResponse, error) + func (r ResetConnectorActiveTopicsResponse) Status() string + func (r ResetConnectorActiveTopicsResponse) StatusCode() int + type RestartConnectorParams struct + IncludeTasks *bool + OnlyFailed *bool + type RestartConnectorResponse struct + Body []byte + HTTPResponse *http.Response + func ParseRestartConnectorResponse(rsp *http.Response) (*RestartConnectorResponse, error) + func (r RestartConnectorResponse) Status() string + func (r RestartConnectorResponse) StatusCode() int + type RestartTaskResponse struct + Body []byte + HTTPResponse *http.Response + func ParseRestartTaskResponse(rsp *http.Response) (*RestartTaskResponse, error) + func (r RestartTaskResponse) Status() string + func (r RestartTaskResponse) StatusCode() int + type ResumeConnectorResponse struct + Body []byte + HTTPResponse *http.Response + func ParseResumeConnectorResponse(rsp *http.Response) (*ResumeConnectorResponse, error) + func (r ResumeConnectorResponse) Status() string + func (r ResumeConnectorResponse) StatusCode() int + type ServerInfo struct + Commit *string + KafkaClusterId *string + Version *string + type ServerInfoResponse struct + Body []byte + HTTPResponse *http.Response + JSONDefault *ServerInfo + func ParseServerInfoResponse(rsp *http.Response) (*ServerInfoResponse, error) + func (r ServerInfoResponse) Status() string + func (r ServerInfoResponse) StatusCode() int + type SetLevelJSONBody map[string]string + type SetLevelJSONRequestBody SetLevelJSONBody + type SetLevelResponse struct + Body []byte + HTTPResponse *http.Response + func ParseSetLevelResponse(rsp *http.Response) (*SetLevelResponse, error) + func (r SetLevelResponse) Status() string + func (r SetLevelResponse) StatusCode() int + type StopConnectorResponse struct + Body []byte + HTTPResponse *http.Response + func ParseStopConnectorResponse(rsp *http.Response) (*StopConnectorResponse, error) + func (r StopConnectorResponse) Status() string + func (r StopConnectorResponse) StatusCode() int + type TaskInfo struct + Config *map[string]string + Id *ConnectorTaskId + type TaskState struct + Id *int32 + Msg *string + State *string + Trace *string + WorkerId *string + type ValidateConfigsJSONBody map[string]string + type ValidateConfigsJSONRequestBody ValidateConfigsJSONBody + type ValidateConfigsResponse struct + Body []byte + HTTPResponse *http.Response + JSONDefault *ConfigInfos + func ParseValidateConfigsResponse(rsp *http.Response) (*ValidateConfigsResponse, error) + func (r ValidateConfigsResponse) Status() string + func (r ValidateConfigsResponse) StatusCode() int
Go to main page