Documentation ¶
Index ¶
- Variables
- func CacheExpires(r *http.Response) time.Time
- type APIClient
- type APIKey
- type APIResponse
- type AddonParameter
- type BasicAuth
- type Channel
- type Configuration
- type Connector
- type ConnectorCluster
- type ConnectorClusterList
- type ConnectorClusterMeta
- type ConnectorClusterRequest
- type ConnectorClusterRequestMeta
- type ConnectorClusterState
- type ConnectorClusterStatus
- type ConnectorClusterStatusStatus
- type ConnectorClustersApiService
- func (a *ConnectorClustersApiService) CreateConnectorCluster(ctx _context.Context, async bool, ...) (ConnectorCluster, *_nethttp.Response, error)
- func (a *ConnectorClustersApiService) DeleteConnectorCluster(ctx _context.Context, connectorClusterId string) (Error, *_nethttp.Response, error)
- func (a *ConnectorClustersApiService) GetConnectorCluster(ctx _context.Context, connectorClusterId string) (ConnectorCluster, *_nethttp.Response, error)
- func (a *ConnectorClustersApiService) GetConnectorClusterAddonParameters(ctx _context.Context, connectorClusterId string, ...) ([]AddonParameter, *_nethttp.Response, error)
- func (a *ConnectorClustersApiService) GetConnectorClusterNamespaces(ctx _context.Context, connectorClusterId string, ...) (ConnectorNamespaceList, *_nethttp.Response, error)
- func (a *ConnectorClustersApiService) ListConnectorClusters(ctx _context.Context, localVarOptionals *ListConnectorClustersOpts) (ConnectorClusterList, *_nethttp.Response, error)
- func (a *ConnectorClustersApiService) UpdateConnectorClusterById(ctx _context.Context, connectorClusterId string, ...) (*_nethttp.Response, error)
- type ConnectorConfiguration
- type ConnectorDesiredState
- type ConnectorList
- type ConnectorMeta
- type ConnectorNamespace
- type ConnectorNamespaceEvalRequest
- type ConnectorNamespaceList
- type ConnectorNamespaceMeta
- type ConnectorNamespacePatchRequest
- type ConnectorNamespaceQuota
- type ConnectorNamespaceRequest
- type ConnectorNamespaceRequestMeta
- type ConnectorNamespaceState
- type ConnectorNamespaceStatus
- type ConnectorNamespaceTenant
- type ConnectorNamespaceTenantKind
- type ConnectorNamespacesApiService
- func (a *ConnectorNamespacesApiService) CreateEvaluationNamespace(ctx _context.Context, ...) (ConnectorNamespace, *_nethttp.Response, error)
- func (a *ConnectorNamespacesApiService) GetConnectorNamespace(ctx _context.Context, connectorNamespaceId string) (ConnectorNamespace, *_nethttp.Response, error)
- func (a *ConnectorNamespacesApiService) ListConnectorNamespaces(ctx _context.Context, localVarOptionals *ListConnectorNamespacesOpts) (ConnectorNamespaceList, *_nethttp.Response, error)
- type ConnectorRequest
- type ConnectorRequestMeta
- type ConnectorServiceApiService
- type ConnectorState
- type ConnectorStatus
- type ConnectorStatusStatus
- type ConnectorType
- type ConnectorTypeLabelCount
- type ConnectorTypeLabelCountList
- type ConnectorTypeList
- type ConnectorTypesApiService
- func (a *ConnectorTypesApiService) GetConnectorTypeByID(ctx _context.Context, connectorTypeId string) (ConnectorType, *_nethttp.Response, error)
- func (a *ConnectorTypesApiService) GetConnectorTypeLabels(ctx _context.Context, localVarOptionals *GetConnectorTypeLabelsOpts) (ConnectorTypeLabelCountList, *_nethttp.Response, error)
- func (a *ConnectorTypesApiService) GetConnectorTypes(ctx _context.Context, localVarOptionals *GetConnectorTypesOpts) (ConnectorTypeList, *_nethttp.Response, error)
- type ConnectorsApiService
- func (a *ConnectorsApiService) CreateConnector(ctx _context.Context, async bool, connectorRequest ConnectorRequest) (Connector, *_nethttp.Response, error)
- func (a *ConnectorsApiService) DeleteConnector(ctx _context.Context, id string) (Error, *_nethttp.Response, error)
- func (a *ConnectorsApiService) GetConnector(ctx _context.Context, id string) (Connector, *_nethttp.Response, error)
- func (a *ConnectorsApiService) ListConnectors(ctx _context.Context, localVarOptionals *ListConnectorsOpts) (ConnectorList, *_nethttp.Response, error)
- func (a *ConnectorsApiService) PatchConnector(ctx _context.Context, id string, body map[string]interface{}) (Connector, *_nethttp.Response, error)
- type Error
- type GenericOpenAPIError
- type GetConnectorClusterAddonParametersOpts
- type GetConnectorClusterNamespacesOpts
- type GetConnectorTypeLabelsOpts
- type GetConnectorTypesOpts
- type KafkaConnectionSettings
- type List
- type ListConnectorClustersOpts
- type ListConnectorNamespacesOpts
- type ListConnectorsOpts
- type ObjectMeta
- type ObjectReference
- type SchemaRegistryConnectionSettings
- type ServerConfiguration
- type ServerVariable
- type ServiceAccount
- type ServiceConnectionSettings
- type VersionMetadata
Constants ¶
This section is empty.
Variables ¶
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") // ContextAPIKey takes an APIKey as authentication for the request ContextAPIKey = contextKey("apikey") )
Functions ¶
Types ¶
type APIClient ¶
type APIClient struct { ConnectorClustersApi *ConnectorClustersApiService ConnectorNamespacesApi *ConnectorNamespacesApiService ConnectorServiceApi *ConnectorServiceApiService ConnectorTypesApi *ConnectorTypesApiService ConnectorsApi *ConnectorsApiService // contains filtered or unexported fields }
APIClient manages communication with the Connector Management API API v0.1.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) ChangeBasePath ¶
ChangeBasePath changes base path to allow switching to mocks
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 ¶
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 APIResonse object.
func NewAPIResponseWithError ¶
func NewAPIResponseWithError(errorMessage string) *APIResponse
NewAPIResponseWithError returns a new APIResponse object with the provided error message.
type AddonParameter ¶
type AddonParameter struct { Id string `json:"id,omitempty"` Value string `json:"value,omitempty"` }
AddonParameter A addon parameter
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 Channel ¶
type Channel string
Channel the model 'Channel'
const (
CHANNEL_STABLE Channel = "stable"
)
List of Channel
type Configuration ¶
type Configuration struct { BasePath string `json:"basePath,omitempty"` 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 []ServerConfiguration 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
type Connector ¶
type Connector struct { Id string `json:"id,omitempty"` Kind string `json:"kind,omitempty"` Href string `json:"href,omitempty"` Owner string `json:"owner,omitempty"` CreatedAt time.Time `json:"created_at,omitempty"` ModifiedAt time.Time `json:"modified_at,omitempty"` Name string `json:"name"` ConnectorTypeId string `json:"connector_type_id"` NamespaceId string `json:"namespace_id"` Channel Channel `json:"channel,omitempty"` DesiredState ConnectorDesiredState `json:"desired_state"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` ResourceVersion int64 `json:"resource_version,omitempty"` Kafka KafkaConnectionSettings `json:"kafka"` ServiceAccount ServiceAccount `json:"service_account"` SchemaRegistry SchemaRegistryConnectionSettings `json:"schema_registry,omitempty"` Connector map[string]interface{} `json:"connector"` Status ConnectorStatusStatus `json:"status,omitempty"` }
Connector struct for Connector
type ConnectorCluster ¶
type ConnectorCluster struct { Id string `json:"id,omitempty"` Kind string `json:"kind,omitempty"` Href string `json:"href,omitempty"` Owner string `json:"owner,omitempty"` CreatedAt time.Time `json:"created_at,omitempty"` ModifiedAt time.Time `json:"modified_at,omitempty"` Name string `json:"name,omitempty"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` Status ConnectorClusterStatusStatus `json:"status,omitempty"` }
ConnectorCluster struct for ConnectorCluster
type ConnectorClusterList ¶
type ConnectorClusterList struct { Kind string `json:"kind"` Page int32 `json:"page"` Size int32 `json:"size"` Total int32 `json:"total"` Items []ConnectorCluster `json:"items"` }
ConnectorClusterList struct for ConnectorClusterList
type ConnectorClusterMeta ¶
type ConnectorClusterMeta struct { Owner string `json:"owner,omitempty"` CreatedAt time.Time `json:"created_at,omitempty"` ModifiedAt time.Time `json:"modified_at,omitempty"` Name string `json:"name,omitempty"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` }
ConnectorClusterMeta struct for ConnectorClusterMeta
type ConnectorClusterRequest ¶
type ConnectorClusterRequest struct { Name string `json:"name,omitempty"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` }
ConnectorClusterRequest Schema for the request to update a data plane cluster's name
type ConnectorClusterRequestMeta ¶
type ConnectorClusterRequestMeta struct { Name string `json:"name,omitempty"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` }
ConnectorClusterRequestMeta struct for ConnectorClusterRequestMeta
type ConnectorClusterState ¶
type ConnectorClusterState string
ConnectorClusterState the model 'ConnectorClusterState'
const ( CONNECTORCLUSTERSTATE_DISCONNECTED ConnectorClusterState = "disconnected" CONNECTORCLUSTERSTATE_READY ConnectorClusterState = "ready" CONNECTORCLUSTERSTATE_DELETING ConnectorClusterState = "deleting" )
List of ConnectorClusterState
type ConnectorClusterStatus ¶
type ConnectorClusterStatus struct {
Status ConnectorClusterStatusStatus `json:"status,omitempty"`
}
ConnectorClusterStatus struct for ConnectorClusterStatus
type ConnectorClusterStatusStatus ¶
type ConnectorClusterStatusStatus struct { State ConnectorClusterState `json:"state,omitempty"` Error string `json:"error,omitempty"` }
ConnectorClusterStatusStatus struct for ConnectorClusterStatusStatus
type ConnectorClustersApiService ¶
type ConnectorClustersApiService service
ConnectorClustersApiService ConnectorClustersApi service
func (*ConnectorClustersApiService) CreateConnectorCluster ¶
func (a *ConnectorClustersApiService) CreateConnectorCluster(ctx _context.Context, async bool, connectorClusterRequest ConnectorClusterRequest) (ConnectorCluster, *_nethttp.Response, error)
CreateConnectorCluster Create a new connector cluster Create a new connector cluster
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param async Perform the action in an asynchronous manner
- @param connectorClusterRequest Connector cluster data
@return ConnectorCluster
func (*ConnectorClustersApiService) DeleteConnectorCluster ¶
func (a *ConnectorClustersApiService) DeleteConnectorCluster(ctx _context.Context, connectorClusterId string) (Error, *_nethttp.Response, error)
DeleteConnectorCluster Delete a connector cluster Delete a connector cluster
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param connectorClusterId The id of the connector cluster
@return Error
func (*ConnectorClustersApiService) GetConnectorCluster ¶
func (a *ConnectorClustersApiService) GetConnectorCluster(ctx _context.Context, connectorClusterId string) (ConnectorCluster, *_nethttp.Response, error)
GetConnectorCluster Get a connector cluster Get a connector cluster
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param connectorClusterId The id of the connector cluster
@return ConnectorCluster
func (*ConnectorClustersApiService) GetConnectorClusterAddonParameters ¶
func (a *ConnectorClustersApiService) GetConnectorClusterAddonParameters(ctx _context.Context, connectorClusterId string, localVarOptionals *GetConnectorClusterAddonParametersOpts) ([]AddonParameter, *_nethttp.Response, error)
GetConnectorClusterAddonParameters Get a connector cluster's addon parameters Get a connector cluster's addon parameters
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param connectorClusterId The id of the connector cluster
- @param optional nil or *GetConnectorClusterAddonParametersOpts - Optional Parameters:
- @param "ResetCredentials" (optional.Bool) - Resets cluster service account credentials when true
@return []AddonParameter
func (*ConnectorClustersApiService) GetConnectorClusterNamespaces ¶
func (a *ConnectorClustersApiService) GetConnectorClusterNamespaces(ctx _context.Context, connectorClusterId string, localVarOptionals *GetConnectorClusterNamespacesOpts) (ConnectorNamespaceList, *_nethttp.Response, error)
GetConnectorClusterNamespaces Get a connector cluster's namespaces Get a connector cluster's namespaces
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param connectorClusterId The id of the connector cluster
- @param optional nil or *GetConnectorClusterNamespacesOpts - Optional Parameters:
- @param "Page" (optional.String) - Page index
- @param "Size" (optional.String) - Number of items in each page
- @param "OrderBy" (optional.String) - Specifies the order by criteria. The syntax of this parameter is similar to the syntax of the `order by` clause of an SQL statement. Each query can be ordered by any of the underlying resource fields supported in the search parameter. For example, to return all Connector types ordered by their name, use the following syntax: ```sql name asc ``` To return all Connector types ordered by their name _and_ version, use the following syntax: ```sql name asc, version asc ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then the results are ordered by name.
- @param "Search" (optional.String) - Search criteria. The syntax of this parameter is similar to the syntax of the `where` clause of a SQL statement. Allowed fields in the search depend on the resource type: * Cluster: id, created_at, updated_at, owner, organisation_id, name, state, client_id * Namespace: id, created_at, updated_at, name, cluster_id, owner, expiration, tenant_user_id, tenant_organisation_id, state * Connector Types: id, created_at, updated_at, version, name, description, label, channel, featured_rank, pricing_tier * Connectors: id, created_at, updated_at, name, owner, organisation_id, connector_type_id, desired_state, state, channel, namespace_id, kafka_id, kafka_bootstrap_server, service_account_client_id, schema_registry_id, schema_registry_url Allowed operators are `<>`, `=`, `IN`, `NOT IN`, `LIKE`, or `ILIKE`. Allowed conjunctive operators are `AND` and `OR`. However, you can use a maximum of 10 conjunctions in a search query. Examples: To return a Connector Type with the name `aws-sqs-source` and the channel `stable`, use the following syntax: ``` name = aws-sqs-source and channel = stable ``` To return a connector instance with a name that starts with `aws`, use the following syntax: ``` name like aws%25 ``` To return a connector type with a name containing `aws` matching any character case combination, use the following syntax: ``` name ilike %25aws%25 ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then all the resources that the user has permission to see are returned. Note. If the query is invalid, an error is returned.
@return ConnectorNamespaceList
func (*ConnectorClustersApiService) ListConnectorClusters ¶
func (a *ConnectorClustersApiService) ListConnectorClusters(ctx _context.Context, localVarOptionals *ListConnectorClustersOpts) (ConnectorClusterList, *_nethttp.Response, error)
ListConnectorClusters Returns a list of connector clusters Returns a list of connector clusters
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param optional nil or *ListConnectorClustersOpts - Optional Parameters:
- @param "Page" (optional.String) - Page index
- @param "Size" (optional.String) - Number of items in each page
- @param "OrderBy" (optional.String) - Specifies the order by criteria. The syntax of this parameter is similar to the syntax of the `order by` clause of an SQL statement. Each query can be ordered by any of the underlying resource fields supported in the search parameter. For example, to return all Connector types ordered by their name, use the following syntax: ```sql name asc ``` To return all Connector types ordered by their name _and_ version, use the following syntax: ```sql name asc, version asc ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then the results are ordered by name.
- @param "Search" (optional.String) - Search criteria. The syntax of this parameter is similar to the syntax of the `where` clause of a SQL statement. Allowed fields in the search depend on the resource type: * Cluster: id, created_at, updated_at, owner, organisation_id, name, state, client_id * Namespace: id, created_at, updated_at, name, cluster_id, owner, expiration, tenant_user_id, tenant_organisation_id, state * Connector Types: id, created_at, updated_at, version, name, description, label, channel, featured_rank, pricing_tier * Connectors: id, created_at, updated_at, name, owner, organisation_id, connector_type_id, desired_state, state, channel, namespace_id, kafka_id, kafka_bootstrap_server, service_account_client_id, schema_registry_id, schema_registry_url Allowed operators are `<>`, `=`, `IN`, `NOT IN`, `LIKE`, or `ILIKE`. Allowed conjunctive operators are `AND` and `OR`. However, you can use a maximum of 10 conjunctions in a search query. Examples: To return a Connector Type with the name `aws-sqs-source` and the channel `stable`, use the following syntax: ``` name = aws-sqs-source and channel = stable ``` To return a connector instance with a name that starts with `aws`, use the following syntax: ``` name like aws%25 ``` To return a connector type with a name containing `aws` matching any character case combination, use the following syntax: ``` name ilike %25aws%25 ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then all the resources that the user has permission to see are returned. Note. If the query is invalid, an error is returned.
@return ConnectorClusterList
func (*ConnectorClustersApiService) UpdateConnectorClusterById ¶
func (a *ConnectorClustersApiService) UpdateConnectorClusterById(ctx _context.Context, connectorClusterId string, connectorClusterRequest ConnectorClusterRequest) (*_nethttp.Response, error)
UpdateConnectorClusterById udpate a connector cluster udpate a connector cluster
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param connectorClusterId The id of the connector cluster
- @param connectorClusterRequest Data to updated connector with
type ConnectorConfiguration ¶
type ConnectorConfiguration struct { Kafka KafkaConnectionSettings `json:"kafka"` ServiceAccount ServiceAccount `json:"service_account"` SchemaRegistry SchemaRegistryConnectionSettings `json:"schema_registry,omitempty"` Connector map[string]interface{} `json:"connector"` }
ConnectorConfiguration struct for ConnectorConfiguration
type ConnectorDesiredState ¶
type ConnectorDesiredState string
ConnectorDesiredState the model 'ConnectorDesiredState'
const ( CONNECTORDESIREDSTATE_UNASSIGNED ConnectorDesiredState = "unassigned" CONNECTORDESIREDSTATE_READY ConnectorDesiredState = "ready" CONNECTORDESIREDSTATE_STOPPED ConnectorDesiredState = "stopped" CONNECTORDESIREDSTATE_DELETED ConnectorDesiredState = "deleted" )
List of ConnectorDesiredState
type ConnectorList ¶
type ConnectorList struct { Kind string `json:"kind"` Page int32 `json:"page"` Size int32 `json:"size"` Total int32 `json:"total"` Items []Connector `json:"items"` }
ConnectorList struct for ConnectorList
type ConnectorMeta ¶
type ConnectorMeta struct { Owner string `json:"owner,omitempty"` CreatedAt time.Time `json:"created_at,omitempty"` ModifiedAt time.Time `json:"modified_at,omitempty"` Name string `json:"name"` ConnectorTypeId string `json:"connector_type_id"` NamespaceId string `json:"namespace_id"` Channel Channel `json:"channel,omitempty"` DesiredState ConnectorDesiredState `json:"desired_state"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` ResourceVersion int64 `json:"resource_version,omitempty"` }
ConnectorMeta struct for ConnectorMeta
type ConnectorNamespace ¶
type ConnectorNamespace struct { Id string `json:"id"` Kind string `json:"kind,omitempty"` Href string `json:"href,omitempty"` Owner string `json:"owner,omitempty"` CreatedAt time.Time `json:"created_at,omitempty"` ModifiedAt time.Time `json:"modified_at,omitempty"` Name string `json:"name"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` ResourceVersion int64 `json:"resource_version"` Quota ConnectorNamespaceQuota `json:"quota,omitempty"` ClusterId string `json:"cluster_id"` // Namespace expiration timestamp in RFC 3339 format Expiration string `json:"expiration,omitempty"` Tenant ConnectorNamespaceTenant `json:"tenant"` Status ConnectorNamespaceStatus `json:"status"` }
ConnectorNamespace A connector namespace
type ConnectorNamespaceEvalRequest ¶
type ConnectorNamespaceEvalRequest struct { // Namespace name must match pattern `^(([A-Za-z0-9][-A-Za-z0-9_.]*)?[A-Za-z0-9])?$`, or it may be empty to be auto-generated. Name string `json:"name,omitempty"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` }
ConnectorNamespaceEvalRequest An evaluation connector namespace create request
type ConnectorNamespaceList ¶
type ConnectorNamespaceList struct { Kind string `json:"kind"` Page int32 `json:"page"` Size int32 `json:"size"` Total int32 `json:"total"` Items []ConnectorNamespace `json:"items"` }
ConnectorNamespaceList struct for ConnectorNamespaceList
type ConnectorNamespaceMeta ¶
type ConnectorNamespaceMeta struct { Owner string `json:"owner,omitempty"` CreatedAt time.Time `json:"created_at,omitempty"` ModifiedAt time.Time `json:"modified_at,omitempty"` // Namespace name must match pattern `^(([A-Za-z0-9][-A-Za-z0-9_.]*)?[A-Za-z0-9])?$`, or it may be empty to be auto-generated. Name string `json:"name,omitempty"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` ResourceVersion int64 `json:"resource_version,omitempty"` Quota ConnectorNamespaceQuota `json:"quota,omitempty"` }
ConnectorNamespaceMeta struct for ConnectorNamespaceMeta
type ConnectorNamespacePatchRequest ¶
type ConnectorNamespacePatchRequest struct { // Namespace name must match pattern `^(([A-Za-z0-9][-A-Za-z0-9_.]*)?[A-Za-z0-9])?$`, or it may be empty to be auto-generated. Name string `json:"name,omitempty"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` }
ConnectorNamespacePatchRequest A connector namespace patch request
type ConnectorNamespaceQuota ¶
type ConnectorNamespaceQuota struct { Connectors int32 `json:"connectors,omitempty"` // Memory quota for limits or requests MemoryRequests string `json:"memory_requests,omitempty"` // Memory quota for limits or requests MemoryLimits string `json:"memory_limits,omitempty"` // CPU quota for limits or requests CpuRequests string `json:"cpu_requests,omitempty"` // CPU quota for limits or requests CpuLimits string `json:"cpu_limits,omitempty"` }
ConnectorNamespaceQuota struct for ConnectorNamespaceQuota
type ConnectorNamespaceRequest ¶
type ConnectorNamespaceRequest struct { // Namespace name must match pattern `^(([A-Za-z0-9][-A-Za-z0-9_.]*)?[A-Za-z0-9])?$`, or it may be empty to be auto-generated. Name string `json:"name"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` ClusterId string `json:"cluster_id"` Kind ConnectorNamespaceTenantKind `json:"kind"` }
ConnectorNamespaceRequest A connector namespace create request
type ConnectorNamespaceRequestMeta ¶
type ConnectorNamespaceRequestMeta struct { // Namespace name must match pattern `^(([A-Za-z0-9][-A-Za-z0-9_.]*)?[A-Za-z0-9])?$`, or it may be empty to be auto-generated. Name string `json:"name,omitempty"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` }
ConnectorNamespaceRequestMeta struct for ConnectorNamespaceRequestMeta
type ConnectorNamespaceState ¶
type ConnectorNamespaceState string
ConnectorNamespaceState the model 'ConnectorNamespaceState'
const ( CONNECTORNAMESPACESTATE_DISCONNECTED ConnectorNamespaceState = "disconnected" CONNECTORNAMESPACESTATE_READY ConnectorNamespaceState = "ready" CONNECTORNAMESPACESTATE_DELETING ConnectorNamespaceState = "deleting" CONNECTORNAMESPACESTATE_DELETED ConnectorNamespaceState = "deleted" )
List of ConnectorNamespaceState
type ConnectorNamespaceStatus ¶
type ConnectorNamespaceStatus struct { State ConnectorNamespaceState `json:"state"` Version string `json:"version,omitempty"` ConnectorsDeployed int32 `json:"connectors_deployed"` Error string `json:"error,omitempty"` }
ConnectorNamespaceStatus struct for ConnectorNamespaceStatus
type ConnectorNamespaceTenant ¶
type ConnectorNamespaceTenant struct { Kind ConnectorNamespaceTenantKind `json:"kind"` // Either user or organisation id depending on the value of kind Id string `json:"id"` }
ConnectorNamespaceTenant struct for ConnectorNamespaceTenant
type ConnectorNamespaceTenantKind ¶
type ConnectorNamespaceTenantKind string
ConnectorNamespaceTenantKind the model 'ConnectorNamespaceTenantKind'
const ( CONNECTORNAMESPACETENANTKIND_USER ConnectorNamespaceTenantKind = "user" CONNECTORNAMESPACETENANTKIND_ORGANISATION ConnectorNamespaceTenantKind = "organisation" )
List of ConnectorNamespaceTenantKind
type ConnectorNamespacesApiService ¶
type ConnectorNamespacesApiService service
ConnectorNamespacesApiService ConnectorNamespacesApi service
func (*ConnectorNamespacesApiService) CreateEvaluationNamespace ¶
func (a *ConnectorNamespacesApiService) CreateEvaluationNamespace(ctx _context.Context, connectorNamespaceEvalRequest ConnectorNamespaceEvalRequest) (ConnectorNamespace, *_nethttp.Response, error)
CreateEvaluationNamespace Create a new short lived evaluation connector namespace Create a new evaluation connector namespace
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param connectorNamespaceEvalRequest Connector namespace data
@return ConnectorNamespace
func (*ConnectorNamespacesApiService) GetConnectorNamespace ¶
func (a *ConnectorNamespacesApiService) GetConnectorNamespace(ctx _context.Context, connectorNamespaceId string) (ConnectorNamespace, *_nethttp.Response, error)
GetConnectorNamespace Get a connector namespace Get a connector namespace
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param connectorNamespaceId The id of the connector namespace
@return ConnectorNamespace
func (*ConnectorNamespacesApiService) ListConnectorNamespaces ¶
func (a *ConnectorNamespacesApiService) ListConnectorNamespaces(ctx _context.Context, localVarOptionals *ListConnectorNamespacesOpts) (ConnectorNamespaceList, *_nethttp.Response, error)
ListConnectorNamespaces Returns a list of connector namespaces Returns a list of connector namespaces
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param optional nil or *ListConnectorNamespacesOpts - Optional Parameters:
- @param "Page" (optional.String) - Page index
- @param "Size" (optional.String) - Number of items in each page
- @param "OrderBy" (optional.String) - Specifies the order by criteria. The syntax of this parameter is similar to the syntax of the `order by` clause of an SQL statement. Each query can be ordered by any of the underlying resource fields supported in the search parameter. For example, to return all Connector types ordered by their name, use the following syntax: ```sql name asc ``` To return all Connector types ordered by their name _and_ version, use the following syntax: ```sql name asc, version asc ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then the results are ordered by name.
- @param "Search" (optional.String) - Search criteria. The syntax of this parameter is similar to the syntax of the `where` clause of a SQL statement. Allowed fields in the search depend on the resource type: * Cluster: id, created_at, updated_at, owner, organisation_id, name, state, client_id * Namespace: id, created_at, updated_at, name, cluster_id, owner, expiration, tenant_user_id, tenant_organisation_id, state * Connector Types: id, created_at, updated_at, version, name, description, label, channel, featured_rank, pricing_tier * Connectors: id, created_at, updated_at, name, owner, organisation_id, connector_type_id, desired_state, state, channel, namespace_id, kafka_id, kafka_bootstrap_server, service_account_client_id, schema_registry_id, schema_registry_url Allowed operators are `<>`, `=`, `IN`, `NOT IN`, `LIKE`, or `ILIKE`. Allowed conjunctive operators are `AND` and `OR`. However, you can use a maximum of 10 conjunctions in a search query. Examples: To return a Connector Type with the name `aws-sqs-source` and the channel `stable`, use the following syntax: ``` name = aws-sqs-source and channel = stable ``` To return a connector instance with a name that starts with `aws`, use the following syntax: ``` name like aws%25 ``` To return a connector type with a name containing `aws` matching any character case combination, use the following syntax: ``` name ilike %25aws%25 ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then all the resources that the user has permission to see are returned. Note. If the query is invalid, an error is returned.
@return ConnectorNamespaceList
type ConnectorRequest ¶
type ConnectorRequest struct { Name string `json:"name"` ConnectorTypeId string `json:"connector_type_id"` NamespaceId string `json:"namespace_id"` Channel Channel `json:"channel,omitempty"` DesiredState ConnectorDesiredState `json:"desired_state"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` Kafka KafkaConnectionSettings `json:"kafka"` ServiceAccount ServiceAccount `json:"service_account"` SchemaRegistry SchemaRegistryConnectionSettings `json:"schema_registry,omitempty"` Connector map[string]interface{} `json:"connector"` }
ConnectorRequest struct for ConnectorRequest
type ConnectorRequestMeta ¶
type ConnectorRequestMeta struct { Name string `json:"name"` ConnectorTypeId string `json:"connector_type_id"` NamespaceId string `json:"namespace_id"` Channel Channel `json:"channel,omitempty"` DesiredState ConnectorDesiredState `json:"desired_state"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` }
ConnectorRequestMeta struct for ConnectorRequestMeta
type ConnectorServiceApiService ¶
type ConnectorServiceApiService service
ConnectorServiceApiService ConnectorServiceApi service
func (*ConnectorServiceApiService) GetVersionMetadata ¶
func (a *ConnectorServiceApiService) GetVersionMetadata(ctx _context.Context) (VersionMetadata, *_nethttp.Response, error)
GetVersionMetadata Returns the version metadata Returns the version metadata
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@return VersionMetadata
type ConnectorState ¶
type ConnectorState string
ConnectorState the model 'ConnectorState'
const ( CONNECTORSTATE_ASSIGNING ConnectorState = "assigning" CONNECTORSTATE_ASSIGNED ConnectorState = "assigned" CONNECTORSTATE_UPDATING ConnectorState = "updating" CONNECTORSTATE_READY ConnectorState = "ready" CONNECTORSTATE_STOPPED ConnectorState = "stopped" CONNECTORSTATE_FAILED ConnectorState = "failed" CONNECTORSTATE_DELETING ConnectorState = "deleting" CONNECTORSTATE_DELETED ConnectorState = "deleted" CONNECTORSTATE_PROVISIONING ConnectorState = "provisioning" CONNECTORSTATE_DEPROVISIONING ConnectorState = "deprovisioning" )
List of ConnectorState
type ConnectorStatus ¶
type ConnectorStatus struct {
Status ConnectorStatusStatus `json:"status,omitempty"`
}
ConnectorStatus struct for ConnectorStatus
type ConnectorStatusStatus ¶
type ConnectorStatusStatus struct { State ConnectorState `json:"state,omitempty"` Error string `json:"error,omitempty"` }
ConnectorStatusStatus struct for ConnectorStatusStatus
type ConnectorType ¶
type ConnectorType struct { Id string `json:"id,omitempty"` Kind string `json:"kind,omitempty"` Href string `json:"href,omitempty"` // Name of the connector type. Name string `json:"name"` // Version of the connector type. Version string `json:"version"` // Channels of the connector type. Channels []Channel `json:"channels,omitempty"` // A description of the connector. Description string `json:"description,omitempty"` // Connector type is deprecated and removed from the catalog. Deprecated bool `json:"deprecated,omitempty"` // URL to an icon of the connector. IconHref string `json:"icon_href,omitempty"` // Labels used to categorize the connector Labels []string `json:"labels,omitempty"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` // Ranking for featured connectors FeaturedRank int32 `json:"featured_rank,omitempty"` // The capabilities supported by the connector Capabilities []string `json:"capabilities,omitempty"` // A json schema that can be used to validate a ConnectorRequest connector field. Schema map[string]interface{} `json:"schema"` }
ConnectorType Represents a connector type supported by the API
type ConnectorTypeLabelCount ¶
type ConnectorTypeLabelCount struct { // Name of the connector type label. Label string `json:"label"` // Number of connector types with this label. Count int32 `json:"count"` }
ConnectorTypeLabelCount Represents a connector type label and the number of types with that label
type ConnectorTypeLabelCountList ¶
type ConnectorTypeLabelCountList struct {
Items []ConnectorTypeLabelCount `json:"items,omitempty"`
}
ConnectorTypeLabelCountList struct for ConnectorTypeLabelCountList
type ConnectorTypeList ¶
type ConnectorTypeList struct { Kind string `json:"kind"` Page int32 `json:"page"` Size int32 `json:"size"` Total int32 `json:"total"` Items []ConnectorType `json:"items"` }
ConnectorTypeList struct for ConnectorTypeList
type ConnectorTypesApiService ¶
type ConnectorTypesApiService service
ConnectorTypesApiService ConnectorTypesApi service
func (*ConnectorTypesApiService) GetConnectorTypeByID ¶
func (a *ConnectorTypesApiService) GetConnectorTypeByID(ctx _context.Context, connectorTypeId string) (ConnectorType, *_nethttp.Response, error)
GetConnectorTypeByID Get a connector type by id Get a connector type by id
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param connectorTypeId The id of the connector type
@return ConnectorType
func (*ConnectorTypesApiService) GetConnectorTypeLabels ¶
func (a *ConnectorTypesApiService) GetConnectorTypeLabels(ctx _context.Context, localVarOptionals *GetConnectorTypeLabelsOpts) (ConnectorTypeLabelCountList, *_nethttp.Response, error)
GetConnectorTypeLabels Returns a list of connector type labels Returns a list of connector type labels
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param optional nil or *GetConnectorTypeLabelsOpts - Optional Parameters:
- @param "OrderBy" (optional.String) - Specifies the order by criteria. The syntax of this parameter is similar to the syntax of the `order by` clause of an SQL statement. Each query can be ordered by any of the underlying resource fields supported in the search parameter. For example, to return all Connector types ordered by their name, use the following syntax: ```sql name asc ``` To return all Connector types ordered by their name _and_ version, use the following syntax: ```sql name asc, version asc ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then the results are ordered by name.
- @param "Search" (optional.String) - Search criteria. The syntax of this parameter is similar to the syntax of the `where` clause of a SQL statement. Allowed fields in the search depend on the resource type: * Cluster: id, created_at, updated_at, owner, organisation_id, name, state, client_id * Namespace: id, created_at, updated_at, name, cluster_id, owner, expiration, tenant_user_id, tenant_organisation_id, state * Connector Types: id, created_at, updated_at, version, name, description, label, channel, featured_rank, pricing_tier * Connectors: id, created_at, updated_at, name, owner, organisation_id, connector_type_id, desired_state, state, channel, namespace_id, kafka_id, kafka_bootstrap_server, service_account_client_id, schema_registry_id, schema_registry_url Allowed operators are `<>`, `=`, `IN`, `NOT IN`, `LIKE`, or `ILIKE`. Allowed conjunctive operators are `AND` and `OR`. However, you can use a maximum of 10 conjunctions in a search query. Examples: To return a Connector Type with the name `aws-sqs-source` and the channel `stable`, use the following syntax: ``` name = aws-sqs-source and channel = stable ``` To return a connector instance with a name that starts with `aws`, use the following syntax: ``` name like aws%25 ``` To return a connector type with a name containing `aws` matching any character case combination, use the following syntax: ``` name ilike %25aws%25 ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then all the resources that the user has permission to see are returned. Note. If the query is invalid, an error is returned.
@return ConnectorTypeLabelCountList
func (*ConnectorTypesApiService) GetConnectorTypes ¶
func (a *ConnectorTypesApiService) GetConnectorTypes(ctx _context.Context, localVarOptionals *GetConnectorTypesOpts) (ConnectorTypeList, *_nethttp.Response, error)
GetConnectorTypes Returns a list of connector types Returns a list of connector types
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param optional nil or *GetConnectorTypesOpts - Optional Parameters:
- @param "Page" (optional.String) - Page index
- @param "Size" (optional.String) - Number of items in each page
- @param "OrderBy" (optional.String) - Specifies the order by criteria. The syntax of this parameter is similar to the syntax of the `order by` clause of an SQL statement. Each query can be ordered by any of the underlying resource fields supported in the search parameter. For example, to return all Connector types ordered by their name, use the following syntax: ```sql name asc ``` To return all Connector types ordered by their name _and_ version, use the following syntax: ```sql name asc, version asc ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then the results are ordered by name.
- @param "Search" (optional.String) - Search criteria. The syntax of this parameter is similar to the syntax of the `where` clause of a SQL statement. Allowed fields in the search depend on the resource type: * Cluster: id, created_at, updated_at, owner, organisation_id, name, state, client_id * Namespace: id, created_at, updated_at, name, cluster_id, owner, expiration, tenant_user_id, tenant_organisation_id, state * Connector Types: id, created_at, updated_at, version, name, description, label, channel, featured_rank, pricing_tier * Connectors: id, created_at, updated_at, name, owner, organisation_id, connector_type_id, desired_state, state, channel, namespace_id, kafka_id, kafka_bootstrap_server, service_account_client_id, schema_registry_id, schema_registry_url Allowed operators are `<>`, `=`, `IN`, `NOT IN`, `LIKE`, or `ILIKE`. Allowed conjunctive operators are `AND` and `OR`. However, you can use a maximum of 10 conjunctions in a search query. Examples: To return a Connector Type with the name `aws-sqs-source` and the channel `stable`, use the following syntax: ``` name = aws-sqs-source and channel = stable ``` To return a connector instance with a name that starts with `aws`, use the following syntax: ``` name like aws%25 ``` To return a connector type with a name containing `aws` matching any character case combination, use the following syntax: ``` name ilike %25aws%25 ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then all the resources that the user has permission to see are returned. Note. If the query is invalid, an error is returned.
@return ConnectorTypeList
type ConnectorsApiService ¶
type ConnectorsApiService service
ConnectorsApiService ConnectorsApi service
func (*ConnectorsApiService) CreateConnector ¶
func (a *ConnectorsApiService) CreateConnector(ctx _context.Context, async bool, connectorRequest ConnectorRequest) (Connector, *_nethttp.Response, error)
CreateConnector Create a new connector Create a new connector
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param async Perform the action in an asynchronous manner
- @param connectorRequest Connector data
@return Connector
func (*ConnectorsApiService) DeleteConnector ¶
func (a *ConnectorsApiService) DeleteConnector(ctx _context.Context, id string) (Error, *_nethttp.Response, error)
DeleteConnector Delete a connector Delete a connector
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param id The ID of record
@return Error
func (*ConnectorsApiService) GetConnector ¶
func (a *ConnectorsApiService) GetConnector(ctx _context.Context, id string) (Connector, *_nethttp.Response, error)
GetConnector Get a connector Get a connector
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param id The ID of record
@return Connector
func (*ConnectorsApiService) ListConnectors ¶
func (a *ConnectorsApiService) ListConnectors(ctx _context.Context, localVarOptionals *ListConnectorsOpts) (ConnectorList, *_nethttp.Response, error)
ListConnectors Returns a list of connector types Returns a list of connector types
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param optional nil or *ListConnectorsOpts - Optional Parameters:
- @param "Page" (optional.String) - Page index
- @param "Size" (optional.String) - Number of items in each page
- @param "OrderBy" (optional.String) - Specifies the order by criteria. The syntax of this parameter is similar to the syntax of the `order by` clause of an SQL statement. Each query can be ordered by any of the underlying resource fields supported in the search parameter. For example, to return all Connector types ordered by their name, use the following syntax: ```sql name asc ``` To return all Connector types ordered by their name _and_ version, use the following syntax: ```sql name asc, version asc ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then the results are ordered by name.
- @param "Search" (optional.String) - Search criteria. The syntax of this parameter is similar to the syntax of the `where` clause of a SQL statement. Allowed fields in the search depend on the resource type: * Cluster: id, created_at, updated_at, owner, organisation_id, name, state, client_id * Namespace: id, created_at, updated_at, name, cluster_id, owner, expiration, tenant_user_id, tenant_organisation_id, state * Connector Types: id, created_at, updated_at, version, name, description, label, channel, featured_rank, pricing_tier * Connectors: id, created_at, updated_at, name, owner, organisation_id, connector_type_id, desired_state, state, channel, namespace_id, kafka_id, kafka_bootstrap_server, service_account_client_id, schema_registry_id, schema_registry_url Allowed operators are `<>`, `=`, `IN`, `NOT IN`, `LIKE`, or `ILIKE`. Allowed conjunctive operators are `AND` and `OR`. However, you can use a maximum of 10 conjunctions in a search query. Examples: To return a Connector Type with the name `aws-sqs-source` and the channel `stable`, use the following syntax: ``` name = aws-sqs-source and channel = stable ``` To return a connector instance with a name that starts with `aws`, use the following syntax: ``` name like aws%25 ``` To return a connector type with a name containing `aws` matching any character case combination, use the following syntax: ``` name ilike %25aws%25 ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then all the resources that the user has permission to see are returned. Note. If the query is invalid, an error is returned.
@return ConnectorList
func (*ConnectorsApiService) PatchConnector ¶
func (a *ConnectorsApiService) PatchConnector(ctx _context.Context, id string, body map[string]interface{}) (Connector, *_nethttp.Response, error)
PatchConnector Patch a connector Patch a connector
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param id The ID of record
- @param body Data to patch the connector with
@return Connector
type Error ¶
type Error struct { Reason string `json:"reason"` OperationId string `json:"operation_id,omitempty"` Id string `json:"id"` Kind string `json:"kind"` Href string `json:"href"` Code string `json:"code"` }
Error struct for Error
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 GetConnectorClusterAddonParametersOpts ¶
GetConnectorClusterAddonParametersOpts Optional parameters for the method 'GetConnectorClusterAddonParameters'
type GetConnectorClusterNamespacesOpts ¶
type GetConnectorClusterNamespacesOpts struct { Page optional.String Size optional.String OrderBy optional.String Search optional.String }
GetConnectorClusterNamespacesOpts Optional parameters for the method 'GetConnectorClusterNamespaces'
type GetConnectorTypeLabelsOpts ¶
GetConnectorTypeLabelsOpts Optional parameters for the method 'GetConnectorTypeLabels'
type GetConnectorTypesOpts ¶
type GetConnectorTypesOpts struct { Page optional.String Size optional.String OrderBy optional.String Search optional.String }
GetConnectorTypesOpts Optional parameters for the method 'GetConnectorTypes'
type KafkaConnectionSettings ¶
KafkaConnectionSettings Holds the configuration to connect to a Kafka Instance.
type List ¶
type List struct { Kind string `json:"kind"` Page int32 `json:"page"` Size int32 `json:"size"` Total int32 `json:"total"` }
List struct for List
type ListConnectorClustersOpts ¶
type ListConnectorClustersOpts struct { Page optional.String Size optional.String OrderBy optional.String Search optional.String }
ListConnectorClustersOpts Optional parameters for the method 'ListConnectorClusters'
type ListConnectorNamespacesOpts ¶
type ListConnectorNamespacesOpts struct { Page optional.String Size optional.String OrderBy optional.String Search optional.String }
ListConnectorNamespacesOpts Optional parameters for the method 'ListConnectorNamespaces'
type ListConnectorsOpts ¶
type ListConnectorsOpts struct { Page optional.String Size optional.String OrderBy optional.String Search optional.String }
ListConnectorsOpts Optional parameters for the method 'ListConnectors'
type ObjectMeta ¶
type ObjectMeta struct { Owner string `json:"owner,omitempty"` CreatedAt time.Time `json:"created_at,omitempty"` ModifiedAt time.Time `json:"modified_at,omitempty"` }
ObjectMeta struct for ObjectMeta
type ObjectReference ¶
type ObjectReference struct { Id string `json:"id,omitempty"` Kind string `json:"kind,omitempty"` Href string `json:"href,omitempty"` }
ObjectReference struct for ObjectReference
type SchemaRegistryConnectionSettings ¶
SchemaRegistryConnectionSettings Holds the configuration to connect to a Schem Registry Instance.
type ServerConfiguration ¶
type ServerConfiguration struct { Url string Description string Variables map[string]ServerVariable }
ServerConfiguration stores the information about a server
type ServerVariable ¶
ServerVariable stores the information about a server variable
type ServiceAccount ¶
type ServiceAccount struct { ClientId string `json:"client_id"` ClientSecret string `json:"client_secret"` }
ServiceAccount struct for ServiceAccount
type ServiceConnectionSettings ¶
ServiceConnectionSettings struct for ServiceConnectionSettings
type VersionMetadata ¶
type VersionMetadata struct { Id string `json:"id,omitempty"` Kind string `json:"kind,omitempty"` Href string `json:"href,omitempty"` Collections []ObjectReference `json:"collections,omitempty"` }
VersionMetadata struct for VersionMetadata
Source Files ¶
- api_connector_clusters.go
- api_connector_namespaces.go
- api_connector_service.go
- api_connector_types.go
- api_connectors.go
- client.go
- configuration.go
- model_addon_parameter.go
- model_channel.go
- model_connector.go
- model_connector_cluster.go
- model_connector_cluster_list.go
- model_connector_cluster_meta.go
- model_connector_cluster_request.go
- model_connector_cluster_request_meta.go
- model_connector_cluster_state.go
- model_connector_cluster_status.go
- model_connector_cluster_status_status.go
- model_connector_configuration.go
- model_connector_desired_state.go
- model_connector_list.go
- model_connector_meta.go
- model_connector_namespace.go
- model_connector_namespace_eval_request.go
- model_connector_namespace_list.go
- model_connector_namespace_meta.go
- model_connector_namespace_patch_request.go
- model_connector_namespace_quota.go
- model_connector_namespace_request.go
- model_connector_namespace_request_meta.go
- model_connector_namespace_state.go
- model_connector_namespace_status.go
- model_connector_namespace_tenant.go
- model_connector_namespace_tenant_kind.go
- model_connector_request.go
- model_connector_request_meta.go
- model_connector_state.go
- model_connector_status.go
- model_connector_status_status.go
- model_connector_type.go
- model_connector_type_label_count.go
- model_connector_type_label_count_list.go
- model_connector_type_list.go
- model_error.go
- model_kafka_connection_settings.go
- model_list.go
- model_object_meta.go
- model_object_reference.go
- model_schema_registry_connection_settings.go
- model_service_account.go
- model_service_connection_settings.go
- model_version_metadata.go
- response.go