openapi

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Dec 13, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

README

Go API client for openapi

This is the documentation of the Apache Kafka Connect REST API.

Overview

This API client was generated by the OpenAPI Generator project. By using the OpenAPI-spec from a remote server, you can easily generate an API client.

  • API version: 3.9.0
  • Package version: 1.0.0
  • Generator version: 7.10.0
  • Build package: org.openapitools.codegen.languages.GoClientCodegen

Installation

Install the following dependencies:

go get github.com/stretchr/testify/assert
go get golang.org/x/net/context

Put the package under your project folder and add the following in import:

import openapi "github.com/darklore/kafka-connect-cli"

To use a proxy, set the environment variable HTTP_PROXY:

os.Setenv("HTTP_PROXY", "http://proxy_name:proxy_port")

Configuration of Server URL

Default configuration comes with Servers field that contains server objects as defined in the OpenAPI specification.

Select Server Configuration

For using other server than the one defined on index 0 set context value openapi.ContextServerIndex of type int.

ctx := context.WithValue(context.Background(), openapi.ContextServerIndex, 1)
Templated Server URL

Templated server URL is formatted using default variables from configuration or from context value openapi.ContextServerVariables of type map[string]string.

ctx := context.WithValue(context.Background(), openapi.ContextServerVariables, map[string]string{
	"basePath": "v2",
})

Note, enum values are always validated and all unused variables are silently ignored.

URLs Configuration per Operation

Each operation can use different server URL defined using OperationServers map in the Configuration. An operation is uniquely identified by "{classname}Service.{nickname}" string. Similar rules for overriding default operation server index and variables applies by using openapi.ContextOperationServerIndices and openapi.ContextOperationServerVariables context maps.

ctx := context.WithValue(context.Background(), openapi.ContextOperationServerIndices, map[string]int{
	"{classname}Service.{nickname}": 2,
})
ctx = context.WithValue(context.Background(), openapi.ContextOperationServerVariables, map[string]map[string]string{
	"{classname}Service.{nickname}": {
		"port": "8443",
	},
})

Documentation for API Endpoints

All URIs are relative to http://localhost

Class Method HTTP request Description
DefaultAPI AlterConnectorOffsets Patch /connectors/{connector}/offsets Alter the offsets for the specified connector
DefaultAPI CreateConnector Post /connectors Create a new connector
DefaultAPI DestroyConnector Delete /connectors/{connector} Delete the specified connector
DefaultAPI GetConnector Get /connectors/{connector} Get the details for the specified connector
DefaultAPI GetConnectorActiveTopics Get /connectors/{connector}/topics Get the list of topics actively used by the specified connector
DefaultAPI GetConnectorConfig Get /connectors/{connector}/config Get the configuration for the specified connector
DefaultAPI GetConnectorConfigDef Get /connector-plugins/{pluginName}/config Get the configuration definition for the specified pluginName
DefaultAPI GetConnectorStatus Get /connectors/{connector}/status Get the status for the specified connector
DefaultAPI GetLogger Get /admin/loggers/{logger} Get the log level for the specified logger
DefaultAPI GetOffsets Get /connectors/{connector}/offsets Get the current offsets for the specified connector
DefaultAPI GetTaskConfigs Get /connectors/{connector}/tasks List all tasks and their configurations for the specified connector
DefaultAPI GetTaskStatus Get /connectors/{connector}/tasks/{task}/status Get the state of the specified task for the specified connector
DefaultAPI GetTasksConfig Get /connectors/{connector}/tasks-config Get the configuration of all tasks for the specified connector
DefaultAPI HealthCheck Get /health Health check endpoint to verify worker readiness and liveness
DefaultAPI ListConnectorPlugins Get /connector-plugins List all connector plugins installed
DefaultAPI ListConnectors Get /connectors List all active connectors
DefaultAPI ListLoggers Get /admin/loggers List the current loggers that have their levels explicitly set and their log levels
DefaultAPI PatchConnectorConfig Patch /connectors/{connector}/config
DefaultAPI PauseConnector Put /connectors/{connector}/pause Pause the specified connector
DefaultAPI PutConnectorConfig Put /connectors/{connector}/config Create or reconfigure the specified connector
DefaultAPI ResetConnectorActiveTopics Put /connectors/{connector}/topics/reset Reset the list of topics actively used by the specified connector
DefaultAPI ResetConnectorOffsets Delete /connectors/{connector}/offsets Reset the offsets for the specified connector
DefaultAPI RestartConnector Post /connectors/{connector}/restart Restart the specified connector
DefaultAPI RestartTask Post /connectors/{connector}/tasks/{task}/restart Restart the specified task for the specified connector
DefaultAPI ResumeConnector Put /connectors/{connector}/resume Resume the specified connector
DefaultAPI ServerInfo Get / Get details about this Connect worker and the ID of the Kafka cluster it is connected to
DefaultAPI SetLevel Put /admin/loggers/{logger} Set the log level for the specified logger
DefaultAPI StopConnector Put /connectors/{connector}/stop Stop the specified connector
DefaultAPI ValidateConfigs Put /connector-plugins/{pluginName}/config/validate Validate the provided configuration against the configuration definition for the specified pluginName

Documentation For Models

Documentation For Authorization

Endpoints do not require authorization.

Documentation for Utility Methods

Due to the fact that model structure members are all pointers, this package contains a number of utility functions to easily obtain pointers to values of basic types. Each of these functions takes a value of the given basic type and returns a pointer to it:

  • PtrBool
  • PtrInt
  • PtrInt32
  • PtrInt64
  • PtrFloat
  • PtrFloat32
  • PtrFloat64
  • PtrString
  • PtrTime

Author

dev@kafka.apache.org

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	JsonCheck = regexp.MustCompile(`(?i:(?:application|text)/(?:[^;]+\+)?json)`)
	XmlCheck  = regexp.MustCompile(`(?i:(?:application|text)/(?:[^;]+\+)?xml)`)
)
View Source 
var (
	// ContextServerIndex uses a server configuration from the index.
	ContextServerIndex = contextKey("serverIndex")

	// ContextOperationServerIndices uses a server configuration from the index mapping.
	ContextOperationServerIndices = contextKey("serverOperationIndices")

	// ContextServerVariables overrides a server configuration variables.
	ContextServerVariables = contextKey("serverVariables")

	// ContextOperationServerVariables overrides a server configuration variables using operation specific values.
	ContextOperationServerVariables = contextKey("serverOperationVariables")
)

Functions

func CacheExpires 

func CacheExpires(r *http.Response) time.Time

CacheExpires helper function to determine remaining time before repeating a request.

func IsNil 

func IsNil(i interface{}) bool

IsNil checks if an input is nil

func PtrBool 

func PtrBool(v bool) *bool

PtrBool is a helper routine that returns a pointer to given boolean value.

func PtrFloat32 

func PtrFloat32(v float32) *float32

PtrFloat32 is a helper routine that returns a pointer to given float value.

func PtrFloat64 

func PtrFloat64(v float64) *float64

PtrFloat64 is a helper routine that returns a pointer to given float value.

func PtrInt 

func PtrInt(v int) *int

PtrInt is a helper routine that returns a pointer to given integer value.

func PtrInt32 

func PtrInt32(v int32) *int32

PtrInt32 is a helper routine that returns a pointer to given integer value.

func PtrInt64 

func PtrInt64(v int64) *int64

PtrInt64 is a helper routine that returns a pointer to given integer value.

func PtrString 

func PtrString(v string) *string

PtrString is a helper routine that returns a pointer to given string value.

func PtrTime 

func PtrTime(v time.Time) *time.Time

PtrTime is helper routine that returns a pointer to given Time value.

Types

type APIClient 

type APIClient struct {
	DefaultAPI *DefaultAPIService
	// contains filtered or unexported fields
}

APIClient manages communication with the Kafka Connect REST API API v3.9.0 In most cases there should be only one, shared, APIClient.

func NewAPIClient 

func NewAPIClient(cfg *Configuration) *APIClient

NewAPIClient creates a new API client. Requires a userAgent string describing your application. optionally a custom http.Client to allow for advanced features such as caching.

func (*APIClient) GetConfig 

func (c *APIClient) GetConfig() *Configuration

Allow modification of underlying config for alternate implementations and testing Caution: modifying the configuration while live can cause data races and potentially unwanted behavior

type APIKey 

type APIKey struct {
	Key    string
	Prefix string
}

APIKey provides API key based authentication to a request passed via context using ContextAPIKey

type APIResponse 

type APIResponse struct {
	*http.Response `json:"-"`
	Message        string `json:"message,omitempty"`
	// Operation is the name of the OpenAPI operation.
	Operation string `json:"operation,omitempty"`
	// RequestURL is the request URL. This value is always available, even if the
	// embedded *http.Response is nil.
	RequestURL string `json:"url,omitempty"`
	// Method is the HTTP method used for the request.  This value is always
	// available, even if the embedded *http.Response is nil.
	Method string `json:"method,omitempty"`
	// Payload holds the contents of the response body (which may be nil or empty).
	// This is provided here as the raw response.Body() reader will have already
	// been drained.
	Payload []byte `json:"-"`
}

APIResponse stores the API response returned by the server.

func NewAPIResponse 

func NewAPIResponse(r *http.Response) *APIResponse

NewAPIResponse returns a new APIResponse object.

func NewAPIResponseWithError 

func NewAPIResponseWithError(errorMessage string) *APIResponse

NewAPIResponseWithError returns a new APIResponse object with the provided error message.

type ApiAlterConnectorOffsetsRequest 

type ApiAlterConnectorOffsetsRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiAlterConnectorOffsetsRequest) ConnectorOffsets 

func (r ApiAlterConnectorOffsetsRequest) ConnectorOffsets(connectorOffsets ConnectorOffsets) ApiAlterConnectorOffsetsRequest

func (ApiAlterConnectorOffsetsRequest) Execute 

func (r ApiAlterConnectorOffsetsRequest) Execute() (*http.Response, error)

type ApiCreateConnectorRequest 

type ApiCreateConnectorRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiCreateConnectorRequest) CreateConnectorRequest 

func (r ApiCreateConnectorRequest) CreateConnectorRequest(createConnectorRequest CreateConnectorRequest) ApiCreateConnectorRequest

func (ApiCreateConnectorRequest) Execute 

func (r ApiCreateConnectorRequest) Execute() (*ConnectorInfo, *http.Response, error)

type ApiDestroyConnectorRequest 

type ApiDestroyConnectorRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiDestroyConnectorRequest) Execute 

func (r ApiDestroyConnectorRequest) Execute() (*http.Response, error)

type ApiGetConnectorActiveTopicsRequest 

type ApiGetConnectorActiveTopicsRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiGetConnectorActiveTopicsRequest) Execute 

func (r ApiGetConnectorActiveTopicsRequest) Execute() (*map[string]ConnectorActiveTopicsValue, *http.Response, error)

type ApiGetConnectorConfigDefRequest 

type ApiGetConnectorConfigDefRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiGetConnectorConfigDefRequest) Execute 

func (r ApiGetConnectorConfigDefRequest) Execute() ([]ConfigKeyInfo, *http.Response, error)

type ApiGetConnectorConfigRequest 

type ApiGetConnectorConfigRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiGetConnectorConfigRequest) Execute 

func (r ApiGetConnectorConfigRequest) Execute() (map[string]string, *http.Response, error)

type ApiGetConnectorRequest 

type ApiGetConnectorRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiGetConnectorRequest) Execute 

func (r ApiGetConnectorRequest) Execute() (*ConnectorInfo, *http.Response, error)

type ApiGetConnectorStatusRequest 

type ApiGetConnectorStatusRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiGetConnectorStatusRequest) Execute 

func (r ApiGetConnectorStatusRequest) Execute() (*ConnectorStateInfo, *http.Response, error)

type ApiGetLoggerRequest 

type ApiGetLoggerRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiGetLoggerRequest) Execute 

func (r ApiGetLoggerRequest) Execute() (*http.Response, error)

type ApiGetOffsetsRequest 

type ApiGetOffsetsRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiGetOffsetsRequest) Execute 

func (r ApiGetOffsetsRequest) Execute() (*ConnectorOffsets, *http.Response, error)

type ApiGetTaskConfigsRequest 

type ApiGetTaskConfigsRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiGetTaskConfigsRequest) Execute 

func (r ApiGetTaskConfigsRequest) Execute() ([]TaskInfo, *http.Response, error)

type ApiGetTaskStatusRequest 

type ApiGetTaskStatusRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiGetTaskStatusRequest) Execute 

func (r ApiGetTaskStatusRequest) Execute() (*TaskState, *http.Response, error)

type ApiGetTasksConfigRequest 

type ApiGetTasksConfigRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiGetTasksConfigRequest) Execute 

func (r ApiGetTasksConfigRequest) Execute() (*map[string]map[string]string, *http.Response, error)

type ApiHealthCheckRequest 

type ApiHealthCheckRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiHealthCheckRequest) Execute 

func (r ApiHealthCheckRequest) Execute() (*http.Response, error)

type ApiListConnectorPluginsRequest 

type ApiListConnectorPluginsRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiListConnectorPluginsRequest) ConnectorsOnly 

func (r ApiListConnectorPluginsRequest) ConnectorsOnly(connectorsOnly bool) ApiListConnectorPluginsRequest

Whether to list only connectors instead of all plugins

func (ApiListConnectorPluginsRequest) Execute 

func (r ApiListConnectorPluginsRequest) Execute() ([]PluginInfo, *http.Response, error)

type ApiListConnectorsRequest 

type ApiListConnectorsRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiListConnectorsRequest) Execute 

func (r ApiListConnectorsRequest) Execute() ([]string, *http.Response, error)

type ApiListLoggersRequest 

type ApiListLoggersRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiListLoggersRequest) Execute 

func (r ApiListLoggersRequest) Execute() (*http.Response, error)

type ApiPatchConnectorConfigRequest 

type ApiPatchConnectorConfigRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiPatchConnectorConfigRequest) Execute 

func (r ApiPatchConnectorConfigRequest) Execute() (*http.Response, error)

func (ApiPatchConnectorConfigRequest) RequestBody 

func (r ApiPatchConnectorConfigRequest) RequestBody(requestBody map[string]string) ApiPatchConnectorConfigRequest

type ApiPauseConnectorRequest 

type ApiPauseConnectorRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiPauseConnectorRequest) Execute 

func (r ApiPauseConnectorRequest) Execute() (*http.Response, error)

type ApiPutConnectorConfigRequest 

type ApiPutConnectorConfigRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiPutConnectorConfigRequest) Body 

func (r ApiPutConnectorConfigRequest) Body(body map[string]string) ApiPutConnectorConfigRequest

func (ApiPutConnectorConfigRequest) Execute 

func (r ApiPutConnectorConfigRequest) Execute() (*ConnectorInfo, *http.Response, error)

type ApiResetConnectorActiveTopicsRequest 

type ApiResetConnectorActiveTopicsRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiResetConnectorActiveTopicsRequest) Execute 

func (r ApiResetConnectorActiveTopicsRequest) Execute() (*http.Response, error)

type ApiResetConnectorOffsetsRequest 

type ApiResetConnectorOffsetsRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiResetConnectorOffsetsRequest) Execute 

func (r ApiResetConnectorOffsetsRequest) Execute() (*http.Response, error)

type ApiRestartConnectorRequest 

type ApiRestartConnectorRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiRestartConnectorRequest) Execute 

func (r ApiRestartConnectorRequest) Execute() (*http.Response, error)

func (ApiRestartConnectorRequest) IncludeTasks 

func (r ApiRestartConnectorRequest) IncludeTasks(includeTasks bool) ApiRestartConnectorRequest

Whether to also restart tasks

func (ApiRestartConnectorRequest) OnlyFailed 

func (r ApiRestartConnectorRequest) OnlyFailed(onlyFailed bool) ApiRestartConnectorRequest

Whether to only restart failed tasks/connectors

type ApiRestartTaskRequest 

type ApiRestartTaskRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiRestartTaskRequest) Execute 

func (r ApiRestartTaskRequest) Execute() (*http.Response, error)

type ApiResumeConnectorRequest 

type ApiResumeConnectorRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiResumeConnectorRequest) Execute 

func (r ApiResumeConnectorRequest) Execute() (*http.Response, error)

type ApiServerInfoRequest 

type ApiServerInfoRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiServerInfoRequest) Execute 

func (r ApiServerInfoRequest) Execute() (*ServerInfo, *http.Response, error)

type ApiSetLevelRequest 

type ApiSetLevelRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiSetLevelRequest) Execute 

func (r ApiSetLevelRequest) Execute() (*http.Response, error)

func (ApiSetLevelRequest) RequestBody 

func (r ApiSetLevelRequest) RequestBody(requestBody map[string]string) ApiSetLevelRequest

func (ApiSetLevelRequest) Scope 

func (r ApiSetLevelRequest) Scope(scope string) ApiSetLevelRequest

The scope for the logging modification (single-worker, cluster-wide, etc.)

type ApiStopConnectorRequest 

type ApiStopConnectorRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiStopConnectorRequest) Execute 

func (r ApiStopConnectorRequest) Execute() (*http.Response, error)

type ApiValidateConfigsRequest 

type ApiValidateConfigsRequest struct {
	ApiService *DefaultAPIService
	// contains filtered or unexported fields
}

func (ApiValidateConfigsRequest) Execute 

func (r ApiValidateConfigsRequest) Execute() (*ConfigInfos, *http.Response, error)

func (ApiValidateConfigsRequest) RequestBody 

func (r ApiValidateConfigsRequest) RequestBody(requestBody map[string]string) ApiValidateConfigsRequest

type BasicAuth 

type BasicAuth struct {
	UserName string `json:"userName,omitempty"`
	Password string `json:"password,omitempty"`
}

BasicAuth provides basic http authentication to a request passed via context using ContextBasicAuth

type ConfigInfo 

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

ConfigInfo struct for ConfigInfo

func NewConfigInfo 

func NewConfigInfo() *ConfigInfo

NewConfigInfo instantiates a new ConfigInfo object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewConfigInfoWithDefaults 

func NewConfigInfoWithDefaults() *ConfigInfo

NewConfigInfoWithDefaults instantiates a new ConfigInfo object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*ConfigInfo) GetDefinition 

func (o *ConfigInfo) GetDefinition() ConfigKeyInfo

GetDefinition returns the Definition field value if set, zero value otherwise.

func (*ConfigInfo) GetDefinitionOk 

func (o *ConfigInfo) GetDefinitionOk() (*ConfigKeyInfo, bool)

GetDefinitionOk returns a tuple with the Definition field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigInfo) GetValue 

func (o *ConfigInfo) GetValue() ConfigValueInfo

GetValue returns the Value field value if set, zero value otherwise.

func (*ConfigInfo) GetValueOk 

func (o *ConfigInfo) GetValueOk() (*ConfigValueInfo, bool)

GetValueOk returns a tuple with the Value field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigInfo) HasDefinition 

func (o *ConfigInfo) HasDefinition() bool

HasDefinition returns a boolean if a field has been set.

func (*ConfigInfo) HasValue 

func (o *ConfigInfo) HasValue() bool

HasValue returns a boolean if a field has been set.

func (ConfigInfo) MarshalJSON 

func (o ConfigInfo) MarshalJSON() ([]byte, error)

func (*ConfigInfo) SetDefinition 

func (o *ConfigInfo) SetDefinition(v ConfigKeyInfo)

SetDefinition gets a reference to the given ConfigKeyInfo and assigns it to the Definition field.

func (*ConfigInfo) SetValue 

func (o *ConfigInfo) SetValue(v ConfigValueInfo)

SetValue gets a reference to the given ConfigValueInfo and assigns it to the Value field.

func (ConfigInfo) ToMap 

func (o ConfigInfo) ToMap() (map[string]interface{}, error)

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 struct for ConfigInfos

func NewConfigInfos 

func NewConfigInfos() *ConfigInfos

NewConfigInfos instantiates a new ConfigInfos object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewConfigInfosWithDefaults 

func NewConfigInfosWithDefaults() *ConfigInfos

NewConfigInfosWithDefaults instantiates a new ConfigInfos object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*ConfigInfos) GetConfigs 

func (o *ConfigInfos) GetConfigs() []ConfigInfo

GetConfigs returns the Configs field value if set, zero value otherwise.

func (*ConfigInfos) GetConfigsOk 

func (o *ConfigInfos) GetConfigsOk() ([]ConfigInfo, bool)

GetConfigsOk returns a tuple with the Configs field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigInfos) GetErrorCount 

func (o *ConfigInfos) GetErrorCount() int32

GetErrorCount returns the ErrorCount field value if set, zero value otherwise.

func (*ConfigInfos) GetErrorCountOk 

func (o *ConfigInfos) GetErrorCountOk() (*int32, bool)

GetErrorCountOk returns a tuple with the ErrorCount field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigInfos) GetGroups 

func (o *ConfigInfos) GetGroups() []string

GetGroups returns the Groups field value if set, zero value otherwise.

func (*ConfigInfos) GetGroupsOk 

func (o *ConfigInfos) GetGroupsOk() ([]string, bool)

GetGroupsOk returns a tuple with the Groups field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigInfos) GetName 

func (o *ConfigInfos) GetName() string

GetName returns the Name field value if set, zero value otherwise.

func (*ConfigInfos) GetNameOk 

func (o *ConfigInfos) GetNameOk() (*string, bool)

GetNameOk returns a tuple with the Name field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigInfos) HasConfigs 

func (o *ConfigInfos) HasConfigs() bool

HasConfigs returns a boolean if a field has been set.

func (*ConfigInfos) HasErrorCount 

func (o *ConfigInfos) HasErrorCount() bool

HasErrorCount returns a boolean if a field has been set.

func (*ConfigInfos) HasGroups 

func (o *ConfigInfos) HasGroups() bool

HasGroups returns a boolean if a field has been set.

func (*ConfigInfos) HasName 

func (o *ConfigInfos) HasName() bool

HasName returns a boolean if a field has been set.

func (ConfigInfos) MarshalJSON 

func (o ConfigInfos) MarshalJSON() ([]byte, error)

func (*ConfigInfos) SetConfigs 

func (o *ConfigInfos) SetConfigs(v []ConfigInfo)

SetConfigs gets a reference to the given []ConfigInfo and assigns it to the Configs field.

func (*ConfigInfos) SetErrorCount 

func (o *ConfigInfos) SetErrorCount(v int32)

SetErrorCount gets a reference to the given int32 and assigns it to the ErrorCount field.

func (*ConfigInfos) SetGroups 

func (o *ConfigInfos) SetGroups(v []string)

SetGroups gets a reference to the given []string and assigns it to the Groups field.

func (*ConfigInfos) SetName 

func (o *ConfigInfos) SetName(v string)

SetName gets a reference to the given string and assigns it to the Name field.

func (ConfigInfos) ToMap 

func (o ConfigInfos) ToMap() (map[string]interface{}, error)

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 struct for ConfigKeyInfo

func NewConfigKeyInfo 

func NewConfigKeyInfo() *ConfigKeyInfo

NewConfigKeyInfo instantiates a new ConfigKeyInfo object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewConfigKeyInfoWithDefaults 

func NewConfigKeyInfoWithDefaults() *ConfigKeyInfo

NewConfigKeyInfoWithDefaults instantiates a new ConfigKeyInfo object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*ConfigKeyInfo) GetDefaultValue 

func (o *ConfigKeyInfo) GetDefaultValue() string

GetDefaultValue returns the DefaultValue field value if set, zero value otherwise.

func (*ConfigKeyInfo) GetDefaultValueOk 

func (o *ConfigKeyInfo) GetDefaultValueOk() (*string, bool)

GetDefaultValueOk returns a tuple with the DefaultValue field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigKeyInfo) GetDependents 

func (o *ConfigKeyInfo) GetDependents() []string

GetDependents returns the Dependents field value if set, zero value otherwise.

func (*ConfigKeyInfo) GetDependentsOk 

func (o *ConfigKeyInfo) GetDependentsOk() ([]string, bool)

GetDependentsOk returns a tuple with the Dependents field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigKeyInfo) GetDisplayName 

func (o *ConfigKeyInfo) GetDisplayName() string

GetDisplayName returns the DisplayName field value if set, zero value otherwise.

func (*ConfigKeyInfo) GetDisplayNameOk 

func (o *ConfigKeyInfo) GetDisplayNameOk() (*string, bool)

GetDisplayNameOk returns a tuple with the DisplayName field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigKeyInfo) GetDocumentation 

func (o *ConfigKeyInfo) GetDocumentation() string

GetDocumentation returns the Documentation field value if set, zero value otherwise.

func (*ConfigKeyInfo) GetDocumentationOk 

func (o *ConfigKeyInfo) GetDocumentationOk() (*string, bool)

GetDocumentationOk returns a tuple with the Documentation field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigKeyInfo) GetGroup 

func (o *ConfigKeyInfo) GetGroup() string

GetGroup returns the Group field value if set, zero value otherwise.

func (*ConfigKeyInfo) GetGroupOk 

func (o *ConfigKeyInfo) GetGroupOk() (*string, bool)

GetGroupOk returns a tuple with the Group field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigKeyInfo) GetImportance 

func (o *ConfigKeyInfo) GetImportance() string

GetImportance returns the Importance field value if set, zero value otherwise.

func (*ConfigKeyInfo) GetImportanceOk 

func (o *ConfigKeyInfo) GetImportanceOk() (*string, bool)

GetImportanceOk returns a tuple with the Importance field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigKeyInfo) GetName 

func (o *ConfigKeyInfo) GetName() string

GetName returns the Name field value if set, zero value otherwise.

func (*ConfigKeyInfo) GetNameOk 

func (o *ConfigKeyInfo) GetNameOk() (*string, bool)

GetNameOk returns a tuple with the Name field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigKeyInfo) GetOrder 

func (o *ConfigKeyInfo) GetOrder() int32

GetOrder returns the Order field value if set, zero value otherwise.

func (*ConfigKeyInfo) GetOrderInGroup 

func (o *ConfigKeyInfo) GetOrderInGroup() int32

GetOrderInGroup returns the OrderInGroup field value if set, zero value otherwise.

func (*ConfigKeyInfo) GetOrderInGroupOk 

func (o *ConfigKeyInfo) GetOrderInGroupOk() (*int32, bool)

GetOrderInGroupOk returns a tuple with the OrderInGroup field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigKeyInfo) GetOrderOk 

func (o *ConfigKeyInfo) GetOrderOk() (*int32, bool)

GetOrderOk returns a tuple with the Order field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigKeyInfo) GetRequired 

func (o *ConfigKeyInfo) GetRequired() bool

GetRequired returns the Required field value if set, zero value otherwise.

func (*ConfigKeyInfo) GetRequiredOk 

func (o *ConfigKeyInfo) GetRequiredOk() (*bool, bool)

GetRequiredOk returns a tuple with the Required field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigKeyInfo) GetType 

func (o *ConfigKeyInfo) GetType() string

GetType returns the Type field value if set, zero value otherwise.

func (*ConfigKeyInfo) GetTypeOk 

func (o *ConfigKeyInfo) GetTypeOk() (*string, bool)

GetTypeOk returns a tuple with the Type field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigKeyInfo) GetWidth 

func (o *ConfigKeyInfo) GetWidth() string

GetWidth returns the Width field value if set, zero value otherwise.

func (*ConfigKeyInfo) GetWidthOk 

func (o *ConfigKeyInfo) GetWidthOk() (*string, bool)

GetWidthOk returns a tuple with the Width field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigKeyInfo) HasDefaultValue 

func (o *ConfigKeyInfo) HasDefaultValue() bool

HasDefaultValue returns a boolean if a field has been set.

func (*ConfigKeyInfo) HasDependents 

func (o *ConfigKeyInfo) HasDependents() bool

HasDependents returns a boolean if a field has been set.

func (*ConfigKeyInfo) HasDisplayName 

func (o *ConfigKeyInfo) HasDisplayName() bool

HasDisplayName returns a boolean if a field has been set.

func (*ConfigKeyInfo) HasDocumentation 

func (o *ConfigKeyInfo) HasDocumentation() bool

HasDocumentation returns a boolean if a field has been set.

func (*ConfigKeyInfo) HasGroup 

func (o *ConfigKeyInfo) HasGroup() bool

HasGroup returns a boolean if a field has been set.

func (*ConfigKeyInfo) HasImportance 

func (o *ConfigKeyInfo) HasImportance() bool

HasImportance returns a boolean if a field has been set.

func (*ConfigKeyInfo) HasName 

func (o *ConfigKeyInfo) HasName() bool

HasName returns a boolean if a field has been set.

func (*ConfigKeyInfo) HasOrder 

func (o *ConfigKeyInfo) HasOrder() bool

HasOrder returns a boolean if a field has been set.

func (*ConfigKeyInfo) HasOrderInGroup 

func (o *ConfigKeyInfo) HasOrderInGroup() bool

HasOrderInGroup returns a boolean if a field has been set.

func (*ConfigKeyInfo) HasRequired 

func (o *ConfigKeyInfo) HasRequired() bool

HasRequired returns a boolean if a field has been set.

func (*ConfigKeyInfo) HasType 

func (o *ConfigKeyInfo) HasType() bool

HasType returns a boolean if a field has been set.

func (*ConfigKeyInfo) HasWidth 

func (o *ConfigKeyInfo) HasWidth() bool

HasWidth returns a boolean if a field has been set.

func (ConfigKeyInfo) MarshalJSON 

func (o ConfigKeyInfo) MarshalJSON() ([]byte, error)

func (*ConfigKeyInfo) SetDefaultValue 

func (o *ConfigKeyInfo) SetDefaultValue(v string)

SetDefaultValue gets a reference to the given string and assigns it to the DefaultValue field.

func (*ConfigKeyInfo) SetDependents 

func (o *ConfigKeyInfo) SetDependents(v []string)

SetDependents gets a reference to the given []string and assigns it to the Dependents field.

func (*ConfigKeyInfo) SetDisplayName 

func (o *ConfigKeyInfo) SetDisplayName(v string)

SetDisplayName gets a reference to the given string and assigns it to the DisplayName field.

func (*ConfigKeyInfo) SetDocumentation 

func (o *ConfigKeyInfo) SetDocumentation(v string)

SetDocumentation gets a reference to the given string and assigns it to the Documentation field.

func (*ConfigKeyInfo) SetGroup 

func (o *ConfigKeyInfo) SetGroup(v string)

SetGroup gets a reference to the given string and assigns it to the Group field.

func (*ConfigKeyInfo) SetImportance 

func (o *ConfigKeyInfo) SetImportance(v string)

SetImportance gets a reference to the given string and assigns it to the Importance field.

func (*ConfigKeyInfo) SetName 

func (o *ConfigKeyInfo) SetName(v string)

SetName gets a reference to the given string and assigns it to the Name field.

func (*ConfigKeyInfo) SetOrder 

func (o *ConfigKeyInfo) SetOrder(v int32)

SetOrder gets a reference to the given int32 and assigns it to the Order field.

func (*ConfigKeyInfo) SetOrderInGroup 

func (o *ConfigKeyInfo) SetOrderInGroup(v int32)

SetOrderInGroup gets a reference to the given int32 and assigns it to the OrderInGroup field.

func (*ConfigKeyInfo) SetRequired 

func (o *ConfigKeyInfo) SetRequired(v bool)

SetRequired gets a reference to the given bool and assigns it to the Required field.

func (*ConfigKeyInfo) SetType 

func (o *ConfigKeyInfo) SetType(v string)

SetType gets a reference to the given string and assigns it to the Type field.

func (*ConfigKeyInfo) SetWidth 

func (o *ConfigKeyInfo) SetWidth(v string)

SetWidth gets a reference to the given string and assigns it to the Width field.

func (ConfigKeyInfo) ToMap 

func (o ConfigKeyInfo) ToMap() (map[string]interface{}, error)

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 struct for ConfigValueInfo

func NewConfigValueInfo 

func NewConfigValueInfo() *ConfigValueInfo

NewConfigValueInfo instantiates a new ConfigValueInfo object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewConfigValueInfoWithDefaults 

func NewConfigValueInfoWithDefaults() *ConfigValueInfo

NewConfigValueInfoWithDefaults instantiates a new ConfigValueInfo object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*ConfigValueInfo) GetErrors 

func (o *ConfigValueInfo) GetErrors() []string

GetErrors returns the Errors field value if set, zero value otherwise.

func (*ConfigValueInfo) GetErrorsOk 

func (o *ConfigValueInfo) GetErrorsOk() ([]string, bool)

GetErrorsOk returns a tuple with the Errors field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigValueInfo) GetName 

func (o *ConfigValueInfo) GetName() string

GetName returns the Name field value if set, zero value otherwise.

func (*ConfigValueInfo) GetNameOk 

func (o *ConfigValueInfo) GetNameOk() (*string, bool)

GetNameOk returns a tuple with the Name field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigValueInfo) GetRecommendedValues 

func (o *ConfigValueInfo) GetRecommendedValues() []string

GetRecommendedValues returns the RecommendedValues field value if set, zero value otherwise.

func (*ConfigValueInfo) GetRecommendedValuesOk 

func (o *ConfigValueInfo) GetRecommendedValuesOk() ([]string, bool)

GetRecommendedValuesOk returns a tuple with the RecommendedValues field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigValueInfo) GetValue 

func (o *ConfigValueInfo) GetValue() string

GetValue returns the Value field value if set, zero value otherwise.

func (*ConfigValueInfo) GetValueOk 

func (o *ConfigValueInfo) GetValueOk() (*string, bool)

GetValueOk returns a tuple with the Value field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigValueInfo) GetVisible 

func (o *ConfigValueInfo) GetVisible() bool

GetVisible returns the Visible field value if set, zero value otherwise.

func (*ConfigValueInfo) GetVisibleOk 

func (o *ConfigValueInfo) GetVisibleOk() (*bool, bool)

GetVisibleOk returns a tuple with the Visible field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigValueInfo) HasErrors 

func (o *ConfigValueInfo) HasErrors() bool

HasErrors returns a boolean if a field has been set.

func (*ConfigValueInfo) HasName 

func (o *ConfigValueInfo) HasName() bool

HasName returns a boolean if a field has been set.

func (*ConfigValueInfo) HasRecommendedValues 

func (o *ConfigValueInfo) HasRecommendedValues() bool

HasRecommendedValues returns a boolean if a field has been set.

func (*ConfigValueInfo) HasValue 

func (o *ConfigValueInfo) HasValue() bool

HasValue returns a boolean if a field has been set.

func (*ConfigValueInfo) HasVisible 

func (o *ConfigValueInfo) HasVisible() bool

HasVisible returns a boolean if a field has been set.

func (ConfigValueInfo) MarshalJSON 

func (o ConfigValueInfo) MarshalJSON() ([]byte, error)

func (*ConfigValueInfo) SetErrors 

func (o *ConfigValueInfo) SetErrors(v []string)

SetErrors gets a reference to the given []string and assigns it to the Errors field.

func (*ConfigValueInfo) SetName 

func (o *ConfigValueInfo) SetName(v string)

SetName gets a reference to the given string and assigns it to the Name field.

func (*ConfigValueInfo) SetRecommendedValues 

func (o *ConfigValueInfo) SetRecommendedValues(v []string)

SetRecommendedValues gets a reference to the given []string and assigns it to the RecommendedValues field.

func (*ConfigValueInfo) SetValue 

func (o *ConfigValueInfo) SetValue(v string)

SetValue gets a reference to the given string and assigns it to the Value field.

func (*ConfigValueInfo) SetVisible 

func (o *ConfigValueInfo) SetVisible(v bool)

SetVisible gets a reference to the given bool and assigns it to the Visible field.

func (ConfigValueInfo) ToMap 

func (o ConfigValueInfo) ToMap() (map[string]interface{}, error)

type Configuration 

type Configuration struct {
	Host             string            `json:"host,omitempty"`
	Scheme           string            `json:"scheme,omitempty"`
	DefaultHeader    map[string]string `json:"defaultHeader,omitempty"`
	UserAgent        string            `json:"userAgent,omitempty"`
	Debug            bool              `json:"debug,omitempty"`
	Servers          ServerConfigurations
	OperationServers map[string]ServerConfigurations
	HTTPClient       *http.Client
}

Configuration stores the configuration of the API client

func NewConfiguration 

func NewConfiguration() *Configuration

NewConfiguration returns a new Configuration object

func (*Configuration) AddDefaultHeader 

func (c *Configuration) AddDefaultHeader(key string, value string)

AddDefaultHeader adds a new HTTP header to the default header in the request

func (*Configuration) ServerURL 

func (c *Configuration) ServerURL(index int, variables map[string]string) (string, error)

ServerURL returns URL based on server settings

func (*Configuration) ServerURLWithContext 

func (c *Configuration) ServerURLWithContext(ctx context.Context, endpoint string) (string, error)

ServerURLWithContext returns a new server URL given an endpoint

type ConnectorActiveTopicsValue 

type ConnectorActiveTopicsValue struct {
	Topics []string `json:"topics,omitempty"`
}

ConnectorActiveTopicsValue struct for ConnectorActiveTopicsValue

func NewConnectorActiveTopicsValue 

func NewConnectorActiveTopicsValue() *ConnectorActiveTopicsValue

NewConnectorActiveTopicsValue instantiates a new ConnectorActiveTopicsValue object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewConnectorActiveTopicsValueWithDefaults 

func NewConnectorActiveTopicsValueWithDefaults() *ConnectorActiveTopicsValue

NewConnectorActiveTopicsValueWithDefaults instantiates a new ConnectorActiveTopicsValue object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*ConnectorActiveTopicsValue) GetTopics 

func (o *ConnectorActiveTopicsValue) GetTopics() []string

GetTopics returns the Topics field value if set, zero value otherwise.

func (*ConnectorActiveTopicsValue) GetTopicsOk 

func (o *ConnectorActiveTopicsValue) GetTopicsOk() ([]string, bool)

GetTopicsOk returns a tuple with the Topics field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorActiveTopicsValue) HasTopics 

func (o *ConnectorActiveTopicsValue) HasTopics() bool

HasTopics returns a boolean if a field has been set.

func (ConnectorActiveTopicsValue) MarshalJSON 

func (o ConnectorActiveTopicsValue) MarshalJSON() ([]byte, error)

func (*ConnectorActiveTopicsValue) SetTopics 

func (o *ConnectorActiveTopicsValue) SetTopics(v []string)

SetTopics gets a reference to the given []string and assigns it to the Topics field.

func (ConnectorActiveTopicsValue) ToMap 

func (o ConnectorActiveTopicsValue) ToMap() (map[string]interface{}, error)

type ConnectorInfo 

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

ConnectorInfo struct for ConnectorInfo

func NewConnectorInfo 

func NewConnectorInfo() *ConnectorInfo

NewConnectorInfo instantiates a new ConnectorInfo object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewConnectorInfoWithDefaults 

func NewConnectorInfoWithDefaults() *ConnectorInfo

NewConnectorInfoWithDefaults instantiates a new ConnectorInfo object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*ConnectorInfo) GetConfig 

func (o *ConnectorInfo) GetConfig() map[string]string

GetConfig returns the Config field value if set, zero value otherwise.

func (*ConnectorInfo) GetConfigOk 

func (o *ConnectorInfo) GetConfigOk() (*map[string]string, bool)

GetConfigOk returns a tuple with the Config field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorInfo) GetName 

func (o *ConnectorInfo) GetName() string

GetName returns the Name field value if set, zero value otherwise.

func (*ConnectorInfo) GetNameOk 

func (o *ConnectorInfo) GetNameOk() (*string, bool)

GetNameOk returns a tuple with the Name field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorInfo) GetTasks 

func (o *ConnectorInfo) GetTasks() []ConnectorTaskId

GetTasks returns the Tasks field value if set, zero value otherwise.

func (*ConnectorInfo) GetTasksOk 

func (o *ConnectorInfo) GetTasksOk() ([]ConnectorTaskId, bool)

GetTasksOk returns a tuple with the Tasks field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorInfo) GetType 

func (o *ConnectorInfo) GetType() string

GetType returns the Type field value if set, zero value otherwise.

func (*ConnectorInfo) GetTypeOk 

func (o *ConnectorInfo) GetTypeOk() (*string, bool)

GetTypeOk returns a tuple with the Type field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorInfo) HasConfig 

func (o *ConnectorInfo) HasConfig() bool

HasConfig returns a boolean if a field has been set.

func (*ConnectorInfo) HasName 

func (o *ConnectorInfo) HasName() bool

HasName returns a boolean if a field has been set.

func (*ConnectorInfo) HasTasks 

func (o *ConnectorInfo) HasTasks() bool

HasTasks returns a boolean if a field has been set.

func (*ConnectorInfo) HasType 

func (o *ConnectorInfo) HasType() bool

HasType returns a boolean if a field has been set.

func (ConnectorInfo) MarshalJSON 

func (o ConnectorInfo) MarshalJSON() ([]byte, error)

func (*ConnectorInfo) SetConfig 

func (o *ConnectorInfo) SetConfig(v map[string]string)

SetConfig gets a reference to the given map[string]string and assigns it to the Config field.

func (*ConnectorInfo) SetName 

func (o *ConnectorInfo) SetName(v string)

SetName gets a reference to the given string and assigns it to the Name field.

func (*ConnectorInfo) SetTasks 

func (o *ConnectorInfo) SetTasks(v []ConnectorTaskId)

SetTasks gets a reference to the given []ConnectorTaskId and assigns it to the Tasks field.

func (*ConnectorInfo) SetType 

func (o *ConnectorInfo) SetType(v string)

SetType gets a reference to the given string and assigns it to the Type field.

func (ConnectorInfo) ToMap 

func (o ConnectorInfo) ToMap() (map[string]interface{}, error)

type ConnectorOffset 

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

ConnectorOffset struct for ConnectorOffset

func NewConnectorOffset 

func NewConnectorOffset() *ConnectorOffset

NewConnectorOffset instantiates a new ConnectorOffset object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewConnectorOffsetWithDefaults 

func NewConnectorOffsetWithDefaults() *ConnectorOffset

NewConnectorOffsetWithDefaults instantiates a new ConnectorOffset object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*ConnectorOffset) GetOffset 

func (o *ConnectorOffset) GetOffset() map[string]map[string]interface{}

GetOffset returns the Offset field value if set, zero value otherwise.

func (*ConnectorOffset) GetOffsetOk 

func (o *ConnectorOffset) GetOffsetOk() (map[string]map[string]interface{}, bool)

GetOffsetOk returns a tuple with the Offset field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorOffset) GetPartition 

func (o *ConnectorOffset) GetPartition() map[string]map[string]interface{}

GetPartition returns the Partition field value if set, zero value otherwise.

func (*ConnectorOffset) GetPartitionOk 

func (o *ConnectorOffset) GetPartitionOk() (map[string]map[string]interface{}, bool)

GetPartitionOk returns a tuple with the Partition field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorOffset) HasOffset 

func (o *ConnectorOffset) HasOffset() bool

HasOffset returns a boolean if a field has been set.

func (*ConnectorOffset) HasPartition 

func (o *ConnectorOffset) HasPartition() bool

HasPartition returns a boolean if a field has been set.

func (ConnectorOffset) MarshalJSON 

func (o ConnectorOffset) MarshalJSON() ([]byte, error)

func (*ConnectorOffset) SetOffset 

func (o *ConnectorOffset) SetOffset(v map[string]map[string]interface{})

SetOffset gets a reference to the given map[string]map[string]interface{} and assigns it to the Offset field.

func (*ConnectorOffset) SetPartition 

func (o *ConnectorOffset) SetPartition(v map[string]map[string]interface{})

SetPartition gets a reference to the given map[string]map[string]interface{} and assigns it to the Partition field.

func (ConnectorOffset) ToMap 

func (o ConnectorOffset) ToMap() (map[string]interface{}, error)

type ConnectorOffsets 

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

ConnectorOffsets struct for ConnectorOffsets

func NewConnectorOffsets 

func NewConnectorOffsets() *ConnectorOffsets

NewConnectorOffsets instantiates a new ConnectorOffsets object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewConnectorOffsetsWithDefaults 

func NewConnectorOffsetsWithDefaults() *ConnectorOffsets

NewConnectorOffsetsWithDefaults instantiates a new ConnectorOffsets object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*ConnectorOffsets) GetOffsets 

func (o *ConnectorOffsets) GetOffsets() []ConnectorOffset

GetOffsets returns the Offsets field value if set, zero value otherwise.

func (*ConnectorOffsets) GetOffsetsOk 

func (o *ConnectorOffsets) GetOffsetsOk() ([]ConnectorOffset, bool)

GetOffsetsOk returns a tuple with the Offsets field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorOffsets) HasOffsets 

func (o *ConnectorOffsets) HasOffsets() bool

HasOffsets returns a boolean if a field has been set.

func (ConnectorOffsets) MarshalJSON 

func (o ConnectorOffsets) MarshalJSON() ([]byte, error)

func (*ConnectorOffsets) SetOffsets 

func (o *ConnectorOffsets) SetOffsets(v []ConnectorOffset)

SetOffsets gets a reference to the given []ConnectorOffset and assigns it to the Offsets field.

func (ConnectorOffsets) ToMap 

func (o ConnectorOffsets) ToMap() (map[string]interface{}, error)

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 struct for ConnectorState

func NewConnectorState 

func NewConnectorState() *ConnectorState

NewConnectorState instantiates a new ConnectorState object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewConnectorStateWithDefaults 

func NewConnectorStateWithDefaults() *ConnectorState

NewConnectorStateWithDefaults instantiates a new ConnectorState object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*ConnectorState) GetMsg 

func (o *ConnectorState) GetMsg() string

GetMsg returns the Msg field value if set, zero value otherwise.

func (*ConnectorState) GetMsgOk 

func (o *ConnectorState) GetMsgOk() (*string, bool)

GetMsgOk returns a tuple with the Msg field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorState) GetState 

func (o *ConnectorState) GetState() string

GetState returns the State field value if set, zero value otherwise.

func (*ConnectorState) GetStateOk 

func (o *ConnectorState) GetStateOk() (*string, bool)

GetStateOk returns a tuple with the State field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorState) GetTrace 

func (o *ConnectorState) GetTrace() string

GetTrace returns the Trace field value if set, zero value otherwise.

func (*ConnectorState) GetTraceOk 

func (o *ConnectorState) GetTraceOk() (*string, bool)

GetTraceOk returns a tuple with the Trace field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorState) GetWorkerId 

func (o *ConnectorState) GetWorkerId() string

GetWorkerId returns the WorkerId field value if set, zero value otherwise.

func (*ConnectorState) GetWorkerIdOk 

func (o *ConnectorState) GetWorkerIdOk() (*string, bool)

GetWorkerIdOk returns a tuple with the WorkerId field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorState) HasMsg 

func (o *ConnectorState) HasMsg() bool

HasMsg returns a boolean if a field has been set.

func (*ConnectorState) HasState 

func (o *ConnectorState) HasState() bool

HasState returns a boolean if a field has been set.

func (*ConnectorState) HasTrace 

func (o *ConnectorState) HasTrace() bool

HasTrace returns a boolean if a field has been set.

func (*ConnectorState) HasWorkerId 

func (o *ConnectorState) HasWorkerId() bool

HasWorkerId returns a boolean if a field has been set.

func (ConnectorState) MarshalJSON 

func (o ConnectorState) MarshalJSON() ([]byte, error)

func (*ConnectorState) SetMsg 

func (o *ConnectorState) SetMsg(v string)

SetMsg gets a reference to the given string and assigns it to the Msg field.

func (*ConnectorState) SetState 

func (o *ConnectorState) SetState(v string)

SetState gets a reference to the given string and assigns it to the State field.

func (*ConnectorState) SetTrace 

func (o *ConnectorState) SetTrace(v string)

SetTrace gets a reference to the given string and assigns it to the Trace field.

func (*ConnectorState) SetWorkerId 

func (o *ConnectorState) SetWorkerId(v string)

SetWorkerId gets a reference to the given string and assigns it to the WorkerId field.

func (ConnectorState) ToMap 

func (o ConnectorState) ToMap() (map[string]interface{}, error)

type ConnectorStateInfo 

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

ConnectorStateInfo struct for ConnectorStateInfo

func NewConnectorStateInfo 

func NewConnectorStateInfo() *ConnectorStateInfo

NewConnectorStateInfo instantiates a new ConnectorStateInfo object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewConnectorStateInfoWithDefaults 

func NewConnectorStateInfoWithDefaults() *ConnectorStateInfo

NewConnectorStateInfoWithDefaults instantiates a new ConnectorStateInfo object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*ConnectorStateInfo) GetConnector 

func (o *ConnectorStateInfo) GetConnector() ConnectorState

GetConnector returns the Connector field value if set, zero value otherwise.

func (*ConnectorStateInfo) GetConnectorOk 

func (o *ConnectorStateInfo) GetConnectorOk() (*ConnectorState, bool)

GetConnectorOk returns a tuple with the Connector field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorStateInfo) GetName 

func (o *ConnectorStateInfo) GetName() string

GetName returns the Name field value if set, zero value otherwise.

func (*ConnectorStateInfo) GetNameOk 

func (o *ConnectorStateInfo) GetNameOk() (*string, bool)

GetNameOk returns a tuple with the Name field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorStateInfo) GetTasks 

func (o *ConnectorStateInfo) GetTasks() []TaskState

GetTasks returns the Tasks field value if set, zero value otherwise.

func (*ConnectorStateInfo) GetTasksOk 

func (o *ConnectorStateInfo) GetTasksOk() ([]TaskState, bool)

GetTasksOk returns a tuple with the Tasks field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorStateInfo) GetType 

func (o *ConnectorStateInfo) GetType() string

GetType returns the Type field value if set, zero value otherwise.

func (*ConnectorStateInfo) GetTypeOk 

func (o *ConnectorStateInfo) GetTypeOk() (*string, bool)

GetTypeOk returns a tuple with the Type field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorStateInfo) HasConnector 

func (o *ConnectorStateInfo) HasConnector() bool

HasConnector returns a boolean if a field has been set.

func (*ConnectorStateInfo) HasName 

func (o *ConnectorStateInfo) HasName() bool

HasName returns a boolean if a field has been set.

func (*ConnectorStateInfo) HasTasks 

func (o *ConnectorStateInfo) HasTasks() bool

HasTasks returns a boolean if a field has been set.

func (*ConnectorStateInfo) HasType 

func (o *ConnectorStateInfo) HasType() bool

HasType returns a boolean if a field has been set.

func (ConnectorStateInfo) MarshalJSON 

func (o ConnectorStateInfo) MarshalJSON() ([]byte, error)

func (*ConnectorStateInfo) SetConnector 

func (o *ConnectorStateInfo) SetConnector(v ConnectorState)

SetConnector gets a reference to the given ConnectorState and assigns it to the Connector field.

func (*ConnectorStateInfo) SetName 

func (o *ConnectorStateInfo) SetName(v string)

SetName gets a reference to the given string and assigns it to the Name field.

func (*ConnectorStateInfo) SetTasks 

func (o *ConnectorStateInfo) SetTasks(v []TaskState)

SetTasks gets a reference to the given []TaskState and assigns it to the Tasks field.

func (*ConnectorStateInfo) SetType 

func (o *ConnectorStateInfo) SetType(v string)

SetType gets a reference to the given string and assigns it to the Type field.

func (ConnectorStateInfo) ToMap 

func (o ConnectorStateInfo) ToMap() (map[string]interface{}, error)

type ConnectorTaskId 

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

ConnectorTaskId struct for ConnectorTaskId

func NewConnectorTaskId 

func NewConnectorTaskId() *ConnectorTaskId

NewConnectorTaskId instantiates a new ConnectorTaskId object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewConnectorTaskIdWithDefaults 

func NewConnectorTaskIdWithDefaults() *ConnectorTaskId

NewConnectorTaskIdWithDefaults instantiates a new ConnectorTaskId object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*ConnectorTaskId) GetConnector 

func (o *ConnectorTaskId) GetConnector() string

GetConnector returns the Connector field value if set, zero value otherwise.

func (*ConnectorTaskId) GetConnectorOk 

func (o *ConnectorTaskId) GetConnectorOk() (*string, bool)

GetConnectorOk returns a tuple with the Connector field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorTaskId) GetTask 

func (o *ConnectorTaskId) GetTask() int32

GetTask returns the Task field value if set, zero value otherwise.

func (*ConnectorTaskId) GetTaskOk 

func (o *ConnectorTaskId) GetTaskOk() (*int32, bool)

GetTaskOk returns a tuple with the Task field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConnectorTaskId) HasConnector 

func (o *ConnectorTaskId) HasConnector() bool

HasConnector returns a boolean if a field has been set.

func (*ConnectorTaskId) HasTask 

func (o *ConnectorTaskId) HasTask() bool

HasTask returns a boolean if a field has been set.

func (ConnectorTaskId) MarshalJSON 

func (o ConnectorTaskId) MarshalJSON() ([]byte, error)

func (*ConnectorTaskId) SetConnector 

func (o *ConnectorTaskId) SetConnector(v string)

SetConnector gets a reference to the given string and assigns it to the Connector field.

func (*ConnectorTaskId) SetTask 

func (o *ConnectorTaskId) SetTask(v int32)

SetTask gets a reference to the given int32 and assigns it to the Task field.

func (ConnectorTaskId) ToMap 

func (o ConnectorTaskId) ToMap() (map[string]interface{}, error)

type CreateConnectorRequest 

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

CreateConnectorRequest struct for CreateConnectorRequest

func NewCreateConnectorRequest 

func NewCreateConnectorRequest() *CreateConnectorRequest

NewCreateConnectorRequest instantiates a new CreateConnectorRequest object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewCreateConnectorRequestWithDefaults 

func NewCreateConnectorRequestWithDefaults() *CreateConnectorRequest

NewCreateConnectorRequestWithDefaults instantiates a new CreateConnectorRequest object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*CreateConnectorRequest) GetConfig 

func (o *CreateConnectorRequest) GetConfig() map[string]string

GetConfig returns the Config field value if set, zero value otherwise.

func (*CreateConnectorRequest) GetConfigOk 

func (o *CreateConnectorRequest) GetConfigOk() (*map[string]string, bool)

GetConfigOk returns a tuple with the Config field value if set, nil otherwise and a boolean to check if the value has been set.

func (*CreateConnectorRequest) GetInitialState 

func (o *CreateConnectorRequest) GetInitialState() string

GetInitialState returns the InitialState field value if set, zero value otherwise.

func (*CreateConnectorRequest) GetInitialStateOk 

func (o *CreateConnectorRequest) GetInitialStateOk() (*string, bool)

GetInitialStateOk returns a tuple with the InitialState field value if set, nil otherwise and a boolean to check if the value has been set.

func (*CreateConnectorRequest) GetName 

func (o *CreateConnectorRequest) GetName() string

GetName returns the Name field value if set, zero value otherwise.

func (*CreateConnectorRequest) GetNameOk 

func (o *CreateConnectorRequest) GetNameOk() (*string, bool)

GetNameOk returns a tuple with the Name field value if set, nil otherwise and a boolean to check if the value has been set.

func (*CreateConnectorRequest) HasConfig 

func (o *CreateConnectorRequest) HasConfig() bool

HasConfig returns a boolean if a field has been set.

func (*CreateConnectorRequest) HasInitialState 

func (o *CreateConnectorRequest) HasInitialState() bool

HasInitialState returns a boolean if a field has been set.

func (*CreateConnectorRequest) HasName 

func (o *CreateConnectorRequest) HasName() bool

HasName returns a boolean if a field has been set.

func (CreateConnectorRequest) MarshalJSON 

func (o CreateConnectorRequest) MarshalJSON() ([]byte, error)

func (*CreateConnectorRequest) SetConfig 

func (o *CreateConnectorRequest) SetConfig(v map[string]string)

SetConfig gets a reference to the given map[string]string and assigns it to the Config field.

func (*CreateConnectorRequest) SetInitialState 

func (o *CreateConnectorRequest) SetInitialState(v string)

SetInitialState gets a reference to the given string and assigns it to the InitialState field.

func (*CreateConnectorRequest) SetName 

func (o *CreateConnectorRequest) SetName(v string)

SetName gets a reference to the given string and assigns it to the Name field.

func (CreateConnectorRequest) ToMap 

func (o CreateConnectorRequest) ToMap() (map[string]interface{}, error)

type DefaultAPIService 

type DefaultAPIService service

DefaultAPIService DefaultAPI service

func (*DefaultAPIService) AlterConnectorOffsets 

func (a *DefaultAPIService) AlterConnectorOffsets(ctx context.Context, connector string) ApiAlterConnectorOffsetsRequest

AlterConnectorOffsets Alter the offsets for the specified connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiAlterConnectorOffsetsRequest

func (*DefaultAPIService) AlterConnectorOffsetsExecute 

func (a *DefaultAPIService) AlterConnectorOffsetsExecute(r ApiAlterConnectorOffsetsRequest) (*http.Response, error)

Execute executes the request

func (*DefaultAPIService) CreateConnector 

func (a *DefaultAPIService) CreateConnector(ctx context.Context) ApiCreateConnectorRequest

CreateConnector Create a new connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@return ApiCreateConnectorRequest

func (*DefaultAPIService) CreateConnectorExecute 

func (a *DefaultAPIService) CreateConnectorExecute(r ApiCreateConnectorRequest) (*ConnectorInfo, *http.Response, error)

Execute executes the request 

@return ConnectorInfo

func (*DefaultAPIService) DestroyConnector 

func (a *DefaultAPIService) DestroyConnector(ctx context.Context, connector string) ApiDestroyConnectorRequest

DestroyConnector Delete the specified connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiDestroyConnectorRequest

func (*DefaultAPIService) DestroyConnectorExecute 

func (a *DefaultAPIService) DestroyConnectorExecute(r ApiDestroyConnectorRequest) (*http.Response, error)

Execute executes the request

func (*DefaultAPIService) GetConnector 

func (a *DefaultAPIService) GetConnector(ctx context.Context, connector string) ApiGetConnectorRequest

GetConnector Get the details for the specified connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiGetConnectorRequest

func (*DefaultAPIService) GetConnectorActiveTopics 

func (a *DefaultAPIService) GetConnectorActiveTopics(ctx context.Context, connector string) ApiGetConnectorActiveTopicsRequest

GetConnectorActiveTopics Get the list of topics actively used by the specified connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiGetConnectorActiveTopicsRequest

func (*DefaultAPIService) GetConnectorActiveTopicsExecute 

func (a *DefaultAPIService) GetConnectorActiveTopicsExecute(r ApiGetConnectorActiveTopicsRequest) (*map[string]ConnectorActiveTopicsValue, *http.Response, error)

Execute executes the request 

@return map[string]ConnectorActiveTopicsValue

func (*DefaultAPIService) GetConnectorConfig 

func (a *DefaultAPIService) GetConnectorConfig(ctx context.Context, connector string) ApiGetConnectorConfigRequest

GetConnectorConfig Get the configuration for the specified connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiGetConnectorConfigRequest

func (*DefaultAPIService) GetConnectorConfigDef 

func (a *DefaultAPIService) GetConnectorConfigDef(ctx context.Context, pluginName string) ApiGetConnectorConfigDefRequest

GetConnectorConfigDef Get the configuration definition for the specified pluginName 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param pluginName
@return ApiGetConnectorConfigDefRequest

func (*DefaultAPIService) GetConnectorConfigDefExecute 

func (a *DefaultAPIService) GetConnectorConfigDefExecute(r ApiGetConnectorConfigDefRequest) ([]ConfigKeyInfo, *http.Response, error)

Execute executes the request 

@return []ConfigKeyInfo

func (*DefaultAPIService) GetConnectorConfigExecute 

func (a *DefaultAPIService) GetConnectorConfigExecute(r ApiGetConnectorConfigRequest) (map[string]string, *http.Response, error)

Execute executes the request 

@return map[string]string

func (*DefaultAPIService) GetConnectorExecute 

func (a *DefaultAPIService) GetConnectorExecute(r ApiGetConnectorRequest) (*ConnectorInfo, *http.Response, error)

Execute executes the request 

@return ConnectorInfo

func (*DefaultAPIService) GetConnectorStatus 

func (a *DefaultAPIService) GetConnectorStatus(ctx context.Context, connector string) ApiGetConnectorStatusRequest

GetConnectorStatus Get the status for the specified connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiGetConnectorStatusRequest

func (*DefaultAPIService) GetConnectorStatusExecute 

func (a *DefaultAPIService) GetConnectorStatusExecute(r ApiGetConnectorStatusRequest) (*ConnectorStateInfo, *http.Response, error)

Execute executes the request 

@return ConnectorStateInfo

func (*DefaultAPIService) GetLogger 

func (a *DefaultAPIService) GetLogger(ctx context.Context, logger string) ApiGetLoggerRequest

GetLogger Get the log level for the specified logger 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param logger
@return ApiGetLoggerRequest

func (*DefaultAPIService) GetLoggerExecute 

func (a *DefaultAPIService) GetLoggerExecute(r ApiGetLoggerRequest) (*http.Response, error)

Execute executes the request

func (*DefaultAPIService) GetOffsets 

func (a *DefaultAPIService) GetOffsets(ctx context.Context, connector string) ApiGetOffsetsRequest

GetOffsets Get the current offsets for the specified connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiGetOffsetsRequest

func (*DefaultAPIService) GetOffsetsExecute 

func (a *DefaultAPIService) GetOffsetsExecute(r ApiGetOffsetsRequest) (*ConnectorOffsets, *http.Response, error)

Execute executes the request 

@return ConnectorOffsets

func (*DefaultAPIService) GetTaskConfigs 

func (a *DefaultAPIService) GetTaskConfigs(ctx context.Context, connector string) ApiGetTaskConfigsRequest

GetTaskConfigs List all tasks and their configurations for the specified connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiGetTaskConfigsRequest

func (*DefaultAPIService) GetTaskConfigsExecute 

func (a *DefaultAPIService) GetTaskConfigsExecute(r ApiGetTaskConfigsRequest) ([]TaskInfo, *http.Response, error)

Execute executes the request 

@return []TaskInfo

func (*DefaultAPIService) GetTaskStatus 

func (a *DefaultAPIService) GetTaskStatus(ctx context.Context, connector string, task int32) ApiGetTaskStatusRequest

GetTaskStatus Get the state of the specified task for the specified connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@param task
@return ApiGetTaskStatusRequest

func (*DefaultAPIService) GetTaskStatusExecute 

func (a *DefaultAPIService) GetTaskStatusExecute(r ApiGetTaskStatusRequest) (*TaskState, *http.Response, error)

Execute executes the request 

@return TaskState

func (*DefaultAPIService) GetTasksConfig 

func (a *DefaultAPIService) GetTasksConfig(ctx context.Context, connector string) ApiGetTasksConfigRequest

GetTasksConfig Get the configuration of all tasks for the specified connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiGetTasksConfigRequest

Deprecated

func (*DefaultAPIService) GetTasksConfigExecute 

func (a *DefaultAPIService) GetTasksConfigExecute(r ApiGetTasksConfigRequest) (*map[string]map[string]string, *http.Response, error)

Execute executes the request 

@return map[string]map[string]string

Deprecated

func (*DefaultAPIService) HealthCheck 

func (a *DefaultAPIService) HealthCheck(ctx context.Context) ApiHealthCheckRequest

HealthCheck Health check endpoint to verify worker readiness and liveness 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@return ApiHealthCheckRequest

func (*DefaultAPIService) HealthCheckExecute 

func (a *DefaultAPIService) HealthCheckExecute(r ApiHealthCheckRequest) (*http.Response, error)

Execute executes the request

func (*DefaultAPIService) ListConnectorPlugins 

func (a *DefaultAPIService) ListConnectorPlugins(ctx context.Context) ApiListConnectorPluginsRequest

ListConnectorPlugins List all connector plugins installed 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@return ApiListConnectorPluginsRequest

func (*DefaultAPIService) ListConnectorPluginsExecute 

func (a *DefaultAPIService) ListConnectorPluginsExecute(r ApiListConnectorPluginsRequest) ([]PluginInfo, *http.Response, error)

Execute executes the request 

@return []PluginInfo

func (*DefaultAPIService) ListConnectors 

func (a *DefaultAPIService) ListConnectors(ctx context.Context) ApiListConnectorsRequest

ListConnectors List all active connectors 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@return ApiListConnectorsRequest

func (*DefaultAPIService) ListConnectorsExecute 

func (a *DefaultAPIService) ListConnectorsExecute(r ApiListConnectorsRequest) ([]string, *http.Response, error)

Execute executes the request 

@return []string

func (*DefaultAPIService) ListLoggers 

func (a *DefaultAPIService) ListLoggers(ctx context.Context) ApiListLoggersRequest

ListLoggers List the current loggers that have their levels explicitly set and their log levels 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@return ApiListLoggersRequest

func (*DefaultAPIService) ListLoggersExecute 

func (a *DefaultAPIService) ListLoggersExecute(r ApiListLoggersRequest) (*http.Response, error)

Execute executes the request

func (*DefaultAPIService) PatchConnectorConfig 

func (a *DefaultAPIService) PatchConnectorConfig(ctx context.Context, connector string) ApiPatchConnectorConfigRequest

PatchConnectorConfig Method for PatchConnectorConfig 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiPatchConnectorConfigRequest

func (*DefaultAPIService) PatchConnectorConfigExecute 

func (a *DefaultAPIService) PatchConnectorConfigExecute(r ApiPatchConnectorConfigRequest) (*http.Response, error)

Execute executes the request

func (*DefaultAPIService) PauseConnector 

func (a *DefaultAPIService) PauseConnector(ctx context.Context, connector string) ApiPauseConnectorRequest

PauseConnector Pause the specified connector

This operation is idempotent and has no effects if the connector is already paused 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiPauseConnectorRequest

func (*DefaultAPIService) PauseConnectorExecute 

func (a *DefaultAPIService) PauseConnectorExecute(r ApiPauseConnectorRequest) (*http.Response, error)

Execute executes the request

func (*DefaultAPIService) PutConnectorConfig 

func (a *DefaultAPIService) PutConnectorConfig(ctx context.Context, connector string) ApiPutConnectorConfigRequest

PutConnectorConfig Create or reconfigure the specified connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiPutConnectorConfigRequest

func (*DefaultAPIService) PutConnectorConfigExecute 

func (a *DefaultAPIService) PutConnectorConfigExecute(r ApiPutConnectorConfigRequest) (*ConnectorInfo, *http.Response, error)

Execute executes the request 

@return ConnectorInfo

func (*DefaultAPIService) ResetConnectorActiveTopics 

func (a *DefaultAPIService) ResetConnectorActiveTopics(ctx context.Context, connector string) ApiResetConnectorActiveTopicsRequest

ResetConnectorActiveTopics Reset the list of topics actively used by the specified connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiResetConnectorActiveTopicsRequest

func (*DefaultAPIService) ResetConnectorActiveTopicsExecute 

func (a *DefaultAPIService) ResetConnectorActiveTopicsExecute(r ApiResetConnectorActiveTopicsRequest) (*http.Response, error)

Execute executes the request

func (*DefaultAPIService) ResetConnectorOffsets 

func (a *DefaultAPIService) ResetConnectorOffsets(ctx context.Context, connector string) ApiResetConnectorOffsetsRequest

ResetConnectorOffsets Reset the offsets for the specified connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiResetConnectorOffsetsRequest

func (*DefaultAPIService) ResetConnectorOffsetsExecute 

func (a *DefaultAPIService) ResetConnectorOffsetsExecute(r ApiResetConnectorOffsetsRequest) (*http.Response, error)

Execute executes the request

func (*DefaultAPIService) RestartConnector 

func (a *DefaultAPIService) RestartConnector(ctx context.Context, connector string) ApiRestartConnectorRequest

RestartConnector Restart the specified connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiRestartConnectorRequest

func (*DefaultAPIService) RestartConnectorExecute 

func (a *DefaultAPIService) RestartConnectorExecute(r ApiRestartConnectorRequest) (*http.Response, error)

Execute executes the request

func (*DefaultAPIService) RestartTask 

func (a *DefaultAPIService) RestartTask(ctx context.Context, connector string, task int32) ApiRestartTaskRequest

RestartTask Restart the specified task for the specified connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@param task
@return ApiRestartTaskRequest

func (*DefaultAPIService) RestartTaskExecute 

func (a *DefaultAPIService) RestartTaskExecute(r ApiRestartTaskRequest) (*http.Response, error)

Execute executes the request

func (*DefaultAPIService) ResumeConnector 

func (a *DefaultAPIService) ResumeConnector(ctx context.Context, connector string) ApiResumeConnectorRequest

ResumeConnector Resume the specified connector

This operation is idempotent and has no effects if the connector is already running 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiResumeConnectorRequest

func (*DefaultAPIService) ResumeConnectorExecute 

func (a *DefaultAPIService) ResumeConnectorExecute(r ApiResumeConnectorRequest) (*http.Response, error)

Execute executes the request

func (*DefaultAPIService) ServerInfo 

func (a *DefaultAPIService) ServerInfo(ctx context.Context) ApiServerInfoRequest

ServerInfo Get details about this Connect worker and the ID of the Kafka cluster it is connected to 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@return ApiServerInfoRequest

func (*DefaultAPIService) ServerInfoExecute 

func (a *DefaultAPIService) ServerInfoExecute(r ApiServerInfoRequest) (*ServerInfo, *http.Response, error)

Execute executes the request 

@return ServerInfo

func (*DefaultAPIService) SetLevel 

func (a *DefaultAPIService) SetLevel(ctx context.Context, logger string) ApiSetLevelRequest

SetLevel Set the log level for the specified logger 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param logger
@return ApiSetLevelRequest

func (*DefaultAPIService) SetLevelExecute 

func (a *DefaultAPIService) SetLevelExecute(r ApiSetLevelRequest) (*http.Response, error)

Execute executes the request

func (*DefaultAPIService) StopConnector 

func (a *DefaultAPIService) StopConnector(ctx context.Context, connector string) ApiStopConnectorRequest

StopConnector Stop the specified connector

This operation is idempotent and has no effects if the connector is already stopped 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connector
@return ApiStopConnectorRequest

func (*DefaultAPIService) StopConnectorExecute 

func (a *DefaultAPIService) StopConnectorExecute(r ApiStopConnectorRequest) (*http.Response, error)

Execute executes the request

func (*DefaultAPIService) ValidateConfigs 

func (a *DefaultAPIService) ValidateConfigs(ctx context.Context, pluginName string) ApiValidateConfigsRequest

ValidateConfigs Validate the provided configuration against the configuration definition for the specified pluginName 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param pluginName
@return ApiValidateConfigsRequest

func (*DefaultAPIService) ValidateConfigsExecute 

func (a *DefaultAPIService) ValidateConfigsExecute(r ApiValidateConfigsRequest) (*ConfigInfos, *http.Response, error)

Execute executes the request 

@return ConfigInfos

type GenericOpenAPIError 

type GenericOpenAPIError struct {
	// contains filtered or unexported fields
}

GenericOpenAPIError Provides access to the body, error and model on returned errors.

func (GenericOpenAPIError) Body 

func (e GenericOpenAPIError) Body() []byte

Body returns the raw bytes of the response

func (GenericOpenAPIError) Error 

func (e GenericOpenAPIError) Error() string

Error returns non-empty string if there was an error.

func (GenericOpenAPIError) Model 

func (e GenericOpenAPIError) Model() interface{}

Model returns the unpacked model of the error

type MappedNullable 

type MappedNullable interface {
	ToMap() (map[string]interface{}, error)
}

type NullableBool 

type NullableBool struct {
	// contains filtered or unexported fields
}

func NewNullableBool 

func NewNullableBool(val *bool) *NullableBool

func (NullableBool) Get 

func (v NullableBool) Get() *bool

func (NullableBool) IsSet 

func (v NullableBool) IsSet() bool

func (NullableBool) MarshalJSON 

func (v NullableBool) MarshalJSON() ([]byte, error)

func (*NullableBool) Set 

func (v *NullableBool) Set(val *bool)

func (*NullableBool) UnmarshalJSON 

func (v *NullableBool) UnmarshalJSON(src []byte) error

func (*NullableBool) Unset 

func (v *NullableBool) Unset()

type NullableConfigInfo 

type NullableConfigInfo struct {
	// contains filtered or unexported fields
}

func NewNullableConfigInfo 

func NewNullableConfigInfo(val *ConfigInfo) *NullableConfigInfo

func (NullableConfigInfo) Get 

func (v NullableConfigInfo) Get() *ConfigInfo

func (NullableConfigInfo) IsSet 

func (v NullableConfigInfo) IsSet() bool

func (NullableConfigInfo) MarshalJSON 

func (v NullableConfigInfo) MarshalJSON() ([]byte, error)

func (*NullableConfigInfo) Set 

func (v *NullableConfigInfo) Set(val *ConfigInfo)

func (*NullableConfigInfo) UnmarshalJSON 

func (v *NullableConfigInfo) UnmarshalJSON(src []byte) error

func (*NullableConfigInfo) Unset 

func (v *NullableConfigInfo) Unset()

type NullableConfigInfos 

type NullableConfigInfos struct {
	// contains filtered or unexported fields
}

func NewNullableConfigInfos 

func NewNullableConfigInfos(val *ConfigInfos) *NullableConfigInfos

func (NullableConfigInfos) Get 

func (v NullableConfigInfos) Get() *ConfigInfos

func (NullableConfigInfos) IsSet 

func (v NullableConfigInfos) IsSet() bool

func (NullableConfigInfos) MarshalJSON 

func (v NullableConfigInfos) MarshalJSON() ([]byte, error)

func (*NullableConfigInfos) Set 

func (v *NullableConfigInfos) Set(val *ConfigInfos)

func (*NullableConfigInfos) UnmarshalJSON 

func (v *NullableConfigInfos) UnmarshalJSON(src []byte) error

func (*NullableConfigInfos) Unset 

func (v *NullableConfigInfos) Unset()

type NullableConfigKeyInfo 

type NullableConfigKeyInfo struct {
	// contains filtered or unexported fields
}

func NewNullableConfigKeyInfo 

func NewNullableConfigKeyInfo(val *ConfigKeyInfo) *NullableConfigKeyInfo

func (NullableConfigKeyInfo) Get 

func (v NullableConfigKeyInfo) Get() *ConfigKeyInfo

func (NullableConfigKeyInfo) IsSet 

func (v NullableConfigKeyInfo) IsSet() bool

func (NullableConfigKeyInfo) MarshalJSON 

func (v NullableConfigKeyInfo) MarshalJSON() ([]byte, error)

func (*NullableConfigKeyInfo) Set 

func (v *NullableConfigKeyInfo) Set(val *ConfigKeyInfo)

func (*NullableConfigKeyInfo) UnmarshalJSON 

func (v *NullableConfigKeyInfo) UnmarshalJSON(src []byte) error

func (*NullableConfigKeyInfo) Unset 

func (v *NullableConfigKeyInfo) Unset()

type NullableConfigValueInfo 

type NullableConfigValueInfo struct {
	// contains filtered or unexported fields
}

func NewNullableConfigValueInfo 

func NewNullableConfigValueInfo(val *ConfigValueInfo) *NullableConfigValueInfo

func (NullableConfigValueInfo) Get 

func (v NullableConfigValueInfo) Get() *ConfigValueInfo

func (NullableConfigValueInfo) IsSet 

func (v NullableConfigValueInfo) IsSet() bool

func (NullableConfigValueInfo) MarshalJSON 

func (v NullableConfigValueInfo) MarshalJSON() ([]byte, error)

func (*NullableConfigValueInfo) Set 

func (v *NullableConfigValueInfo) Set(val *ConfigValueInfo)

func (*NullableConfigValueInfo) UnmarshalJSON 

func (v *NullableConfigValueInfo) UnmarshalJSON(src []byte) error

func (*NullableConfigValueInfo) Unset 

func (v *NullableConfigValueInfo) Unset()

type NullableConnectorActiveTopicsValue 

type NullableConnectorActiveTopicsValue struct {
	// contains filtered or unexported fields
}

func NewNullableConnectorActiveTopicsValue 

func NewNullableConnectorActiveTopicsValue(val *ConnectorActiveTopicsValue) *NullableConnectorActiveTopicsValue

func (NullableConnectorActiveTopicsValue) Get 

func (v NullableConnectorActiveTopicsValue) Get() *ConnectorActiveTopicsValue

func (NullableConnectorActiveTopicsValue) IsSet 

func (v NullableConnectorActiveTopicsValue) IsSet() bool

func (NullableConnectorActiveTopicsValue) MarshalJSON 

func (v NullableConnectorActiveTopicsValue) MarshalJSON() ([]byte, error)

func (*NullableConnectorActiveTopicsValue) Set 

func (v *NullableConnectorActiveTopicsValue) Set(val *ConnectorActiveTopicsValue)

func (*NullableConnectorActiveTopicsValue) UnmarshalJSON 

func (v *NullableConnectorActiveTopicsValue) UnmarshalJSON(src []byte) error

func (*NullableConnectorActiveTopicsValue) Unset 

func (v *NullableConnectorActiveTopicsValue) Unset()

type NullableConnectorInfo 

type NullableConnectorInfo struct {
	// contains filtered or unexported fields
}

func NewNullableConnectorInfo 

func NewNullableConnectorInfo(val *ConnectorInfo) *NullableConnectorInfo

func (NullableConnectorInfo) Get 

func (v NullableConnectorInfo) Get() *ConnectorInfo

func (NullableConnectorInfo) IsSet 

func (v NullableConnectorInfo) IsSet() bool

func (NullableConnectorInfo) MarshalJSON 

func (v NullableConnectorInfo) MarshalJSON() ([]byte, error)

func (*NullableConnectorInfo) Set 

func (v *NullableConnectorInfo) Set(val *ConnectorInfo)

func (*NullableConnectorInfo) UnmarshalJSON 

func (v *NullableConnectorInfo) UnmarshalJSON(src []byte) error

func (*NullableConnectorInfo) Unset 

func (v *NullableConnectorInfo) Unset()

type NullableConnectorOffset 

type NullableConnectorOffset struct {
	// contains filtered or unexported fields
}

func NewNullableConnectorOffset 

func NewNullableConnectorOffset(val *ConnectorOffset) *NullableConnectorOffset

func (NullableConnectorOffset) Get 

func (v NullableConnectorOffset) Get() *ConnectorOffset

func (NullableConnectorOffset) IsSet 

func (v NullableConnectorOffset) IsSet() bool

func (NullableConnectorOffset) MarshalJSON 

func (v NullableConnectorOffset) MarshalJSON() ([]byte, error)

func (*NullableConnectorOffset) Set 

func (v *NullableConnectorOffset) Set(val *ConnectorOffset)

func (*NullableConnectorOffset) UnmarshalJSON 

func (v *NullableConnectorOffset) UnmarshalJSON(src []byte) error

func (*NullableConnectorOffset) Unset 

func (v *NullableConnectorOffset) Unset()

type NullableConnectorOffsets 

type NullableConnectorOffsets struct {
	// contains filtered or unexported fields
}

func NewNullableConnectorOffsets 

func NewNullableConnectorOffsets(val *ConnectorOffsets) *NullableConnectorOffsets

func (NullableConnectorOffsets) Get 

func (v NullableConnectorOffsets) Get() *ConnectorOffsets

func (NullableConnectorOffsets) IsSet 

func (v NullableConnectorOffsets) IsSet() bool

func (NullableConnectorOffsets) MarshalJSON 

func (v NullableConnectorOffsets) MarshalJSON() ([]byte, error)

func (*NullableConnectorOffsets) Set 

func (v *NullableConnectorOffsets) Set(val *ConnectorOffsets)

func (*NullableConnectorOffsets) UnmarshalJSON 

func (v *NullableConnectorOffsets) UnmarshalJSON(src []byte) error

func (*NullableConnectorOffsets) Unset 

func (v *NullableConnectorOffsets) Unset()

type NullableConnectorState 

type NullableConnectorState struct {
	// contains filtered or unexported fields
}

func NewNullableConnectorState 

func NewNullableConnectorState(val *ConnectorState) *NullableConnectorState

func (NullableConnectorState) Get 

func (v NullableConnectorState) Get() *ConnectorState

func (NullableConnectorState) IsSet 

func (v NullableConnectorState) IsSet() bool

func (NullableConnectorState) MarshalJSON 

func (v NullableConnectorState) MarshalJSON() ([]byte, error)

func (*NullableConnectorState) Set 

func (v *NullableConnectorState) Set(val *ConnectorState)

func (*NullableConnectorState) UnmarshalJSON 

func (v *NullableConnectorState) UnmarshalJSON(src []byte) error

func (*NullableConnectorState) Unset 

func (v *NullableConnectorState) Unset()

type NullableConnectorStateInfo 

type NullableConnectorStateInfo struct {
	// contains filtered or unexported fields
}

func NewNullableConnectorStateInfo 

func NewNullableConnectorStateInfo(val *ConnectorStateInfo) *NullableConnectorStateInfo

func (NullableConnectorStateInfo) Get 

func (v NullableConnectorStateInfo) Get() *ConnectorStateInfo

func (NullableConnectorStateInfo) IsSet 

func (v NullableConnectorStateInfo) IsSet() bool

func (NullableConnectorStateInfo) MarshalJSON 

func (v NullableConnectorStateInfo) MarshalJSON() ([]byte, error)

func (*NullableConnectorStateInfo) Set 

func (v *NullableConnectorStateInfo) Set(val *ConnectorStateInfo)

func (*NullableConnectorStateInfo) UnmarshalJSON 

func (v *NullableConnectorStateInfo) UnmarshalJSON(src []byte) error

func (*NullableConnectorStateInfo) Unset 

func (v *NullableConnectorStateInfo) Unset()

type NullableConnectorTaskId 

type NullableConnectorTaskId struct {
	// contains filtered or unexported fields
}

func NewNullableConnectorTaskId 

func NewNullableConnectorTaskId(val *ConnectorTaskId) *NullableConnectorTaskId

func (NullableConnectorTaskId) Get 

func (v NullableConnectorTaskId) Get() *ConnectorTaskId

func (NullableConnectorTaskId) IsSet 

func (v NullableConnectorTaskId) IsSet() bool

func (NullableConnectorTaskId) MarshalJSON 

func (v NullableConnectorTaskId) MarshalJSON() ([]byte, error)

func (*NullableConnectorTaskId) Set 

func (v *NullableConnectorTaskId) Set(val *ConnectorTaskId)

func (*NullableConnectorTaskId) UnmarshalJSON 

func (v *NullableConnectorTaskId) UnmarshalJSON(src []byte) error

func (*NullableConnectorTaskId) Unset 

func (v *NullableConnectorTaskId) Unset()

type NullableCreateConnectorRequest 

type NullableCreateConnectorRequest struct {
	// contains filtered or unexported fields
}

func NewNullableCreateConnectorRequest 

func NewNullableCreateConnectorRequest(val *CreateConnectorRequest) *NullableCreateConnectorRequest

func (NullableCreateConnectorRequest) Get 

func (v NullableCreateConnectorRequest) Get() *CreateConnectorRequest

func (NullableCreateConnectorRequest) IsSet 

func (v NullableCreateConnectorRequest) IsSet() bool

func (NullableCreateConnectorRequest) MarshalJSON 

func (v NullableCreateConnectorRequest) MarshalJSON() ([]byte, error)

func (*NullableCreateConnectorRequest) Set 

func (v *NullableCreateConnectorRequest) Set(val *CreateConnectorRequest)

func (*NullableCreateConnectorRequest) UnmarshalJSON 

func (v *NullableCreateConnectorRequest) UnmarshalJSON(src []byte) error

func (*NullableCreateConnectorRequest) Unset 

func (v *NullableCreateConnectorRequest) Unset()

type NullableFloat32 

type NullableFloat32 struct {
	// contains filtered or unexported fields
}

func NewNullableFloat32 

func NewNullableFloat32(val *float32) *NullableFloat32

func (NullableFloat32) Get 

func (v NullableFloat32) Get() *float32

func (NullableFloat32) IsSet 

func (v NullableFloat32) IsSet() bool

func (NullableFloat32) MarshalJSON 

func (v NullableFloat32) MarshalJSON() ([]byte, error)

func (*NullableFloat32) Set 

func (v *NullableFloat32) Set(val *float32)

func (*NullableFloat32) UnmarshalJSON 

func (v *NullableFloat32) UnmarshalJSON(src []byte) error

func (*NullableFloat32) Unset 

func (v *NullableFloat32) Unset()

type NullableFloat64 

type NullableFloat64 struct {
	// contains filtered or unexported fields
}

func NewNullableFloat64 

func NewNullableFloat64(val *float64) *NullableFloat64

func (NullableFloat64) Get 

func (v NullableFloat64) Get() *float64

func (NullableFloat64) IsSet 

func (v NullableFloat64) IsSet() bool

func (NullableFloat64) MarshalJSON 

func (v NullableFloat64) MarshalJSON() ([]byte, error)

func (*NullableFloat64) Set 

func (v *NullableFloat64) Set(val *float64)

func (*NullableFloat64) UnmarshalJSON 

func (v *NullableFloat64) UnmarshalJSON(src []byte) error

func (*NullableFloat64) Unset 

func (v *NullableFloat64) Unset()

type NullableInt 

type NullableInt struct {
	// contains filtered or unexported fields
}

func NewNullableInt 

func NewNullableInt(val *int) *NullableInt

func (NullableInt) Get 

func (v NullableInt) Get() *int

func (NullableInt) IsSet 

func (v NullableInt) IsSet() bool

func (NullableInt) MarshalJSON 

func (v NullableInt) MarshalJSON() ([]byte, error)

func (*NullableInt) Set 

func (v *NullableInt) Set(val *int)

func (*NullableInt) UnmarshalJSON 

func (v *NullableInt) UnmarshalJSON(src []byte) error

func (*NullableInt) Unset 

func (v *NullableInt) Unset()

type NullableInt32 

type NullableInt32 struct {
	// contains filtered or unexported fields
}

func NewNullableInt32 

func NewNullableInt32(val *int32) *NullableInt32

func (NullableInt32) Get 

func (v NullableInt32) Get() *int32

func (NullableInt32) IsSet 

func (v NullableInt32) IsSet() bool

func (NullableInt32) MarshalJSON 

func (v NullableInt32) MarshalJSON() ([]byte, error)

func (*NullableInt32) Set 

func (v *NullableInt32) Set(val *int32)

func (*NullableInt32) UnmarshalJSON 

func (v *NullableInt32) UnmarshalJSON(src []byte) error

func (*NullableInt32) Unset 

func (v *NullableInt32) Unset()

type NullableInt64 

type NullableInt64 struct {
	// contains filtered or unexported fields
}

func NewNullableInt64 

func NewNullableInt64(val *int64) *NullableInt64

func (NullableInt64) Get 

func (v NullableInt64) Get() *int64

func (NullableInt64) IsSet 

func (v NullableInt64) IsSet() bool

func (NullableInt64) MarshalJSON 

func (v NullableInt64) MarshalJSON() ([]byte, error)

func (*NullableInt64) Set 

func (v *NullableInt64) Set(val *int64)

func (*NullableInt64) UnmarshalJSON 

func (v *NullableInt64) UnmarshalJSON(src []byte) error

func (*NullableInt64) Unset 

func (v *NullableInt64) Unset()

type NullablePluginInfo 

type NullablePluginInfo struct {
	// contains filtered or unexported fields
}

func NewNullablePluginInfo 

func NewNullablePluginInfo(val *PluginInfo) *NullablePluginInfo

func (NullablePluginInfo) Get 

func (v NullablePluginInfo) Get() *PluginInfo

func (NullablePluginInfo) IsSet 

func (v NullablePluginInfo) IsSet() bool

func (NullablePluginInfo) MarshalJSON 

func (v NullablePluginInfo) MarshalJSON() ([]byte, error)

func (*NullablePluginInfo) Set 

func (v *NullablePluginInfo) Set(val *PluginInfo)

func (*NullablePluginInfo) UnmarshalJSON 

func (v *NullablePluginInfo) UnmarshalJSON(src []byte) error

func (*NullablePluginInfo) Unset 

func (v *NullablePluginInfo) Unset()

type NullableServerInfo 

type NullableServerInfo struct {
	// contains filtered or unexported fields
}

func NewNullableServerInfo 

func NewNullableServerInfo(val *ServerInfo) *NullableServerInfo

func (NullableServerInfo) Get 

func (v NullableServerInfo) Get() *ServerInfo

func (NullableServerInfo) IsSet 

func (v NullableServerInfo) IsSet() bool

func (NullableServerInfo) MarshalJSON 

func (v NullableServerInfo) MarshalJSON() ([]byte, error)

func (*NullableServerInfo) Set 

func (v *NullableServerInfo) Set(val *ServerInfo)

func (*NullableServerInfo) UnmarshalJSON 

func (v *NullableServerInfo) UnmarshalJSON(src []byte) error

func (*NullableServerInfo) Unset 

func (v *NullableServerInfo) Unset()

type NullableString 

type NullableString struct {
	// contains filtered or unexported fields
}

func NewNullableString 

func NewNullableString(val *string) *NullableString

func (NullableString) Get 

func (v NullableString) Get() *string

func (NullableString) IsSet 

func (v NullableString) IsSet() bool

func (NullableString) MarshalJSON 

func (v NullableString) MarshalJSON() ([]byte, error)

func (*NullableString) Set 

func (v *NullableString) Set(val *string)

func (*NullableString) UnmarshalJSON 

func (v *NullableString) UnmarshalJSON(src []byte) error

func (*NullableString) Unset 

func (v *NullableString) Unset()

type NullableTaskInfo 

type NullableTaskInfo struct {
	// contains filtered or unexported fields
}

func NewNullableTaskInfo 

func NewNullableTaskInfo(val *TaskInfo) *NullableTaskInfo

func (NullableTaskInfo) Get 

func (v NullableTaskInfo) Get() *TaskInfo

func (NullableTaskInfo) IsSet 

func (v NullableTaskInfo) IsSet() bool

func (NullableTaskInfo) MarshalJSON 

func (v NullableTaskInfo) MarshalJSON() ([]byte, error)

func (*NullableTaskInfo) Set 

func (v *NullableTaskInfo) Set(val *TaskInfo)

func (*NullableTaskInfo) UnmarshalJSON 

func (v *NullableTaskInfo) UnmarshalJSON(src []byte) error

func (*NullableTaskInfo) Unset 

func (v *NullableTaskInfo) Unset()

type NullableTaskState 

type NullableTaskState struct {
	// contains filtered or unexported fields
}

func NewNullableTaskState 

func NewNullableTaskState(val *TaskState) *NullableTaskState

func (NullableTaskState) Get 

func (v NullableTaskState) Get() *TaskState

func (NullableTaskState) IsSet 

func (v NullableTaskState) IsSet() bool

func (NullableTaskState) MarshalJSON 

func (v NullableTaskState) MarshalJSON() ([]byte, error)

func (*NullableTaskState) Set 

func (v *NullableTaskState) Set(val *TaskState)

func (*NullableTaskState) UnmarshalJSON 

func (v *NullableTaskState) UnmarshalJSON(src []byte) error

func (*NullableTaskState) Unset 

func (v *NullableTaskState) Unset()

type NullableTime 

type NullableTime struct {
	// contains filtered or unexported fields
}

func NewNullableTime 

func NewNullableTime(val *time.Time) *NullableTime

func (NullableTime) Get 

func (v NullableTime) Get() *time.Time

func (NullableTime) IsSet 

func (v NullableTime) IsSet() bool

func (NullableTime) MarshalJSON 

func (v NullableTime) MarshalJSON() ([]byte, error)

func (*NullableTime) Set 

func (v *NullableTime) Set(val *time.Time)

func (*NullableTime) UnmarshalJSON 

func (v *NullableTime) UnmarshalJSON(src []byte) error

func (*NullableTime) Unset 

func (v *NullableTime) Unset()

type PluginInfo 

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

PluginInfo struct for PluginInfo

func NewPluginInfo 

func NewPluginInfo() *PluginInfo

NewPluginInfo instantiates a new PluginInfo object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewPluginInfoWithDefaults 

func NewPluginInfoWithDefaults() *PluginInfo

NewPluginInfoWithDefaults instantiates a new PluginInfo object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*PluginInfo) GetClass 

func (o *PluginInfo) GetClass() string

GetClass returns the Class field value if set, zero value otherwise.

func (*PluginInfo) GetClassOk 

func (o *PluginInfo) GetClassOk() (*string, bool)

GetClassOk returns a tuple with the Class field value if set, nil otherwise and a boolean to check if the value has been set.

func (*PluginInfo) GetType 

func (o *PluginInfo) GetType() string

GetType returns the Type field value if set, zero value otherwise.

func (*PluginInfo) GetTypeOk 

func (o *PluginInfo) GetTypeOk() (*string, bool)

GetTypeOk returns a tuple with the Type field value if set, nil otherwise and a boolean to check if the value has been set.

func (*PluginInfo) GetVersion 

func (o *PluginInfo) GetVersion() string

GetVersion returns the Version field value if set, zero value otherwise.

func (*PluginInfo) GetVersionOk 

func (o *PluginInfo) GetVersionOk() (*string, bool)

GetVersionOk returns a tuple with the Version field value if set, nil otherwise and a boolean to check if the value has been set.

func (*PluginInfo) HasClass 

func (o *PluginInfo) HasClass() bool

HasClass returns a boolean if a field has been set.

func (*PluginInfo) HasType 

func (o *PluginInfo) HasType() bool

HasType returns a boolean if a field has been set.

func (*PluginInfo) HasVersion 

func (o *PluginInfo) HasVersion() bool

HasVersion returns a boolean if a field has been set.

func (PluginInfo) MarshalJSON 

func (o PluginInfo) MarshalJSON() ([]byte, error)

func (*PluginInfo) SetClass 

func (o *PluginInfo) SetClass(v string)

SetClass gets a reference to the given string and assigns it to the Class field.

func (*PluginInfo) SetType 

func (o *PluginInfo) SetType(v string)

SetType gets a reference to the given string and assigns it to the Type field.

func (*PluginInfo) SetVersion 

func (o *PluginInfo) SetVersion(v string)

SetVersion gets a reference to the given string and assigns it to the Version field.

func (PluginInfo) ToMap 

func (o PluginInfo) ToMap() (map[string]interface{}, error)

type ServerConfiguration 

type ServerConfiguration struct {
	URL         string
	Description string
	Variables   map[string]ServerVariable
}

ServerConfiguration stores the information about a server

type ServerConfigurations 

type ServerConfigurations []ServerConfiguration

ServerConfigurations stores multiple ServerConfiguration items

func (ServerConfigurations) URL 

func (sc ServerConfigurations) URL(index int, variables map[string]string) (string, error)

URL formats template on a index using given variables

type ServerInfo 

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

ServerInfo struct for ServerInfo

func NewServerInfo 

func NewServerInfo() *ServerInfo

NewServerInfo instantiates a new ServerInfo object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewServerInfoWithDefaults 

func NewServerInfoWithDefaults() *ServerInfo

NewServerInfoWithDefaults instantiates a new ServerInfo object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*ServerInfo) GetCommit 

func (o *ServerInfo) GetCommit() string

GetCommit returns the Commit field value if set, zero value otherwise.

func (*ServerInfo) GetCommitOk 

func (o *ServerInfo) GetCommitOk() (*string, bool)

GetCommitOk returns a tuple with the Commit field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ServerInfo) GetKafkaClusterId 

func (o *ServerInfo) GetKafkaClusterId() string

GetKafkaClusterId returns the KafkaClusterId field value if set, zero value otherwise.

func (*ServerInfo) GetKafkaClusterIdOk 

func (o *ServerInfo) GetKafkaClusterIdOk() (*string, bool)

GetKafkaClusterIdOk returns a tuple with the KafkaClusterId field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ServerInfo) GetVersion 

func (o *ServerInfo) GetVersion() string

GetVersion returns the Version field value if set, zero value otherwise.

func (*ServerInfo) GetVersionOk 

func (o *ServerInfo) GetVersionOk() (*string, bool)

GetVersionOk returns a tuple with the Version field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ServerInfo) HasCommit 

func (o *ServerInfo) HasCommit() bool

HasCommit returns a boolean if a field has been set.

func (*ServerInfo) HasKafkaClusterId 

func (o *ServerInfo) HasKafkaClusterId() bool

HasKafkaClusterId returns a boolean if a field has been set.

func (*ServerInfo) HasVersion 

func (o *ServerInfo) HasVersion() bool

HasVersion returns a boolean if a field has been set.

func (ServerInfo) MarshalJSON 

func (o ServerInfo) MarshalJSON() ([]byte, error)

func (*ServerInfo) SetCommit 

func (o *ServerInfo) SetCommit(v string)

SetCommit gets a reference to the given string and assigns it to the Commit field.

func (*ServerInfo) SetKafkaClusterId 

func (o *ServerInfo) SetKafkaClusterId(v string)

SetKafkaClusterId gets a reference to the given string and assigns it to the KafkaClusterId field.

func (*ServerInfo) SetVersion 

func (o *ServerInfo) SetVersion(v string)

SetVersion gets a reference to the given string and assigns it to the Version field.

func (ServerInfo) ToMap 

func (o ServerInfo) ToMap() (map[string]interface{}, error)

type ServerVariable 

type ServerVariable struct {
	Description  string
	DefaultValue string
	EnumValues   []string
}

ServerVariable stores the information about a server variable

type TaskInfo 

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

TaskInfo struct for TaskInfo

func NewTaskInfo 

func NewTaskInfo() *TaskInfo

NewTaskInfo instantiates a new TaskInfo object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewTaskInfoWithDefaults 

func NewTaskInfoWithDefaults() *TaskInfo

NewTaskInfoWithDefaults instantiates a new TaskInfo object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*TaskInfo) GetConfig 

func (o *TaskInfo) GetConfig() map[string]string

GetConfig returns the Config field value if set, zero value otherwise.

func (*TaskInfo) GetConfigOk 

func (o *TaskInfo) GetConfigOk() (*map[string]string, bool)

GetConfigOk returns a tuple with the Config field value if set, nil otherwise and a boolean to check if the value has been set.

func (*TaskInfo) GetId 

func (o *TaskInfo) GetId() ConnectorTaskId

GetId returns the Id field value if set, zero value otherwise.

func (*TaskInfo) GetIdOk 

func (o *TaskInfo) GetIdOk() (*ConnectorTaskId, bool)

GetIdOk returns a tuple with the Id field value if set, nil otherwise and a boolean to check if the value has been set.

func (*TaskInfo) HasConfig 

func (o *TaskInfo) HasConfig() bool

HasConfig returns a boolean if a field has been set.

func (*TaskInfo) HasId 

func (o *TaskInfo) HasId() bool

HasId returns a boolean if a field has been set.

func (TaskInfo) MarshalJSON 

func (o TaskInfo) MarshalJSON() ([]byte, error)

func (*TaskInfo) SetConfig 

func (o *TaskInfo) SetConfig(v map[string]string)

SetConfig gets a reference to the given map[string]string and assigns it to the Config field.

func (*TaskInfo) SetId 

func (o *TaskInfo) SetId(v ConnectorTaskId)

SetId gets a reference to the given ConnectorTaskId and assigns it to the Id field.

func (TaskInfo) ToMap 

func (o TaskInfo) ToMap() (map[string]interface{}, error)

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 struct for TaskState

func NewTaskState 

func NewTaskState() *TaskState

NewTaskState instantiates a new TaskState object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewTaskStateWithDefaults 

func NewTaskStateWithDefaults() *TaskState

NewTaskStateWithDefaults instantiates a new TaskState object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*TaskState) GetId 

func (o *TaskState) GetId() int32

GetId returns the Id field value if set, zero value otherwise.

func (*TaskState) GetIdOk 

func (o *TaskState) GetIdOk() (*int32, bool)

GetIdOk returns a tuple with the Id field value if set, nil otherwise and a boolean to check if the value has been set.

func (*TaskState) GetMsg 

func (o *TaskState) GetMsg() string

GetMsg returns the Msg field value if set, zero value otherwise.

func (*TaskState) GetMsgOk 

func (o *TaskState) GetMsgOk() (*string, bool)

GetMsgOk returns a tuple with the Msg field value if set, nil otherwise and a boolean to check if the value has been set.

func (*TaskState) GetState 

func (o *TaskState) GetState() string

GetState returns the State field value if set, zero value otherwise.

func (*TaskState) GetStateOk 

func (o *TaskState) GetStateOk() (*string, bool)

GetStateOk returns a tuple with the State field value if set, nil otherwise and a boolean to check if the value has been set.

func (*TaskState) GetTrace 

func (o *TaskState) GetTrace() string

GetTrace returns the Trace field value if set, zero value otherwise.

func (*TaskState) GetTraceOk 

func (o *TaskState) GetTraceOk() (*string, bool)

GetTraceOk returns a tuple with the Trace field value if set, nil otherwise and a boolean to check if the value has been set.

func (*TaskState) GetWorkerId 

func (o *TaskState) GetWorkerId() string

GetWorkerId returns the WorkerId field value if set, zero value otherwise.

func (*TaskState) GetWorkerIdOk 

func (o *TaskState) GetWorkerIdOk() (*string, bool)

GetWorkerIdOk returns a tuple with the WorkerId field value if set, nil otherwise and a boolean to check if the value has been set.

func (*TaskState) HasId 

func (o *TaskState) HasId() bool

HasId returns a boolean if a field has been set.

func (*TaskState) HasMsg 

func (o *TaskState) HasMsg() bool

HasMsg returns a boolean if a field has been set.

func (*TaskState) HasState 

func (o *TaskState) HasState() bool

HasState returns a boolean if a field has been set.

func (*TaskState) HasTrace 

func (o *TaskState) HasTrace() bool

HasTrace returns a boolean if a field has been set.

func (*TaskState) HasWorkerId 

func (o *TaskState) HasWorkerId() bool

HasWorkerId returns a boolean if a field has been set.

func (TaskState) MarshalJSON 

func (o TaskState) MarshalJSON() ([]byte, error)

func (*TaskState) SetId 

func (o *TaskState) SetId(v int32)

SetId gets a reference to the given int32 and assigns it to the Id field.

func (*TaskState) SetMsg 

func (o *TaskState) SetMsg(v string)

SetMsg gets a reference to the given string and assigns it to the Msg field.

func (*TaskState) SetState 

func (o *TaskState) SetState(v string)

SetState gets a reference to the given string and assigns it to the State field.

func (*TaskState) SetTrace 

func (o *TaskState) SetTrace(v string)

SetTrace gets a reference to the given string and assigns it to the Trace field.

func (*TaskState) SetWorkerId 

func (o *TaskState) SetWorkerId(v string)

SetWorkerId gets a reference to the given string and assigns it to the WorkerId field.

func (TaskState) ToMap 

func (o TaskState) ToMap() (map[string]interface{}, error)

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.