admin

package
v0.0.0-...-da48874 Latest Latest
Warning

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

 Go to latest Published: Apr 4, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

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 {
	ConnectorClustersAdminApi *ConnectorClustersAdminApiService

	ConnectorNamespacesAdminApi *ConnectorNamespacesAdminApiService

	ConnectorTypesApi *ConnectorTypesApiService
	// contains filtered or unexported fields
}

APIClient manages communication with the Connector Service Fleet Manager Admin APIs API v0.0.3 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 ApiCreateConnectorNamespaceRequest 

type ApiCreateConnectorNamespaceRequest struct {
	ApiService *ConnectorNamespacesAdminApiService
	// contains filtered or unexported fields
}

func (ApiCreateConnectorNamespaceRequest) ConnectorNamespaceWithTenantRequest 

func (r ApiCreateConnectorNamespaceRequest) ConnectorNamespaceWithTenantRequest(connectorNamespaceWithTenantRequest ConnectorNamespaceWithTenantRequest) ApiCreateConnectorNamespaceRequest

Namespace to create

func (ApiCreateConnectorNamespaceRequest) Execute 

func (r ApiCreateConnectorNamespaceRequest) Execute() (*ConnectorNamespace, *http.Response, error)

type ApiDeleteConnectorNamespaceRequest 

type ApiDeleteConnectorNamespaceRequest struct {
	ApiService *ConnectorClustersAdminApiService
	// contains filtered or unexported fields
}

func (ApiDeleteConnectorNamespaceRequest) Execute 

func (r ApiDeleteConnectorNamespaceRequest) Execute() (*Error, *http.Response, error)

func (ApiDeleteConnectorNamespaceRequest) Force 

func (r ApiDeleteConnectorNamespaceRequest) Force(force bool) ApiDeleteConnectorNamespaceRequest

Flag to force deletion of namespace in Fleet manager if true

type ApiDeleteConnectorRequest 

type ApiDeleteConnectorRequest struct {
	ApiService *ConnectorClustersAdminApiService
	// contains filtered or unexported fields
}

func (ApiDeleteConnectorRequest) Execute 

func (r ApiDeleteConnectorRequest) Execute() (*Error, *http.Response, error)

func (ApiDeleteConnectorRequest) Force 

func (r ApiDeleteConnectorRequest) Force(force bool) ApiDeleteConnectorRequest

Flag to force deletion of connector in Fleet manager if true

type ApiGetClusterConnectorsRequest 

type ApiGetClusterConnectorsRequest struct {
	ApiService *ConnectorClustersAdminApiService
	// contains filtered or unexported fields
}

func (ApiGetClusterConnectorsRequest) Execute 

func (r ApiGetClusterConnectorsRequest) Execute() (*ConnectorAdminViewList, *http.Response, error)

func (ApiGetClusterConnectorsRequest) OrderBy 

func (r ApiGetClusterConnectorsRequest) OrderBy(orderBy string) ApiGetClusterConnectorsRequest

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.

func (ApiGetClusterConnectorsRequest) Page 

func (r ApiGetClusterConnectorsRequest) Page(page string) ApiGetClusterConnectorsRequest

Page index

func (ApiGetClusterConnectorsRequest) Search 

func (r ApiGetClusterConnectorsRequest) Search(search string) ApiGetClusterConnectorsRequest

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 `<>`, `=`, `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.

func (ApiGetClusterConnectorsRequest) Size 

func (r ApiGetClusterConnectorsRequest) Size(size string) ApiGetClusterConnectorsRequest

Number of items in each page

type ApiGetClusterDeploymentsRequest 

type ApiGetClusterDeploymentsRequest struct {
	ApiService *ConnectorClustersAdminApiService
	// contains filtered or unexported fields
}

func (ApiGetClusterDeploymentsRequest) ChannelUpdates 

func (r ApiGetClusterDeploymentsRequest) ChannelUpdates(channelUpdates bool) ApiGetClusterDeploymentsRequest

include only deployments that have channel updates

func (ApiGetClusterDeploymentsRequest) DanglingDeployments 

func (r ApiGetClusterDeploymentsRequest) DanglingDeployments(danglingDeployments bool) ApiGetClusterDeploymentsRequest

include only not deleted deployments belonging to a deleted connector

func (ApiGetClusterDeploymentsRequest) Execute 

func (r ApiGetClusterDeploymentsRequest) Execute() (*ConnectorDeploymentAdminViewList, *http.Response, error)

func (ApiGetClusterDeploymentsRequest) OperatorUpdates 

func (r ApiGetClusterDeploymentsRequest) OperatorUpdates(operatorUpdates bool) ApiGetClusterDeploymentsRequest

include only deployments that have operator updates

func (ApiGetClusterDeploymentsRequest) OrderBy 

func (r ApiGetClusterDeploymentsRequest) OrderBy(orderBy string) ApiGetClusterDeploymentsRequest

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.

func (ApiGetClusterDeploymentsRequest) Page 

func (r ApiGetClusterDeploymentsRequest) Page(page string) ApiGetClusterDeploymentsRequest

Page index

func (ApiGetClusterDeploymentsRequest) Size 

func (r ApiGetClusterDeploymentsRequest) Size(size string) ApiGetClusterDeploymentsRequest

Number of items in each page

type ApiGetClusterNamespacesRequest 

type ApiGetClusterNamespacesRequest struct {
	ApiService *ConnectorClustersAdminApiService
	// contains filtered or unexported fields
}

func (ApiGetClusterNamespacesRequest) Execute 

func (r ApiGetClusterNamespacesRequest) Execute() (*ConnectorNamespaceList, *http.Response, error)

func (ApiGetClusterNamespacesRequest) OrderBy 

func (r ApiGetClusterNamespacesRequest) OrderBy(orderBy string) ApiGetClusterNamespacesRequest

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.

func (ApiGetClusterNamespacesRequest) Page 

func (r ApiGetClusterNamespacesRequest) Page(page string) ApiGetClusterNamespacesRequest

Page index

func (ApiGetClusterNamespacesRequest) Search 

func (r ApiGetClusterNamespacesRequest) Search(search string) ApiGetClusterNamespacesRequest

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 `<>`, `=`, `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.

func (ApiGetClusterNamespacesRequest) Size 

func (r ApiGetClusterNamespacesRequest) Size(size string) ApiGetClusterNamespacesRequest

Number of items in each page

type ApiGetConnectorClusterRequest 

type ApiGetConnectorClusterRequest struct {
	ApiService *ConnectorClustersAdminApiService
	// contains filtered or unexported fields
}

func (ApiGetConnectorClusterRequest) Execute 

func (r ApiGetConnectorClusterRequest) Execute() (*ConnectorClusterAdminView, *http.Response, error)

type ApiGetConnectorDeploymentRequest 

type ApiGetConnectorDeploymentRequest struct {
	ApiService *ConnectorClustersAdminApiService
	// contains filtered or unexported fields
}

func (ApiGetConnectorDeploymentRequest) Execute 

func (r ApiGetConnectorDeploymentRequest) Execute() (*ConnectorDeploymentAdminView, *http.Response, error)

type ApiGetConnectorNamespaceRequest 

type ApiGetConnectorNamespaceRequest struct {
	ApiService *ConnectorClustersAdminApiService
	// contains filtered or unexported fields
}

func (ApiGetConnectorNamespaceRequest) Execute 

func (r ApiGetConnectorNamespaceRequest) Execute() (*ConnectorNamespace, *http.Response, error)

type ApiGetConnectorNamespacesRequest 

type ApiGetConnectorNamespacesRequest struct {
	ApiService *ConnectorNamespacesAdminApiService
	// contains filtered or unexported fields
}

func (ApiGetConnectorNamespacesRequest) Execute 

func (r ApiGetConnectorNamespacesRequest) Execute() (*ConnectorNamespaceList, *http.Response, error)

func (ApiGetConnectorNamespacesRequest) OrderBy 

func (r ApiGetConnectorNamespacesRequest) OrderBy(orderBy string) ApiGetConnectorNamespacesRequest

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.

func (ApiGetConnectorNamespacesRequest) Page 

func (r ApiGetConnectorNamespacesRequest) Page(page string) ApiGetConnectorNamespacesRequest

Page index

func (ApiGetConnectorNamespacesRequest) Search 

func (r ApiGetConnectorNamespacesRequest) Search(search string) ApiGetConnectorNamespacesRequest

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 `<>`, `=`, `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.

func (ApiGetConnectorNamespacesRequest) Size 

func (r ApiGetConnectorNamespacesRequest) Size(size string) ApiGetConnectorNamespacesRequest

Number of items in each page

type ApiGetConnectorRequest 

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

func (ApiGetConnectorRequest) Execute 

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

type ApiGetConnectorTypeByIDRequest 

type ApiGetConnectorTypeByIDRequest struct {
	ApiService *ConnectorTypesApiService
	// contains filtered or unexported fields
}

func (ApiGetConnectorTypeByIDRequest) Execute 

func (r ApiGetConnectorTypeByIDRequest) Execute() (*ConnectorTypeAdminView, *http.Response, error)

type ApiGetConnectorTypesRequest 

type ApiGetConnectorTypesRequest struct {
	ApiService *ConnectorTypesApiService
	// contains filtered or unexported fields
}

func (ApiGetConnectorTypesRequest) Execute 

func (r ApiGetConnectorTypesRequest) Execute() (*ConnectorTypeAdminViewList, *http.Response, error)

func (ApiGetConnectorTypesRequest) OrderBy 

func (r ApiGetConnectorTypesRequest) OrderBy(orderBy string) ApiGetConnectorTypesRequest

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.

func (ApiGetConnectorTypesRequest) Page 

func (r ApiGetConnectorTypesRequest) Page(page string) ApiGetConnectorTypesRequest

Page index

func (ApiGetConnectorTypesRequest) Search 

func (r ApiGetConnectorTypesRequest) Search(search string) ApiGetConnectorTypesRequest

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 `<>`, `=`, `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.

func (ApiGetConnectorTypesRequest) Size 

func (r ApiGetConnectorTypesRequest) Size(size string) ApiGetConnectorTypesRequest

Number of items in each page

type ApiGetNamespaceConnectorsRequest 

type ApiGetNamespaceConnectorsRequest struct {
	ApiService *ConnectorClustersAdminApiService
	// contains filtered or unexported fields
}

func (ApiGetNamespaceConnectorsRequest) Execute 

func (r ApiGetNamespaceConnectorsRequest) Execute() (*ConnectorAdminViewList, *http.Response, error)

func (ApiGetNamespaceConnectorsRequest) OrderBy 

func (r ApiGetNamespaceConnectorsRequest) OrderBy(orderBy string) ApiGetNamespaceConnectorsRequest

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.

func (ApiGetNamespaceConnectorsRequest) Page 

func (r ApiGetNamespaceConnectorsRequest) Page(page string) ApiGetNamespaceConnectorsRequest

Page index

func (ApiGetNamespaceConnectorsRequest) Search 

func (r ApiGetNamespaceConnectorsRequest) Search(search string) ApiGetNamespaceConnectorsRequest

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 `<>`, `=`, `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.

func (ApiGetNamespaceConnectorsRequest) Size 

func (r ApiGetNamespaceConnectorsRequest) Size(size string) ApiGetNamespaceConnectorsRequest

Number of items in each page

type ApiGetNamespaceDeploymentsRequest 

type ApiGetNamespaceDeploymentsRequest struct {
	ApiService *ConnectorClustersAdminApiService
	// contains filtered or unexported fields
}

func (ApiGetNamespaceDeploymentsRequest) ChannelUpdates 

func (r ApiGetNamespaceDeploymentsRequest) ChannelUpdates(channelUpdates bool) ApiGetNamespaceDeploymentsRequest

include only deployments that have channel updates

func (ApiGetNamespaceDeploymentsRequest) DanglingDeployments 

func (r ApiGetNamespaceDeploymentsRequest) DanglingDeployments(danglingDeployments bool) ApiGetNamespaceDeploymentsRequest

include only not deleted deployments belonging to a deleted connector

func (ApiGetNamespaceDeploymentsRequest) Execute 

func (r ApiGetNamespaceDeploymentsRequest) Execute() (*ConnectorDeploymentAdminViewList, *http.Response, error)

func (ApiGetNamespaceDeploymentsRequest) OperatorUpdates 

func (r ApiGetNamespaceDeploymentsRequest) OperatorUpdates(operatorUpdates bool) ApiGetNamespaceDeploymentsRequest

include only deployments that have operator updates

func (ApiGetNamespaceDeploymentsRequest) OrderBy 

func (r ApiGetNamespaceDeploymentsRequest) OrderBy(orderBy string) ApiGetNamespaceDeploymentsRequest

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.

func (ApiGetNamespaceDeploymentsRequest) Page 

func (r ApiGetNamespaceDeploymentsRequest) Page(page string) ApiGetNamespaceDeploymentsRequest

Page index

func (ApiGetNamespaceDeploymentsRequest) Size 

func (r ApiGetNamespaceDeploymentsRequest) Size(size string) ApiGetNamespaceDeploymentsRequest

Number of items in each page

type ApiListConnectorClustersRequest 

type ApiListConnectorClustersRequest struct {
	ApiService *ConnectorClustersAdminApiService
	// contains filtered or unexported fields
}

func (ApiListConnectorClustersRequest) Execute 

func (r ApiListConnectorClustersRequest) Execute() (*ConnectorClusterAdminList, *http.Response, error)

func (ApiListConnectorClustersRequest) OrderBy 

func (r ApiListConnectorClustersRequest) OrderBy(orderBy string) ApiListConnectorClustersRequest

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.

func (ApiListConnectorClustersRequest) Page 

func (r ApiListConnectorClustersRequest) Page(page string) ApiListConnectorClustersRequest

Page index

func (ApiListConnectorClustersRequest) Search 

func (r ApiListConnectorClustersRequest) Search(search string) ApiListConnectorClustersRequest

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 `<>`, `=`, `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.

func (ApiListConnectorClustersRequest) Size 

func (r ApiListConnectorClustersRequest) Size(size string) ApiListConnectorClustersRequest

Number of items in each page

type ApiPatchConnectorClusterDeploymentAdminRequest 

type ApiPatchConnectorClusterDeploymentAdminRequest struct {
	ApiService *ConnectorClustersAdminApiService
	// contains filtered or unexported fields
}

func (ApiPatchConnectorClusterDeploymentAdminRequest) Body 

func (r ApiPatchConnectorClusterDeploymentAdminRequest) Body(body map[string]interface{}) ApiPatchConnectorClusterDeploymentAdminRequest

Data to patch the deployment with

func (ApiPatchConnectorClusterDeploymentAdminRequest) Execute 

func (r ApiPatchConnectorClusterDeploymentAdminRequest) Execute() (*ConnectorDeploymentAdminView, *http.Response, error)

type ApiPatchConnectorRequest 

type ApiPatchConnectorRequest struct {
	ApiService *ConnectorClustersAdminApiService
	// contains filtered or unexported fields
}

func (ApiPatchConnectorRequest) Body 

func (r ApiPatchConnectorRequest) Body(body map[string]interface{}) ApiPatchConnectorRequest

Data to patch the connector with

func (ApiPatchConnectorRequest) Execute 

func (r ApiPatchConnectorRequest) Execute() (*ConnectorAdminView, *http.Response, error)

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 {
	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 ConnectorAdminRequest 

type ConnectorAdminRequest struct {
	DesiredState ConnectorDesiredState `json:"desired_state"`
}

ConnectorAdminRequest struct for ConnectorAdminRequest

type ConnectorAdminView 

type ConnectorAdminView 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"`
	Status          ConnectorStatusStatus `json:"status,omitempty"`
}

ConnectorAdminView struct for ConnectorAdminView

type ConnectorAdminViewList 

type ConnectorAdminViewList struct {
	Kind  string               `json:"kind"`
	Page  int32                `json:"page"`
	Size  int32                `json:"size"`
	Total int32                `json:"total"`
	Items []ConnectorAdminView `json:"items"`
}

ConnectorAdminViewList struct for ConnectorAdminViewList

type ConnectorAdminViewListAllOf 

type ConnectorAdminViewListAllOf struct {
	Items []ConnectorAdminView `json:"items,omitempty"`
}

ConnectorAdminViewListAllOf struct for ConnectorAdminViewListAllOf

type ConnectorAvailableOperatorUpgrade 

type ConnectorAvailableOperatorUpgrade struct {
	ConnectorId     string                 `json:"connector_id,omitempty"`
	NamespaceId     string                 `json:"namespace_id,omitempty"`
	ConnectorTypeId string                 `json:"connector_type_id,omitempty"`
	Channel         string                 `json:"channel,omitempty"`
	Operator        ConnectorUpgradeStatus `json:"operator,omitempty"`
}

ConnectorAvailableOperatorUpgrade An available operator upgrade for a connector

type ConnectorAvailableOperatorUpgradeList 

type ConnectorAvailableOperatorUpgradeList struct {
	Kind  string                              `json:"kind"`
	Page  int32                               `json:"page"`
	Size  int32                               `json:"size"`
	Total int32                               `json:"total"`
	Items []ConnectorAvailableOperatorUpgrade `json:"items"`
}

ConnectorAvailableOperatorUpgradeList struct for ConnectorAvailableOperatorUpgradeList

type ConnectorAvailableOperatorUpgradeListAllOf 

type ConnectorAvailableOperatorUpgradeListAllOf struct {
	Items []ConnectorAvailableOperatorUpgrade `json:"items,omitempty"`
}

ConnectorAvailableOperatorUpgradeListAllOf struct for ConnectorAvailableOperatorUpgradeListAllOf

type ConnectorAvailableOperatorUpgradeOperator 

type ConnectorAvailableOperatorUpgradeOperator struct {
	AssignedId  string `json:"assigned_id,omitempty"`
	AvailableId string `json:"available_id,omitempty"`
}

ConnectorAvailableOperatorUpgradeOperator struct for ConnectorAvailableOperatorUpgradeOperator

type ConnectorAvailableTypeUpgrade 

type ConnectorAvailableTypeUpgrade struct {
	ConnectorId     string                                     `json:"connector_id,omitempty"`
	NamespaceId     string                                     `json:"namespace_id,omitempty"`
	ConnectorTypeId string                                     `json:"connector_type_id,omitempty"`
	Channel         string                                     `json:"channel,omitempty"`
	ShardMetadata   ConnectorAvailableTypeUpgradeShardMetadata `json:"shard_metadata,omitempty"`
}

ConnectorAvailableTypeUpgrade An available type upgrade for a connector

type ConnectorAvailableTypeUpgradeList 

type ConnectorAvailableTypeUpgradeList struct {
	Kind  string                          `json:"kind"`
	Page  int32                           `json:"page"`
	Size  int32                           `json:"size"`
	Total int32                           `json:"total"`
	Items []ConnectorAvailableTypeUpgrade `json:"items"`
}

ConnectorAvailableTypeUpgradeList struct for ConnectorAvailableTypeUpgradeList

type ConnectorAvailableTypeUpgradeListAllOf 

type ConnectorAvailableTypeUpgradeListAllOf struct {
	Items []ConnectorAvailableTypeUpgrade `json:"items,omitempty"`
}

ConnectorAvailableTypeUpgradeListAllOf struct for ConnectorAvailableTypeUpgradeListAllOf

type ConnectorAvailableTypeUpgradeShardMetadata 

type ConnectorAvailableTypeUpgradeShardMetadata struct {
	AssignedId  int64 `json:"assigned_id,omitempty"`
	AvailableId int64 `json:"available_id,omitempty"`
}

ConnectorAvailableTypeUpgradeShardMetadata struct for ConnectorAvailableTypeUpgradeShardMetadata

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"`
	Status     ConnectorClusterStatusStatus `json:"status,omitempty"`
}

ConnectorCluster struct for ConnectorCluster

type ConnectorClusterAdminList 

type ConnectorClusterAdminList struct {
	Kind  string                      `json:"kind"`
	Page  int32                       `json:"page"`
	Size  int32                       `json:"size"`
	Total int32                       `json:"total"`
	Items []ConnectorClusterAdminView `json:"items"`
}

ConnectorClusterAdminList struct for ConnectorClusterAdminList

type ConnectorClusterAdminListAllOf 

type ConnectorClusterAdminListAllOf struct {
	Items []ConnectorClusterAdminView `json:"items,omitempty"`
}

ConnectorClusterAdminListAllOf struct for ConnectorClusterAdminListAllOf

type ConnectorClusterAdminStatus 

type ConnectorClusterAdminStatus struct {
	State      ConnectorClusterState    `json:"state,omitempty"`
	Version    string                   `json:"version,omitempty"`
	Conditions []MetaV1Condition        `json:"conditions,omitempty"`
	Platform   ConnectorClusterPlatform `json:"platform,omitempty"`
	// the list of installed operators
	Operators []ConnectorClusterAdminStatusOperatorsInner `json:"operators,omitempty"`
}

ConnectorClusterAdminStatus struct for ConnectorClusterAdminStatus

type ConnectorClusterAdminStatusOperatorsInner 

type ConnectorClusterAdminStatusOperatorsInner struct {
	Operator ConnectorOperator `json:"operator,omitempty"`
	// the namespace to which the operator has been installed
	Namespace string `json:"namespace,omitempty"`
	// the status of the operator
	Status string `json:"status,omitempty"`
}

ConnectorClusterAdminStatusOperatorsInner struct for ConnectorClusterAdminStatusOperatorsInner

type ConnectorClusterAdminView 

type ConnectorClusterAdminView 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      ConnectorClusterAdminStatus `json:"status,omitempty"`
}

ConnectorClusterAdminView struct for ConnectorClusterAdminView

type ConnectorClusterAdminViewAllOf 

type ConnectorClusterAdminViewAllOf struct {
	Status ConnectorClusterAdminStatus `json:"status,omitempty"`
}

ConnectorClusterAdminViewAllOf struct for ConnectorClusterAdminViewAllOf

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 ConnectorClusterListAllOf 

type ConnectorClusterListAllOf struct {
	Items []ConnectorCluster `json:"items,omitempty"`
}

ConnectorClusterListAllOf struct for ConnectorClusterListAllOf

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 ConnectorClusterPlatform 

type ConnectorClusterPlatform struct {
	// the kubernetes cluster type
	Type string `json:"type,omitempty"`
	// uniquely identifies the kubernetes cluster
	Id string `json:"id,omitempty"`
	// optional version of the kubernetes cluster
	Version string `json:"version,omitempty"`
}

ConnectorClusterPlatform information about the kubernetes platform

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 ConnectorClustersAdminApiService 

type ConnectorClustersAdminApiService service

ConnectorClustersAdminApiService ConnectorClustersAdminApi service

func (*ConnectorClustersAdminApiService) DeleteConnector 

func (a *ConnectorClustersAdminApiService) DeleteConnector(ctx context.Context, connectorId string) ApiDeleteConnectorRequest

DeleteConnector Delete a connector 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param connectorId The id of the connector to delete
@return ApiDeleteConnectorRequest

func (*ConnectorClustersAdminApiService) DeleteConnectorExecute 

func (a *ConnectorClustersAdminApiService) DeleteConnectorExecute(r ApiDeleteConnectorRequest) (*Error, *http.Response, error)

Execute executes the request 

@return Error

func (*ConnectorClustersAdminApiService) DeleteConnectorNamespace 

func (a *ConnectorClustersAdminApiService) DeleteConnectorNamespace(ctx context.Context, namespaceId string) ApiDeleteConnectorNamespaceRequest

DeleteConnectorNamespace Delete a connector namespace 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param namespaceId The id of the namespace to delete
@return ApiDeleteConnectorNamespaceRequest

func (*ConnectorClustersAdminApiService) DeleteConnectorNamespaceExecute 

func (a *ConnectorClustersAdminApiService) DeleteConnectorNamespaceExecute(r ApiDeleteConnectorNamespaceRequest) (*Error, *http.Response, error)

Execute executes the request 

@return Error

func (*ConnectorClustersAdminApiService) GetClusterConnectors 

func (a *ConnectorClustersAdminApiService) GetClusterConnectors(ctx context.Context, connectorClusterId string) ApiGetClusterConnectorsRequest

GetClusterConnectors Get a list of available connectors in a 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 ApiGetClusterConnectorsRequest

func (*ConnectorClustersAdminApiService) GetClusterConnectorsExecute 

func (a *ConnectorClustersAdminApiService) GetClusterConnectorsExecute(r ApiGetClusterConnectorsRequest) (*ConnectorAdminViewList, *http.Response, error)

Execute executes the request 

@return ConnectorAdminViewList

func (*ConnectorClustersAdminApiService) GetClusterDeployments 

func (a *ConnectorClustersAdminApiService) GetClusterDeployments(ctx context.Context, connectorClusterId string) ApiGetClusterDeploymentsRequest

GetClusterDeployments Get a list of available deployments in a 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 cluster
@return ApiGetClusterDeploymentsRequest

func (*ConnectorClustersAdminApiService) GetClusterDeploymentsExecute 

func (a *ConnectorClustersAdminApiService) GetClusterDeploymentsExecute(r ApiGetClusterDeploymentsRequest) (*ConnectorDeploymentAdminViewList, *http.Response, error)

Execute executes the request 

@return ConnectorDeploymentAdminViewList

func (*ConnectorClustersAdminApiService) GetClusterNamespaces 

func (a *ConnectorClustersAdminApiService) GetClusterNamespaces(ctx context.Context, connectorClusterId string) ApiGetClusterNamespacesRequest

GetClusterNamespaces Get a list of available connector namespaces in 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 ApiGetClusterNamespacesRequest

func (*ConnectorClustersAdminApiService) GetClusterNamespacesExecute 

func (a *ConnectorClustersAdminApiService) GetClusterNamespacesExecute(r ApiGetClusterNamespacesRequest) (*ConnectorNamespaceList, *http.Response, error)

Execute executes the request 

@return ConnectorNamespaceList

func (*ConnectorClustersAdminApiService) GetConnector 

func (a *ConnectorClustersAdminApiService) GetConnector(ctx context.Context, connectorId string) ApiGetConnectorRequest

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 connectorId The id of the connector to delete
@return ApiGetConnectorRequest

func (*ConnectorClustersAdminApiService) GetConnectorCluster 

func (a *ConnectorClustersAdminApiService) GetConnectorCluster(ctx context.Context, connectorClusterId string) ApiGetConnectorClusterRequest

GetConnectorCluster 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 ApiGetConnectorClusterRequest

func (*ConnectorClustersAdminApiService) GetConnectorClusterExecute 

func (a *ConnectorClustersAdminApiService) GetConnectorClusterExecute(r ApiGetConnectorClusterRequest) (*ConnectorClusterAdminView, *http.Response, error)

Execute executes the request 

@return ConnectorClusterAdminView

func (*ConnectorClustersAdminApiService) GetConnectorDeployment 

func (a *ConnectorClustersAdminApiService) GetConnectorDeployment(ctx context.Context, connectorClusterId string, deploymentId string) ApiGetConnectorDeploymentRequest

GetConnectorDeployment Get a connector deployment

Get a connector deployment 

@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 deploymentId The id of the connector deployment
@return ApiGetConnectorDeploymentRequest

func (*ConnectorClustersAdminApiService) GetConnectorDeploymentExecute 

func (a *ConnectorClustersAdminApiService) GetConnectorDeploymentExecute(r ApiGetConnectorDeploymentRequest) (*ConnectorDeploymentAdminView, *http.Response, error)

Execute executes the request 

@return ConnectorDeploymentAdminView

func (*ConnectorClustersAdminApiService) GetConnectorExecute 

func (a *ConnectorClustersAdminApiService) GetConnectorExecute(r ApiGetConnectorRequest) (*ConnectorAdminView, *http.Response, error)

Execute executes the request 

@return ConnectorAdminView

func (*ConnectorClustersAdminApiService) GetConnectorNamespace 

func (a *ConnectorClustersAdminApiService) GetConnectorNamespace(ctx context.Context, namespaceId string) ApiGetConnectorNamespaceRequest

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 namespaceId The id of the namespace
@return ApiGetConnectorNamespaceRequest

func (*ConnectorClustersAdminApiService) GetConnectorNamespaceExecute 

func (a *ConnectorClustersAdminApiService) GetConnectorNamespaceExecute(r ApiGetConnectorNamespaceRequest) (*ConnectorNamespace, *http.Response, error)

Execute executes the request 

@return ConnectorNamespace

func (*ConnectorClustersAdminApiService) GetNamespaceConnectors 

func (a *ConnectorClustersAdminApiService) GetNamespaceConnectors(ctx context.Context, namespaceId string) ApiGetNamespaceConnectorsRequest

GetNamespaceConnectors Get a list of available connectors in a namespace 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param namespaceId The id of the namespace
@return ApiGetNamespaceConnectorsRequest

func (*ConnectorClustersAdminApiService) GetNamespaceConnectorsExecute 

func (a *ConnectorClustersAdminApiService) GetNamespaceConnectorsExecute(r ApiGetNamespaceConnectorsRequest) (*ConnectorAdminViewList, *http.Response, error)

Execute executes the request 

@return ConnectorAdminViewList

func (*ConnectorClustersAdminApiService) GetNamespaceDeployments 

func (a *ConnectorClustersAdminApiService) GetNamespaceDeployments(ctx context.Context, namespaceId string) ApiGetNamespaceDeploymentsRequest

GetNamespaceDeployments Get a list of available deployments in a namespace 

@param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param namespaceId The id of the namespace
@return ApiGetNamespaceDeploymentsRequest

func (*ConnectorClustersAdminApiService) GetNamespaceDeploymentsExecute 

func (a *ConnectorClustersAdminApiService) GetNamespaceDeploymentsExecute(r ApiGetNamespaceDeploymentsRequest) (*ConnectorDeploymentAdminViewList, *http.Response, error)

Execute executes the request 

@return ConnectorDeploymentAdminViewList

func (*ConnectorClustersAdminApiService) ListConnectorClusters 

func (a *ConnectorClustersAdminApiService) ListConnectorClusters(ctx context.Context) ApiListConnectorClustersRequest

ListConnectorClusters Returns a list of connector clusters 

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

func (*ConnectorClustersAdminApiService) ListConnectorClustersExecute 

func (a *ConnectorClustersAdminApiService) ListConnectorClustersExecute(r ApiListConnectorClustersRequest) (*ConnectorClusterAdminList, *http.Response, error)

Execute executes the request 

@return ConnectorClusterAdminList

func (*ConnectorClustersAdminApiService) PatchConnector 

func (a *ConnectorClustersAdminApiService) PatchConnector(ctx context.Context, connectorId string) ApiPatchConnectorRequest

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 connectorId The id of the connector to delete
@return ApiPatchConnectorRequest

func (*ConnectorClustersAdminApiService) PatchConnectorClusterDeploymentAdmin 

func (a *ConnectorClustersAdminApiService) PatchConnectorClusterDeploymentAdmin(ctx context.Context, connectorClusterId string, deploymentId string) ApiPatchConnectorClusterDeploymentAdminRequest

PatchConnectorClusterDeploymentAdmin Patch a deployment

Patch a deployment 

@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 deploymentId The id of the connector deployment
@return ApiPatchConnectorClusterDeploymentAdminRequest

func (*ConnectorClustersAdminApiService) PatchConnectorClusterDeploymentAdminExecute 

func (a *ConnectorClustersAdminApiService) PatchConnectorClusterDeploymentAdminExecute(r ApiPatchConnectorClusterDeploymentAdminRequest) (*ConnectorDeploymentAdminView, *http.Response, error)

Execute executes the request 

@return ConnectorDeploymentAdminView

func (*ConnectorClustersAdminApiService) PatchConnectorExecute 

func (a *ConnectorClustersAdminApiService) PatchConnectorExecute(r ApiPatchConnectorRequest) (*ConnectorAdminView, *http.Response, error)

Execute executes the request 

@return ConnectorAdminView

type ConnectorDeploymentAdminSpec 

type ConnectorDeploymentAdminSpec struct {
	ConnectorId              string `json:"connector_id,omitempty"`
	ConnectorResourceVersion int64  `json:"connector_resource_version,omitempty"`
	ConnectorTypeId          string `json:"connector_type_id,omitempty"`
	ClusterId                string `json:"cluster_id,omitempty"`
	NamespaceId              string `json:"namespace_id,omitempty"`
	// allow the connector to upgrade to a new operator
	// Deprecated
	DeprecatedAllowUpgrade bool `json:"allow_upgrade,omitempty"`
	// an optional operator id that the connector should be run under.
	OperatorId    string                 `json:"operator_id,omitempty"`
	DesiredState  ConnectorDesiredState  `json:"desired_state,omitempty"`
	ShardMetadata map[string]interface{} `json:"shard_metadata,omitempty"`
}

ConnectorDeploymentAdminSpec Holds the deployment specification of a connector

type ConnectorDeploymentAdminStatus 

type ConnectorDeploymentAdminStatus struct {
	Phase           ConnectorState                              `json:"phase,omitempty"`
	ResourceVersion int64                                       `json:"resource_version,omitempty"`
	ShardMetadata   ConnectorDeploymentAdminStatusShardMetadata `json:"shard_metadata,omitempty"`
	Operators       ConnectorDeploymentAdminStatusOperators     `json:"operators,omitempty"`
	Conditions      []MetaV1Condition                           `json:"conditions,omitempty"`
}

ConnectorDeploymentAdminStatus The status of connector deployment

type ConnectorDeploymentAdminStatusOperators 

type ConnectorDeploymentAdminStatusOperators struct {
	Assigned  ConnectorOperator `json:"assigned,omitempty"`
	Available ConnectorOperator `json:"available,omitempty"`
}

ConnectorDeploymentAdminStatusOperators struct for ConnectorDeploymentAdminStatusOperators

type ConnectorDeploymentAdminStatusShardMetadata 

type ConnectorDeploymentAdminStatusShardMetadata struct {
	Assigned  ConnectorShardMetadata `json:"assigned,omitempty"`
	Available ConnectorShardMetadata `json:"available,omitempty"`
}

ConnectorDeploymentAdminStatusShardMetadata latest available revision of deployment shared metadata

type ConnectorDeploymentAdminView 

type ConnectorDeploymentAdminView struct {
	Id       string                                    `json:"id,omitempty"`
	Kind     string                                    `json:"kind,omitempty"`
	Href     string                                    `json:"href,omitempty"`
	Metadata ConnectorDeploymentAdminViewAllOfMetadata `json:"metadata,omitempty"`
	Spec     ConnectorDeploymentAdminSpec              `json:"spec,omitempty"`
	Status   ConnectorDeploymentAdminStatus            `json:"status,omitempty"`
}

ConnectorDeploymentAdminView Holds the deployment configuration of a connector

type ConnectorDeploymentAdminViewAllOf 

type ConnectorDeploymentAdminViewAllOf struct {
	Metadata ConnectorDeploymentAdminViewAllOfMetadata `json:"metadata,omitempty"`
	Spec     ConnectorDeploymentAdminSpec              `json:"spec,omitempty"`
	Status   ConnectorDeploymentAdminStatus            `json:"status,omitempty"`
}

ConnectorDeploymentAdminViewAllOf struct for ConnectorDeploymentAdminViewAllOf

type ConnectorDeploymentAdminViewAllOfMetadata 

type ConnectorDeploymentAdminViewAllOfMetadata struct {
	CreatedAt       time.Time `json:"created_at"`
	UpdatedAt       time.Time `json:"updated_at"`
	ResourceVersion int64     `json:"resource_version"`
	ResolvedSecrets bool      `json:"resolved_secrets"`
	// Name-value string annotations for resource
	Annotations map[string]string `json:"annotations,omitempty"`
}

ConnectorDeploymentAdminViewAllOfMetadata struct for ConnectorDeploymentAdminViewAllOfMetadata

type ConnectorDeploymentAdminViewList 

type ConnectorDeploymentAdminViewList struct {
	Kind  string                         `json:"kind"`
	Page  int32                          `json:"page"`
	Size  int32                          `json:"size"`
	Total int32                          `json:"total"`
	Items []ConnectorDeploymentAdminView `json:"items"`
}

ConnectorDeploymentAdminViewList struct for ConnectorDeploymentAdminViewList

type ConnectorDeploymentAdminViewListAllOf 

type ConnectorDeploymentAdminViewListAllOf struct {
	Items []ConnectorDeploymentAdminView `json:"items,omitempty"`
}

ConnectorDeploymentAdminViewListAllOf struct for ConnectorDeploymentAdminViewListAllOf

type ConnectorDeploymentSpec 

type ConnectorDeploymentSpec struct {
	ConnectorId              string `json:"connector_id,omitempty"`
	ConnectorResourceVersion int64  `json:"connector_resource_version,omitempty"`
	ConnectorTypeId          string `json:"connector_type_id,omitempty"`
	ClusterId                string `json:"cluster_id,omitempty"`
	NamespaceId              string `json:"namespace_id,omitempty"`
	// allow the connector to upgrade to a new operator
	// Deprecated
	DeprecatedAllowUpgrade bool `json:"allow_upgrade,omitempty"`
	// an optional operator id that the connector should be run under.
	OperatorId    string                 `json:"operator_id,omitempty"`
	DesiredState  ConnectorDesiredState  `json:"desired_state,omitempty"`
	ShardMetadata map[string]interface{} `json:"shard_metadata,omitempty"`
}

ConnectorDeploymentSpec Holds the deployment specification of a connector

type ConnectorDeploymentStatus 

type ConnectorDeploymentStatus struct {
	Phase           ConnectorState                     `json:"phase,omitempty"`
	ResourceVersion int64                              `json:"resource_version,omitempty"`
	Operators       ConnectorDeploymentStatusOperators `json:"operators,omitempty"`
	Conditions      []MetaV1Condition                  `json:"conditions,omitempty"`
}

ConnectorDeploymentStatus The status of connector deployment

type ConnectorDeploymentStatusOperators 

type ConnectorDeploymentStatusOperators struct {
	Assigned  ConnectorOperator `json:"assigned,omitempty"`
	Available ConnectorOperator `json:"available,omitempty"`
}

ConnectorDeploymentStatusOperators struct for ConnectorDeploymentStatusOperators

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 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 ConnectorMetaAllOf 

type ConnectorMetaAllOf struct {
	ResourceVersion int64 `json:"resource_version,omitempty"`
}

ConnectorMetaAllOf struct for ConnectorMetaAllOf

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 ConnectorNamespaceAllOf 

type ConnectorNamespaceAllOf struct {
	Name      string `json:"name"`
	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"`
}

ConnectorNamespaceAllOf struct for ConnectorNamespaceAllOf

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 ConnectorNamespaceListAllOf 

type ConnectorNamespaceListAllOf struct {
	Items []ConnectorNamespace `json:"items,omitempty"`
}

ConnectorNamespaceListAllOf struct for ConnectorNamespaceListAllOf

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 ConnectorNamespaceMetaAllOf 

type ConnectorNamespaceMetaAllOf struct {
	ResourceVersion int64                   `json:"resource_version,omitempty"`
	Quota           ConnectorNamespaceQuota `json:"quota,omitempty"`
}

ConnectorNamespaceMetaAllOf struct for ConnectorNamespaceMetaAllOf

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 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 ConnectorNamespaceRequestMetaAnnotations 

type ConnectorNamespaceRequestMetaAnnotations struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

ConnectorNamespaceRequestMetaAnnotations struct for ConnectorNamespaceRequestMetaAnnotations

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 ConnectorNamespaceWithTenantRequest 

type ConnectorNamespaceWithTenantRequest 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"`
	Tenant      ConnectorNamespaceTenant `json:"tenant"`
	// Namespace expiration timestamp in RFC 3339 format
	Expiration string `json:"expiration,omitempty"`
}

ConnectorNamespaceWithTenantRequest struct for ConnectorNamespaceWithTenantRequest

type ConnectorNamespaceWithTenantRequestAllOf 

type ConnectorNamespaceWithTenantRequestAllOf struct {
	ClusterId string                   `json:"cluster_id,omitempty"`
	Tenant    ConnectorNamespaceTenant `json:"tenant,omitempty"`
	// Namespace expiration timestamp in RFC 3339 format
	Expiration string `json:"expiration,omitempty"`
}

ConnectorNamespaceWithTenantRequestAllOf struct for ConnectorNamespaceWithTenantRequestAllOf

type ConnectorNamespacesAdminApiService 

type ConnectorNamespacesAdminApiService service

ConnectorNamespacesAdminApiService ConnectorNamespacesAdminApi service

func (*ConnectorNamespacesAdminApiService) CreateConnectorNamespace 

func (a *ConnectorNamespacesAdminApiService) CreateConnectorNamespace(ctx context.Context) ApiCreateConnectorNamespaceRequest

CreateConnectorNamespace Create a connector namespace 

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

func (*ConnectorNamespacesAdminApiService) CreateConnectorNamespaceExecute 

func (a *ConnectorNamespacesAdminApiService) CreateConnectorNamespaceExecute(r ApiCreateConnectorNamespaceRequest) (*ConnectorNamespace, *http.Response, error)

Execute executes the request 

@return ConnectorNamespace

func (*ConnectorNamespacesAdminApiService) GetConnectorNamespaces 

func (a *ConnectorNamespacesAdminApiService) GetConnectorNamespaces(ctx context.Context) ApiGetConnectorNamespacesRequest

GetConnectorNamespaces Get a list of available connector namespaces 

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

func (*ConnectorNamespacesAdminApiService) GetConnectorNamespacesExecute 

func (a *ConnectorNamespacesAdminApiService) GetConnectorNamespacesExecute(r ApiGetConnectorNamespacesRequest) (*ConnectorNamespaceList, *http.Response, error)

Execute executes the request 

@return ConnectorNamespaceList

type ConnectorOperator 

type ConnectorOperator struct {
	// the id of the operator
	Id string `json:"id,omitempty"`
	// the type of the operator
	Type string `json:"type,omitempty"`
	// the version of the operator
	Version string `json:"version,omitempty"`
}

ConnectorOperator identifies an operator that runs on the fleet shards used to manage connectors.

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 ConnectorShardMetadata 

type ConnectorShardMetadata struct {
	// the channel of the shard metadata
	Channel string `json:"channel,omitempty"`
	// the connector type id this shard metadata refers to
	ConnectorTypeId string `json:"connector_type_id,omitempty"`
	// the revision of the shard metadate
	Revision int64 `json:"revision,omitempty"`
}

ConnectorShardMetadata identifies a shard metadata of a connector type.

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 ConnectorTypeAdminView 

type ConnectorTypeAdminView 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 map[string]ConnectorTypeChannel `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"`
}

ConnectorTypeAdminView Holds the connector type

type ConnectorTypeAdminViewAllOf 

type ConnectorTypeAdminViewAllOf struct {
	Channels map[string]ConnectorTypeChannel `json:"channels,omitempty"`
}

ConnectorTypeAdminViewAllOf struct for ConnectorTypeAdminViewAllOf

type ConnectorTypeAdminViewList 

type ConnectorTypeAdminViewList struct {
	Kind  string                   `json:"kind"`
	Page  int32                    `json:"page"`
	Size  int32                    `json:"size"`
	Total int32                    `json:"total"`
	Items []ConnectorTypeAdminView `json:"items"`
}

ConnectorTypeAdminViewList struct for ConnectorTypeAdminViewList

type ConnectorTypeAdminViewListAllOf 

type ConnectorTypeAdminViewListAllOf struct {
	Items []ConnectorTypeAdminView `json:"items,omitempty"`
}

ConnectorTypeAdminViewListAllOf struct for ConnectorTypeAdminViewListAllOf

type ConnectorTypeAllOf 

type ConnectorTypeAllOf struct {
	// Name of the connector type.
	Name string `json:"name,omitempty"`
	// Version of the connector type.
	Version string `json:"version,omitempty"`
	// 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,omitempty"`
}

ConnectorTypeAllOf struct for ConnectorTypeAllOf

type ConnectorTypeChannel 

type ConnectorTypeChannel struct {
	ShardMetadata map[string]interface{} `json:"shard_metadata,omitempty"`
}

ConnectorTypeChannel Holds the connector type channel

type ConnectorTypesApiService 

type ConnectorTypesApiService service

ConnectorTypesApiService ConnectorTypesApi service

func (*ConnectorTypesApiService) GetConnectorTypeByID 

func (a *ConnectorTypesApiService) GetConnectorTypeByID(ctx context.Context, connectorTypeId string) ApiGetConnectorTypeByIDRequest

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 ApiGetConnectorTypeByIDRequest

func (*ConnectorTypesApiService) GetConnectorTypeByIDExecute 

func (a *ConnectorTypesApiService) GetConnectorTypeByIDExecute(r ApiGetConnectorTypeByIDRequest) (*ConnectorTypeAdminView, *http.Response, error)

Execute executes the request 

@return ConnectorTypeAdminView

func (*ConnectorTypesApiService) GetConnectorTypes 

func (a *ConnectorTypesApiService) GetConnectorTypes(ctx context.Context) ApiGetConnectorTypesRequest

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().
@return ApiGetConnectorTypesRequest

func (*ConnectorTypesApiService) GetConnectorTypesExecute 

func (a *ConnectorTypesApiService) GetConnectorTypesExecute(r ApiGetConnectorTypesRequest) (*ConnectorTypeAdminViewList, *http.Response, error)

Execute executes the request 

@return ConnectorTypeAdminViewList

type ConnectorUpgradeStatus 

type ConnectorUpgradeStatus struct {
	AssignedId  string `json:"assigned_id,omitempty"`
	AvailableId string `json:"available_id,omitempty"`
}

ConnectorUpgradeStatus Assigned and available update ids

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 ErrorAllOf 

type ErrorAllOf struct {
	Code        string `json:"code,omitempty"`
	Reason      string `json:"reason,omitempty"`
	OperationId string `json:"operation_id,omitempty"`
}

ErrorAllOf struct for ErrorAllOf

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 List 

type List struct {
	Kind  string            `json:"kind"`
	Page  int32             `json:"page"`
	Size  int32             `json:"size"`
	Total int32             `json:"total"`
	Items []ObjectReference `json:"items"`
}

List struct for List

type MetaV1Condition 

type MetaV1Condition struct {
	Type               string `json:"type,omitempty"`
	Reason             string `json:"reason,omitempty"`
	Message            string `json:"message,omitempty"`
	Status             string `json:"status,omitempty"`
	LastTransitionTime string `json:"last_transition_time,omitempty"`
}

MetaV1Condition struct for MetaV1Condition

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 NullableFloat32 

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

func NewNullableFloat32 

func NewNullableFloat32(val *float32) *NullableFloat32

func (NullableFloat32) Get 

func (v NullableFloat32) Get() *float32

func (NullableFloat32) IsSet 

func (v NullableFloat32) IsSet() bool

func (NullableFloat32) MarshalJSON 

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

func (*NullableFloat32) Set 

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

func (*NullableFloat32) UnmarshalJSON 

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

func (*NullableFloat32) Unset 

func (v *NullableFloat32) Unset()

type NullableFloat64 

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

func NewNullableFloat64 

func NewNullableFloat64(val *float64) *NullableFloat64

func (NullableFloat64) Get 

func (v NullableFloat64) Get() *float64

func (NullableFloat64) IsSet 

func (v NullableFloat64) IsSet() bool

func (NullableFloat64) MarshalJSON 

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

func (*NullableFloat64) Set 

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

func (*NullableFloat64) UnmarshalJSON 

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

func (*NullableFloat64) Unset 

func (v *NullableFloat64) Unset()

type NullableInt 

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

func NewNullableInt 

func NewNullableInt(val *int) *NullableInt

func (NullableInt) Get 

func (v NullableInt) Get() *int

func (NullableInt) IsSet 

func (v NullableInt) IsSet() bool

func (NullableInt) MarshalJSON 

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

func (*NullableInt) Set 

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

func (*NullableInt) UnmarshalJSON 

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

func (*NullableInt) Unset 

func (v *NullableInt) Unset()

type NullableInt32 

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

func NewNullableInt32 

func NewNullableInt32(val *int32) *NullableInt32

func (NullableInt32) Get 

func (v NullableInt32) Get() *int32

func (NullableInt32) IsSet 

func (v NullableInt32) IsSet() bool

func (NullableInt32) MarshalJSON 

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

func (*NullableInt32) Set 

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

func (*NullableInt32) UnmarshalJSON 

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

func (*NullableInt32) Unset 

func (v *NullableInt32) Unset()

type NullableInt64 

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

func NewNullableInt64 

func NewNullableInt64(val *int64) *NullableInt64

func (NullableInt64) Get 

func (v NullableInt64) Get() *int64

func (NullableInt64) IsSet 

func (v NullableInt64) IsSet() bool

func (NullableInt64) MarshalJSON 

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

func (*NullableInt64) Set 

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

func (*NullableInt64) UnmarshalJSON 

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

func (*NullableInt64) Unset 

func (v *NullableInt64) Unset()

type 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 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 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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