api

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 11, 2023 License: MIT Imports: 13 Imported by: 0

Documentation

Overview

Package api provides primitives to interact with the openapi HTTP API.

Code generated by github.com/deepmap/oapi-codegen version v1.15.0 DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetSwagger 

func GetSwagger() (swagger *openapi3.T, err error)

GetSwagger returns the Swagger specification corresponding to the generated code in this file. The external references of Swagger specification are resolved. The logic of resolving external references is tightly connected to "import-mapping" feature. Externally referenced files must be embedded in the corresponding golang packages. Urls can be supported but this task was out of the scope.

func NewCreateConnectorRequest 

func NewCreateConnectorRequest(server string, body CreateConnectorJSONRequestBody) (*http.Request, error)

NewCreateConnectorRequest calls the generic CreateConnector builder with application/json body

func NewCreateConnectorRequestWithBody 

func NewCreateConnectorRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

NewCreateConnectorRequestWithBody generates requests for CreateConnector with any type of body

func NewDestroyConnectorRequest 

func NewDestroyConnectorRequest(server string, connector string) (*http.Request, error)

NewDestroyConnectorRequest generates requests for DestroyConnector

func NewGetConnectorActiveTopicsRequest 

func NewGetConnectorActiveTopicsRequest(server string, connector string) (*http.Request, error)

NewGetConnectorActiveTopicsRequest generates requests for GetConnectorActiveTopics

func NewGetConnectorConfigDefRequest 

func NewGetConnectorConfigDefRequest(server string, pluginName string) (*http.Request, error)

NewGetConnectorConfigDefRequest generates requests for GetConnectorConfigDef

func NewGetConnectorConfigRequest 

func NewGetConnectorConfigRequest(server string, connector string) (*http.Request, error)

NewGetConnectorConfigRequest generates requests for GetConnectorConfig

func NewGetConnectorRequest 

func NewGetConnectorRequest(server string, connector string) (*http.Request, error)

NewGetConnectorRequest generates requests for GetConnector

func NewGetConnectorStatusRequest 

func NewGetConnectorStatusRequest(server string, connector string) (*http.Request, error)

NewGetConnectorStatusRequest generates requests for GetConnectorStatus

func NewGetLoggerRequest 

func NewGetLoggerRequest(server string, logger string) (*http.Request, error)

NewGetLoggerRequest generates requests for GetLogger

func NewGetOffsetsRequest 

func NewGetOffsetsRequest(server string, connector string) (*http.Request, error)

NewGetOffsetsRequest generates requests for GetOffsets

func NewGetTaskConfigsRequest 

func NewGetTaskConfigsRequest(server string, connector string) (*http.Request, error)

NewGetTaskConfigsRequest generates requests for GetTaskConfigs

func NewGetTaskStatusRequest 

func NewGetTaskStatusRequest(server string, connector string, task int32) (*http.Request, error)

NewGetTaskStatusRequest generates requests for GetTaskStatus

func NewGetTasksConfigRequest 

func NewGetTasksConfigRequest(server string, connector string) (*http.Request, error)

NewGetTasksConfigRequest generates requests for GetTasksConfig

func NewListConnectorPluginsRequest 

func NewListConnectorPluginsRequest(server string, params *ListConnectorPluginsParams) (*http.Request, error)

NewListConnectorPluginsRequest generates requests for ListConnectorPlugins

func NewListConnectorsRequest 

func NewListConnectorsRequest(server string) (*http.Request, error)

NewListConnectorsRequest generates requests for ListConnectors

func NewListLoggersRequest 

func NewListLoggersRequest(server string) (*http.Request, error)

NewListLoggersRequest generates requests for ListLoggers

func NewPauseConnectorRequest 

func NewPauseConnectorRequest(server string, connector string) (*http.Request, error)

NewPauseConnectorRequest generates requests for PauseConnector

func NewPutConnectorConfigRequest 

func NewPutConnectorConfigRequest(server string, connector string, body PutConnectorConfigJSONRequestBody) (*http.Request, error)

NewPutConnectorConfigRequest calls the generic PutConnectorConfig builder with application/json body

func NewPutConnectorConfigRequestWithBody 

func NewPutConnectorConfigRequestWithBody(server string, connector string, contentType string, body io.Reader) (*http.Request, error)

NewPutConnectorConfigRequestWithBody generates requests for PutConnectorConfig with any type of body

func NewResetConnectorActiveTopicsRequest 

func NewResetConnectorActiveTopicsRequest(server string, connector string) (*http.Request, error)

NewResetConnectorActiveTopicsRequest generates requests for ResetConnectorActiveTopics

func NewRestartConnectorRequest 

func NewRestartConnectorRequest(server string, connector string, params *RestartConnectorParams) (*http.Request, error)

NewRestartConnectorRequest generates requests for RestartConnector

func NewRestartTaskRequest 

func NewRestartTaskRequest(server string, connector string, task int32) (*http.Request, error)

NewRestartTaskRequest generates requests for RestartTask

func NewResumeConnectorRequest 

func NewResumeConnectorRequest(server string, connector string) (*http.Request, error)

NewResumeConnectorRequest generates requests for ResumeConnector

func NewServerInfoRequest 

func NewServerInfoRequest(server string) (*http.Request, error)

NewServerInfoRequest generates requests for ServerInfo

func NewSetLevelRequest 

func NewSetLevelRequest(server string, logger string, body SetLevelJSONRequestBody) (*http.Request, error)

NewSetLevelRequest calls the generic SetLevel builder with application/json body

func NewSetLevelRequestWithBody 

func NewSetLevelRequestWithBody(server string, logger string, contentType string, body io.Reader) (*http.Request, error)

NewSetLevelRequestWithBody generates requests for SetLevel with any type of body

func NewStopConnectorRequest 

func NewStopConnectorRequest(server string, connector string) (*http.Request, error)

NewStopConnectorRequest generates requests for StopConnector

func NewValidateConfigsRequest 

func NewValidateConfigsRequest(server string, pluginName string, body ValidateConfigsJSONRequestBody) (*http.Request, error)

NewValidateConfigsRequest calls the generic ValidateConfigs builder with application/json body

func NewValidateConfigsRequestWithBody 

func NewValidateConfigsRequestWithBody(server string, pluginName string, contentType string, body io.Reader) (*http.Request, error)

NewValidateConfigsRequestWithBody generates requests for ValidateConfigs with any type of body

func PathToRawSpec 

func PathToRawSpec(pathToFile string) map[string]func() ([]byte, error)

Constructs a synthetic filesystem for resolving external references when loading openapi specifications.

Types

type Client 

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
}

Client which conforms to the OpenAPI3 specification for this service.

func NewClient 

func NewClient(server string, opts ...ClientOption) (*Client, error)

Creates a new Client, with reasonable defaults

func (*Client) CreateConnector 

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

func (*Client) CreateConnectorWithBody 

func (c *Client) CreateConnectorWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DestroyConnector 

func (c *Client) DestroyConnector(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetConnector 

func (c *Client) GetConnector(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetConnectorActiveTopics 

func (c *Client) GetConnectorActiveTopics(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetConnectorConfig 

func (c *Client) GetConnectorConfig(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetConnectorConfigDef 

func (c *Client) GetConnectorConfigDef(ctx context.Context, pluginName string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetConnectorStatus 

func (c *Client) GetConnectorStatus(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetLogger 

func (c *Client) GetLogger(ctx context.Context, logger string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetOffsets 

func (c *Client) GetOffsets(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetTaskConfigs 

func (c *Client) GetTaskConfigs(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetTaskStatus 

func (c *Client) GetTaskStatus(ctx context.Context, connector string, task int32, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetTasksConfig 

func (c *Client) GetTasksConfig(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListConnectorPlugins 

func (c *Client) ListConnectorPlugins(ctx context.Context, params *ListConnectorPluginsParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListConnectors 

func (c *Client) ListConnectors(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListLoggers 

func (c *Client) ListLoggers(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PauseConnector 

func (c *Client) PauseConnector(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutConnectorConfig 

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

func (*Client) PutConnectorConfigWithBody 

func (c *Client) PutConnectorConfigWithBody(ctx context.Context, connector string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ResetConnectorActiveTopics 

func (c *Client) ResetConnectorActiveTopics(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RestartConnector 

func (c *Client) RestartConnector(ctx context.Context, connector string, params *RestartConnectorParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RestartTask 

func (c *Client) RestartTask(ctx context.Context, connector string, task int32, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ResumeConnector 

func (c *Client) ResumeConnector(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ServerInfo 

func (c *Client) ServerInfo(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) SetLevel 

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

func (*Client) SetLevelWithBody 

func (c *Client) SetLevelWithBody(ctx context.Context, logger string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) StopConnector 

func (c *Client) StopConnector(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ValidateConfigs 

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

func (*Client) ValidateConfigsWithBody 

func (c *Client) ValidateConfigsWithBody(ctx context.Context, pluginName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

type ClientInterface 

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)
}

The interface specification for the client above.

type ClientOption 

type ClientOption func(*Client) error

ClientOption allows setting custom parameters during construction

func WithBaseURL 

func WithBaseURL(baseURL string) ClientOption

WithBaseURL overrides the baseURL.

func WithHTTPClient 

func WithHTTPClient(doer HttpRequestDoer) ClientOption

WithHTTPClient allows overriding the default Doer, which is automatically created using http.Client. This is useful for tests.

func WithRequestEditorFn 

func WithRequestEditorFn(fn RequestEditorFn) ClientOption

WithRequestEditorFn allows setting up a callback function, which will be called right before sending the request. This can be used to mutate the request.

type ClientWithResponses 

type ClientWithResponses struct {
	ClientInterface
}

ClientWithResponses builds on ClientInterface to offer response payloads

func NewClientWithResponses 

func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, error)

NewClientWithResponses creates a new ClientWithResponses, which wraps Client with return type handling

func (*ClientWithResponses) CreateConnectorWithBodyWithResponse 

func (c *ClientWithResponses) CreateConnectorWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CreateConnectorResponse, error)

CreateConnectorWithBodyWithResponse request with arbitrary body returning *CreateConnectorResponse

func (*ClientWithResponses) CreateConnectorWithResponse 

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

func (*ClientWithResponses) DestroyConnectorWithResponse 

func (c *ClientWithResponses) DestroyConnectorWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*DestroyConnectorResponse, error)

DestroyConnectorWithResponse request returning *DestroyConnectorResponse

func (*ClientWithResponses) GetConnectorActiveTopicsWithResponse 

func (c *ClientWithResponses) GetConnectorActiveTopicsWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorActiveTopicsResponse, error)

GetConnectorActiveTopicsWithResponse request returning *GetConnectorActiveTopicsResponse

func (*ClientWithResponses) GetConnectorConfigDefWithResponse 

func (c *ClientWithResponses) GetConnectorConfigDefWithResponse(ctx context.Context, pluginName string, reqEditors ...RequestEditorFn) (*GetConnectorConfigDefResponse, error)

GetConnectorConfigDefWithResponse request returning *GetConnectorConfigDefResponse

func (*ClientWithResponses) GetConnectorConfigWithResponse 

func (c *ClientWithResponses) GetConnectorConfigWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorConfigResponse, error)

GetConnectorConfigWithResponse request returning *GetConnectorConfigResponse

func (*ClientWithResponses) GetConnectorStatusWithResponse 

func (c *ClientWithResponses) GetConnectorStatusWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorStatusResponse, error)

GetConnectorStatusWithResponse request returning *GetConnectorStatusResponse

func (*ClientWithResponses) GetConnectorWithResponse 

func (c *ClientWithResponses) GetConnectorWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetConnectorResponse, error)

GetConnectorWithResponse request returning *GetConnectorResponse

func (*ClientWithResponses) GetLoggerWithResponse 

func (c *ClientWithResponses) GetLoggerWithResponse(ctx context.Context, logger string, reqEditors ...RequestEditorFn) (*GetLoggerResponse, error)

GetLoggerWithResponse request returning *GetLoggerResponse

func (*ClientWithResponses) GetOffsetsWithResponse 

func (c *ClientWithResponses) GetOffsetsWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetOffsetsResponse, error)

GetOffsetsWithResponse request returning *GetOffsetsResponse

func (*ClientWithResponses) GetTaskConfigsWithResponse 

func (c *ClientWithResponses) GetTaskConfigsWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetTaskConfigsResponse, error)

GetTaskConfigsWithResponse request returning *GetTaskConfigsResponse

func (*ClientWithResponses) GetTaskStatusWithResponse 

func (c *ClientWithResponses) GetTaskStatusWithResponse(ctx context.Context, connector string, task int32, reqEditors ...RequestEditorFn) (*GetTaskStatusResponse, error)

GetTaskStatusWithResponse request returning *GetTaskStatusResponse

func (*ClientWithResponses) GetTasksConfigWithResponse 

func (c *ClientWithResponses) GetTasksConfigWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*GetTasksConfigResponse, error)

GetTasksConfigWithResponse request returning *GetTasksConfigResponse

func (*ClientWithResponses) ListConnectorPluginsWithResponse 

func (c *ClientWithResponses) ListConnectorPluginsWithResponse(ctx context.Context, params *ListConnectorPluginsParams, reqEditors ...RequestEditorFn) (*ListConnectorPluginsResponse, error)

ListConnectorPluginsWithResponse request returning *ListConnectorPluginsResponse

func (*ClientWithResponses) ListConnectorsWithResponse 

func (c *ClientWithResponses) ListConnectorsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListConnectorsResponse, error)

ListConnectorsWithResponse request returning *ListConnectorsResponse

func (*ClientWithResponses) ListLoggersWithResponse 

func (c *ClientWithResponses) ListLoggersWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListLoggersResponse, error)

ListLoggersWithResponse request returning *ListLoggersResponse

func (*ClientWithResponses) PauseConnectorWithResponse 

func (c *ClientWithResponses) PauseConnectorWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*PauseConnectorResponse, error)

PauseConnectorWithResponse request returning *PauseConnectorResponse

func (*ClientWithResponses) PutConnectorConfigWithBodyWithResponse 

func (c *ClientWithResponses) PutConnectorConfigWithBodyWithResponse(ctx context.Context, connector string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutConnectorConfigResponse, error)

PutConnectorConfigWithBodyWithResponse request with arbitrary body returning *PutConnectorConfigResponse

func (*ClientWithResponses) PutConnectorConfigWithResponse 

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

func (*ClientWithResponses) ResetConnectorActiveTopicsWithResponse 

func (c *ClientWithResponses) ResetConnectorActiveTopicsWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*ResetConnectorActiveTopicsResponse, error)

ResetConnectorActiveTopicsWithResponse request returning *ResetConnectorActiveTopicsResponse

func (*ClientWithResponses) RestartConnectorWithResponse 

func (c *ClientWithResponses) RestartConnectorWithResponse(ctx context.Context, connector string, params *RestartConnectorParams, reqEditors ...RequestEditorFn) (*RestartConnectorResponse, error)

RestartConnectorWithResponse request returning *RestartConnectorResponse

func (*ClientWithResponses) RestartTaskWithResponse 

func (c *ClientWithResponses) RestartTaskWithResponse(ctx context.Context, connector string, task int32, reqEditors ...RequestEditorFn) (*RestartTaskResponse, error)

RestartTaskWithResponse request returning *RestartTaskResponse

func (*ClientWithResponses) ResumeConnectorWithResponse 

func (c *ClientWithResponses) ResumeConnectorWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*ResumeConnectorResponse, error)

ResumeConnectorWithResponse request returning *ResumeConnectorResponse

func (*ClientWithResponses) ServerInfoWithResponse 

func (c *ClientWithResponses) ServerInfoWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ServerInfoResponse, error)

ServerInfoWithResponse request returning *ServerInfoResponse

func (*ClientWithResponses) SetLevelWithBodyWithResponse 

func (c *ClientWithResponses) SetLevelWithBodyWithResponse(ctx context.Context, logger string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SetLevelResponse, error)

SetLevelWithBodyWithResponse request with arbitrary body returning *SetLevelResponse

func (*ClientWithResponses) SetLevelWithResponse 

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

func (*ClientWithResponses) StopConnectorWithResponse 

func (c *ClientWithResponses) StopConnectorWithResponse(ctx context.Context, connector string, reqEditors ...RequestEditorFn) (*StopConnectorResponse, error)

StopConnectorWithResponse request returning *StopConnectorResponse

func (*ClientWithResponses) ValidateConfigsWithBodyWithResponse 

func (c *ClientWithResponses) ValidateConfigsWithBodyWithResponse(ctx context.Context, pluginName string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ValidateConfigsResponse, error)

ValidateConfigsWithBodyWithResponse request with arbitrary body returning *ValidateConfigsResponse

func (*ClientWithResponses) ValidateConfigsWithResponse 

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

type ClientWithResponsesInterface 

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)
}

ClientWithResponsesInterface is the interface specification for the client with responses above.

type ConfigInfo 

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

ConfigInfo defines model for ConfigInfo.

type ConfigInfos 

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

ConfigInfos defines model for ConfigInfos.

type ConfigKeyInfo 

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"`
}

ConfigKeyInfo defines model for ConfigKeyInfo.

type ConfigValueInfo 

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"`
}

ConfigValueInfo defines model for ConfigValueInfo.

type ConnectorInfo 

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"`
}

ConnectorInfo defines model for ConnectorInfo.

type ConnectorInfoType 

type ConnectorInfoType string

ConnectorInfoType defines model for ConnectorInfo.Type. 

const (
	ConnectorInfoTypeSink    ConnectorInfoType = "sink"
	ConnectorInfoTypeSource  ConnectorInfoType = "source"
	ConnectorInfoTypeUnknown ConnectorInfoType = "unknown"
)

Defines values for ConnectorInfoType.

type ConnectorOffset 

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

ConnectorOffset defines model for ConnectorOffset.

type ConnectorOffsets 

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

ConnectorOffsets defines model for ConnectorOffsets.

type ConnectorState 

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

ConnectorState defines model for ConnectorState.

type ConnectorStateInfo 

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

ConnectorStateInfo defines model for ConnectorStateInfo.

type ConnectorStateInfoType 

type ConnectorStateInfoType string

ConnectorStateInfoType defines model for ConnectorStateInfo.Type. 

const (
	ConnectorStateInfoTypeSink    ConnectorStateInfoType = "sink"
	ConnectorStateInfoTypeSource  ConnectorStateInfoType = "source"
	ConnectorStateInfoTypeUnknown ConnectorStateInfoType = "unknown"
)

Defines values for ConnectorStateInfoType.

type ConnectorTaskId 

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

ConnectorTaskId defines model for ConnectorTaskId.

type CreateConnectorJSONRequestBody 

type CreateConnectorJSONRequestBody = CreateConnectorRequest

CreateConnectorJSONRequestBody defines body for CreateConnector for application/json ContentType.

type CreateConnectorRequest 

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

CreateConnectorRequest defines model for CreateConnectorRequest.

type CreateConnectorResponse 

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

func ParseCreateConnectorResponse 

func ParseCreateConnectorResponse(rsp *http.Response) (*CreateConnectorResponse, error)

ParseCreateConnectorResponse parses an HTTP response from a CreateConnectorWithResponse call

func (CreateConnectorResponse) Status 

func (r CreateConnectorResponse) Status() string

Status returns HTTPResponse.Status

func (CreateConnectorResponse) StatusCode 

func (r CreateConnectorResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DestroyConnectorResponse 

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

func ParseDestroyConnectorResponse 

func ParseDestroyConnectorResponse(rsp *http.Response) (*DestroyConnectorResponse, error)

ParseDestroyConnectorResponse parses an HTTP response from a DestroyConnectorWithResponse call

func (DestroyConnectorResponse) Status 

func (r DestroyConnectorResponse) Status() string

Status returns HTTPResponse.Status

func (DestroyConnectorResponse) StatusCode 

func (r DestroyConnectorResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetConnectorActiveTopicsResponse 

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

func ParseGetConnectorActiveTopicsResponse 

func ParseGetConnectorActiveTopicsResponse(rsp *http.Response) (*GetConnectorActiveTopicsResponse, error)

ParseGetConnectorActiveTopicsResponse parses an HTTP response from a GetConnectorActiveTopicsWithResponse call

func (GetConnectorActiveTopicsResponse) Status 

func (r GetConnectorActiveTopicsResponse) Status() string

Status returns HTTPResponse.Status

func (GetConnectorActiveTopicsResponse) StatusCode 

func (r GetConnectorActiveTopicsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetConnectorConfigDefResponse 

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

func ParseGetConnectorConfigDefResponse 

func ParseGetConnectorConfigDefResponse(rsp *http.Response) (*GetConnectorConfigDefResponse, error)

ParseGetConnectorConfigDefResponse parses an HTTP response from a GetConnectorConfigDefWithResponse call

func (GetConnectorConfigDefResponse) Status 

func (r GetConnectorConfigDefResponse) Status() string

Status returns HTTPResponse.Status

func (GetConnectorConfigDefResponse) StatusCode 

func (r GetConnectorConfigDefResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetConnectorConfigResponse 

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

func ParseGetConnectorConfigResponse 

func ParseGetConnectorConfigResponse(rsp *http.Response) (*GetConnectorConfigResponse, error)

ParseGetConnectorConfigResponse parses an HTTP response from a GetConnectorConfigWithResponse call

func (GetConnectorConfigResponse) Status 

func (r GetConnectorConfigResponse) Status() string

Status returns HTTPResponse.Status

func (GetConnectorConfigResponse) StatusCode 

func (r GetConnectorConfigResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetConnectorResponse 

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

func ParseGetConnectorResponse 

func ParseGetConnectorResponse(rsp *http.Response) (*GetConnectorResponse, error)

ParseGetConnectorResponse parses an HTTP response from a GetConnectorWithResponse call

func (GetConnectorResponse) Status 

func (r GetConnectorResponse) Status() string

Status returns HTTPResponse.Status

func (GetConnectorResponse) StatusCode 

func (r GetConnectorResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetConnectorStatusResponse 

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

func ParseGetConnectorStatusResponse 

func ParseGetConnectorStatusResponse(rsp *http.Response) (*GetConnectorStatusResponse, error)

ParseGetConnectorStatusResponse parses an HTTP response from a GetConnectorStatusWithResponse call

func (GetConnectorStatusResponse) Status 

func (r GetConnectorStatusResponse) Status() string

Status returns HTTPResponse.Status

func (GetConnectorStatusResponse) StatusCode 

func (r GetConnectorStatusResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetLoggerResponse 

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

func ParseGetLoggerResponse 

func ParseGetLoggerResponse(rsp *http.Response) (*GetLoggerResponse, error)

ParseGetLoggerResponse parses an HTTP response from a GetLoggerWithResponse call

func (GetLoggerResponse) Status 

func (r GetLoggerResponse) Status() string

Status returns HTTPResponse.Status

func (GetLoggerResponse) StatusCode 

func (r GetLoggerResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetOffsetsResponse 

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

func ParseGetOffsetsResponse 

func ParseGetOffsetsResponse(rsp *http.Response) (*GetOffsetsResponse, error)

ParseGetOffsetsResponse parses an HTTP response from a GetOffsetsWithResponse call

func (GetOffsetsResponse) Status 

func (r GetOffsetsResponse) Status() string

Status returns HTTPResponse.Status

func (GetOffsetsResponse) StatusCode 

func (r GetOffsetsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetTaskConfigsResponse 

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

func ParseGetTaskConfigsResponse 

func ParseGetTaskConfigsResponse(rsp *http.Response) (*GetTaskConfigsResponse, error)

ParseGetTaskConfigsResponse parses an HTTP response from a GetTaskConfigsWithResponse call

func (GetTaskConfigsResponse) Status 

func (r GetTaskConfigsResponse) Status() string

Status returns HTTPResponse.Status

func (GetTaskConfigsResponse) StatusCode 

func (r GetTaskConfigsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetTaskStatusResponse 

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

func ParseGetTaskStatusResponse 

func ParseGetTaskStatusResponse(rsp *http.Response) (*GetTaskStatusResponse, error)

ParseGetTaskStatusResponse parses an HTTP response from a GetTaskStatusWithResponse call

func (GetTaskStatusResponse) Status 

func (r GetTaskStatusResponse) Status() string

Status returns HTTPResponse.Status

func (GetTaskStatusResponse) StatusCode 

func (r GetTaskStatusResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetTasksConfigResponse 

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

func ParseGetTasksConfigResponse 

func ParseGetTasksConfigResponse(rsp *http.Response) (*GetTasksConfigResponse, error)

ParseGetTasksConfigResponse parses an HTTP response from a GetTasksConfigWithResponse call

func (GetTasksConfigResponse) Status 

func (r GetTasksConfigResponse) Status() string

Status returns HTTPResponse.Status

func (GetTasksConfigResponse) StatusCode 

func (r GetTasksConfigResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type HttpRequestDoer 

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

Doer performs HTTP requests.

The standard http.Client implements this interface.

type ListConnectorPluginsParams 

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

ListConnectorPluginsParams defines parameters for ListConnectorPlugins.

type ListConnectorPluginsResponse 

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

func ParseListConnectorPluginsResponse 

func ParseListConnectorPluginsResponse(rsp *http.Response) (*ListConnectorPluginsResponse, error)

ParseListConnectorPluginsResponse parses an HTTP response from a ListConnectorPluginsWithResponse call

func (ListConnectorPluginsResponse) Status 

func (r ListConnectorPluginsResponse) Status() string

Status returns HTTPResponse.Status

func (ListConnectorPluginsResponse) StatusCode 

func (r ListConnectorPluginsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListConnectorsResponse 

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

func ParseListConnectorsResponse 

func ParseListConnectorsResponse(rsp *http.Response) (*ListConnectorsResponse, error)

ParseListConnectorsResponse parses an HTTP response from a ListConnectorsWithResponse call

func (ListConnectorsResponse) Status 

func (r ListConnectorsResponse) Status() string

Status returns HTTPResponse.Status

func (ListConnectorsResponse) StatusCode 

func (r ListConnectorsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListLoggersResponse 

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

func ParseListLoggersResponse 

func ParseListLoggersResponse(rsp *http.Response) (*ListLoggersResponse, error)

ParseListLoggersResponse parses an HTTP response from a ListLoggersWithResponse call

func (ListLoggersResponse) Status 

func (r ListLoggersResponse) Status() string

Status returns HTTPResponse.Status

func (ListLoggersResponse) StatusCode 

func (r ListLoggersResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type PauseConnectorResponse 

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

func ParsePauseConnectorResponse 

func ParsePauseConnectorResponse(rsp *http.Response) (*PauseConnectorResponse, error)

ParsePauseConnectorResponse parses an HTTP response from a PauseConnectorWithResponse call

func (PauseConnectorResponse) Status 

func (r PauseConnectorResponse) Status() string

Status returns HTTPResponse.Status

func (PauseConnectorResponse) StatusCode 

func (r PauseConnectorResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type PluginInfo 

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

PluginInfo defines model for PluginInfo.

type PutConnectorConfigJSONBody 

type PutConnectorConfigJSONBody map[string]string

PutConnectorConfigJSONBody defines parameters for PutConnectorConfig.

type PutConnectorConfigJSONRequestBody 

type PutConnectorConfigJSONRequestBody PutConnectorConfigJSONBody

PutConnectorConfigJSONRequestBody defines body for PutConnectorConfig for application/json ContentType.

type PutConnectorConfigResponse 

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

func ParsePutConnectorConfigResponse 

func ParsePutConnectorConfigResponse(rsp *http.Response) (*PutConnectorConfigResponse, error)

ParsePutConnectorConfigResponse parses an HTTP response from a PutConnectorConfigWithResponse call

func (PutConnectorConfigResponse) Status 

func (r PutConnectorConfigResponse) Status() string

Status returns HTTPResponse.Status

func (PutConnectorConfigResponse) StatusCode 

func (r PutConnectorConfigResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type RequestEditorFn 

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

RequestEditorFn is the function signature for the RequestEditor callback function

type ResetConnectorActiveTopicsResponse 

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

func ParseResetConnectorActiveTopicsResponse 

func ParseResetConnectorActiveTopicsResponse(rsp *http.Response) (*ResetConnectorActiveTopicsResponse, error)

ParseResetConnectorActiveTopicsResponse parses an HTTP response from a ResetConnectorActiveTopicsWithResponse call

func (ResetConnectorActiveTopicsResponse) Status 

func (r ResetConnectorActiveTopicsResponse) Status() string

Status returns HTTPResponse.Status

func (ResetConnectorActiveTopicsResponse) StatusCode 

func (r ResetConnectorActiveTopicsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type RestartConnectorParams 

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"`
}

RestartConnectorParams defines parameters for RestartConnector.

type RestartConnectorResponse 

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

func ParseRestartConnectorResponse 

func ParseRestartConnectorResponse(rsp *http.Response) (*RestartConnectorResponse, error)

ParseRestartConnectorResponse parses an HTTP response from a RestartConnectorWithResponse call

func (RestartConnectorResponse) Status 

func (r RestartConnectorResponse) Status() string

Status returns HTTPResponse.Status

func (RestartConnectorResponse) StatusCode 

func (r RestartConnectorResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type RestartTaskResponse 

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

func ParseRestartTaskResponse 

func ParseRestartTaskResponse(rsp *http.Response) (*RestartTaskResponse, error)

ParseRestartTaskResponse parses an HTTP response from a RestartTaskWithResponse call

func (RestartTaskResponse) Status 

func (r RestartTaskResponse) Status() string

Status returns HTTPResponse.Status

func (RestartTaskResponse) StatusCode 

func (r RestartTaskResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ResumeConnectorResponse 

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

func ParseResumeConnectorResponse 

func ParseResumeConnectorResponse(rsp *http.Response) (*ResumeConnectorResponse, error)

ParseResumeConnectorResponse parses an HTTP response from a ResumeConnectorWithResponse call

func (ResumeConnectorResponse) Status 

func (r ResumeConnectorResponse) Status() string

Status returns HTTPResponse.Status

func (ResumeConnectorResponse) StatusCode 

func (r ResumeConnectorResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ServerInfo 

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

ServerInfo defines model for ServerInfo.

type ServerInfoResponse 

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

func ParseServerInfoResponse 

func ParseServerInfoResponse(rsp *http.Response) (*ServerInfoResponse, error)

ParseServerInfoResponse parses an HTTP response from a ServerInfoWithResponse call

func (ServerInfoResponse) Status 

func (r ServerInfoResponse) Status() string

Status returns HTTPResponse.Status

func (ServerInfoResponse) StatusCode 

func (r ServerInfoResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type SetLevelJSONBody 

type SetLevelJSONBody map[string]string

SetLevelJSONBody defines parameters for SetLevel.

type SetLevelJSONRequestBody 

type SetLevelJSONRequestBody SetLevelJSONBody

SetLevelJSONRequestBody defines body for SetLevel for application/json ContentType.

type SetLevelResponse 

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

func ParseSetLevelResponse 

func ParseSetLevelResponse(rsp *http.Response) (*SetLevelResponse, error)

ParseSetLevelResponse parses an HTTP response from a SetLevelWithResponse call

func (SetLevelResponse) Status 

func (r SetLevelResponse) Status() string

Status returns HTTPResponse.Status

func (SetLevelResponse) StatusCode 

func (r SetLevelResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type StopConnectorResponse 

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

func ParseStopConnectorResponse 

func ParseStopConnectorResponse(rsp *http.Response) (*StopConnectorResponse, error)

ParseStopConnectorResponse parses an HTTP response from a StopConnectorWithResponse call

func (StopConnectorResponse) Status 

func (r StopConnectorResponse) Status() string

Status returns HTTPResponse.Status

func (StopConnectorResponse) StatusCode 

func (r StopConnectorResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type TaskInfo 

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

TaskInfo defines model for TaskInfo.

type TaskState 

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"`
}

TaskState defines model for TaskState.

type ValidateConfigsJSONBody 

type ValidateConfigsJSONBody map[string]string

ValidateConfigsJSONBody defines parameters for ValidateConfigs.

type ValidateConfigsJSONRequestBody 

type ValidateConfigsJSONRequestBody ValidateConfigsJSONBody

ValidateConfigsJSONRequestBody defines body for ValidateConfigs for application/json ContentType.

type ValidateConfigsResponse 

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

func ParseValidateConfigsResponse 

func ParseValidateConfigsResponse(rsp *http.Response) (*ValidateConfigsResponse, error)

ParseValidateConfigsResponse parses an HTTP response from a ValidateConfigsWithResponse call

func (ValidateConfigsResponse) Status 

func (r ValidateConfigsResponse) Status() string

Status returns HTTPResponse.Status

func (ValidateConfigsResponse) StatusCode 

func (r ValidateConfigsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.