v1

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: May 8, 2024 License: Apache-2.0 Imports: 22 Imported by: 4

README

Go API client for v1

REST API for managing connectors

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.

Installation

Install the following dependencies:

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

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

import sw "./v1"

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 sw.ContextServerIndex of type int.

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

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

ctx := context.WithValue(context.Background(), sw.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 sw.ContextOperationServerIndices and sw.ContextOperationServerVariables context maps.

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

Documentation for API Endpoints

All URIs are relative to https://api.confluent.cloud

Class Method HTTP request Description
ConnectorsConnectV1Api CreateConnectv1Connector Post /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connectors Create a Connector
ConnectorsConnectV1Api CreateOrUpdateConnectv1ConnectorConfig Put /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connectors/{connector_name}/config Create or Update a Connector Configuration
ConnectorsConnectV1Api DeleteConnectv1Connector Delete /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connectors/{connector_name} Delete a Connector
ConnectorsConnectV1Api GetConnectv1ConnectorConfig Get /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connectors/{connector_name}/config Read a Connector Configuration
ConnectorsConnectV1Api ListConnectv1Connectors Get /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connectors List of Connectors
ConnectorsConnectV1Api ListConnectv1ConnectorsWithExpansions Get /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connectors?expand=info,status,id List of Connectors with Expansions
ConnectorsConnectV1Api ReadConnectv1Connector Get /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connectors/{connector_name} Read a Connector
LifecycleConnectV1Api PauseConnectv1Connector Put /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connectors/{connector_name}/pause Pause a Connector
LifecycleConnectV1Api ResumeConnectv1Connector Put /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connectors/{connector_name}/resume Resume a Connector
ManagedConnectorPluginsConnectV1Api ListConnectv1ConnectorPlugins Get /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connector-plugins List of Managed Connector plugins
ManagedConnectorPluginsConnectV1Api ValidateConnectv1ConnectorPlugin Put /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connector-plugins/{plugin_name}/config/validate Validate a Managed Connector Plugin
OffsetsConnectV1Api AlterConnectv1ConnectorOffsetsRequest Post /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connectors/{connector_name}/offsets/request Request to Alter the Connector Offsets
OffsetsConnectV1Api GetConnectv1ConnectorOffsets Get /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connectors/{connector_name}/offsets Get a Connector Offsets
OffsetsConnectV1Api GetConnectv1ConnectorOffsetsRequestStatus Get /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connectors/{connector_name}/offsets/request/status Get the Status of Altered Offset Request
StatusConnectV1Api ListConnectv1ConnectorTasks Get /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connectors/{connector_name}/tasks List of Connector Tasks
StatusConnectV1Api ReadConnectv1ConnectorStatus Get /connect/v1/environments/{environment_id}/clusters/{kafka_cluster_id}/connectors/{connector_name}/status Read a Connector Status

Documentation For Models

Documentation For Authorization

cloud-api-key
  • Type: HTTP basic authentication

Example

auth := context.WithValue(context.Background(), sw.ContextBasicAuth, sw.BasicAuth{
    UserName: "username",
    Password: "password",
})
r, err := client.Service.Operation(auth, args)
confluent-sts-access-token
  • Type: OAuth
  • Flow: application
  • Authorization URL:
  • Scopes: N/A

Example

auth := context.WithValue(context.Background(), sw.ContextAccessToken, "ACCESSTOKENSTRING")
r, err := client.Service.Operation(auth, args)

Or via OAuth2 module to automatically refresh tokens and perform user authentication.

import "golang.org/x/oauth2"

/* Perform OAuth2 round trip request and obtain a token */

tokenSource := oauth2cfg.TokenSource(createContext(httpClient), &token)
auth := context.WithValue(oauth2.NoContext, sw.ContextOAuth2, tokenSource)
r, err := client.Service.Operation(auth, args)

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

[email protected]

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ContextOAuth2 takes an oauth2.TokenSource as authentication for the request.
	ContextOAuth2 = contextKey("token")

	// ContextBasicAuth takes BasicAuth as authentication for the request.
	ContextBasicAuth = contextKey("basic")

	// ContextAccessToken takes a string oauth2 access token as authentication for the request.
	ContextAccessToken = contextKey("accesstoken")

	// ContextAPIKeys takes a string apikey as authentication for the request
	ContextAPIKeys = contextKey("apiKeys")

	// ContextHttpSignatureAuth takes HttpSignatureAuth as authentication for the request.
	ContextHttpSignatureAuth = contextKey("httpsignature")

	// 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 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 {
	ConnectorsConnectV1Api ConnectorsConnectV1Api

	LifecycleConnectV1Api LifecycleConnectV1Api

	ManagedConnectorPluginsConnectV1Api ManagedConnectorPluginsConnectV1Api

	OffsetsConnectV1Api OffsetsConnectV1Api

	StatusConnectV1Api StatusConnectV1Api
	// contains filtered or unexported fields
}

APIClient manages communication with the Kafka Connect APIs API v1.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 ApiAlterConnectv1ConnectorOffsetsRequestRequest added in v0.5.0 

type ApiAlterConnectv1ConnectorOffsetsRequestRequest struct {
	ApiService OffsetsConnectV1Api
	// contains filtered or unexported fields
}

func (ApiAlterConnectv1ConnectorOffsetsRequestRequest) ConnectV1AlterOffsetRequest added in v0.5.0 

func (r ApiAlterConnectv1ConnectorOffsetsRequestRequest) ConnectV1AlterOffsetRequest(connectV1AlterOffsetRequest ConnectV1AlterOffsetRequest) ApiAlterConnectv1ConnectorOffsetsRequestRequest

func (ApiAlterConnectv1ConnectorOffsetsRequestRequest) Execute added in v0.5.0 

func (r ApiAlterConnectv1ConnectorOffsetsRequestRequest) Execute() (ConnectV1AlterOffsetRequestInfo, *_nethttp.Response, error)

type ApiCreateConnectv1ConnectorRequest 

type ApiCreateConnectv1ConnectorRequest struct {
	ApiService ConnectorsConnectV1Api
	// contains filtered or unexported fields
}

func (ApiCreateConnectv1ConnectorRequest) Execute 

func (r ApiCreateConnectv1ConnectorRequest) Execute() (ConnectV1ConnectorWithOffsets, *_nethttp.Response, error)

func (ApiCreateConnectv1ConnectorRequest) InlineObject 

func (r ApiCreateConnectv1ConnectorRequest) InlineObject(inlineObject InlineObject) ApiCreateConnectv1ConnectorRequest

type ApiCreateOrUpdateConnectv1ConnectorConfigRequest 

type ApiCreateOrUpdateConnectv1ConnectorConfigRequest struct {
	ApiService ConnectorsConnectV1Api
	// contains filtered or unexported fields
}

func (ApiCreateOrUpdateConnectv1ConnectorConfigRequest) Execute 

func (r ApiCreateOrUpdateConnectv1ConnectorConfigRequest) Execute() (ConnectV1Connector, *_nethttp.Response, error)

func (ApiCreateOrUpdateConnectv1ConnectorConfigRequest) RequestBody 

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

Configuration parameters for the connector. All values should be strings.

type ApiDeleteConnectv1ConnectorRequest 

type ApiDeleteConnectv1ConnectorRequest struct {
	ApiService ConnectorsConnectV1Api
	// contains filtered or unexported fields
}

func (ApiDeleteConnectv1ConnectorRequest) Execute 

func (r ApiDeleteConnectv1ConnectorRequest) Execute() (InlineResponse200, *_nethttp.Response, error)

type ApiGetConnectv1ConnectorConfigRequest 

type ApiGetConnectv1ConnectorConfigRequest struct {
	ApiService ConnectorsConnectV1Api
	// contains filtered or unexported fields
}

func (ApiGetConnectv1ConnectorConfigRequest) Execute 

func (r ApiGetConnectv1ConnectorConfigRequest) Execute() (map[string]string, *_nethttp.Response, error)

type ApiGetConnectv1ConnectorOffsetsRequest added in v0.5.0 

type ApiGetConnectv1ConnectorOffsetsRequest struct {
	ApiService OffsetsConnectV1Api
	// contains filtered or unexported fields
}

func (ApiGetConnectv1ConnectorOffsetsRequest) Execute added in v0.5.0 

func (r ApiGetConnectv1ConnectorOffsetsRequest) Execute() (ConnectV1ConnectorOffsets, *_nethttp.Response, error)

type ApiGetConnectv1ConnectorOffsetsRequestStatusRequest added in v0.5.0 

type ApiGetConnectv1ConnectorOffsetsRequestStatusRequest struct {
	ApiService OffsetsConnectV1Api
	// contains filtered or unexported fields
}

func (ApiGetConnectv1ConnectorOffsetsRequestStatusRequest) Execute added in v0.5.0 

func (r ApiGetConnectv1ConnectorOffsetsRequestStatusRequest) Execute() (ConnectV1AlterOffsetStatus, *_nethttp.Response, error)

type ApiListConnectv1ConnectorPluginsRequest 

type ApiListConnectv1ConnectorPluginsRequest struct {
	ApiService ManagedConnectorPluginsConnectV1Api
	// contains filtered or unexported fields
}

func (ApiListConnectv1ConnectorPluginsRequest) Execute 

func (r ApiListConnectv1ConnectorPluginsRequest) Execute() ([]InlineResponse2002, *_nethttp.Response, error)

type ApiListConnectv1ConnectorTasksRequest 

type ApiListConnectv1ConnectorTasksRequest struct {
	ApiService StatusConnectV1Api
	// contains filtered or unexported fields
}

func (ApiListConnectv1ConnectorTasksRequest) Execute 

func (r ApiListConnectv1ConnectorTasksRequest) Execute() ([]map[string]interface{}, *_nethttp.Response, error)

type ApiListConnectv1ConnectorsRequest 

type ApiListConnectv1ConnectorsRequest struct {
	ApiService ConnectorsConnectV1Api
	// contains filtered or unexported fields
}

func (ApiListConnectv1ConnectorsRequest) Execute 

func (r ApiListConnectv1ConnectorsRequest) Execute() ([]string, *_nethttp.Response, error)

type ApiListConnectv1ConnectorsWithExpansionsRequest 

type ApiListConnectv1ConnectorsWithExpansionsRequest struct {
	ApiService ConnectorsConnectV1Api
	// contains filtered or unexported fields
}

func (ApiListConnectv1ConnectorsWithExpansionsRequest) Execute 

func (r ApiListConnectv1ConnectorsWithExpansionsRequest) Execute() (map[string]ConnectV1ConnectorExpansion, *_nethttp.Response, error)

func (ApiListConnectv1ConnectorsWithExpansionsRequest) Expand 

func (r ApiListConnectv1ConnectorsWithExpansionsRequest) Expand(expand string) ApiListConnectv1ConnectorsWithExpansionsRequest

- id : Returns metadata of each connector such as id and id type. - info : Returns metadata of each connector such as the configuration, task information, and type of connector. - status : Returns additional state information of each connector including their status and tasks.

type ApiPauseConnectv1ConnectorRequest 

type ApiPauseConnectv1ConnectorRequest struct {
	ApiService LifecycleConnectV1Api
	// contains filtered or unexported fields
}

func (ApiPauseConnectv1ConnectorRequest) Execute 

func (r ApiPauseConnectv1ConnectorRequest) Execute() (*_nethttp.Response, error)

type ApiReadConnectv1ConnectorRequest 

type ApiReadConnectv1ConnectorRequest struct {
	ApiService ConnectorsConnectV1Api
	// contains filtered or unexported fields
}

func (ApiReadConnectv1ConnectorRequest) Execute 

func (r ApiReadConnectv1ConnectorRequest) Execute() (ConnectV1Connector, *_nethttp.Response, error)

type ApiReadConnectv1ConnectorStatusRequest 

type ApiReadConnectv1ConnectorStatusRequest struct {
	ApiService StatusConnectV1Api
	// contains filtered or unexported fields
}

func (ApiReadConnectv1ConnectorStatusRequest) Execute 

func (r ApiReadConnectv1ConnectorStatusRequest) Execute() (InlineResponse2001, *_nethttp.Response, error)

type ApiResumeConnectv1ConnectorRequest 

type ApiResumeConnectv1ConnectorRequest struct {
	ApiService LifecycleConnectV1Api
	// contains filtered or unexported fields
}

func (ApiResumeConnectv1ConnectorRequest) Execute 

func (r ApiResumeConnectv1ConnectorRequest) Execute() (*_nethttp.Response, error)

type ApiValidateConnectv1ConnectorPluginRequest 

type ApiValidateConnectv1ConnectorPluginRequest struct {
	ApiService ManagedConnectorPluginsConnectV1Api
	// contains filtered or unexported fields
}

func (ApiValidateConnectv1ConnectorPluginRequest) Execute 

func (r ApiValidateConnectv1ConnectorPluginRequest) Execute() (InlineResponse2003, *_nethttp.Response, error)

func (ApiValidateConnectv1ConnectorPluginRequest) RequestBody 

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

Configuration parameters for the connector. All values should be strings.

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 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 ConnectV1AlterOffsetRequest added in v0.5.0 

type ConnectV1AlterOffsetRequest struct {
	Type ConnectV1AlterOffsetRequestType `json:"type,omitempty"`
	// Array of offsets which are categorised into partitions.
	Offsets *[]map[string]interface{} `json:"offsets,omitempty"`
}

ConnectV1AlterOffsetRequest Request to alter the offset of a connector. The offsets parameter is options for DELETE type.

func NewConnectV1AlterOffsetRequest added in v0.5.0 

func NewConnectV1AlterOffsetRequest(type_ ConnectV1AlterOffsetRequestType) *ConnectV1AlterOffsetRequest

NewConnectV1AlterOffsetRequest instantiates a new ConnectV1AlterOffsetRequest 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 NewConnectV1AlterOffsetRequestWithDefaults added in v0.5.0 

func NewConnectV1AlterOffsetRequestWithDefaults() *ConnectV1AlterOffsetRequest

NewConnectV1AlterOffsetRequestWithDefaults instantiates a new ConnectV1AlterOffsetRequest 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 (*ConnectV1AlterOffsetRequest) GetOffsets added in v0.5.0 

func (o *ConnectV1AlterOffsetRequest) GetOffsets() []map[string]interface{}

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

func (*ConnectV1AlterOffsetRequest) GetOffsetsOk added in v0.5.0 

func (o *ConnectV1AlterOffsetRequest) GetOffsetsOk() (*[]map[string]interface{}, 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 (*ConnectV1AlterOffsetRequest) GetType added in v0.5.0 

func (o *ConnectV1AlterOffsetRequest) GetType() ConnectV1AlterOffsetRequestType

GetType returns the Type field value

func (*ConnectV1AlterOffsetRequest) GetTypeOk added in v0.5.0 

func (o *ConnectV1AlterOffsetRequest) GetTypeOk() (*ConnectV1AlterOffsetRequestType, bool)

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

func (*ConnectV1AlterOffsetRequest) HasOffsets added in v0.5.0 

func (o *ConnectV1AlterOffsetRequest) HasOffsets() bool

HasOffsets returns a boolean if a field has been set.

func (ConnectV1AlterOffsetRequest) MarshalJSON added in v0.5.0 

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

func (*ConnectV1AlterOffsetRequest) Redact added in v0.5.0 

func (o *ConnectV1AlterOffsetRequest) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1AlterOffsetRequest) SetOffsets added in v0.5.0 

func (o *ConnectV1AlterOffsetRequest) SetOffsets(v []map[string]interface{})

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

func (*ConnectV1AlterOffsetRequest) SetType added in v0.5.0 

func (o *ConnectV1AlterOffsetRequest) SetType(v ConnectV1AlterOffsetRequestType)

SetType sets field value

type ConnectV1AlterOffsetRequestInfo added in v0.5.0 

type ConnectV1AlterOffsetRequestInfo struct {
	// The ID of the connector.
	Id string `json:"id,omitempty"`
	// The name of the connector.
	Name string `json:"name,omitempty"`
	// Array of offsets which are categorised into partitions.
	Offsets *[]map[string]interface{} `json:"offsets,omitempty"`
	// The time at which the request was made. The time is in UTC, ISO 8601 format.
	RequestedAt time.Time                       `json:"requested_at,omitempty"`
	Type        ConnectV1AlterOffsetRequestType `json:"type,omitempty"`
}

ConnectV1AlterOffsetRequestInfo The request made to alter offsets.

func NewConnectV1AlterOffsetRequestInfo added in v0.5.0 

func NewConnectV1AlterOffsetRequestInfo(id string, name string, requestedAt time.Time, type_ ConnectV1AlterOffsetRequestType) *ConnectV1AlterOffsetRequestInfo

NewConnectV1AlterOffsetRequestInfo instantiates a new ConnectV1AlterOffsetRequestInfo 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 NewConnectV1AlterOffsetRequestInfoWithDefaults added in v0.5.0 

func NewConnectV1AlterOffsetRequestInfoWithDefaults() *ConnectV1AlterOffsetRequestInfo

NewConnectV1AlterOffsetRequestInfoWithDefaults instantiates a new ConnectV1AlterOffsetRequestInfo 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 (*ConnectV1AlterOffsetRequestInfo) GetId added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) GetId() string

GetId returns the Id field value

func (*ConnectV1AlterOffsetRequestInfo) GetIdOk added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) GetIdOk() (*string, bool)

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

func (*ConnectV1AlterOffsetRequestInfo) GetName added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) GetName() string

GetName returns the Name field value

func (*ConnectV1AlterOffsetRequestInfo) GetNameOk added in v0.5.0 

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

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

func (*ConnectV1AlterOffsetRequestInfo) GetOffsets added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) GetOffsets() []map[string]interface{}

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

func (*ConnectV1AlterOffsetRequestInfo) GetOffsetsOk added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) GetOffsetsOk() (*[]map[string]interface{}, 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 (*ConnectV1AlterOffsetRequestInfo) GetRequestedAt added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) GetRequestedAt() time.Time

GetRequestedAt returns the RequestedAt field value

func (*ConnectV1AlterOffsetRequestInfo) GetRequestedAtOk added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) GetRequestedAtOk() (*time.Time, bool)

GetRequestedAtOk returns a tuple with the RequestedAt field value and a boolean to check if the value has been set.

func (*ConnectV1AlterOffsetRequestInfo) GetType added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) GetType() ConnectV1AlterOffsetRequestType

GetType returns the Type field value

func (*ConnectV1AlterOffsetRequestInfo) GetTypeOk added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) GetTypeOk() (*ConnectV1AlterOffsetRequestType, bool)

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

func (*ConnectV1AlterOffsetRequestInfo) HasOffsets added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) HasOffsets() bool

HasOffsets returns a boolean if a field has been set.

func (ConnectV1AlterOffsetRequestInfo) MarshalJSON added in v0.5.0 

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

func (*ConnectV1AlterOffsetRequestInfo) Redact added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1AlterOffsetRequestInfo) SetId added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) SetId(v string)

SetId sets field value

func (*ConnectV1AlterOffsetRequestInfo) SetName added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) SetName(v string)

SetName sets field value

func (*ConnectV1AlterOffsetRequestInfo) SetOffsets added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) SetOffsets(v []map[string]interface{})

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

func (*ConnectV1AlterOffsetRequestInfo) SetRequestedAt added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) SetRequestedAt(v time.Time)

SetRequestedAt sets field value

func (*ConnectV1AlterOffsetRequestInfo) SetType added in v0.5.0 

func (o *ConnectV1AlterOffsetRequestInfo) SetType(v ConnectV1AlterOffsetRequestType)

SetType sets field value

type ConnectV1AlterOffsetRequestType added in v0.5.0 

type ConnectV1AlterOffsetRequestType string

ConnectV1AlterOffsetRequestType The type of alter operation. PATCH will update the offset to the provided values. The update will only happen for the partitions provided in the request. DELETE will delete the offset for the provided partitions and reset them back to the base state. It is as if, a fresh new connector was created. For sink connectors PATCH/DELETE will move the offsets to the provided point in the topic partition. If the offset provided is not present in the topic partition it will by default reset to the earliest offset in the topic partition. For source connectors, post PATCH/DELETE the connector will attempt to read from the position defined in the altered offsets. 

const (
	PATCH  ConnectV1AlterOffsetRequestType = "PATCH"
	DELETE ConnectV1AlterOffsetRequestType = "DELETE"
)

List of connect.v1.AlterOffsetRequestType

func NewConnectV1AlterOffsetRequestTypeFromValue added in v0.5.0 

func NewConnectV1AlterOffsetRequestTypeFromValue(v string) (*ConnectV1AlterOffsetRequestType, error)

NewConnectV1AlterOffsetRequestTypeFromValue returns a pointer to a valid ConnectV1AlterOffsetRequestType for the value passed as argument, or an error if the value passed is not allowed by the enum

func (ConnectV1AlterOffsetRequestType) IsValid added in v0.5.0 

func (v ConnectV1AlterOffsetRequestType) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (ConnectV1AlterOffsetRequestType) Ptr added in v0.5.0 

func (v ConnectV1AlterOffsetRequestType) Ptr() *ConnectV1AlterOffsetRequestType

Ptr returns reference to connect.v1.AlterOffsetRequestType value

func (*ConnectV1AlterOffsetRequestType) UnmarshalJSON added in v0.5.0 

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

type ConnectV1AlterOffsetStatus added in v0.5.0 

type ConnectV1AlterOffsetStatus struct {
	Request ConnectV1AlterOffsetRequestInfo  `json:"request,omitempty"`
	Status  ConnectV1AlterOffsetStatusStatus `json:"status,omitempty"`
	// Array of offsets which are categorised into partitions.
	PreviousOffsets *[]map[string]interface{} `json:"previous_offsets,omitempty"`
	// The time at which the offsets were applied. The time is in UTC, ISO 8601 format.
	AppliedAt NullableTime `json:"applied_at,omitempty"`
}

ConnectV1AlterOffsetStatus Status of the alter offset operation. The previous offsets in the response is the offsets that the connector last processed, before the offsets were altered, via a patch or delete operation.

func NewConnectV1AlterOffsetStatus added in v0.5.0 

func NewConnectV1AlterOffsetStatus(request ConnectV1AlterOffsetRequestInfo, status ConnectV1AlterOffsetStatusStatus) *ConnectV1AlterOffsetStatus

NewConnectV1AlterOffsetStatus instantiates a new ConnectV1AlterOffsetStatus 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 NewConnectV1AlterOffsetStatusWithDefaults added in v0.5.0 

func NewConnectV1AlterOffsetStatusWithDefaults() *ConnectV1AlterOffsetStatus

NewConnectV1AlterOffsetStatusWithDefaults instantiates a new ConnectV1AlterOffsetStatus 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 (*ConnectV1AlterOffsetStatus) GetAppliedAt added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) GetAppliedAt() time.Time

GetAppliedAt returns the AppliedAt field value if set, zero value otherwise (both if not set or set to explicit null).

func (*ConnectV1AlterOffsetStatus) GetAppliedAtOk added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) GetAppliedAtOk() (*time.Time, bool)

GetAppliedAtOk returns a tuple with the AppliedAt field value if set, nil otherwise and a boolean to check if the value has been set. NOTE: If the value is an explicit nil, `nil, true` will be returned

func (*ConnectV1AlterOffsetStatus) GetPreviousOffsets added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) GetPreviousOffsets() []map[string]interface{}

GetPreviousOffsets returns the PreviousOffsets field value if set, zero value otherwise.

func (*ConnectV1AlterOffsetStatus) GetPreviousOffsetsOk added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) GetPreviousOffsetsOk() (*[]map[string]interface{}, bool)

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

func (*ConnectV1AlterOffsetStatus) GetRequest added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) GetRequest() ConnectV1AlterOffsetRequestInfo

GetRequest returns the Request field value

func (*ConnectV1AlterOffsetStatus) GetRequestOk added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) GetRequestOk() (*ConnectV1AlterOffsetRequestInfo, bool)

GetRequestOk returns a tuple with the Request field value and a boolean to check if the value has been set.

func (*ConnectV1AlterOffsetStatus) GetStatus added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) GetStatus() ConnectV1AlterOffsetStatusStatus

GetStatus returns the Status field value

func (*ConnectV1AlterOffsetStatus) GetStatusOk added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) GetStatusOk() (*ConnectV1AlterOffsetStatusStatus, bool)

GetStatusOk returns a tuple with the Status field value and a boolean to check if the value has been set.

func (*ConnectV1AlterOffsetStatus) HasAppliedAt added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) HasAppliedAt() bool

HasAppliedAt returns a boolean if a field has been set.

func (*ConnectV1AlterOffsetStatus) HasPreviousOffsets added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) HasPreviousOffsets() bool

HasPreviousOffsets returns a boolean if a field has been set.

func (ConnectV1AlterOffsetStatus) MarshalJSON added in v0.5.0 

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

func (*ConnectV1AlterOffsetStatus) Redact added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1AlterOffsetStatus) SetAppliedAt added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) SetAppliedAt(v time.Time)

SetAppliedAt gets a reference to the given NullableTime and assigns it to the AppliedAt field.

func (*ConnectV1AlterOffsetStatus) SetAppliedAtNil added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) SetAppliedAtNil()

SetAppliedAtNil sets the value for AppliedAt to be an explicit nil

func (*ConnectV1AlterOffsetStatus) SetPreviousOffsets added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) SetPreviousOffsets(v []map[string]interface{})

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

func (*ConnectV1AlterOffsetStatus) SetRequest added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) SetRequest(v ConnectV1AlterOffsetRequestInfo)

SetRequest sets field value

func (*ConnectV1AlterOffsetStatus) SetStatus added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) SetStatus(v ConnectV1AlterOffsetStatusStatus)

SetStatus sets field value

func (*ConnectV1AlterOffsetStatus) UnsetAppliedAt added in v0.5.0 

func (o *ConnectV1AlterOffsetStatus) UnsetAppliedAt()

UnsetAppliedAt ensures that no value is present for AppliedAt, not even an explicit nil

type ConnectV1AlterOffsetStatusStatus added in v0.5.0 

type ConnectV1AlterOffsetStatusStatus struct {
	// The phase of the alter offset operation.   PENDING: The offset alter operation is in progress.  APPLIED: The offset alter operation has been applied to the connector.  FAILED:  The offset alter operation has failed to be applied to the connector.
	Phase string `json:"phase,omitempty"`
	// An info message from the alter offset operation.
	Message *string `json:"message,omitempty"`
}

ConnectV1AlterOffsetStatusStatus The response of the alter offsets operation.

func NewConnectV1AlterOffsetStatusStatus added in v0.5.0 

func NewConnectV1AlterOffsetStatusStatus(phase string) *ConnectV1AlterOffsetStatusStatus

NewConnectV1AlterOffsetStatusStatus instantiates a new ConnectV1AlterOffsetStatusStatus 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 NewConnectV1AlterOffsetStatusStatusWithDefaults added in v0.5.0 

func NewConnectV1AlterOffsetStatusStatusWithDefaults() *ConnectV1AlterOffsetStatusStatus

NewConnectV1AlterOffsetStatusStatusWithDefaults instantiates a new ConnectV1AlterOffsetStatusStatus 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 (*ConnectV1AlterOffsetStatusStatus) GetMessage added in v0.5.0 

func (o *ConnectV1AlterOffsetStatusStatus) GetMessage() string

GetMessage returns the Message field value if set, zero value otherwise.

func (*ConnectV1AlterOffsetStatusStatus) GetMessageOk added in v0.5.0 

func (o *ConnectV1AlterOffsetStatusStatus) GetMessageOk() (*string, bool)

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

func (*ConnectV1AlterOffsetStatusStatus) GetPhase added in v0.5.0 

func (o *ConnectV1AlterOffsetStatusStatus) GetPhase() string

GetPhase returns the Phase field value

func (*ConnectV1AlterOffsetStatusStatus) GetPhaseOk added in v0.5.0 

func (o *ConnectV1AlterOffsetStatusStatus) GetPhaseOk() (*string, bool)

GetPhaseOk returns a tuple with the Phase field value and a boolean to check if the value has been set.

func (*ConnectV1AlterOffsetStatusStatus) HasMessage added in v0.5.0 

func (o *ConnectV1AlterOffsetStatusStatus) HasMessage() bool

HasMessage returns a boolean if a field has been set.

func (ConnectV1AlterOffsetStatusStatus) MarshalJSON added in v0.5.0 

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

func (*ConnectV1AlterOffsetStatusStatus) Redact added in v0.5.0 

func (o *ConnectV1AlterOffsetStatusStatus) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1AlterOffsetStatusStatus) SetMessage added in v0.5.0 

func (o *ConnectV1AlterOffsetStatusStatus) SetMessage(v string)

SetMessage gets a reference to the given string and assigns it to the Message field.

func (*ConnectV1AlterOffsetStatusStatus) SetPhase added in v0.5.0 

func (o *ConnectV1AlterOffsetStatusStatus) SetPhase(v string)

SetPhase sets field value

type ConnectV1Connector 

type ConnectV1Connector struct {
	// Name of the connector
	Name string `json:"name,omitempty"`
	// Configuration parameters for the connector. These configurations are the minimum set of key-value pairs (KVP) which can be used to define how the connector connects Kafka to the external system. Some of these KVPs are common to all the connectors, such as connection parameters to Kafka, connector metadata, etc. The list of common connector configurations is as follows  - cloud.environment - cloud.provider - connector.class - kafka.api.key - kafka.api.secret - kafka.endpoint - kafka.region - name  A specific connector such as `GcsSink` would have additional parameters such as `gcs.bucket.name`, `flush.size`, etc.
	Config map[string]string `json:"config,omitempty"`
	// List of active tasks generated by the connector
	Tasks *[]ConnectV1ConnectorTasks `json:"tasks,omitempty"`
	// Type of connector, sink or source
	Type *string `json:"type,omitempty"`
}

ConnectV1Connector struct for ConnectV1Connector

func NewConnectV1Connector 

func NewConnectV1Connector(name string, config map[string]string) *ConnectV1Connector

NewConnectV1Connector instantiates a new ConnectV1Connector 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 NewConnectV1ConnectorWithDefaults 

func NewConnectV1ConnectorWithDefaults() *ConnectV1Connector

NewConnectV1ConnectorWithDefaults instantiates a new ConnectV1Connector 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 (*ConnectV1Connector) GetConfig 

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

GetConfig returns the Config field value

func (*ConnectV1Connector) GetConfigOk 

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

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

func (*ConnectV1Connector) GetName 

func (o *ConnectV1Connector) GetName() string

GetName returns the Name field value

func (*ConnectV1Connector) GetNameOk 

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

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

func (*ConnectV1Connector) GetTasks 

func (o *ConnectV1Connector) GetTasks() []ConnectV1ConnectorTasks

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

func (*ConnectV1Connector) GetTasksOk 

func (o *ConnectV1Connector) GetTasksOk() (*[]ConnectV1ConnectorTasks, 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 (*ConnectV1Connector) GetType 

func (o *ConnectV1Connector) GetType() string

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

func (*ConnectV1Connector) GetTypeOk 

func (o *ConnectV1Connector) 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 (*ConnectV1Connector) HasTasks 

func (o *ConnectV1Connector) HasTasks() bool

HasTasks returns a boolean if a field has been set.

func (*ConnectV1Connector) HasType 

func (o *ConnectV1Connector) HasType() bool

HasType returns a boolean if a field has been set.

func (ConnectV1Connector) MarshalJSON 

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

func (*ConnectV1Connector) Redact 

func (o *ConnectV1Connector) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1Connector) SetConfig 

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

SetConfig sets field value

func (*ConnectV1Connector) SetName 

func (o *ConnectV1Connector) SetName(v string)

SetName sets field value

func (*ConnectV1Connector) SetTasks 

func (o *ConnectV1Connector) SetTasks(v []ConnectV1ConnectorTasks)

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

func (*ConnectV1Connector) SetType 

func (o *ConnectV1Connector) SetType(v string)

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

type ConnectV1ConnectorError 

type ConnectV1ConnectorError struct {
	Error *ConnectV1ConnectorErrorError `json:"error,omitempty"`
}

ConnectV1ConnectorError struct for ConnectV1ConnectorError

func NewConnectV1ConnectorError 

func NewConnectV1ConnectorError() *ConnectV1ConnectorError

NewConnectV1ConnectorError instantiates a new ConnectV1ConnectorError 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 NewConnectV1ConnectorErrorWithDefaults 

func NewConnectV1ConnectorErrorWithDefaults() *ConnectV1ConnectorError

NewConnectV1ConnectorErrorWithDefaults instantiates a new ConnectV1ConnectorError 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 (*ConnectV1ConnectorError) GetError 

func (o *ConnectV1ConnectorError) GetError() ConnectV1ConnectorErrorError

GetError returns the Error field value if set, zero value otherwise.

func (*ConnectV1ConnectorError) GetErrorOk 

func (o *ConnectV1ConnectorError) GetErrorOk() (*ConnectV1ConnectorErrorError, bool)

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

func (*ConnectV1ConnectorError) HasError 

func (o *ConnectV1ConnectorError) HasError() bool

HasError returns a boolean if a field has been set.

func (ConnectV1ConnectorError) MarshalJSON 

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

func (*ConnectV1ConnectorError) Redact 

func (o *ConnectV1ConnectorError) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1ConnectorError) SetError 

func (o *ConnectV1ConnectorError) SetError(v ConnectV1ConnectorErrorError)

SetError gets a reference to the given ConnectV1ConnectorErrorError and assigns it to the Error field.

type ConnectV1ConnectorErrorError 

type ConnectV1ConnectorErrorError struct {
	// Error code for the type of error
	Code *int32 `json:"code,omitempty"`
	// Human readable error message
	Message *string `json:"message,omitempty"`
}

ConnectV1ConnectorErrorError Connector Error with error code and message.

func NewConnectV1ConnectorErrorError 

func NewConnectV1ConnectorErrorError() *ConnectV1ConnectorErrorError

NewConnectV1ConnectorErrorError instantiates a new ConnectV1ConnectorErrorError 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 NewConnectV1ConnectorErrorErrorWithDefaults 

func NewConnectV1ConnectorErrorErrorWithDefaults() *ConnectV1ConnectorErrorError

NewConnectV1ConnectorErrorErrorWithDefaults instantiates a new ConnectV1ConnectorErrorError 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 (*ConnectV1ConnectorErrorError) GetCode 

func (o *ConnectV1ConnectorErrorError) GetCode() int32

GetCode returns the Code field value if set, zero value otherwise.

func (*ConnectV1ConnectorErrorError) GetCodeOk 

func (o *ConnectV1ConnectorErrorError) GetCodeOk() (*int32, bool)

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

func (*ConnectV1ConnectorErrorError) GetMessage 

func (o *ConnectV1ConnectorErrorError) GetMessage() string

GetMessage returns the Message field value if set, zero value otherwise.

func (*ConnectV1ConnectorErrorError) GetMessageOk 

func (o *ConnectV1ConnectorErrorError) GetMessageOk() (*string, bool)

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

func (*ConnectV1ConnectorErrorError) HasCode 

func (o *ConnectV1ConnectorErrorError) HasCode() bool

HasCode returns a boolean if a field has been set.

func (*ConnectV1ConnectorErrorError) HasMessage 

func (o *ConnectV1ConnectorErrorError) HasMessage() bool

HasMessage returns a boolean if a field has been set.

func (ConnectV1ConnectorErrorError) MarshalJSON 

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

func (*ConnectV1ConnectorErrorError) Redact 

func (o *ConnectV1ConnectorErrorError) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1ConnectorErrorError) SetCode 

func (o *ConnectV1ConnectorErrorError) SetCode(v int32)

SetCode gets a reference to the given int32 and assigns it to the Code field.

func (*ConnectV1ConnectorErrorError) SetMessage 

func (o *ConnectV1ConnectorErrorError) SetMessage(v string)

SetMessage gets a reference to the given string and assigns it to the Message field.

type ConnectV1ConnectorExpansion 

type ConnectV1ConnectorExpansion struct {
	Id     *ConnectV1ConnectorExpansionId     `json:"id,omitempty"`
	Info   *ConnectV1ConnectorExpansionInfo   `json:"info,omitempty"`
	Status *ConnectV1ConnectorExpansionStatus `json:"status,omitempty"`
}

ConnectV1ConnectorExpansion Name of connector

func NewConnectV1ConnectorExpansion 

func NewConnectV1ConnectorExpansion() *ConnectV1ConnectorExpansion

NewConnectV1ConnectorExpansion instantiates a new ConnectV1ConnectorExpansion 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 NewConnectV1ConnectorExpansionWithDefaults 

func NewConnectV1ConnectorExpansionWithDefaults() *ConnectV1ConnectorExpansion

NewConnectV1ConnectorExpansionWithDefaults instantiates a new ConnectV1ConnectorExpansion 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 (*ConnectV1ConnectorExpansion) GetId 

func (o *ConnectV1ConnectorExpansion) GetId() ConnectV1ConnectorExpansionId

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

func (*ConnectV1ConnectorExpansion) GetIdOk 

func (o *ConnectV1ConnectorExpansion) GetIdOk() (*ConnectV1ConnectorExpansionId, 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 (*ConnectV1ConnectorExpansion) GetInfo 

func (o *ConnectV1ConnectorExpansion) GetInfo() ConnectV1ConnectorExpansionInfo

GetInfo returns the Info field value if set, zero value otherwise.

func (*ConnectV1ConnectorExpansion) GetInfoOk 

func (o *ConnectV1ConnectorExpansion) GetInfoOk() (*ConnectV1ConnectorExpansionInfo, bool)

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

func (*ConnectV1ConnectorExpansion) GetStatus 

func (o *ConnectV1ConnectorExpansion) GetStatus() ConnectV1ConnectorExpansionStatus

GetStatus returns the Status field value if set, zero value otherwise.

func (*ConnectV1ConnectorExpansion) GetStatusOk 

func (o *ConnectV1ConnectorExpansion) GetStatusOk() (*ConnectV1ConnectorExpansionStatus, bool)

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

func (*ConnectV1ConnectorExpansion) HasId 

func (o *ConnectV1ConnectorExpansion) HasId() bool

HasId returns a boolean if a field has been set.

func (*ConnectV1ConnectorExpansion) HasInfo 

func (o *ConnectV1ConnectorExpansion) HasInfo() bool

HasInfo returns a boolean if a field has been set.

func (*ConnectV1ConnectorExpansion) HasStatus 

func (o *ConnectV1ConnectorExpansion) HasStatus() bool

HasStatus returns a boolean if a field has been set.

func (ConnectV1ConnectorExpansion) MarshalJSON 

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

func (*ConnectV1ConnectorExpansion) Redact 

func (o *ConnectV1ConnectorExpansion) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1ConnectorExpansion) SetId 

func (o *ConnectV1ConnectorExpansion) SetId(v ConnectV1ConnectorExpansionId)

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

func (*ConnectV1ConnectorExpansion) SetInfo 

func (o *ConnectV1ConnectorExpansion) SetInfo(v ConnectV1ConnectorExpansionInfo)

SetInfo gets a reference to the given ConnectV1ConnectorExpansionInfo and assigns it to the Info field.

func (*ConnectV1ConnectorExpansion) SetStatus 

func (o *ConnectV1ConnectorExpansion) SetStatus(v ConnectV1ConnectorExpansionStatus)

SetStatus gets a reference to the given ConnectV1ConnectorExpansionStatus and assigns it to the Status field.

type ConnectV1ConnectorExpansionId 

type ConnectV1ConnectorExpansionId struct {
	// The ID of the connector.
	Id *string `json:"id,omitempty"`
	// Type of the value in the `id` property.
	IdType *string `json:"id_type,omitempty"`
}

ConnectV1ConnectorExpansionId The ID of connector.

func NewConnectV1ConnectorExpansionId 

func NewConnectV1ConnectorExpansionId() *ConnectV1ConnectorExpansionId

NewConnectV1ConnectorExpansionId instantiates a new ConnectV1ConnectorExpansionId 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 NewConnectV1ConnectorExpansionIdWithDefaults 

func NewConnectV1ConnectorExpansionIdWithDefaults() *ConnectV1ConnectorExpansionId

NewConnectV1ConnectorExpansionIdWithDefaults instantiates a new ConnectV1ConnectorExpansionId 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 (*ConnectV1ConnectorExpansionId) GetId 

func (o *ConnectV1ConnectorExpansionId) GetId() string

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

func (*ConnectV1ConnectorExpansionId) GetIdOk 

func (o *ConnectV1ConnectorExpansionId) GetIdOk() (*string, 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 (*ConnectV1ConnectorExpansionId) GetIdType 

func (o *ConnectV1ConnectorExpansionId) GetIdType() string

GetIdType returns the IdType field value if set, zero value otherwise.

func (*ConnectV1ConnectorExpansionId) GetIdTypeOk 

func (o *ConnectV1ConnectorExpansionId) GetIdTypeOk() (*string, bool)

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

func (*ConnectV1ConnectorExpansionId) HasId 

func (o *ConnectV1ConnectorExpansionId) HasId() bool

HasId returns a boolean if a field has been set.

func (*ConnectV1ConnectorExpansionId) HasIdType 

func (o *ConnectV1ConnectorExpansionId) HasIdType() bool

HasIdType returns a boolean if a field has been set.

func (ConnectV1ConnectorExpansionId) MarshalJSON 

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

func (*ConnectV1ConnectorExpansionId) Redact 

func (o *ConnectV1ConnectorExpansionId) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1ConnectorExpansionId) SetId 

func (o *ConnectV1ConnectorExpansionId) SetId(v string)

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

func (*ConnectV1ConnectorExpansionId) SetIdType 

func (o *ConnectV1ConnectorExpansionId) SetIdType(v string)

SetIdType gets a reference to the given string and assigns it to the IdType field.

type ConnectV1ConnectorExpansionInfo 

type ConnectV1ConnectorExpansionInfo struct {
	// Name of the connector.
	Name *string `json:"name,omitempty"`
	// Configuration parameters for the connector. These configurations are the minimum set of key-value pairs (KVP) which are used to define how the connector connects Kafka to the external system. Some of these KVPs are common to all the connectors, such as connection parameters to Kafka, connector metadata, etc. The list of common connector configurations is as follows    - cloud.environment   - cloud.provider   - connector.class   - kafka.api.key   - kafka.api.secret   - kafka.endpoint   - kafka.region   - name  For example, a connector like `GcsSink` would have additional parameters such as `gcs.bucket.name`, `flush.size`, etc.
	Config *map[string]string `json:"config,omitempty"`
}

ConnectV1ConnectorExpansionInfo Metadata of the connector.

func NewConnectV1ConnectorExpansionInfo 

func NewConnectV1ConnectorExpansionInfo() *ConnectV1ConnectorExpansionInfo

NewConnectV1ConnectorExpansionInfo instantiates a new ConnectV1ConnectorExpansionInfo 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 NewConnectV1ConnectorExpansionInfoWithDefaults 

func NewConnectV1ConnectorExpansionInfoWithDefaults() *ConnectV1ConnectorExpansionInfo

NewConnectV1ConnectorExpansionInfoWithDefaults instantiates a new ConnectV1ConnectorExpansionInfo 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 (*ConnectV1ConnectorExpansionInfo) GetConfig 

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

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

func (*ConnectV1ConnectorExpansionInfo) GetConfigOk 

func (o *ConnectV1ConnectorExpansionInfo) 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 (*ConnectV1ConnectorExpansionInfo) GetName 

func (o *ConnectV1ConnectorExpansionInfo) GetName() string

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

func (*ConnectV1ConnectorExpansionInfo) GetNameOk 

func (o *ConnectV1ConnectorExpansionInfo) 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 (*ConnectV1ConnectorExpansionInfo) HasConfig 

func (o *ConnectV1ConnectorExpansionInfo) HasConfig() bool

HasConfig returns a boolean if a field has been set.

func (*ConnectV1ConnectorExpansionInfo) HasName 

func (o *ConnectV1ConnectorExpansionInfo) HasName() bool

HasName returns a boolean if a field has been set.

func (ConnectV1ConnectorExpansionInfo) MarshalJSON 

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

func (*ConnectV1ConnectorExpansionInfo) Redact 

func (o *ConnectV1ConnectorExpansionInfo) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1ConnectorExpansionInfo) SetConfig 

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

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

func (*ConnectV1ConnectorExpansionInfo) SetName 

func (o *ConnectV1ConnectorExpansionInfo) SetName(v string)

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

type ConnectV1ConnectorExpansionStatus 

type ConnectV1ConnectorExpansionStatus struct {
	// The name of the connector.
	Name string `json:"name,omitempty"`
	// Type of connector, sink or source.
	Type      string                                     `json:"type,omitempty"`
	Connector ConnectV1ConnectorExpansionStatusConnector `json:"connector,omitempty"`
	// A map containing the task status.
	Tasks *[]InlineResponse2001Tasks `json:"tasks,omitempty"`
}

ConnectV1ConnectorExpansionStatus Status of the connector and its tasks.

func NewConnectV1ConnectorExpansionStatus 

func NewConnectV1ConnectorExpansionStatus(name string, type_ string, connector ConnectV1ConnectorExpansionStatusConnector) *ConnectV1ConnectorExpansionStatus

NewConnectV1ConnectorExpansionStatus instantiates a new ConnectV1ConnectorExpansionStatus 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 NewConnectV1ConnectorExpansionStatusWithDefaults 

func NewConnectV1ConnectorExpansionStatusWithDefaults() *ConnectV1ConnectorExpansionStatus

NewConnectV1ConnectorExpansionStatusWithDefaults instantiates a new ConnectV1ConnectorExpansionStatus 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 (*ConnectV1ConnectorExpansionStatus) GetConnector 

func (o *ConnectV1ConnectorExpansionStatus) GetConnector() ConnectV1ConnectorExpansionStatusConnector

GetConnector returns the Connector field value

func (*ConnectV1ConnectorExpansionStatus) GetConnectorOk 

func (o *ConnectV1ConnectorExpansionStatus) GetConnectorOk() (*ConnectV1ConnectorExpansionStatusConnector, bool)

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

func (*ConnectV1ConnectorExpansionStatus) GetName 

func (o *ConnectV1ConnectorExpansionStatus) GetName() string

GetName returns the Name field value

func (*ConnectV1ConnectorExpansionStatus) GetNameOk 

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

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

func (*ConnectV1ConnectorExpansionStatus) GetTasks 

func (o *ConnectV1ConnectorExpansionStatus) GetTasks() []InlineResponse2001Tasks

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

func (*ConnectV1ConnectorExpansionStatus) GetTasksOk 

func (o *ConnectV1ConnectorExpansionStatus) GetTasksOk() (*[]InlineResponse2001Tasks, 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 (*ConnectV1ConnectorExpansionStatus) GetType 

func (o *ConnectV1ConnectorExpansionStatus) GetType() string

GetType returns the Type field value

func (*ConnectV1ConnectorExpansionStatus) GetTypeOk 

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

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

func (*ConnectV1ConnectorExpansionStatus) HasTasks 

func (o *ConnectV1ConnectorExpansionStatus) HasTasks() bool

HasTasks returns a boolean if a field has been set.

func (ConnectV1ConnectorExpansionStatus) MarshalJSON 

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

func (*ConnectV1ConnectorExpansionStatus) Redact 

func (o *ConnectV1ConnectorExpansionStatus) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1ConnectorExpansionStatus) SetConnector 

func (o *ConnectV1ConnectorExpansionStatus) SetConnector(v ConnectV1ConnectorExpansionStatusConnector)

SetConnector sets field value

func (*ConnectV1ConnectorExpansionStatus) SetName 

func (o *ConnectV1ConnectorExpansionStatus) SetName(v string)

SetName sets field value

func (*ConnectV1ConnectorExpansionStatus) SetTasks 

func (o *ConnectV1ConnectorExpansionStatus) SetTasks(v []InlineResponse2001Tasks)

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

func (*ConnectV1ConnectorExpansionStatus) SetType 

func (o *ConnectV1ConnectorExpansionStatus) SetType(v string)

SetType sets field value

type ConnectV1ConnectorExpansionStatusConnector 

type ConnectV1ConnectorExpansionStatusConnector struct {
	// The state of the connector.
	State string `json:"state,omitempty"`
	// The worker ID of the connector.
	WorkerId string `json:"worker_id,omitempty"`
	// Exception message in case of an error.
	Trace *string `json:"trace,omitempty"`
}

ConnectV1ConnectorExpansionStatusConnector A map containing connector status.

func NewConnectV1ConnectorExpansionStatusConnector 

func NewConnectV1ConnectorExpansionStatusConnector(state string, workerId string) *ConnectV1ConnectorExpansionStatusConnector

NewConnectV1ConnectorExpansionStatusConnector instantiates a new ConnectV1ConnectorExpansionStatusConnector 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 NewConnectV1ConnectorExpansionStatusConnectorWithDefaults 

func NewConnectV1ConnectorExpansionStatusConnectorWithDefaults() *ConnectV1ConnectorExpansionStatusConnector

NewConnectV1ConnectorExpansionStatusConnectorWithDefaults instantiates a new ConnectV1ConnectorExpansionStatusConnector 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 (*ConnectV1ConnectorExpansionStatusConnector) GetState 

func (o *ConnectV1ConnectorExpansionStatusConnector) GetState() string

GetState returns the State field value

func (*ConnectV1ConnectorExpansionStatusConnector) GetStateOk 

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

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

func (*ConnectV1ConnectorExpansionStatusConnector) GetTrace 

func (o *ConnectV1ConnectorExpansionStatusConnector) GetTrace() string

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

func (*ConnectV1ConnectorExpansionStatusConnector) GetTraceOk 

func (o *ConnectV1ConnectorExpansionStatusConnector) 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 (*ConnectV1ConnectorExpansionStatusConnector) GetWorkerId 

func (o *ConnectV1ConnectorExpansionStatusConnector) GetWorkerId() string

GetWorkerId returns the WorkerId field value

func (*ConnectV1ConnectorExpansionStatusConnector) GetWorkerIdOk 

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

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

func (*ConnectV1ConnectorExpansionStatusConnector) HasTrace 

func (o *ConnectV1ConnectorExpansionStatusConnector) HasTrace() bool

HasTrace returns a boolean if a field has been set.

func (ConnectV1ConnectorExpansionStatusConnector) MarshalJSON 

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

func (*ConnectV1ConnectorExpansionStatusConnector) Redact 

func (o *ConnectV1ConnectorExpansionStatusConnector) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1ConnectorExpansionStatusConnector) SetState 

func (o *ConnectV1ConnectorExpansionStatusConnector) SetState(v string)

SetState sets field value

func (*ConnectV1ConnectorExpansionStatusConnector) SetTrace 

func (o *ConnectV1ConnectorExpansionStatusConnector) SetTrace(v string)

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

func (*ConnectV1ConnectorExpansionStatusConnector) SetWorkerId 

func (o *ConnectV1ConnectorExpansionStatusConnector) SetWorkerId(v string)

SetWorkerId sets field value

type ConnectV1ConnectorOffsets added in v0.5.0 

type ConnectV1ConnectorOffsets struct {
	// The name of the connector.
	Name *string `json:"name,omitempty"`
	// The ID of the connector.
	Id *string `json:"id,omitempty"`
	// Array of offsets which are categorised into partitions.
	Offsets  *[]map[string]interface{}          `json:"offsets,omitempty"`
	Metadata *ConnectV1ConnectorOffsetsMetadata `json:"metadata,omitempty"`
}

ConnectV1ConnectorOffsets Offsets for a connector

func NewConnectV1ConnectorOffsets added in v0.5.0 

func NewConnectV1ConnectorOffsets() *ConnectV1ConnectorOffsets

NewConnectV1ConnectorOffsets instantiates a new ConnectV1ConnectorOffsets 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 NewConnectV1ConnectorOffsetsWithDefaults added in v0.5.0 

func NewConnectV1ConnectorOffsetsWithDefaults() *ConnectV1ConnectorOffsets

NewConnectV1ConnectorOffsetsWithDefaults instantiates a new ConnectV1ConnectorOffsets 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 (*ConnectV1ConnectorOffsets) GetId added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) GetId() string

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

func (*ConnectV1ConnectorOffsets) GetIdOk added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) GetIdOk() (*string, 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 (*ConnectV1ConnectorOffsets) GetMetadata added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) GetMetadata() ConnectV1ConnectorOffsetsMetadata

GetMetadata returns the Metadata field value if set, zero value otherwise.

func (*ConnectV1ConnectorOffsets) GetMetadataOk added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) GetMetadataOk() (*ConnectV1ConnectorOffsetsMetadata, bool)

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

func (*ConnectV1ConnectorOffsets) GetName added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) GetName() string

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

func (*ConnectV1ConnectorOffsets) GetNameOk added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) 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 (*ConnectV1ConnectorOffsets) GetOffsets added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) GetOffsets() []map[string]interface{}

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

func (*ConnectV1ConnectorOffsets) GetOffsetsOk added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) GetOffsetsOk() (*[]map[string]interface{}, 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 (*ConnectV1ConnectorOffsets) HasId added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) HasId() bool

HasId returns a boolean if a field has been set.

func (*ConnectV1ConnectorOffsets) HasMetadata added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) HasMetadata() bool

HasMetadata returns a boolean if a field has been set.

func (*ConnectV1ConnectorOffsets) HasName added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) HasName() bool

HasName returns a boolean if a field has been set.

func (*ConnectV1ConnectorOffsets) HasOffsets added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) HasOffsets() bool

HasOffsets returns a boolean if a field has been set.

func (ConnectV1ConnectorOffsets) MarshalJSON added in v0.5.0 

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

func (*ConnectV1ConnectorOffsets) Redact added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1ConnectorOffsets) SetId added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) SetId(v string)

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

func (*ConnectV1ConnectorOffsets) SetMetadata added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) SetMetadata(v ConnectV1ConnectorOffsetsMetadata)

SetMetadata gets a reference to the given ConnectV1ConnectorOffsetsMetadata and assigns it to the Metadata field.

func (*ConnectV1ConnectorOffsets) SetName added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) SetName(v string)

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

func (*ConnectV1ConnectorOffsets) SetOffsets added in v0.5.0 

func (o *ConnectV1ConnectorOffsets) SetOffsets(v []map[string]interface{})

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

type ConnectV1ConnectorOffsetsMetadata added in v0.5.0 

type ConnectV1ConnectorOffsetsMetadata struct {
	// The time at which the offsets were observed. The time is in UTC, ISO 8601 format.
	ObservedAt *time.Time `json:"observed_at,omitempty"`
}

ConnectV1ConnectorOffsetsMetadata Metadata of the connector offset.

func NewConnectV1ConnectorOffsetsMetadata added in v0.5.0 

func NewConnectV1ConnectorOffsetsMetadata() *ConnectV1ConnectorOffsetsMetadata

NewConnectV1ConnectorOffsetsMetadata instantiates a new ConnectV1ConnectorOffsetsMetadata 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 NewConnectV1ConnectorOffsetsMetadataWithDefaults added in v0.5.0 

func NewConnectV1ConnectorOffsetsMetadataWithDefaults() *ConnectV1ConnectorOffsetsMetadata

NewConnectV1ConnectorOffsetsMetadataWithDefaults instantiates a new ConnectV1ConnectorOffsetsMetadata 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 (*ConnectV1ConnectorOffsetsMetadata) GetObservedAt added in v0.5.0 

func (o *ConnectV1ConnectorOffsetsMetadata) GetObservedAt() time.Time

GetObservedAt returns the ObservedAt field value if set, zero value otherwise.

func (*ConnectV1ConnectorOffsetsMetadata) GetObservedAtOk added in v0.5.0 

func (o *ConnectV1ConnectorOffsetsMetadata) GetObservedAtOk() (*time.Time, bool)

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

func (*ConnectV1ConnectorOffsetsMetadata) HasObservedAt added in v0.5.0 

func (o *ConnectV1ConnectorOffsetsMetadata) HasObservedAt() bool

HasObservedAt returns a boolean if a field has been set.

func (ConnectV1ConnectorOffsetsMetadata) MarshalJSON added in v0.5.0 

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

func (*ConnectV1ConnectorOffsetsMetadata) Redact added in v0.5.0 

func (o *ConnectV1ConnectorOffsetsMetadata) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1ConnectorOffsetsMetadata) SetObservedAt added in v0.5.0 

func (o *ConnectV1ConnectorOffsetsMetadata) SetObservedAt(v time.Time)

SetObservedAt gets a reference to the given time.Time and assigns it to the ObservedAt field.

type ConnectV1ConnectorTasks 

type ConnectV1ConnectorTasks struct {
	// The name of the connector the task belongs to
	Connector string `json:"connector,omitempty"`
	// Task ID within the connector
	Task int32 `json:"task,omitempty"`
}

ConnectV1ConnectorTasks struct for ConnectV1ConnectorTasks

func NewConnectV1ConnectorTasks 

func NewConnectV1ConnectorTasks(connector string, task int32) *ConnectV1ConnectorTasks

NewConnectV1ConnectorTasks instantiates a new ConnectV1ConnectorTasks 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 NewConnectV1ConnectorTasksWithDefaults 

func NewConnectV1ConnectorTasksWithDefaults() *ConnectV1ConnectorTasks

NewConnectV1ConnectorTasksWithDefaults instantiates a new ConnectV1ConnectorTasks 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 (*ConnectV1ConnectorTasks) GetConnector 

func (o *ConnectV1ConnectorTasks) GetConnector() string

GetConnector returns the Connector field value

func (*ConnectV1ConnectorTasks) GetConnectorOk 

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

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

func (*ConnectV1ConnectorTasks) GetTask 

func (o *ConnectV1ConnectorTasks) GetTask() int32

GetTask returns the Task field value

func (*ConnectV1ConnectorTasks) GetTaskOk 

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

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

func (ConnectV1ConnectorTasks) MarshalJSON 

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

func (*ConnectV1ConnectorTasks) Redact 

func (o *ConnectV1ConnectorTasks) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1ConnectorTasks) SetConnector 

func (o *ConnectV1ConnectorTasks) SetConnector(v string)

SetConnector sets field value

func (*ConnectV1ConnectorTasks) SetTask 

func (o *ConnectV1ConnectorTasks) SetTask(v int32)

SetTask sets field value

type ConnectV1ConnectorWithOffsets added in v0.7.0 

type ConnectV1ConnectorWithOffsets struct {
	// Name of the connector
	Name string `json:"name,omitempty"`
	// Configuration parameters for the connector. These configurations are the minimum set of key-value pairs which can be used to define how the connector connects Kafka to the external system. Some of these key-value pairs are common to all the connectors, such as connection parameters to Kafka, connector metadata, etc. The list of common connector configurations is as follows - cloud.environment - cloud.provider - connector.class - kafka.api.key - kafka.api.secret - kafka.endpoint - kafka.region - name A specific connector such as `GcsSink` would have additional parameters such as `gcs.bucket.name`, `flush.size`, etc.
	Config map[string]string `json:"config,omitempty"`
	// List of active tasks generated by the connector
	Tasks *[]ConnectV1ConnectorTasks `json:"tasks,omitempty"`
	// Type of connector, sink or source
	Type *string `json:"type,omitempty"`
	// Array of offsets which are categorised into partitions.
	Offsets *[]map[string]interface{} `json:"offsets,omitempty"`
}

ConnectV1ConnectorWithOffsets struct for ConnectV1ConnectorWithOffsets

func NewConnectV1ConnectorWithOffsets added in v0.7.0 

func NewConnectV1ConnectorWithOffsets(name string, config map[string]string) *ConnectV1ConnectorWithOffsets

NewConnectV1ConnectorWithOffsets instantiates a new ConnectV1ConnectorWithOffsets 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 NewConnectV1ConnectorWithOffsetsWithDefaults added in v0.7.0 

func NewConnectV1ConnectorWithOffsetsWithDefaults() *ConnectV1ConnectorWithOffsets

NewConnectV1ConnectorWithOffsetsWithDefaults instantiates a new ConnectV1ConnectorWithOffsets 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 (*ConnectV1ConnectorWithOffsets) GetConfig added in v0.7.0 

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

GetConfig returns the Config field value

func (*ConnectV1ConnectorWithOffsets) GetConfigOk added in v0.7.0 

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

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

func (*ConnectV1ConnectorWithOffsets) GetName added in v0.7.0 

func (o *ConnectV1ConnectorWithOffsets) GetName() string

GetName returns the Name field value

func (*ConnectV1ConnectorWithOffsets) GetNameOk added in v0.7.0 

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

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

func (*ConnectV1ConnectorWithOffsets) GetOffsets added in v0.7.0 

func (o *ConnectV1ConnectorWithOffsets) GetOffsets() []map[string]interface{}

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

func (*ConnectV1ConnectorWithOffsets) GetOffsetsOk added in v0.7.0 

func (o *ConnectV1ConnectorWithOffsets) GetOffsetsOk() (*[]map[string]interface{}, 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 (*ConnectV1ConnectorWithOffsets) GetTasks added in v0.7.0 

func (o *ConnectV1ConnectorWithOffsets) GetTasks() []ConnectV1ConnectorTasks

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

func (*ConnectV1ConnectorWithOffsets) GetTasksOk added in v0.7.0 

func (o *ConnectV1ConnectorWithOffsets) GetTasksOk() (*[]ConnectV1ConnectorTasks, 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 (*ConnectV1ConnectorWithOffsets) GetType added in v0.7.0 

func (o *ConnectV1ConnectorWithOffsets) GetType() string

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

func (*ConnectV1ConnectorWithOffsets) GetTypeOk added in v0.7.0 

func (o *ConnectV1ConnectorWithOffsets) 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 (*ConnectV1ConnectorWithOffsets) HasOffsets added in v0.7.0 

func (o *ConnectV1ConnectorWithOffsets) HasOffsets() bool

HasOffsets returns a boolean if a field has been set.

func (*ConnectV1ConnectorWithOffsets) HasTasks added in v0.7.0 

func (o *ConnectV1ConnectorWithOffsets) HasTasks() bool

HasTasks returns a boolean if a field has been set.

func (*ConnectV1ConnectorWithOffsets) HasType added in v0.7.0 

func (o *ConnectV1ConnectorWithOffsets) HasType() bool

HasType returns a boolean if a field has been set.

func (ConnectV1ConnectorWithOffsets) MarshalJSON added in v0.7.0 

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

func (*ConnectV1ConnectorWithOffsets) Redact added in v0.7.0 

func (o *ConnectV1ConnectorWithOffsets) Redact()

Redact resets all sensitive fields to their zero value.

func (*ConnectV1ConnectorWithOffsets) SetConfig added in v0.7.0 

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

SetConfig sets field value

func (*ConnectV1ConnectorWithOffsets) SetName added in v0.7.0 

func (o *ConnectV1ConnectorWithOffsets) SetName(v string)

SetName sets field value

func (*ConnectV1ConnectorWithOffsets) SetOffsets added in v0.7.0 

func (o *ConnectV1ConnectorWithOffsets) SetOffsets(v []map[string]interface{})

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

func (*ConnectV1ConnectorWithOffsets) SetTasks added in v0.7.0 

func (o *ConnectV1ConnectorWithOffsets) SetTasks(v []ConnectV1ConnectorTasks)

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

func (*ConnectV1ConnectorWithOffsets) SetType added in v0.7.0 

func (o *ConnectV1ConnectorWithOffsets) SetType(v string)

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

type ConnectorsConnectV1Api added in v0.5.0 

type ConnectorsConnectV1Api interface {

	/*
			CreateConnectv1Connector Create a Connector

			[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

		Create a new connector. Returns the new connector information if successful.

			 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
			 @param environmentId The unique identifier of the environment this resource belongs to.
			 @param kafkaClusterId The unique identifier for the Kafka cluster.
			 @return ApiCreateConnectv1ConnectorRequest
	*/
	CreateConnectv1Connector(ctx _context.Context, environmentId string, kafkaClusterId string) ApiCreateConnectv1ConnectorRequest

	// CreateConnectv1ConnectorExecute executes the request
	//  @return ConnectV1ConnectorWithOffsets
	CreateConnectv1ConnectorExecute(r ApiCreateConnectv1ConnectorRequest) (ConnectV1ConnectorWithOffsets, *_nethttp.Response, error)

	/*
		CreateOrUpdateConnectv1ConnectorConfig Create or Update a Connector Configuration

		Create a new connector using the given configuration, or update the configuration for an existing connector. Returns information about the connector after the change has been made.

		 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
		 @param connectorName The unique name of the connector.
		 @param environmentId The unique identifier of the environment this resource belongs to.
		 @param kafkaClusterId The unique identifier for the Kafka cluster.
		 @return ApiCreateOrUpdateConnectv1ConnectorConfigRequest
	*/
	CreateOrUpdateConnectv1ConnectorConfig(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiCreateOrUpdateConnectv1ConnectorConfigRequest

	// CreateOrUpdateConnectv1ConnectorConfigExecute executes the request
	//  @return ConnectV1Connector
	CreateOrUpdateConnectv1ConnectorConfigExecute(r ApiCreateOrUpdateConnectv1ConnectorConfigRequest) (ConnectV1Connector, *_nethttp.Response, error)

	/*
			DeleteConnectv1Connector Delete a Connector

			[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

		Delete a connector. Halts all tasks and deletes the connector configuration.

			 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
			 @param connectorName The unique name of the connector.
			 @param environmentId The unique identifier of the environment this resource belongs to.
			 @param kafkaClusterId The unique identifier for the Kafka cluster.
			 @return ApiDeleteConnectv1ConnectorRequest
	*/
	DeleteConnectv1Connector(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiDeleteConnectv1ConnectorRequest

	// DeleteConnectv1ConnectorExecute executes the request
	//  @return InlineResponse200
	DeleteConnectv1ConnectorExecute(r ApiDeleteConnectv1ConnectorRequest) (InlineResponse200, *_nethttp.Response, error)

	/*
			GetConnectv1ConnectorConfig Read a Connector Configuration

			[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

		Get the configuration for the connector.

			 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
			 @param connectorName The unique name of the connector.
			 @param environmentId The unique identifier of the environment this resource belongs to.
			 @param kafkaClusterId The unique identifier for the Kafka cluster.
			 @return ApiGetConnectv1ConnectorConfigRequest
	*/
	GetConnectv1ConnectorConfig(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiGetConnectv1ConnectorConfigRequest

	// GetConnectv1ConnectorConfigExecute executes the request
	//  @return map[string]string
	GetConnectv1ConnectorConfigExecute(r ApiGetConnectv1ConnectorConfigRequest) (map[string]string, *_nethttp.Response, error)

	/*
			ListConnectv1Connectors List of Connectors

			[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

		Retrieve a list of "names" of the active connectors. You can then make a [read request](#operation/readConnectv1Connector) for a specific connector by name.

			 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
			 @param environmentId The unique identifier of the environment this resource belongs to.
			 @param kafkaClusterId The unique identifier for the Kafka cluster.
			 @return ApiListConnectv1ConnectorsRequest
	*/
	ListConnectv1Connectors(ctx _context.Context, environmentId string, kafkaClusterId string) ApiListConnectv1ConnectorsRequest

	// ListConnectv1ConnectorsExecute executes the request
	//  @return []string
	ListConnectv1ConnectorsExecute(r ApiListConnectv1ConnectorsRequest) ([]string, *_nethttp.Response, error)

	/*
			ListConnectv1ConnectorsWithExpansions List of Connectors with Expansions

			[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

		Retrieve an object with the queried expansions of all connectors. Without `expand` query parameter, this list connector’s endpoint will return a [list of only the connector names](#operation/listConnectv1Connectors).

			 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
			 @param environmentId The unique identifier of the environment this resource belongs to.
			 @param kafkaClusterId The unique identifier for the Kafka cluster.
			 @return ApiListConnectv1ConnectorsWithExpansionsRequest
	*/
	ListConnectv1ConnectorsWithExpansions(ctx _context.Context, environmentId string, kafkaClusterId string) ApiListConnectv1ConnectorsWithExpansionsRequest

	// ListConnectv1ConnectorsWithExpansionsExecute executes the request
	//  @return map[string]ConnectV1ConnectorExpansion
	ListConnectv1ConnectorsWithExpansionsExecute(r ApiListConnectv1ConnectorsWithExpansionsRequest) (map[string]ConnectV1ConnectorExpansion, *_nethttp.Response, error)

	/*
			ReadConnectv1Connector Read a Connector

			[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

		Get information about the connector.

			 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
			 @param connectorName The unique name of the connector.
			 @param environmentId The unique identifier of the environment this resource belongs to.
			 @param kafkaClusterId The unique identifier for the Kafka cluster.
			 @return ApiReadConnectv1ConnectorRequest
	*/
	ReadConnectv1Connector(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiReadConnectv1ConnectorRequest

	// ReadConnectv1ConnectorExecute executes the request
	//  @return ConnectV1Connector
	ReadConnectv1ConnectorExecute(r ApiReadConnectv1ConnectorRequest) (ConnectV1Connector, *_nethttp.Response, error)
}

type ConnectorsConnectV1ApiService added in v0.5.0 

type ConnectorsConnectV1ApiService service

ConnectorsConnectV1ApiService ConnectorsConnectV1Api service

func (*ConnectorsConnectV1ApiService) CreateConnectv1Connector added in v0.5.0 

func (a *ConnectorsConnectV1ApiService) CreateConnectv1Connector(ctx _context.Context, environmentId string, kafkaClusterId string) ApiCreateConnectv1ConnectorRequest

CreateConnectv1Connector Create a Connector

[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

Create a new connector. Returns the new connector information if successful. 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiCreateConnectv1ConnectorRequest

func (*ConnectorsConnectV1ApiService) CreateConnectv1ConnectorExecute added in v0.5.0 

func (a *ConnectorsConnectV1ApiService) CreateConnectv1ConnectorExecute(r ApiCreateConnectv1ConnectorRequest) (ConnectV1ConnectorWithOffsets, *_nethttp.Response, error)

Execute executes the request 

@return ConnectV1ConnectorWithOffsets

func (*ConnectorsConnectV1ApiService) CreateOrUpdateConnectv1ConnectorConfig added in v0.5.0 

func (a *ConnectorsConnectV1ApiService) CreateOrUpdateConnectv1ConnectorConfig(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiCreateOrUpdateConnectv1ConnectorConfigRequest

CreateOrUpdateConnectv1ConnectorConfig Create or Update a Connector Configuration

Create a new connector using the given configuration, or update the configuration for an existing connector. Returns information about the connector after the change has been made. 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connectorName The unique name of the connector.
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiCreateOrUpdateConnectv1ConnectorConfigRequest

func (*ConnectorsConnectV1ApiService) CreateOrUpdateConnectv1ConnectorConfigExecute added in v0.5.0 

func (a *ConnectorsConnectV1ApiService) CreateOrUpdateConnectv1ConnectorConfigExecute(r ApiCreateOrUpdateConnectv1ConnectorConfigRequest) (ConnectV1Connector, *_nethttp.Response, error)

Execute executes the request 

@return ConnectV1Connector

func (*ConnectorsConnectV1ApiService) DeleteConnectv1Connector added in v0.5.0 

func (a *ConnectorsConnectV1ApiService) DeleteConnectv1Connector(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiDeleteConnectv1ConnectorRequest

DeleteConnectv1Connector Delete a Connector

[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

Delete a connector. Halts all tasks and deletes the connector configuration. 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connectorName The unique name of the connector.
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiDeleteConnectv1ConnectorRequest

func (*ConnectorsConnectV1ApiService) DeleteConnectv1ConnectorExecute added in v0.5.0 

func (a *ConnectorsConnectV1ApiService) DeleteConnectv1ConnectorExecute(r ApiDeleteConnectv1ConnectorRequest) (InlineResponse200, *_nethttp.Response, error)

Execute executes the request 

@return InlineResponse200

func (*ConnectorsConnectV1ApiService) GetConnectv1ConnectorConfig added in v0.5.0 

func (a *ConnectorsConnectV1ApiService) GetConnectv1ConnectorConfig(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiGetConnectv1ConnectorConfigRequest

GetConnectv1ConnectorConfig Read a Connector Configuration

[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

Get the configuration for the connector. 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connectorName The unique name of the connector.
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiGetConnectv1ConnectorConfigRequest

func (*ConnectorsConnectV1ApiService) GetConnectv1ConnectorConfigExecute added in v0.5.0 

func (a *ConnectorsConnectV1ApiService) GetConnectv1ConnectorConfigExecute(r ApiGetConnectv1ConnectorConfigRequest) (map[string]string, *_nethttp.Response, error)

Execute executes the request 

@return map[string]string

func (*ConnectorsConnectV1ApiService) ListConnectv1Connectors added in v0.5.0 

func (a *ConnectorsConnectV1ApiService) ListConnectv1Connectors(ctx _context.Context, environmentId string, kafkaClusterId string) ApiListConnectv1ConnectorsRequest

ListConnectv1Connectors List of Connectors

[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

Retrieve a list of "names" of the active connectors. You can then make a [read request](#operation/readConnectv1Connector) for a specific connector by name. 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiListConnectv1ConnectorsRequest

func (*ConnectorsConnectV1ApiService) ListConnectv1ConnectorsExecute added in v0.5.0 

func (a *ConnectorsConnectV1ApiService) ListConnectv1ConnectorsExecute(r ApiListConnectv1ConnectorsRequest) ([]string, *_nethttp.Response, error)

Execute executes the request 

@return []string

func (*ConnectorsConnectV1ApiService) ListConnectv1ConnectorsWithExpansions added in v0.5.0 

func (a *ConnectorsConnectV1ApiService) ListConnectv1ConnectorsWithExpansions(ctx _context.Context, environmentId string, kafkaClusterId string) ApiListConnectv1ConnectorsWithExpansionsRequest

ListConnectv1ConnectorsWithExpansions List of Connectors with Expansions

[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

Retrieve an object with the queried expansions of all connectors. Without `expand` query parameter, this list connector’s endpoint will return a [list of only the connector names](#operation/listConnectv1Connectors). 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiListConnectv1ConnectorsWithExpansionsRequest

func (*ConnectorsConnectV1ApiService) ListConnectv1ConnectorsWithExpansionsExecute added in v0.5.0 

func (a *ConnectorsConnectV1ApiService) ListConnectv1ConnectorsWithExpansionsExecute(r ApiListConnectv1ConnectorsWithExpansionsRequest) (map[string]ConnectV1ConnectorExpansion, *_nethttp.Response, error)

Execute executes the request 

@return map[string]ConnectV1ConnectorExpansion

func (*ConnectorsConnectV1ApiService) ReadConnectv1Connector added in v0.5.0 

func (a *ConnectorsConnectV1ApiService) ReadConnectv1Connector(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiReadConnectv1ConnectorRequest

ReadConnectv1Connector Read a Connector

[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

Get information about the connector. 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connectorName The unique name of the connector.
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiReadConnectv1ConnectorRequest

func (*ConnectorsConnectV1ApiService) ReadConnectv1ConnectorExecute added in v0.5.0 

func (a *ConnectorsConnectV1ApiService) ReadConnectv1ConnectorExecute(r ApiReadConnectv1ConnectorRequest) (ConnectV1Connector, *_nethttp.Response, error)

Execute executes the request 

@return ConnectV1Connector

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 InlineObject 

type InlineObject struct {
	// Name of the connector to create.
	Name *string `json:"name,omitempty"`
	// Configuration parameters for the connector. All values should be strings.
	Config *map[string]string `json:"config,omitempty"`
	// Array of offsets which are categorised into partitions.
	Offsets *[]map[string]interface{} `json:"offsets,omitempty"`
}

InlineObject struct for InlineObject

func NewInlineObject 

func NewInlineObject() *InlineObject

NewInlineObject instantiates a new InlineObject 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 NewInlineObjectWithDefaults 

func NewInlineObjectWithDefaults() *InlineObject

NewInlineObjectWithDefaults instantiates a new InlineObject 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 (*InlineObject) GetConfig 

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

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

func (*InlineObject) GetConfigOk 

func (o *InlineObject) 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 (*InlineObject) GetName 

func (o *InlineObject) GetName() string

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

func (*InlineObject) GetNameOk 

func (o *InlineObject) 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 (*InlineObject) GetOffsets added in v0.7.0 

func (o *InlineObject) GetOffsets() []map[string]interface{}

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

func (*InlineObject) GetOffsetsOk added in v0.7.0 

func (o *InlineObject) GetOffsetsOk() (*[]map[string]interface{}, 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 (*InlineObject) HasConfig 

func (o *InlineObject) HasConfig() bool

HasConfig returns a boolean if a field has been set.

func (*InlineObject) HasName 

func (o *InlineObject) HasName() bool

HasName returns a boolean if a field has been set.

func (*InlineObject) HasOffsets added in v0.7.0 

func (o *InlineObject) HasOffsets() bool

HasOffsets returns a boolean if a field has been set.

func (InlineObject) MarshalJSON 

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

func (*InlineObject) Redact 

func (o *InlineObject) Redact()

Redact resets all sensitive fields to their zero value.

func (*InlineObject) SetConfig 

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

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

func (*InlineObject) SetName 

func (o *InlineObject) SetName(v string)

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

func (*InlineObject) SetOffsets added in v0.7.0 

func (o *InlineObject) SetOffsets(v []map[string]interface{})

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

type InlineResponse200 

type InlineResponse200 struct {
	Error map[string]interface{} `json:"error,omitempty"`
}

InlineResponse200 struct for InlineResponse200

func NewInlineResponse200 

func NewInlineResponse200() *InlineResponse200

NewInlineResponse200 instantiates a new InlineResponse200 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 NewInlineResponse200WithDefaults 

func NewInlineResponse200WithDefaults() *InlineResponse200

NewInlineResponse200WithDefaults instantiates a new InlineResponse200 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 (*InlineResponse200) GetError 

func (o *InlineResponse200) GetError() map[string]interface{}

GetError returns the Error field value if set, zero value otherwise (both if not set or set to explicit null).

func (*InlineResponse200) GetErrorOk 

func (o *InlineResponse200) GetErrorOk() (*map[string]interface{}, bool)

GetErrorOk returns a tuple with the Error field value if set, nil otherwise and a boolean to check if the value has been set. NOTE: If the value is an explicit nil, `nil, true` will be returned

func (*InlineResponse200) HasError 

func (o *InlineResponse200) HasError() bool

HasError returns a boolean if a field has been set.

func (InlineResponse200) MarshalJSON 

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

func (*InlineResponse200) Redact 

func (o *InlineResponse200) Redact()

Redact resets all sensitive fields to their zero value.

func (*InlineResponse200) SetError 

func (o *InlineResponse200) SetError(v map[string]interface{})

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

type InlineResponse2001 

type InlineResponse2001 struct {
	// The name of the connector.
	Name string `json:"name,omitempty"`
	// Type of connector, sink or source.
	Type      string                      `json:"type,omitempty"`
	Connector InlineResponse2001Connector `json:"connector,omitempty"`
	// The map containing the task status.
	Tasks *[]InlineResponse2001Tasks `json:"tasks,omitempty"`
}

InlineResponse2001 struct for InlineResponse2001

func NewInlineResponse2001 

func NewInlineResponse2001(name string, type_ string, connector InlineResponse2001Connector) *InlineResponse2001

NewInlineResponse2001 instantiates a new InlineResponse2001 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 NewInlineResponse2001WithDefaults 

func NewInlineResponse2001WithDefaults() *InlineResponse2001

NewInlineResponse2001WithDefaults instantiates a new InlineResponse2001 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 (*InlineResponse2001) GetConnector 

func (o *InlineResponse2001) GetConnector() InlineResponse2001Connector

GetConnector returns the Connector field value

func (*InlineResponse2001) GetConnectorOk 

func (o *InlineResponse2001) GetConnectorOk() (*InlineResponse2001Connector, bool)

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

func (*InlineResponse2001) GetName 

func (o *InlineResponse2001) GetName() string

GetName returns the Name field value

func (*InlineResponse2001) GetNameOk 

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

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

func (*InlineResponse2001) GetTasks 

func (o *InlineResponse2001) GetTasks() []InlineResponse2001Tasks

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

func (*InlineResponse2001) GetTasksOk 

func (o *InlineResponse2001) GetTasksOk() (*[]InlineResponse2001Tasks, 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 (*InlineResponse2001) GetType 

func (o *InlineResponse2001) GetType() string

GetType returns the Type field value

func (*InlineResponse2001) GetTypeOk 

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

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

func (*InlineResponse2001) HasTasks 

func (o *InlineResponse2001) HasTasks() bool

HasTasks returns a boolean if a field has been set.

func (InlineResponse2001) MarshalJSON 

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

func (*InlineResponse2001) Redact 

func (o *InlineResponse2001) Redact()

Redact resets all sensitive fields to their zero value.

func (*InlineResponse2001) SetConnector 

func (o *InlineResponse2001) SetConnector(v InlineResponse2001Connector)

SetConnector sets field value

func (*InlineResponse2001) SetName 

func (o *InlineResponse2001) SetName(v string)

SetName sets field value

func (*InlineResponse2001) SetTasks 

func (o *InlineResponse2001) SetTasks(v []InlineResponse2001Tasks)

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

func (*InlineResponse2001) SetType 

func (o *InlineResponse2001) SetType(v string)

SetType sets field value

type InlineResponse2001Connector 

type InlineResponse2001Connector struct {
	// The state of the connector.
	State string `json:"state,omitempty"`
	// The worker ID of the connector.
	WorkerId string `json:"worker_id,omitempty"`
	// The exception name in case of error.
	Trace *string `json:"trace,omitempty"`
}

InlineResponse2001Connector The map containing connector status.

func NewInlineResponse2001Connector 

func NewInlineResponse2001Connector(state string, workerId string) *InlineResponse2001Connector

NewInlineResponse2001Connector instantiates a new InlineResponse2001Connector 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 NewInlineResponse2001ConnectorWithDefaults 

func NewInlineResponse2001ConnectorWithDefaults() *InlineResponse2001Connector

NewInlineResponse2001ConnectorWithDefaults instantiates a new InlineResponse2001Connector 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 (*InlineResponse2001Connector) GetState 

func (o *InlineResponse2001Connector) GetState() string

GetState returns the State field value

func (*InlineResponse2001Connector) GetStateOk 

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

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

func (*InlineResponse2001Connector) GetTrace 

func (o *InlineResponse2001Connector) GetTrace() string

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

func (*InlineResponse2001Connector) GetTraceOk 

func (o *InlineResponse2001Connector) 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 (*InlineResponse2001Connector) GetWorkerId 

func (o *InlineResponse2001Connector) GetWorkerId() string

GetWorkerId returns the WorkerId field value

func (*InlineResponse2001Connector) GetWorkerIdOk 

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

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

func (*InlineResponse2001Connector) HasTrace 

func (o *InlineResponse2001Connector) HasTrace() bool

HasTrace returns a boolean if a field has been set.

func (InlineResponse2001Connector) MarshalJSON 

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

func (*InlineResponse2001Connector) Redact 

func (o *InlineResponse2001Connector) Redact()

Redact resets all sensitive fields to their zero value.

func (*InlineResponse2001Connector) SetState 

func (o *InlineResponse2001Connector) SetState(v string)

SetState sets field value

func (*InlineResponse2001Connector) SetTrace 

func (o *InlineResponse2001Connector) SetTrace(v string)

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

func (*InlineResponse2001Connector) SetWorkerId 

func (o *InlineResponse2001Connector) SetWorkerId(v string)

SetWorkerId sets field value

type InlineResponse2001Tasks 

type InlineResponse2001Tasks struct {
	// The ID of task.
	Id int32 `json:"id,omitempty"`
	// The state of the task.
	State string `json:"state,omitempty"`
	// The worker ID of the task.
	WorkerId string  `json:"worker_id,omitempty"`
	Msg      *string `json:"msg,omitempty"`
}

InlineResponse2001Tasks struct for InlineResponse2001Tasks

func NewInlineResponse2001Tasks 

func NewInlineResponse2001Tasks(id int32, state string, workerId string) *InlineResponse2001Tasks

NewInlineResponse2001Tasks instantiates a new InlineResponse2001Tasks 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 NewInlineResponse2001TasksWithDefaults 

func NewInlineResponse2001TasksWithDefaults() *InlineResponse2001Tasks

NewInlineResponse2001TasksWithDefaults instantiates a new InlineResponse2001Tasks 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 (*InlineResponse2001Tasks) GetId 

func (o *InlineResponse2001Tasks) GetId() int32

GetId returns the Id field value

func (*InlineResponse2001Tasks) GetIdOk 

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

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

func (*InlineResponse2001Tasks) GetMsg 

func (o *InlineResponse2001Tasks) GetMsg() string

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

func (*InlineResponse2001Tasks) GetMsgOk 

func (o *InlineResponse2001Tasks) 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 (*InlineResponse2001Tasks) GetState 

func (o *InlineResponse2001Tasks) GetState() string

GetState returns the State field value

func (*InlineResponse2001Tasks) GetStateOk 

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

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

func (*InlineResponse2001Tasks) GetWorkerId 

func (o *InlineResponse2001Tasks) GetWorkerId() string

GetWorkerId returns the WorkerId field value

func (*InlineResponse2001Tasks) GetWorkerIdOk 

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

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

func (*InlineResponse2001Tasks) HasMsg 

func (o *InlineResponse2001Tasks) HasMsg() bool

HasMsg returns a boolean if a field has been set.

func (InlineResponse2001Tasks) MarshalJSON 

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

func (*InlineResponse2001Tasks) Redact 

func (o *InlineResponse2001Tasks) Redact()

Redact resets all sensitive fields to their zero value.

func (*InlineResponse2001Tasks) SetId 

func (o *InlineResponse2001Tasks) SetId(v int32)

SetId sets field value

func (*InlineResponse2001Tasks) SetMsg 

func (o *InlineResponse2001Tasks) SetMsg(v string)

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

func (*InlineResponse2001Tasks) SetState 

func (o *InlineResponse2001Tasks) SetState(v string)

SetState sets field value

func (*InlineResponse2001Tasks) SetWorkerId 

func (o *InlineResponse2001Tasks) SetWorkerId(v string)

SetWorkerId sets field value

type InlineResponse2002 

type InlineResponse2002 struct {
	// The connector class name. E.g. BigQuerySink.
	Class string `json:"class,omitempty"`
	// Type of connector, sink or source.
	Type string `json:"type,omitempty"`
	// The version string for the connector available.
	Version *string `json:"version,omitempty"`
}

InlineResponse2002 struct for InlineResponse2002

func NewInlineResponse2002 

func NewInlineResponse2002(class string, type_ string) *InlineResponse2002

NewInlineResponse2002 instantiates a new InlineResponse2002 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 NewInlineResponse2002WithDefaults 

func NewInlineResponse2002WithDefaults() *InlineResponse2002

NewInlineResponse2002WithDefaults instantiates a new InlineResponse2002 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 (*InlineResponse2002) GetClass 

func (o *InlineResponse2002) GetClass() string

GetClass returns the Class field value

func (*InlineResponse2002) GetClassOk 

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

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

func (*InlineResponse2002) GetType 

func (o *InlineResponse2002) GetType() string

GetType returns the Type field value

func (*InlineResponse2002) GetTypeOk 

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

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

func (*InlineResponse2002) GetVersion 

func (o *InlineResponse2002) GetVersion() string

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

func (*InlineResponse2002) GetVersionOk 

func (o *InlineResponse2002) 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 (*InlineResponse2002) HasVersion 

func (o *InlineResponse2002) HasVersion() bool

HasVersion returns a boolean if a field has been set.

func (InlineResponse2002) MarshalJSON 

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

func (*InlineResponse2002) Redact 

func (o *InlineResponse2002) Redact()

Redact resets all sensitive fields to their zero value.

func (*InlineResponse2002) SetClass 

func (o *InlineResponse2002) SetClass(v string)

SetClass sets field value

func (*InlineResponse2002) SetType 

func (o *InlineResponse2002) SetType(v string)

SetType sets field value

func (*InlineResponse2002) SetVersion 

func (o *InlineResponse2002) SetVersion(v string)

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

type InlineResponse2003 

type InlineResponse2003 struct {
	// The class name of the connector plugin.
	Name *string `json:"name,omitempty"`
	// The list of groups used in configuration definitions.
	Groups *[]string `json:"groups,omitempty"`
	// The total number of errors encountered during configuration validation.
	ErrorCount *int32                       `json:"error_count,omitempty"`
	Configs    *[]InlineResponse2003Configs `json:"configs,omitempty"`
}

InlineResponse2003 struct for InlineResponse2003

func NewInlineResponse2003 

func NewInlineResponse2003() *InlineResponse2003

NewInlineResponse2003 instantiates a new InlineResponse2003 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 NewInlineResponse2003WithDefaults 

func NewInlineResponse2003WithDefaults() *InlineResponse2003

NewInlineResponse2003WithDefaults instantiates a new InlineResponse2003 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 (*InlineResponse2003) GetConfigs 

func (o *InlineResponse2003) GetConfigs() []InlineResponse2003Configs

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

func (*InlineResponse2003) GetConfigsOk 

func (o *InlineResponse2003) GetConfigsOk() (*[]InlineResponse2003Configs, 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 (*InlineResponse2003) GetErrorCount 

func (o *InlineResponse2003) GetErrorCount() int32

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

func (*InlineResponse2003) GetErrorCountOk 

func (o *InlineResponse2003) 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 (*InlineResponse2003) GetGroups 

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

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

func (*InlineResponse2003) GetGroupsOk 

func (o *InlineResponse2003) 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 (*InlineResponse2003) GetName 

func (o *InlineResponse2003) GetName() string

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

func (*InlineResponse2003) GetNameOk 

func (o *InlineResponse2003) 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 (*InlineResponse2003) HasConfigs 

func (o *InlineResponse2003) HasConfigs() bool

HasConfigs returns a boolean if a field has been set.

func (*InlineResponse2003) HasErrorCount 

func (o *InlineResponse2003) HasErrorCount() bool

HasErrorCount returns a boolean if a field has been set.

func (*InlineResponse2003) HasGroups 

func (o *InlineResponse2003) HasGroups() bool

HasGroups returns a boolean if a field has been set.

func (*InlineResponse2003) HasName 

func (o *InlineResponse2003) HasName() bool

HasName returns a boolean if a field has been set.

func (InlineResponse2003) MarshalJSON 

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

func (*InlineResponse2003) Redact 

func (o *InlineResponse2003) Redact()

Redact resets all sensitive fields to their zero value.

func (*InlineResponse2003) SetConfigs 

func (o *InlineResponse2003) SetConfigs(v []InlineResponse2003Configs)

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

func (*InlineResponse2003) SetErrorCount 

func (o *InlineResponse2003) SetErrorCount(v int32)

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

func (*InlineResponse2003) SetGroups 

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

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

func (*InlineResponse2003) SetName 

func (o *InlineResponse2003) SetName(v string)

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

type InlineResponse2003Configs 

type InlineResponse2003Configs struct {
	Definition *InlineResponse2003Definition `json:"definition,omitempty"`
	Value      *InlineResponse2003Value      `json:"value,omitempty"`
	// Map of metadata details about the connector configuration, such as type of input, etc.
	Metadata *map[string]interface{} `json:"metadata,omitempty"`
}

InlineResponse2003Configs struct for InlineResponse2003Configs

func NewInlineResponse2003Configs 

func NewInlineResponse2003Configs() *InlineResponse2003Configs

NewInlineResponse2003Configs instantiates a new InlineResponse2003Configs 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 NewInlineResponse2003ConfigsWithDefaults 

func NewInlineResponse2003ConfigsWithDefaults() *InlineResponse2003Configs

NewInlineResponse2003ConfigsWithDefaults instantiates a new InlineResponse2003Configs 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 (*InlineResponse2003Configs) GetDefinition 

func (o *InlineResponse2003Configs) GetDefinition() InlineResponse2003Definition

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

func (*InlineResponse2003Configs) GetDefinitionOk 

func (o *InlineResponse2003Configs) GetDefinitionOk() (*InlineResponse2003Definition, 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 (*InlineResponse2003Configs) GetMetadata 

func (o *InlineResponse2003Configs) GetMetadata() map[string]interface{}

GetMetadata returns the Metadata field value if set, zero value otherwise.

func (*InlineResponse2003Configs) GetMetadataOk 

func (o *InlineResponse2003Configs) GetMetadataOk() (*map[string]interface{}, bool)

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

func (*InlineResponse2003Configs) GetValue 

func (o *InlineResponse2003Configs) GetValue() InlineResponse2003Value

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

func (*InlineResponse2003Configs) GetValueOk 

func (o *InlineResponse2003Configs) GetValueOk() (*InlineResponse2003Value, 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 (*InlineResponse2003Configs) HasDefinition 

func (o *InlineResponse2003Configs) HasDefinition() bool

HasDefinition returns a boolean if a field has been set.

func (*InlineResponse2003Configs) HasMetadata 

func (o *InlineResponse2003Configs) HasMetadata() bool

HasMetadata returns a boolean if a field has been set.

func (*InlineResponse2003Configs) HasValue 

func (o *InlineResponse2003Configs) HasValue() bool

HasValue returns a boolean if a field has been set.

func (InlineResponse2003Configs) MarshalJSON 

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

func (*InlineResponse2003Configs) Redact 

func (o *InlineResponse2003Configs) Redact()

Redact resets all sensitive fields to their zero value.

func (*InlineResponse2003Configs) SetDefinition 

func (o *InlineResponse2003Configs) SetDefinition(v InlineResponse2003Definition)

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

func (*InlineResponse2003Configs) SetMetadata 

func (o *InlineResponse2003Configs) SetMetadata(v map[string]interface{})

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

func (*InlineResponse2003Configs) SetValue 

func (o *InlineResponse2003Configs) SetValue(v InlineResponse2003Value)

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

type InlineResponse2003Definition 

type InlineResponse2003Definition struct {
	// The name of the configuration
	Name *string `json:"name,omitempty"`
	// The config types
	Type *string `json:"type,omitempty"`
	// Whether this configuration is required
	Required *bool `json:"required,omitempty"`
	// Default value for this configuration
	DefaultValue *string `json:"default_value,omitempty"`
	// The importance level for a configuration
	Importance *string `json:"importance,omitempty"`
	// The documentation for the configuration
	Documentation *string `json:"documentation,omitempty"`
	// The UI group to which the configuration belongs to
	Group *string `json:"group,omitempty"`
	// The width of a configuration value
	Width       *string `json:"width,omitempty"`
	DisplayName *string `json:"display_name,omitempty"`
	// Other configurations on which this configuration is dependent
	Dependents *[]string `json:"dependents,omitempty"`
	// The order of configuration in specified group
	Order *int32  `json:"order,omitempty"`
	Alias *string `json:"alias,omitempty"`
}

InlineResponse2003Definition The definition for a config in the connector plugin, which includes the name, type, importance, etc.

func NewInlineResponse2003Definition 

func NewInlineResponse2003Definition() *InlineResponse2003Definition

NewInlineResponse2003Definition instantiates a new InlineResponse2003Definition 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 NewInlineResponse2003DefinitionWithDefaults 

func NewInlineResponse2003DefinitionWithDefaults() *InlineResponse2003Definition

NewInlineResponse2003DefinitionWithDefaults instantiates a new InlineResponse2003Definition 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 (*InlineResponse2003Definition) GetAlias 

func (o *InlineResponse2003Definition) GetAlias() string

GetAlias returns the Alias field value if set, zero value otherwise.

func (*InlineResponse2003Definition) GetAliasOk 

func (o *InlineResponse2003Definition) GetAliasOk() (*string, bool)

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

func (*InlineResponse2003Definition) GetDefaultValue 

func (o *InlineResponse2003Definition) GetDefaultValue() string

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

func (*InlineResponse2003Definition) GetDefaultValueOk 

func (o *InlineResponse2003Definition) 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 (*InlineResponse2003Definition) GetDependents 

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

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

func (*InlineResponse2003Definition) GetDependentsOk 

func (o *InlineResponse2003Definition) 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 (*InlineResponse2003Definition) GetDisplayName 

func (o *InlineResponse2003Definition) GetDisplayName() string

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

func (*InlineResponse2003Definition) GetDisplayNameOk 

func (o *InlineResponse2003Definition) 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 (*InlineResponse2003Definition) GetDocumentation 

func (o *InlineResponse2003Definition) GetDocumentation() string

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

func (*InlineResponse2003Definition) GetDocumentationOk 

func (o *InlineResponse2003Definition) 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 (*InlineResponse2003Definition) GetGroup 

func (o *InlineResponse2003Definition) GetGroup() string

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

func (*InlineResponse2003Definition) GetGroupOk 

func (o *InlineResponse2003Definition) 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 (*InlineResponse2003Definition) GetImportance 

func (o *InlineResponse2003Definition) GetImportance() string

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

func (*InlineResponse2003Definition) GetImportanceOk 

func (o *InlineResponse2003Definition) 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 (*InlineResponse2003Definition) GetName 

func (o *InlineResponse2003Definition) GetName() string

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

func (*InlineResponse2003Definition) GetNameOk 

func (o *InlineResponse2003Definition) 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 (*InlineResponse2003Definition) GetOrder 

func (o *InlineResponse2003Definition) GetOrder() int32

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

func (*InlineResponse2003Definition) GetOrderOk 

func (o *InlineResponse2003Definition) 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 (*InlineResponse2003Definition) GetRequired 

func (o *InlineResponse2003Definition) GetRequired() bool

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

func (*InlineResponse2003Definition) GetRequiredOk 

func (o *InlineResponse2003Definition) 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 (*InlineResponse2003Definition) GetType 

func (o *InlineResponse2003Definition) GetType() string

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

func (*InlineResponse2003Definition) GetTypeOk 

func (o *InlineResponse2003Definition) 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 (*InlineResponse2003Definition) GetWidth 

func (o *InlineResponse2003Definition) GetWidth() string

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

func (*InlineResponse2003Definition) GetWidthOk 

func (o *InlineResponse2003Definition) 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 (*InlineResponse2003Definition) HasAlias 

func (o *InlineResponse2003Definition) HasAlias() bool

HasAlias returns a boolean if a field has been set.

func (*InlineResponse2003Definition) HasDefaultValue 

func (o *InlineResponse2003Definition) HasDefaultValue() bool

HasDefaultValue returns a boolean if a field has been set.

func (*InlineResponse2003Definition) HasDependents 

func (o *InlineResponse2003Definition) HasDependents() bool

HasDependents returns a boolean if a field has been set.

func (*InlineResponse2003Definition) HasDisplayName 

func (o *InlineResponse2003Definition) HasDisplayName() bool

HasDisplayName returns a boolean if a field has been set.

func (*InlineResponse2003Definition) HasDocumentation 

func (o *InlineResponse2003Definition) HasDocumentation() bool

HasDocumentation returns a boolean if a field has been set.

func (*InlineResponse2003Definition) HasGroup 

func (o *InlineResponse2003Definition) HasGroup() bool

HasGroup returns a boolean if a field has been set.

func (*InlineResponse2003Definition) HasImportance 

func (o *InlineResponse2003Definition) HasImportance() bool

HasImportance returns a boolean if a field has been set.

func (*InlineResponse2003Definition) HasName 

func (o *InlineResponse2003Definition) HasName() bool

HasName returns a boolean if a field has been set.

func (*InlineResponse2003Definition) HasOrder 

func (o *InlineResponse2003Definition) HasOrder() bool

HasOrder returns a boolean if a field has been set.

func (*InlineResponse2003Definition) HasRequired 

func (o *InlineResponse2003Definition) HasRequired() bool

HasRequired returns a boolean if a field has been set.

func (*InlineResponse2003Definition) HasType 

func (o *InlineResponse2003Definition) HasType() bool

HasType returns a boolean if a field has been set.

func (*InlineResponse2003Definition) HasWidth 

func (o *InlineResponse2003Definition) HasWidth() bool

HasWidth returns a boolean if a field has been set.

func (InlineResponse2003Definition) MarshalJSON 

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

func (*InlineResponse2003Definition) Redact 

func (o *InlineResponse2003Definition) Redact()

Redact resets all sensitive fields to their zero value.

func (*InlineResponse2003Definition) SetAlias 

func (o *InlineResponse2003Definition) SetAlias(v string)

SetAlias gets a reference to the given string and assigns it to the Alias field.

func (*InlineResponse2003Definition) SetDefaultValue 

func (o *InlineResponse2003Definition) SetDefaultValue(v string)

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

func (*InlineResponse2003Definition) SetDependents 

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

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

func (*InlineResponse2003Definition) SetDisplayName 

func (o *InlineResponse2003Definition) SetDisplayName(v string)

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

func (*InlineResponse2003Definition) SetDocumentation 

func (o *InlineResponse2003Definition) SetDocumentation(v string)

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

func (*InlineResponse2003Definition) SetGroup 

func (o *InlineResponse2003Definition) SetGroup(v string)

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

func (*InlineResponse2003Definition) SetImportance 

func (o *InlineResponse2003Definition) SetImportance(v string)

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

func (*InlineResponse2003Definition) SetName 

func (o *InlineResponse2003Definition) SetName(v string)

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

func (*InlineResponse2003Definition) SetOrder 

func (o *InlineResponse2003Definition) SetOrder(v int32)

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

func (*InlineResponse2003Definition) SetRequired 

func (o *InlineResponse2003Definition) SetRequired(v bool)

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

func (*InlineResponse2003Definition) SetType 

func (o *InlineResponse2003Definition) SetType(v string)

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

func (*InlineResponse2003Definition) SetWidth 

func (o *InlineResponse2003Definition) SetWidth(v string)

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

type InlineResponse2003Value 

type InlineResponse2003Value struct {
	// The name of the configuration
	Name *string `json:"name,omitempty"`
	// The value for the configuration
	Value *string `json:"value,omitempty"`
	// The list of valid values for the configuration
	RecommendedValues *[]string `json:"recommended_values,omitempty"`
	// Errors, if any, in the configuration value
	Errors *[]string `json:"errors,omitempty"`
	// The visibility of the configuration. Based on the values of other configuration fields, this visibility boolean value points out if the current field should be visible or not.
	Visible *bool `json:"visible,omitempty"`
}

InlineResponse2003Value The current value for a config, which includes the name, value, recommended values, etc.

func NewInlineResponse2003Value 

func NewInlineResponse2003Value() *InlineResponse2003Value

NewInlineResponse2003Value instantiates a new InlineResponse2003Value 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 NewInlineResponse2003ValueWithDefaults 

func NewInlineResponse2003ValueWithDefaults() *InlineResponse2003Value

NewInlineResponse2003ValueWithDefaults instantiates a new InlineResponse2003Value 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 (*InlineResponse2003Value) GetErrors 

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

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

func (*InlineResponse2003Value) GetErrorsOk 

func (o *InlineResponse2003Value) 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 (*InlineResponse2003Value) GetName 

func (o *InlineResponse2003Value) GetName() string

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

func (*InlineResponse2003Value) GetNameOk 

func (o *InlineResponse2003Value) 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 (*InlineResponse2003Value) GetRecommendedValues 

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

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

func (*InlineResponse2003Value) GetRecommendedValuesOk 

func (o *InlineResponse2003Value) 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 (*InlineResponse2003Value) GetValue 

func (o *InlineResponse2003Value) GetValue() string

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

func (*InlineResponse2003Value) GetValueOk 

func (o *InlineResponse2003Value) 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 (*InlineResponse2003Value) GetVisible 

func (o *InlineResponse2003Value) GetVisible() bool

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

func (*InlineResponse2003Value) GetVisibleOk 

func (o *InlineResponse2003Value) 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 (*InlineResponse2003Value) HasErrors 

func (o *InlineResponse2003Value) HasErrors() bool

HasErrors returns a boolean if a field has been set.

func (*InlineResponse2003Value) HasName 

func (o *InlineResponse2003Value) HasName() bool

HasName returns a boolean if a field has been set.

func (*InlineResponse2003Value) HasRecommendedValues 

func (o *InlineResponse2003Value) HasRecommendedValues() bool

HasRecommendedValues returns a boolean if a field has been set.

func (*InlineResponse2003Value) HasValue 

func (o *InlineResponse2003Value) HasValue() bool

HasValue returns a boolean if a field has been set.

func (*InlineResponse2003Value) HasVisible 

func (o *InlineResponse2003Value) HasVisible() bool

HasVisible returns a boolean if a field has been set.

func (InlineResponse2003Value) MarshalJSON 

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

func (*InlineResponse2003Value) Redact 

func (o *InlineResponse2003Value) Redact()

Redact resets all sensitive fields to their zero value.

func (*InlineResponse2003Value) SetErrors 

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

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

func (*InlineResponse2003Value) SetName 

func (o *InlineResponse2003Value) SetName(v string)

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

func (*InlineResponse2003Value) SetRecommendedValues 

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

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

func (*InlineResponse2003Value) SetValue 

func (o *InlineResponse2003Value) SetValue(v string)

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

func (*InlineResponse2003Value) SetVisible 

func (o *InlineResponse2003Value) SetVisible(v bool)

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

type InlineResponse400 

type InlineResponse400 struct {
	Code    *int32  `json:"code,omitempty"`
	Message *string `json:"message,omitempty"`
}

InlineResponse400 struct for InlineResponse400

func NewInlineResponse400 

func NewInlineResponse400() *InlineResponse400

NewInlineResponse400 instantiates a new InlineResponse400 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 NewInlineResponse400WithDefaults 

func NewInlineResponse400WithDefaults() *InlineResponse400

NewInlineResponse400WithDefaults instantiates a new InlineResponse400 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 (*InlineResponse400) GetCode 

func (o *InlineResponse400) GetCode() int32

GetCode returns the Code field value if set, zero value otherwise.

func (*InlineResponse400) GetCodeOk 

func (o *InlineResponse400) GetCodeOk() (*int32, bool)

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

func (*InlineResponse400) GetMessage 

func (o *InlineResponse400) GetMessage() string

GetMessage returns the Message field value if set, zero value otherwise.

func (*InlineResponse400) GetMessageOk 

func (o *InlineResponse400) GetMessageOk() (*string, bool)

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

func (*InlineResponse400) HasCode 

func (o *InlineResponse400) HasCode() bool

HasCode returns a boolean if a field has been set.

func (*InlineResponse400) HasMessage 

func (o *InlineResponse400) HasMessage() bool

HasMessage returns a boolean if a field has been set.

func (InlineResponse400) MarshalJSON 

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

func (*InlineResponse400) Redact 

func (o *InlineResponse400) Redact()

Redact resets all sensitive fields to their zero value.

func (*InlineResponse400) SetCode 

func (o *InlineResponse400) SetCode(v int32)

SetCode gets a reference to the given int32 and assigns it to the Code field.

func (*InlineResponse400) SetMessage 

func (o *InlineResponse400) SetMessage(v string)

SetMessage gets a reference to the given string and assigns it to the Message field.

type InlineResponse500 

type InlineResponse500 struct {
	ErrorCode *int32  `json:"error_code,omitempty"`
	Message   *string `json:"message,omitempty"`
}

InlineResponse500 struct for InlineResponse500

func NewInlineResponse500 

func NewInlineResponse500() *InlineResponse500

NewInlineResponse500 instantiates a new InlineResponse500 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 NewInlineResponse500WithDefaults 

func NewInlineResponse500WithDefaults() *InlineResponse500

NewInlineResponse500WithDefaults instantiates a new InlineResponse500 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 (*InlineResponse500) GetErrorCode 

func (o *InlineResponse500) GetErrorCode() int32

GetErrorCode returns the ErrorCode field value if set, zero value otherwise.

func (*InlineResponse500) GetErrorCodeOk 

func (o *InlineResponse500) GetErrorCodeOk() (*int32, bool)

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

func (*InlineResponse500) GetMessage 

func (o *InlineResponse500) GetMessage() string

GetMessage returns the Message field value if set, zero value otherwise.

func (*InlineResponse500) GetMessageOk 

func (o *InlineResponse500) GetMessageOk() (*string, bool)

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

func (*InlineResponse500) HasErrorCode 

func (o *InlineResponse500) HasErrorCode() bool

HasErrorCode returns a boolean if a field has been set.

func (*InlineResponse500) HasMessage 

func (o *InlineResponse500) HasMessage() bool

HasMessage returns a boolean if a field has been set.

func (InlineResponse500) MarshalJSON 

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

func (*InlineResponse500) Redact 

func (o *InlineResponse500) Redact()

Redact resets all sensitive fields to their zero value.

func (*InlineResponse500) SetErrorCode 

func (o *InlineResponse500) SetErrorCode(v int32)

SetErrorCode gets a reference to the given int32 and assigns it to the ErrorCode field.

func (*InlineResponse500) SetMessage 

func (o *InlineResponse500) SetMessage(v string)

SetMessage gets a reference to the given string and assigns it to the Message field.

type LifecycleConnectV1Api added in v0.5.0 

type LifecycleConnectV1Api interface {

	/*
			PauseConnectv1Connector Pause a Connector

			[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

		Pause the connector and its tasks. Stops message processing until the connector is resumed. This call is asynchronous and the tasks will not transition to PAUSED state at the same time.

			 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
			 @param connectorName The unique name of the connector.
			 @param environmentId The unique identifier of the environment this resource belongs to.
			 @param kafkaClusterId The unique identifier for the Kafka cluster.
			 @return ApiPauseConnectv1ConnectorRequest
	*/
	PauseConnectv1Connector(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiPauseConnectv1ConnectorRequest

	// PauseConnectv1ConnectorExecute executes the request
	PauseConnectv1ConnectorExecute(r ApiPauseConnectv1ConnectorRequest) (*_nethttp.Response, error)

	/*
			ResumeConnectv1Connector Resume a Connector

			[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

		Resume a paused connector or do nothing if the connector is not paused. This call is asynchronous and the tasks will not transition to RUNNING state at the same time.

			 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
			 @param connectorName The unique name of the connector.
			 @param environmentId The unique identifier of the environment this resource belongs to.
			 @param kafkaClusterId The unique identifier for the Kafka cluster.
			 @return ApiResumeConnectv1ConnectorRequest
	*/
	ResumeConnectv1Connector(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiResumeConnectv1ConnectorRequest

	// ResumeConnectv1ConnectorExecute executes the request
	ResumeConnectv1ConnectorExecute(r ApiResumeConnectv1ConnectorRequest) (*_nethttp.Response, error)
}

type LifecycleConnectV1ApiService added in v0.5.0 

type LifecycleConnectV1ApiService service

LifecycleConnectV1ApiService LifecycleConnectV1Api service

func (*LifecycleConnectV1ApiService) PauseConnectv1Connector added in v0.5.0 

func (a *LifecycleConnectV1ApiService) PauseConnectv1Connector(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiPauseConnectv1ConnectorRequest

PauseConnectv1Connector Pause a Connector

[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

Pause the connector and its tasks. Stops message processing until the connector is resumed. This call is asynchronous and the tasks will not transition to PAUSED state at the same time. 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connectorName The unique name of the connector.
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiPauseConnectv1ConnectorRequest

func (*LifecycleConnectV1ApiService) PauseConnectv1ConnectorExecute added in v0.5.0 

func (a *LifecycleConnectV1ApiService) PauseConnectv1ConnectorExecute(r ApiPauseConnectv1ConnectorRequest) (*_nethttp.Response, error)

Execute executes the request

func (*LifecycleConnectV1ApiService) ResumeConnectv1Connector added in v0.5.0 

func (a *LifecycleConnectV1ApiService) ResumeConnectv1Connector(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiResumeConnectv1ConnectorRequest

ResumeConnectv1Connector Resume a Connector

[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

Resume a paused connector or do nothing if the connector is not paused. This call is asynchronous and the tasks will not transition to RUNNING state at the same time. 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connectorName The unique name of the connector.
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiResumeConnectv1ConnectorRequest

func (*LifecycleConnectV1ApiService) ResumeConnectv1ConnectorExecute added in v0.5.0 

func (a *LifecycleConnectV1ApiService) ResumeConnectv1ConnectorExecute(r ApiResumeConnectv1ConnectorRequest) (*_nethttp.Response, error)

Execute executes the request

type ManagedConnectorPluginsConnectV1Api added in v0.5.0 

type ManagedConnectorPluginsConnectV1Api interface {

	/*
			ListConnectv1ConnectorPlugins List of Managed Connector plugins

			[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

		Return a list of Managed Connector plugins installed in the Kafka Connect cluster.

			 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
			 @param environmentId The unique identifier of the environment this resource belongs to.
			 @param kafkaClusterId The unique identifier for the Kafka cluster.
			 @return ApiListConnectv1ConnectorPluginsRequest
	*/
	ListConnectv1ConnectorPlugins(ctx _context.Context, environmentId string, kafkaClusterId string) ApiListConnectv1ConnectorPluginsRequest

	// ListConnectv1ConnectorPluginsExecute executes the request
	//  @return []InlineResponse2002
	ListConnectv1ConnectorPluginsExecute(r ApiListConnectv1ConnectorPluginsRequest) ([]InlineResponse2002, *_nethttp.Response, error)

	/*
			ValidateConnectv1ConnectorPlugin Validate a Managed Connector Plugin

			[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

		Validate the provided configuration values against the configuration definition. This API performs per config validation and returns suggested values and validation error messages.

			 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
			 @param pluginName The unique name of the connector plugin.
			 @param environmentId The unique identifier of the environment this resource belongs to.
			 @param kafkaClusterId The unique identifier for the Kafka cluster.
			 @return ApiValidateConnectv1ConnectorPluginRequest
	*/
	ValidateConnectv1ConnectorPlugin(ctx _context.Context, pluginName string, environmentId string, kafkaClusterId string) ApiValidateConnectv1ConnectorPluginRequest

	// ValidateConnectv1ConnectorPluginExecute executes the request
	//  @return InlineResponse2003
	ValidateConnectv1ConnectorPluginExecute(r ApiValidateConnectv1ConnectorPluginRequest) (InlineResponse2003, *_nethttp.Response, error)
}

type ManagedConnectorPluginsConnectV1ApiService added in v0.5.0 

type ManagedConnectorPluginsConnectV1ApiService service

ManagedConnectorPluginsConnectV1ApiService ManagedConnectorPluginsConnectV1Api service

func (*ManagedConnectorPluginsConnectV1ApiService) ListConnectv1ConnectorPlugins added in v0.5.0 

func (a *ManagedConnectorPluginsConnectV1ApiService) ListConnectv1ConnectorPlugins(ctx _context.Context, environmentId string, kafkaClusterId string) ApiListConnectv1ConnectorPluginsRequest

ListConnectv1ConnectorPlugins List of Managed Connector plugins

[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

Return a list of Managed Connector plugins installed in the Kafka Connect cluster. 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiListConnectv1ConnectorPluginsRequest

func (*ManagedConnectorPluginsConnectV1ApiService) ListConnectv1ConnectorPluginsExecute added in v0.5.0 

func (a *ManagedConnectorPluginsConnectV1ApiService) ListConnectv1ConnectorPluginsExecute(r ApiListConnectv1ConnectorPluginsRequest) ([]InlineResponse2002, *_nethttp.Response, error)

Execute executes the request 

@return []InlineResponse2002

func (*ManagedConnectorPluginsConnectV1ApiService) ValidateConnectv1ConnectorPlugin added in v0.5.0 

func (a *ManagedConnectorPluginsConnectV1ApiService) ValidateConnectv1ConnectorPlugin(ctx _context.Context, pluginName string, environmentId string, kafkaClusterId string) ApiValidateConnectv1ConnectorPluginRequest

ValidateConnectv1ConnectorPlugin Validate a Managed Connector Plugin

[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

Validate the provided configuration values against the configuration definition. This API performs per config validation and returns suggested values and validation error messages. 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param pluginName The unique name of the connector plugin.
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiValidateConnectv1ConnectorPluginRequest

func (*ManagedConnectorPluginsConnectV1ApiService) ValidateConnectv1ConnectorPluginExecute added in v0.5.0 

func (a *ManagedConnectorPluginsConnectV1ApiService) ValidateConnectv1ConnectorPluginExecute(r ApiValidateConnectv1ConnectorPluginRequest) (InlineResponse2003, *_nethttp.Response, error)

Execute executes the request 

@return InlineResponse2003

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 NullableConnectV1AlterOffsetRequest added in v0.5.0 

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

func NewNullableConnectV1AlterOffsetRequest added in v0.5.0 

func NewNullableConnectV1AlterOffsetRequest(val *ConnectV1AlterOffsetRequest) *NullableConnectV1AlterOffsetRequest

func (NullableConnectV1AlterOffsetRequest) Get added in v0.5.0 

func (v NullableConnectV1AlterOffsetRequest) Get() *ConnectV1AlterOffsetRequest

func (NullableConnectV1AlterOffsetRequest) IsSet added in v0.5.0 

func (v NullableConnectV1AlterOffsetRequest) IsSet() bool

func (NullableConnectV1AlterOffsetRequest) MarshalJSON added in v0.5.0 

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

func (*NullableConnectV1AlterOffsetRequest) Set added in v0.5.0 

func (v *NullableConnectV1AlterOffsetRequest) Set(val *ConnectV1AlterOffsetRequest)

func (*NullableConnectV1AlterOffsetRequest) UnmarshalJSON added in v0.5.0 

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

func (*NullableConnectV1AlterOffsetRequest) Unset added in v0.5.0 

func (v *NullableConnectV1AlterOffsetRequest) Unset()

type NullableConnectV1AlterOffsetRequestInfo added in v0.5.0 

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

func NewNullableConnectV1AlterOffsetRequestInfo added in v0.5.0 

func NewNullableConnectV1AlterOffsetRequestInfo(val *ConnectV1AlterOffsetRequestInfo) *NullableConnectV1AlterOffsetRequestInfo

func (NullableConnectV1AlterOffsetRequestInfo) Get added in v0.5.0 

func (v NullableConnectV1AlterOffsetRequestInfo) Get() *ConnectV1AlterOffsetRequestInfo

func (NullableConnectV1AlterOffsetRequestInfo) IsSet added in v0.5.0 

func (v NullableConnectV1AlterOffsetRequestInfo) IsSet() bool

func (NullableConnectV1AlterOffsetRequestInfo) MarshalJSON added in v0.5.0 

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

func (*NullableConnectV1AlterOffsetRequestInfo) Set added in v0.5.0 

func (v *NullableConnectV1AlterOffsetRequestInfo) Set(val *ConnectV1AlterOffsetRequestInfo)

func (*NullableConnectV1AlterOffsetRequestInfo) UnmarshalJSON added in v0.5.0 

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

func (*NullableConnectV1AlterOffsetRequestInfo) Unset added in v0.5.0 

func (v *NullableConnectV1AlterOffsetRequestInfo) Unset()

type NullableConnectV1AlterOffsetRequestType added in v0.5.0 

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

func NewNullableConnectV1AlterOffsetRequestType added in v0.5.0 

func NewNullableConnectV1AlterOffsetRequestType(val *ConnectV1AlterOffsetRequestType) *NullableConnectV1AlterOffsetRequestType

func (NullableConnectV1AlterOffsetRequestType) Get added in v0.5.0 

func (v NullableConnectV1AlterOffsetRequestType) Get() *ConnectV1AlterOffsetRequestType

func (NullableConnectV1AlterOffsetRequestType) IsSet added in v0.5.0 

func (v NullableConnectV1AlterOffsetRequestType) IsSet() bool

func (NullableConnectV1AlterOffsetRequestType) MarshalJSON added in v0.5.0 

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

func (*NullableConnectV1AlterOffsetRequestType) Set added in v0.5.0 

func (v *NullableConnectV1AlterOffsetRequestType) Set(val *ConnectV1AlterOffsetRequestType)

func (*NullableConnectV1AlterOffsetRequestType) UnmarshalJSON added in v0.5.0 

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

func (*NullableConnectV1AlterOffsetRequestType) Unset added in v0.5.0 

func (v *NullableConnectV1AlterOffsetRequestType) Unset()

type NullableConnectV1AlterOffsetStatus added in v0.5.0 

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

func NewNullableConnectV1AlterOffsetStatus added in v0.5.0 

func NewNullableConnectV1AlterOffsetStatus(val *ConnectV1AlterOffsetStatus) *NullableConnectV1AlterOffsetStatus

func (NullableConnectV1AlterOffsetStatus) Get added in v0.5.0 

func (v NullableConnectV1AlterOffsetStatus) Get() *ConnectV1AlterOffsetStatus

func (NullableConnectV1AlterOffsetStatus) IsSet added in v0.5.0 

func (v NullableConnectV1AlterOffsetStatus) IsSet() bool

func (NullableConnectV1AlterOffsetStatus) MarshalJSON added in v0.5.0 

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

func (*NullableConnectV1AlterOffsetStatus) Set added in v0.5.0 

func (v *NullableConnectV1AlterOffsetStatus) Set(val *ConnectV1AlterOffsetStatus)

func (*NullableConnectV1AlterOffsetStatus) UnmarshalJSON added in v0.5.0 

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

func (*NullableConnectV1AlterOffsetStatus) Unset added in v0.5.0 

func (v *NullableConnectV1AlterOffsetStatus) Unset()

type NullableConnectV1AlterOffsetStatusStatus added in v0.5.0 

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

func NewNullableConnectV1AlterOffsetStatusStatus added in v0.5.0 

func NewNullableConnectV1AlterOffsetStatusStatus(val *ConnectV1AlterOffsetStatusStatus) *NullableConnectV1AlterOffsetStatusStatus

func (NullableConnectV1AlterOffsetStatusStatus) Get added in v0.5.0 

func (v NullableConnectV1AlterOffsetStatusStatus) Get() *ConnectV1AlterOffsetStatusStatus

func (NullableConnectV1AlterOffsetStatusStatus) IsSet added in v0.5.0 

func (v NullableConnectV1AlterOffsetStatusStatus) IsSet() bool

func (NullableConnectV1AlterOffsetStatusStatus) MarshalJSON added in v0.5.0 

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

func (*NullableConnectV1AlterOffsetStatusStatus) Set added in v0.5.0 

func (v *NullableConnectV1AlterOffsetStatusStatus) Set(val *ConnectV1AlterOffsetStatusStatus)

func (*NullableConnectV1AlterOffsetStatusStatus) UnmarshalJSON added in v0.5.0 

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

func (*NullableConnectV1AlterOffsetStatusStatus) Unset added in v0.5.0 

func (v *NullableConnectV1AlterOffsetStatusStatus) Unset()

type NullableConnectV1Connector 

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

func NewNullableConnectV1Connector 

func NewNullableConnectV1Connector(val *ConnectV1Connector) *NullableConnectV1Connector

func (NullableConnectV1Connector) Get 

func (v NullableConnectV1Connector) Get() *ConnectV1Connector

func (NullableConnectV1Connector) IsSet 

func (v NullableConnectV1Connector) IsSet() bool

func (NullableConnectV1Connector) MarshalJSON 

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

func (*NullableConnectV1Connector) Set 

func (v *NullableConnectV1Connector) Set(val *ConnectV1Connector)

func (*NullableConnectV1Connector) UnmarshalJSON 

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

func (*NullableConnectV1Connector) Unset 

func (v *NullableConnectV1Connector) Unset()

type NullableConnectV1ConnectorError 

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

func NewNullableConnectV1ConnectorError 

func NewNullableConnectV1ConnectorError(val *ConnectV1ConnectorError) *NullableConnectV1ConnectorError

func (NullableConnectV1ConnectorError) Get 

func (v NullableConnectV1ConnectorError) Get() *ConnectV1ConnectorError

func (NullableConnectV1ConnectorError) IsSet 

func (v NullableConnectV1ConnectorError) IsSet() bool

func (NullableConnectV1ConnectorError) MarshalJSON 

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

func (*NullableConnectV1ConnectorError) Set 

func (v *NullableConnectV1ConnectorError) Set(val *ConnectV1ConnectorError)

func (*NullableConnectV1ConnectorError) UnmarshalJSON 

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

func (*NullableConnectV1ConnectorError) Unset 

func (v *NullableConnectV1ConnectorError) Unset()

type NullableConnectV1ConnectorErrorError 

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

func NewNullableConnectV1ConnectorErrorError 

func NewNullableConnectV1ConnectorErrorError(val *ConnectV1ConnectorErrorError) *NullableConnectV1ConnectorErrorError

func (NullableConnectV1ConnectorErrorError) Get 

func (v NullableConnectV1ConnectorErrorError) Get() *ConnectV1ConnectorErrorError

func (NullableConnectV1ConnectorErrorError) IsSet 

func (v NullableConnectV1ConnectorErrorError) IsSet() bool

func (NullableConnectV1ConnectorErrorError) MarshalJSON 

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

func (*NullableConnectV1ConnectorErrorError) Set 

func (v *NullableConnectV1ConnectorErrorError) Set(val *ConnectV1ConnectorErrorError)

func (*NullableConnectV1ConnectorErrorError) UnmarshalJSON 

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

func (*NullableConnectV1ConnectorErrorError) Unset 

func (v *NullableConnectV1ConnectorErrorError) Unset()

type NullableConnectV1ConnectorExpansion 

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

func NewNullableConnectV1ConnectorExpansion 

func NewNullableConnectV1ConnectorExpansion(val *ConnectV1ConnectorExpansion) *NullableConnectV1ConnectorExpansion

func (NullableConnectV1ConnectorExpansion) Get 

func (v NullableConnectV1ConnectorExpansion) Get() *ConnectV1ConnectorExpansion

func (NullableConnectV1ConnectorExpansion) IsSet 

func (v NullableConnectV1ConnectorExpansion) IsSet() bool

func (NullableConnectV1ConnectorExpansion) MarshalJSON 

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

func (*NullableConnectV1ConnectorExpansion) Set 

func (v *NullableConnectV1ConnectorExpansion) Set(val *ConnectV1ConnectorExpansion)

func (*NullableConnectV1ConnectorExpansion) UnmarshalJSON 

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

func (*NullableConnectV1ConnectorExpansion) Unset 

func (v *NullableConnectV1ConnectorExpansion) Unset()

type NullableConnectV1ConnectorExpansionId 

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

func NewNullableConnectV1ConnectorExpansionId 

func NewNullableConnectV1ConnectorExpansionId(val *ConnectV1ConnectorExpansionId) *NullableConnectV1ConnectorExpansionId

func (NullableConnectV1ConnectorExpansionId) Get 

func (v NullableConnectV1ConnectorExpansionId) Get() *ConnectV1ConnectorExpansionId

func (NullableConnectV1ConnectorExpansionId) IsSet 

func (v NullableConnectV1ConnectorExpansionId) IsSet() bool

func (NullableConnectV1ConnectorExpansionId) MarshalJSON 

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

func (*NullableConnectV1ConnectorExpansionId) Set 

func (v *NullableConnectV1ConnectorExpansionId) Set(val *ConnectV1ConnectorExpansionId)

func (*NullableConnectV1ConnectorExpansionId) UnmarshalJSON 

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

func (*NullableConnectV1ConnectorExpansionId) Unset 

func (v *NullableConnectV1ConnectorExpansionId) Unset()

type NullableConnectV1ConnectorExpansionInfo 

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

func NewNullableConnectV1ConnectorExpansionInfo 

func NewNullableConnectV1ConnectorExpansionInfo(val *ConnectV1ConnectorExpansionInfo) *NullableConnectV1ConnectorExpansionInfo

func (NullableConnectV1ConnectorExpansionInfo) Get 

func (v NullableConnectV1ConnectorExpansionInfo) Get() *ConnectV1ConnectorExpansionInfo

func (NullableConnectV1ConnectorExpansionInfo) IsSet 

func (v NullableConnectV1ConnectorExpansionInfo) IsSet() bool

func (NullableConnectV1ConnectorExpansionInfo) MarshalJSON 

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

func (*NullableConnectV1ConnectorExpansionInfo) Set 

func (v *NullableConnectV1ConnectorExpansionInfo) Set(val *ConnectV1ConnectorExpansionInfo)

func (*NullableConnectV1ConnectorExpansionInfo) UnmarshalJSON 

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

func (*NullableConnectV1ConnectorExpansionInfo) Unset 

func (v *NullableConnectV1ConnectorExpansionInfo) Unset()

type NullableConnectV1ConnectorExpansionStatus 

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

func NewNullableConnectV1ConnectorExpansionStatus 

func NewNullableConnectV1ConnectorExpansionStatus(val *ConnectV1ConnectorExpansionStatus) *NullableConnectV1ConnectorExpansionStatus

func (NullableConnectV1ConnectorExpansionStatus) Get 

func (v NullableConnectV1ConnectorExpansionStatus) Get() *ConnectV1ConnectorExpansionStatus

func (NullableConnectV1ConnectorExpansionStatus) IsSet 

func (v NullableConnectV1ConnectorExpansionStatus) IsSet() bool

func (NullableConnectV1ConnectorExpansionStatus) MarshalJSON 

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

func (*NullableConnectV1ConnectorExpansionStatus) Set 

func (v *NullableConnectV1ConnectorExpansionStatus) Set(val *ConnectV1ConnectorExpansionStatus)

func (*NullableConnectV1ConnectorExpansionStatus) UnmarshalJSON 

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

func (*NullableConnectV1ConnectorExpansionStatus) Unset 

func (v *NullableConnectV1ConnectorExpansionStatus) Unset()

type NullableConnectV1ConnectorExpansionStatusConnector 

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

func NewNullableConnectV1ConnectorExpansionStatusConnector 

func NewNullableConnectV1ConnectorExpansionStatusConnector(val *ConnectV1ConnectorExpansionStatusConnector) *NullableConnectV1ConnectorExpansionStatusConnector

func (NullableConnectV1ConnectorExpansionStatusConnector) Get 

func (v NullableConnectV1ConnectorExpansionStatusConnector) Get() *ConnectV1ConnectorExpansionStatusConnector

func (NullableConnectV1ConnectorExpansionStatusConnector) IsSet 

func (v NullableConnectV1ConnectorExpansionStatusConnector) IsSet() bool

func (NullableConnectV1ConnectorExpansionStatusConnector) MarshalJSON 

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

func (*NullableConnectV1ConnectorExpansionStatusConnector) Set 

func (v *NullableConnectV1ConnectorExpansionStatusConnector) Set(val *ConnectV1ConnectorExpansionStatusConnector)

func (*NullableConnectV1ConnectorExpansionStatusConnector) UnmarshalJSON 

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

func (*NullableConnectV1ConnectorExpansionStatusConnector) Unset 

func (v *NullableConnectV1ConnectorExpansionStatusConnector) Unset()

type NullableConnectV1ConnectorOffsets added in v0.5.0 

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

func NewNullableConnectV1ConnectorOffsets added in v0.5.0 

func NewNullableConnectV1ConnectorOffsets(val *ConnectV1ConnectorOffsets) *NullableConnectV1ConnectorOffsets

func (NullableConnectV1ConnectorOffsets) Get added in v0.5.0 

func (v NullableConnectV1ConnectorOffsets) Get() *ConnectV1ConnectorOffsets

func (NullableConnectV1ConnectorOffsets) IsSet added in v0.5.0 

func (v NullableConnectV1ConnectorOffsets) IsSet() bool

func (NullableConnectV1ConnectorOffsets) MarshalJSON added in v0.5.0 

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

func (*NullableConnectV1ConnectorOffsets) Set added in v0.5.0 

func (v *NullableConnectV1ConnectorOffsets) Set(val *ConnectV1ConnectorOffsets)

func (*NullableConnectV1ConnectorOffsets) UnmarshalJSON added in v0.5.0 

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

func (*NullableConnectV1ConnectorOffsets) Unset added in v0.5.0 

func (v *NullableConnectV1ConnectorOffsets) Unset()

type NullableConnectV1ConnectorOffsetsMetadata added in v0.5.0 

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

func NewNullableConnectV1ConnectorOffsetsMetadata added in v0.5.0 

func NewNullableConnectV1ConnectorOffsetsMetadata(val *ConnectV1ConnectorOffsetsMetadata) *NullableConnectV1ConnectorOffsetsMetadata

func (NullableConnectV1ConnectorOffsetsMetadata) Get added in v0.5.0 

func (v NullableConnectV1ConnectorOffsetsMetadata) Get() *ConnectV1ConnectorOffsetsMetadata

func (NullableConnectV1ConnectorOffsetsMetadata) IsSet added in v0.5.0 

func (v NullableConnectV1ConnectorOffsetsMetadata) IsSet() bool

func (NullableConnectV1ConnectorOffsetsMetadata) MarshalJSON added in v0.5.0 

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

func (*NullableConnectV1ConnectorOffsetsMetadata) Set added in v0.5.0 

func (v *NullableConnectV1ConnectorOffsetsMetadata) Set(val *ConnectV1ConnectorOffsetsMetadata)

func (*NullableConnectV1ConnectorOffsetsMetadata) UnmarshalJSON added in v0.5.0 

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

func (*NullableConnectV1ConnectorOffsetsMetadata) Unset added in v0.5.0 

func (v *NullableConnectV1ConnectorOffsetsMetadata) Unset()

type NullableConnectV1ConnectorTasks 

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

func NewNullableConnectV1ConnectorTasks 

func NewNullableConnectV1ConnectorTasks(val *ConnectV1ConnectorTasks) *NullableConnectV1ConnectorTasks

func (NullableConnectV1ConnectorTasks) Get 

func (v NullableConnectV1ConnectorTasks) Get() *ConnectV1ConnectorTasks

func (NullableConnectV1ConnectorTasks) IsSet 

func (v NullableConnectV1ConnectorTasks) IsSet() bool

func (NullableConnectV1ConnectorTasks) MarshalJSON 

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

func (*NullableConnectV1ConnectorTasks) Set 

func (v *NullableConnectV1ConnectorTasks) Set(val *ConnectV1ConnectorTasks)

func (*NullableConnectV1ConnectorTasks) UnmarshalJSON 

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

func (*NullableConnectV1ConnectorTasks) Unset 

func (v *NullableConnectV1ConnectorTasks) Unset()

type NullableConnectV1ConnectorWithOffsets added in v0.7.0 

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

func NewNullableConnectV1ConnectorWithOffsets added in v0.7.0 

func NewNullableConnectV1ConnectorWithOffsets(val *ConnectV1ConnectorWithOffsets) *NullableConnectV1ConnectorWithOffsets

func (NullableConnectV1ConnectorWithOffsets) Get added in v0.7.0 

func (v NullableConnectV1ConnectorWithOffsets) Get() *ConnectV1ConnectorWithOffsets

func (NullableConnectV1ConnectorWithOffsets) IsSet added in v0.7.0 

func (v NullableConnectV1ConnectorWithOffsets) IsSet() bool

func (NullableConnectV1ConnectorWithOffsets) MarshalJSON added in v0.7.0 

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

func (*NullableConnectV1ConnectorWithOffsets) Set added in v0.7.0 

func (v *NullableConnectV1ConnectorWithOffsets) Set(val *ConnectV1ConnectorWithOffsets)

func (*NullableConnectV1ConnectorWithOffsets) UnmarshalJSON added in v0.7.0 

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

func (*NullableConnectV1ConnectorWithOffsets) Unset added in v0.7.0 

func (v *NullableConnectV1ConnectorWithOffsets) 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 NullableInlineObject 

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

func NewNullableInlineObject 

func NewNullableInlineObject(val *InlineObject) *NullableInlineObject

func (NullableInlineObject) Get 

func (v NullableInlineObject) Get() *InlineObject

func (NullableInlineObject) IsSet 

func (v NullableInlineObject) IsSet() bool

func (NullableInlineObject) MarshalJSON 

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

func (*NullableInlineObject) Set 

func (v *NullableInlineObject) Set(val *InlineObject)

func (*NullableInlineObject) UnmarshalJSON 

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

func (*NullableInlineObject) Unset 

func (v *NullableInlineObject) Unset()

type NullableInlineResponse200 

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

func NewNullableInlineResponse200 

func NewNullableInlineResponse200(val *InlineResponse200) *NullableInlineResponse200

func (NullableInlineResponse200) Get 

func (v NullableInlineResponse200) Get() *InlineResponse200

func (NullableInlineResponse200) IsSet 

func (v NullableInlineResponse200) IsSet() bool

func (NullableInlineResponse200) MarshalJSON 

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

func (*NullableInlineResponse200) Set 

func (v *NullableInlineResponse200) Set(val *InlineResponse200)

func (*NullableInlineResponse200) UnmarshalJSON 

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

func (*NullableInlineResponse200) Unset 

func (v *NullableInlineResponse200) Unset()

type NullableInlineResponse2001 

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

func NewNullableInlineResponse2001 

func NewNullableInlineResponse2001(val *InlineResponse2001) *NullableInlineResponse2001

func (NullableInlineResponse2001) Get 

func (v NullableInlineResponse2001) Get() *InlineResponse2001

func (NullableInlineResponse2001) IsSet 

func (v NullableInlineResponse2001) IsSet() bool

func (NullableInlineResponse2001) MarshalJSON 

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

func (*NullableInlineResponse2001) Set 

func (v *NullableInlineResponse2001) Set(val *InlineResponse2001)

func (*NullableInlineResponse2001) UnmarshalJSON 

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

func (*NullableInlineResponse2001) Unset 

func (v *NullableInlineResponse2001) Unset()

type NullableInlineResponse2001Connector 

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

func NewNullableInlineResponse2001Connector 

func NewNullableInlineResponse2001Connector(val *InlineResponse2001Connector) *NullableInlineResponse2001Connector

func (NullableInlineResponse2001Connector) Get 

func (v NullableInlineResponse2001Connector) Get() *InlineResponse2001Connector

func (NullableInlineResponse2001Connector) IsSet 

func (v NullableInlineResponse2001Connector) IsSet() bool

func (NullableInlineResponse2001Connector) MarshalJSON 

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

func (*NullableInlineResponse2001Connector) Set 

func (v *NullableInlineResponse2001Connector) Set(val *InlineResponse2001Connector)

func (*NullableInlineResponse2001Connector) UnmarshalJSON 

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

func (*NullableInlineResponse2001Connector) Unset 

func (v *NullableInlineResponse2001Connector) Unset()

type NullableInlineResponse2001Tasks 

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

func NewNullableInlineResponse2001Tasks 

func NewNullableInlineResponse2001Tasks(val *InlineResponse2001Tasks) *NullableInlineResponse2001Tasks

func (NullableInlineResponse2001Tasks) Get 

func (v NullableInlineResponse2001Tasks) Get() *InlineResponse2001Tasks

func (NullableInlineResponse2001Tasks) IsSet 

func (v NullableInlineResponse2001Tasks) IsSet() bool

func (NullableInlineResponse2001Tasks) MarshalJSON 

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

func (*NullableInlineResponse2001Tasks) Set 

func (v *NullableInlineResponse2001Tasks) Set(val *InlineResponse2001Tasks)

func (*NullableInlineResponse2001Tasks) UnmarshalJSON 

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

func (*NullableInlineResponse2001Tasks) Unset 

func (v *NullableInlineResponse2001Tasks) Unset()

type NullableInlineResponse2002 

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

func NewNullableInlineResponse2002 

func NewNullableInlineResponse2002(val *InlineResponse2002) *NullableInlineResponse2002

func (NullableInlineResponse2002) Get 

func (v NullableInlineResponse2002) Get() *InlineResponse2002

func (NullableInlineResponse2002) IsSet 

func (v NullableInlineResponse2002) IsSet() bool

func (NullableInlineResponse2002) MarshalJSON 

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

func (*NullableInlineResponse2002) Set 

func (v *NullableInlineResponse2002) Set(val *InlineResponse2002)

func (*NullableInlineResponse2002) UnmarshalJSON 

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

func (*NullableInlineResponse2002) Unset 

func (v *NullableInlineResponse2002) Unset()

type NullableInlineResponse2003 

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

func NewNullableInlineResponse2003 

func NewNullableInlineResponse2003(val *InlineResponse2003) *NullableInlineResponse2003

func (NullableInlineResponse2003) Get 

func (v NullableInlineResponse2003) Get() *InlineResponse2003

func (NullableInlineResponse2003) IsSet 

func (v NullableInlineResponse2003) IsSet() bool

func (NullableInlineResponse2003) MarshalJSON 

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

func (*NullableInlineResponse2003) Set 

func (v *NullableInlineResponse2003) Set(val *InlineResponse2003)

func (*NullableInlineResponse2003) UnmarshalJSON 

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

func (*NullableInlineResponse2003) Unset 

func (v *NullableInlineResponse2003) Unset()

type NullableInlineResponse2003Configs 

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

func NewNullableInlineResponse2003Configs 

func NewNullableInlineResponse2003Configs(val *InlineResponse2003Configs) *NullableInlineResponse2003Configs

func (NullableInlineResponse2003Configs) Get 

func (v NullableInlineResponse2003Configs) Get() *InlineResponse2003Configs

func (NullableInlineResponse2003Configs) IsSet 

func (v NullableInlineResponse2003Configs) IsSet() bool

func (NullableInlineResponse2003Configs) MarshalJSON 

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

func (*NullableInlineResponse2003Configs) Set 

func (v *NullableInlineResponse2003Configs) Set(val *InlineResponse2003Configs)

func (*NullableInlineResponse2003Configs) UnmarshalJSON 

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

func (*NullableInlineResponse2003Configs) Unset 

func (v *NullableInlineResponse2003Configs) Unset()

type NullableInlineResponse2003Definition 

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

func NewNullableInlineResponse2003Definition 

func NewNullableInlineResponse2003Definition(val *InlineResponse2003Definition) *NullableInlineResponse2003Definition

func (NullableInlineResponse2003Definition) Get 

func (v NullableInlineResponse2003Definition) Get() *InlineResponse2003Definition

func (NullableInlineResponse2003Definition) IsSet 

func (v NullableInlineResponse2003Definition) IsSet() bool

func (NullableInlineResponse2003Definition) MarshalJSON 

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

func (*NullableInlineResponse2003Definition) Set 

func (v *NullableInlineResponse2003Definition) Set(val *InlineResponse2003Definition)

func (*NullableInlineResponse2003Definition) UnmarshalJSON 

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

func (*NullableInlineResponse2003Definition) Unset 

func (v *NullableInlineResponse2003Definition) Unset()

type NullableInlineResponse2003Value 

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

func NewNullableInlineResponse2003Value 

func NewNullableInlineResponse2003Value(val *InlineResponse2003Value) *NullableInlineResponse2003Value

func (NullableInlineResponse2003Value) Get 

func (v NullableInlineResponse2003Value) Get() *InlineResponse2003Value

func (NullableInlineResponse2003Value) IsSet 

func (v NullableInlineResponse2003Value) IsSet() bool

func (NullableInlineResponse2003Value) MarshalJSON 

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

func (*NullableInlineResponse2003Value) Set 

func (v *NullableInlineResponse2003Value) Set(val *InlineResponse2003Value)

func (*NullableInlineResponse2003Value) UnmarshalJSON 

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

func (*NullableInlineResponse2003Value) Unset 

func (v *NullableInlineResponse2003Value) Unset()

type NullableInlineResponse400 

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

func NewNullableInlineResponse400 

func NewNullableInlineResponse400(val *InlineResponse400) *NullableInlineResponse400

func (NullableInlineResponse400) Get 

func (v NullableInlineResponse400) Get() *InlineResponse400

func (NullableInlineResponse400) IsSet 

func (v NullableInlineResponse400) IsSet() bool

func (NullableInlineResponse400) MarshalJSON 

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

func (*NullableInlineResponse400) Set 

func (v *NullableInlineResponse400) Set(val *InlineResponse400)

func (*NullableInlineResponse400) UnmarshalJSON 

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

func (*NullableInlineResponse400) Unset 

func (v *NullableInlineResponse400) Unset()

type NullableInlineResponse500 

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

func NewNullableInlineResponse500 

func NewNullableInlineResponse500(val *InlineResponse500) *NullableInlineResponse500

func (NullableInlineResponse500) Get 

func (v NullableInlineResponse500) Get() *InlineResponse500

func (NullableInlineResponse500) IsSet 

func (v NullableInlineResponse500) IsSet() bool

func (NullableInlineResponse500) MarshalJSON 

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

func (*NullableInlineResponse500) Set 

func (v *NullableInlineResponse500) Set(val *InlineResponse500)

func (*NullableInlineResponse500) UnmarshalJSON 

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

func (*NullableInlineResponse500) Unset 

func (v *NullableInlineResponse500) 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 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 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 OffsetsConnectV1Api added in v0.5.0 

type OffsetsConnectV1Api interface {

	/*
			AlterConnectv1ConnectorOffsetsRequest Request to Alter the Connector Offsets

			[![Preview](https://img.shields.io/badge/Lifecycle%20Stage-Preview-%2300afba)](#section/Versioning/API-Lifecycle-Policy)

		Request to alter the offsets of a connector. This supports the ability to PATCH/DELETE the offsets of a connector.
		Note, you will see momentary downtime as this will internally stop the connector, while the offsets are being altered.
		You can only make one alter offsets request at a time for a connector.

			 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
			 @param connectorName The unique name of the connector.
			 @param environmentId The unique identifier of the environment this resource belongs to.
			 @param kafkaClusterId The unique identifier for the Kafka cluster.
			 @return ApiAlterConnectv1ConnectorOffsetsRequestRequest
	*/
	AlterConnectv1ConnectorOffsetsRequest(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiAlterConnectv1ConnectorOffsetsRequestRequest

	// AlterConnectv1ConnectorOffsetsRequestExecute executes the request
	//  @return ConnectV1AlterOffsetRequestInfo
	AlterConnectv1ConnectorOffsetsRequestExecute(r ApiAlterConnectv1ConnectorOffsetsRequestRequest) (ConnectV1AlterOffsetRequestInfo, *_nethttp.Response, error)

	/*
			GetConnectv1ConnectorOffsets Get a Connector Offsets

			[![Preview](https://img.shields.io/badge/Lifecycle%20Stage-Preview-%2300afba)](#section/Versioning/API-Lifecycle-Policy)

		Get the current offsets for the connector. The offsets provide information on the point in the source system,
		from which the connector is pulling in data. The offsets of a connector are continuously observed periodically and are queryable via this API.

			 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
			 @param connectorName The unique name of the connector.
			 @param environmentId The unique identifier of the environment this resource belongs to.
			 @param kafkaClusterId The unique identifier for the Kafka cluster.
			 @return ApiGetConnectv1ConnectorOffsetsRequest
	*/
	GetConnectv1ConnectorOffsets(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiGetConnectv1ConnectorOffsetsRequest

	// GetConnectv1ConnectorOffsetsExecute executes the request
	//  @return ConnectV1ConnectorOffsets
	GetConnectv1ConnectorOffsetsExecute(r ApiGetConnectv1ConnectorOffsetsRequest) (ConnectV1ConnectorOffsets, *_nethttp.Response, error)

	/*
			GetConnectv1ConnectorOffsetsRequestStatus Get the Status of Altered Offset Request

			[![Preview](https://img.shields.io/badge/Lifecycle%20Stage-Preview-%2300afba)](#section/Versioning/API-Lifecycle-Policy)

		Get the status of the previous alter offset request.

			 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
			 @param connectorName The unique name of the connector.
			 @param environmentId The unique identifier of the environment this resource belongs to.
			 @param kafkaClusterId The unique identifier for the Kafka cluster.
			 @return ApiGetConnectv1ConnectorOffsetsRequestStatusRequest
	*/
	GetConnectv1ConnectorOffsetsRequestStatus(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiGetConnectv1ConnectorOffsetsRequestStatusRequest

	// GetConnectv1ConnectorOffsetsRequestStatusExecute executes the request
	//  @return ConnectV1AlterOffsetStatus
	GetConnectv1ConnectorOffsetsRequestStatusExecute(r ApiGetConnectv1ConnectorOffsetsRequestStatusRequest) (ConnectV1AlterOffsetStatus, *_nethttp.Response, error)
}

type OffsetsConnectV1ApiService added in v0.5.0 

type OffsetsConnectV1ApiService service

OffsetsConnectV1ApiService OffsetsConnectV1Api service

func (*OffsetsConnectV1ApiService) AlterConnectv1ConnectorOffsetsRequest added in v0.5.0 

func (a *OffsetsConnectV1ApiService) AlterConnectv1ConnectorOffsetsRequest(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiAlterConnectv1ConnectorOffsetsRequestRequest

AlterConnectv1ConnectorOffsetsRequest Request to Alter the Connector Offsets

[![Preview](https://img.shields.io/badge/Lifecycle%20Stage-Preview-%2300afba)](#section/Versioning/API-Lifecycle-Policy)

Request to alter the offsets of a connector. This supports the ability to PATCH/DELETE the offsets of a connector. Note, you will see momentary downtime as this will internally stop the connector, while the offsets are being altered. You can only make one alter offsets request at a time for a connector. 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connectorName The unique name of the connector.
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiAlterConnectv1ConnectorOffsetsRequestRequest

func (*OffsetsConnectV1ApiService) AlterConnectv1ConnectorOffsetsRequestExecute added in v0.5.0 

func (a *OffsetsConnectV1ApiService) AlterConnectv1ConnectorOffsetsRequestExecute(r ApiAlterConnectv1ConnectorOffsetsRequestRequest) (ConnectV1AlterOffsetRequestInfo, *_nethttp.Response, error)

Execute executes the request 

@return ConnectV1AlterOffsetRequestInfo

func (*OffsetsConnectV1ApiService) GetConnectv1ConnectorOffsets added in v0.5.0 

func (a *OffsetsConnectV1ApiService) GetConnectv1ConnectorOffsets(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiGetConnectv1ConnectorOffsetsRequest

GetConnectv1ConnectorOffsets Get a Connector Offsets

[![Preview](https://img.shields.io/badge/Lifecycle%20Stage-Preview-%2300afba)](#section/Versioning/API-Lifecycle-Policy)

Get the current offsets for the connector. The offsets provide information on the point in the source system, from which the connector is pulling in data. The offsets of a connector are continuously observed periodically and are queryable via this API. 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connectorName The unique name of the connector.
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiGetConnectv1ConnectorOffsetsRequest

func (*OffsetsConnectV1ApiService) GetConnectv1ConnectorOffsetsExecute added in v0.5.0 

func (a *OffsetsConnectV1ApiService) GetConnectv1ConnectorOffsetsExecute(r ApiGetConnectv1ConnectorOffsetsRequest) (ConnectV1ConnectorOffsets, *_nethttp.Response, error)

Execute executes the request 

@return ConnectV1ConnectorOffsets

func (*OffsetsConnectV1ApiService) GetConnectv1ConnectorOffsetsRequestStatus added in v0.5.0 

func (a *OffsetsConnectV1ApiService) GetConnectv1ConnectorOffsetsRequestStatus(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiGetConnectv1ConnectorOffsetsRequestStatusRequest

GetConnectv1ConnectorOffsetsRequestStatus Get the Status of Altered Offset Request

[![Preview](https://img.shields.io/badge/Lifecycle%20Stage-Preview-%2300afba)](#section/Versioning/API-Lifecycle-Policy)

Get the status of the previous alter offset request. 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connectorName The unique name of the connector.
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiGetConnectv1ConnectorOffsetsRequestStatusRequest

func (*OffsetsConnectV1ApiService) GetConnectv1ConnectorOffsetsRequestStatusExecute added in v0.5.0 

func (a *OffsetsConnectV1ApiService) GetConnectv1ConnectorOffsetsRequestStatusExecute(r ApiGetConnectv1ConnectorOffsetsRequestStatusRequest) (ConnectV1AlterOffsetStatus, *_nethttp.Response, error)

Execute executes the request 

@return ConnectV1AlterOffsetStatus

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 ServerVariable 

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

ServerVariable stores the information about a server variable

type StatusConnectV1Api added in v0.5.0 

type StatusConnectV1Api interface {

	/*
			ListConnectv1ConnectorTasks List of Connector Tasks

			[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

		Get a list of tasks currently running for the connector.

			 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
			 @param connectorName The unique name of the connector.
			 @param environmentId The unique identifier of the environment this resource belongs to.
			 @param kafkaClusterId The unique identifier for the Kafka cluster.
			 @return ApiListConnectv1ConnectorTasksRequest
	*/
	ListConnectv1ConnectorTasks(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiListConnectv1ConnectorTasksRequest

	// ListConnectv1ConnectorTasksExecute executes the request
	//  @return []map[string]interface{}
	ListConnectv1ConnectorTasksExecute(r ApiListConnectv1ConnectorTasksRequest) ([]map[string]interface{}, *_nethttp.Response, error)

	/*
		ReadConnectv1ConnectorStatus Read a Connector Status

		Get current status of the connector. This includes whether it is running, failed, or paused. Also includes which worker it is assigned to, error information if it has failed, and the state of all its tasks.

		 @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
		 @param connectorName The unique name of the connector.
		 @param environmentId The unique identifier of the environment this resource belongs to.
		 @param kafkaClusterId The unique identifier for the Kafka cluster.
		 @return ApiReadConnectv1ConnectorStatusRequest
	*/
	ReadConnectv1ConnectorStatus(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiReadConnectv1ConnectorStatusRequest

	// ReadConnectv1ConnectorStatusExecute executes the request
	//  @return InlineResponse2001
	ReadConnectv1ConnectorStatusExecute(r ApiReadConnectv1ConnectorStatusRequest) (InlineResponse2001, *_nethttp.Response, error)
}

type StatusConnectV1ApiService added in v0.5.0 

type StatusConnectV1ApiService service

StatusConnectV1ApiService StatusConnectV1Api service

func (*StatusConnectV1ApiService) ListConnectv1ConnectorTasks added in v0.5.0 

func (a *StatusConnectV1ApiService) ListConnectv1ConnectorTasks(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiListConnectv1ConnectorTasksRequest

ListConnectv1ConnectorTasks List of Connector Tasks

[![General Availability](https://img.shields.io/badge/Lifecycle%20Stage-General%20Availability-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy)

Get a list of tasks currently running for the connector. 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connectorName The unique name of the connector.
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiListConnectv1ConnectorTasksRequest

func (*StatusConnectV1ApiService) ListConnectv1ConnectorTasksExecute added in v0.5.0 

func (a *StatusConnectV1ApiService) ListConnectv1ConnectorTasksExecute(r ApiListConnectv1ConnectorTasksRequest) ([]map[string]interface{}, *_nethttp.Response, error)

Execute executes the request 

@return []map[string]interface{}

func (*StatusConnectV1ApiService) ReadConnectv1ConnectorStatus added in v0.5.0 

func (a *StatusConnectV1ApiService) ReadConnectv1ConnectorStatus(ctx _context.Context, connectorName string, environmentId string, kafkaClusterId string) ApiReadConnectv1ConnectorStatusRequest

ReadConnectv1ConnectorStatus Read a Connector Status

Get current status of the connector. This includes whether it is running, failed, or paused. Also includes which worker it is assigned to, error information if it has failed, and the state of all its tasks. 

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connectorName The unique name of the connector.
@param environmentId The unique identifier of the environment this resource belongs to.
@param kafkaClusterId The unique identifier for the Kafka cluster.
@return ApiReadConnectv1ConnectorStatusRequest

func (*StatusConnectV1ApiService) ReadConnectv1ConnectorStatusExecute added in v0.5.0 

func (a *StatusConnectV1ApiService) ReadConnectv1ConnectorStatusExecute(r ApiReadConnectv1ConnectorStatusRequest) (InlineResponse2001, *_nethttp.Response, error)

Execute executes the request 

@return InlineResponse2001

Source Files

View all Source files

Directories

Path Synopsis

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.
JackTT - Gopher 🇻🇳