public

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 {
	ConnectorClustersApi *ConnectorClustersApiService

	ConnectorNamespacesApi *ConnectorNamespacesApiService

	ConnectorServiceApi *ConnectorServiceApiService

	ConnectorTypesApi *ConnectorTypesApiService

	ConnectorsApi *ConnectorsApiService
	// contains filtered or unexported fields
}

APIClient manages communication with the Connector Management API API v0.1.0 In most cases there should be only one, shared, APIClient.

func NewAPIClient 

func NewAPIClient(cfg *Configuration) *APIClient

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

func (*APIClient) 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 AddonParameter 

type AddonParameter struct {
	Id    string `json:"id,omitempty"`
	Value string `json:"value,omitempty"`
}

AddonParameter A addon parameter

type ApiCreateConnectorClusterRequest 

type ApiCreateConnectorClusterRequest struct {
	ApiService *ConnectorClustersApiService
	// contains filtered or unexported fields
}

func (ApiCreateConnectorClusterRequest) Async 

func (r ApiCreateConnectorClusterRequest) Async(async bool) ApiCreateConnectorClusterRequest

Perform the action in an asynchronous manner

func (ApiCreateConnectorClusterRequest) ConnectorClusterRequest 

func (r ApiCreateConnectorClusterRequest) ConnectorClusterRequest(connectorClusterRequest ConnectorClusterRequest) ApiCreateConnectorClusterRequest

Connector cluster data

func (ApiCreateConnectorClusterRequest) Execute 

func (r ApiCreateConnectorClusterRequest) Execute() (*ConnectorCluster, *http.Response, error)

type ApiCreateConnectorRequest 

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

func (ApiCreateConnectorRequest) Async 

func (r ApiCreateConnectorRequest) Async(async bool) ApiCreateConnectorRequest

Perform the action in an asynchronous manner

func (ApiCreateConnectorRequest) ConnectorRequest 

func (r ApiCreateConnectorRequest) ConnectorRequest(connectorRequest ConnectorRequest) ApiCreateConnectorRequest

Connector data

func (ApiCreateConnectorRequest) Execute 

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

type ApiCreateEvaluationNamespaceRequest 

type ApiCreateEvaluationNamespaceRequest struct {
	ApiService *ConnectorNamespacesApiService
	// contains filtered or unexported fields
}

func (ApiCreateEvaluationNamespaceRequest) ConnectorNamespaceEvalRequest 

func (r ApiCreateEvaluationNamespaceRequest) ConnectorNamespaceEvalRequest(connectorNamespaceEvalRequest ConnectorNamespaceEvalRequest) ApiCreateEvaluationNamespaceRequest

Connector namespace data

func (ApiCreateEvaluationNamespaceRequest) Execute 

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

type ApiDeleteConnectorClusterRequest 

type ApiDeleteConnectorClusterRequest struct {
	ApiService *ConnectorClustersApiService
	// contains filtered or unexported fields
}

func (ApiDeleteConnectorClusterRequest) Execute 

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

type ApiDeleteConnectorRequest 

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

func (ApiDeleteConnectorRequest) Execute 

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

type ApiGetConnectorClusterAddonParametersRequest 

type ApiGetConnectorClusterAddonParametersRequest struct {
	ApiService *ConnectorClustersApiService
	// contains filtered or unexported fields
}

func (ApiGetConnectorClusterAddonParametersRequest) Execute 

func (r ApiGetConnectorClusterAddonParametersRequest) Execute() ([]AddonParameter, *http.Response, error)

func (ApiGetConnectorClusterAddonParametersRequest) ResetCredentials 

func (r ApiGetConnectorClusterAddonParametersRequest) ResetCredentials(resetCredentials bool) ApiGetConnectorClusterAddonParametersRequest

Resets cluster service account credentials when true

type ApiGetConnectorClusterNamespacesRequest 

type ApiGetConnectorClusterNamespacesRequest struct {
	ApiService *ConnectorClustersApiService
	// contains filtered or unexported fields
}

func (ApiGetConnectorClusterNamespacesRequest) Execute 

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

func (ApiGetConnectorClusterNamespacesRequest) OrderBy 

func (r ApiGetConnectorClusterNamespacesRequest) OrderBy(orderBy string) ApiGetConnectorClusterNamespacesRequest

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 (ApiGetConnectorClusterNamespacesRequest) Page 

func (r ApiGetConnectorClusterNamespacesRequest) Page(page string) ApiGetConnectorClusterNamespacesRequest

Page index

func (ApiGetConnectorClusterNamespacesRequest) Search 

func (r ApiGetConnectorClusterNamespacesRequest) Search(search string) ApiGetConnectorClusterNamespacesRequest

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 (ApiGetConnectorClusterNamespacesRequest) Size 

func (r ApiGetConnectorClusterNamespacesRequest) Size(size string) ApiGetConnectorClusterNamespacesRequest

Number of items in each page

type ApiGetConnectorClusterRequest 

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

func (ApiGetConnectorClusterRequest) Execute 

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

type ApiGetConnectorNamespaceRequest 

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

func (ApiGetConnectorNamespaceRequest) Execute 

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

type ApiGetConnectorRequest 

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

func (ApiGetConnectorRequest) Execute 

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

type ApiGetConnectorTypeByIDRequest 

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

func (ApiGetConnectorTypeByIDRequest) Execute 

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

type ApiGetConnectorTypeLabelsRequest 

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

func (ApiGetConnectorTypeLabelsRequest) Execute 

func (r ApiGetConnectorTypeLabelsRequest) Execute() (*ConnectorTypeLabelCountList, *http.Response, error)

func (ApiGetConnectorTypeLabelsRequest) OrderBy 

func (r ApiGetConnectorTypeLabelsRequest) OrderBy(orderBy string) ApiGetConnectorTypeLabelsRequest

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 (ApiGetConnectorTypeLabelsRequest) Search 

func (r ApiGetConnectorTypeLabelsRequest) Search(search string) ApiGetConnectorTypeLabelsRequest

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.

type ApiGetConnectorTypesRequest 

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

func (ApiGetConnectorTypesRequest) Execute 

func (r ApiGetConnectorTypesRequest) Execute() (*ConnectorTypeList, *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 ApiGetVersionMetadataRequest 

type ApiGetVersionMetadataRequest struct {
	ApiService *ConnectorServiceApiService
	// contains filtered or unexported fields
}

func (ApiGetVersionMetadataRequest) Execute 

func (r ApiGetVersionMetadataRequest) Execute() (*VersionMetadata, *http.Response, error)

type ApiListConnectorClustersRequest 

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

func (ApiListConnectorClustersRequest) Execute 

func (r ApiListConnectorClustersRequest) Execute() (*ConnectorClusterList, *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 ApiListConnectorNamespacesRequest 

type ApiListConnectorNamespacesRequest struct {
	ApiService *ConnectorNamespacesApiService
	// contains filtered or unexported fields
}

func (ApiListConnectorNamespacesRequest) Execute 

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

func (ApiListConnectorNamespacesRequest) OrderBy 

func (r ApiListConnectorNamespacesRequest) OrderBy(orderBy string) ApiListConnectorNamespacesRequest

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 (ApiListConnectorNamespacesRequest) Page 

func (r ApiListConnectorNamespacesRequest) Page(page string) ApiListConnectorNamespacesRequest

Page index

func (ApiListConnectorNamespacesRequest) Search 

func (r ApiListConnectorNamespacesRequest) Search(search string) ApiListConnectorNamespacesRequest

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 (ApiListConnectorNamespacesRequest) Size 

func (r ApiListConnectorNamespacesRequest) Size(size string) ApiListConnectorNamespacesRequest

Number of items in each page

type ApiListConnectorsRequest 

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

func (ApiListConnectorsRequest) Execute 

func (r ApiListConnectorsRequest) Execute() (*ConnectorList, *http.Response, error)

func (ApiListConnectorsRequest) OrderBy 

func (r ApiListConnectorsRequest) OrderBy(orderBy string) ApiListConnectorsRequest

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 (ApiListConnectorsRequest) Page 

func (r ApiListConnectorsRequest) Page(page string) ApiListConnectorsRequest

Page index

func (ApiListConnectorsRequest) Search 

func (r ApiListConnectorsRequest) Search(search string) ApiListConnectorsRequest

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 (ApiListConnectorsRequest) Size 

func (r ApiListConnectorsRequest) Size(size string) ApiListConnectorsRequest

Number of items in each page

type ApiPatchConnectorRequest 

type ApiPatchConnectorRequest struct {
	ApiService *ConnectorsApiService
	// 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() (*Connector, *http.Response, error)

type ApiUpdateConnectorClusterByIdRequest 

type ApiUpdateConnectorClusterByIdRequest struct {
	ApiService *ConnectorClustersApiService
	// contains filtered or unexported fields
}

func (ApiUpdateConnectorClusterByIdRequest) ConnectorClusterRequest 

func (r ApiUpdateConnectorClusterByIdRequest) ConnectorClusterRequest(connectorClusterRequest ConnectorClusterRequest) ApiUpdateConnectorClusterByIdRequest

Data to updated connector with

func (ApiUpdateConnectorClusterByIdRequest) Execute 

func (r ApiUpdateConnectorClusterByIdRequest) Execute() (*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 Connector 

type Connector struct {
	Id              string                `json:"id,omitempty"`
	Kind            string                `json:"kind,omitempty"`
	Href            string                `json:"href,omitempty"`
	Owner           string                `json:"owner,omitempty"`
	CreatedAt       time.Time             `json:"created_at,omitempty"`
	ModifiedAt      time.Time             `json:"modified_at,omitempty"`
	Name            string                `json:"name"`
	ConnectorTypeId string                `json:"connector_type_id"`
	NamespaceId     string                `json:"namespace_id"`
	Channel         Channel               `json:"channel,omitempty"`
	DesiredState    ConnectorDesiredState `json:"desired_state"`
	// Name-value string annotations for resource
	Annotations     map[string]string                `json:"annotations,omitempty"`
	ResourceVersion int64                            `json:"resource_version,omitempty"`
	Kafka           KafkaConnectionSettings          `json:"kafka"`
	ServiceAccount  ServiceAccount                   `json:"service_account"`
	SchemaRegistry  SchemaRegistryConnectionSettings `json:"schema_registry,omitempty"`
	Connector       map[string]interface{}           `json:"connector"`
	Status          ConnectorStatusStatus            `json:"status,omitempty"`
}

Connector struct for Connector

type ConnectorCluster 

type ConnectorCluster struct {
	Id         string    `json:"id,omitempty"`
	Kind       string    `json:"kind,omitempty"`
	Href       string    `json:"href,omitempty"`
	Owner      string    `json:"owner,omitempty"`
	CreatedAt  time.Time `json:"created_at,omitempty"`
	ModifiedAt time.Time `json:"modified_at,omitempty"`
	Name       string    `json:"name,omitempty"`
	// Name-value string annotations for resource
	Annotations map[string]string            `json:"annotations,omitempty"`
	Status      ConnectorClusterStatusStatus `json:"status,omitempty"`
}

ConnectorCluster struct for ConnectorCluster

type ConnectorClusterList 

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

ConnectorClusterList struct for ConnectorClusterList

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

type ConnectorClusterRequest struct {
	Name string `json:"name,omitempty"`
	// Name-value string annotations for resource
	Annotations map[string]string `json:"annotations,omitempty"`
}

ConnectorClusterRequest Schema for the request to update a data plane cluster's name

type ConnectorClusterRequestMeta 

type ConnectorClusterRequestMeta struct {
	Name string `json:"name,omitempty"`
	// Name-value string annotations for resource
	Annotations map[string]string `json:"annotations,omitempty"`
}

ConnectorClusterRequestMeta struct for ConnectorClusterRequestMeta

type ConnectorClusterState 

type ConnectorClusterState string

ConnectorClusterState the model 'ConnectorClusterState' 

const (
	CONNECTORCLUSTERSTATE_DISCONNECTED ConnectorClusterState = "disconnected"
	CONNECTORCLUSTERSTATE_READY        ConnectorClusterState = "ready"
	CONNECTORCLUSTERSTATE_DELETING     ConnectorClusterState = "deleting"
)

List of ConnectorClusterState

type ConnectorClusterStatus 

type ConnectorClusterStatus struct {
	Status ConnectorClusterStatusStatus `json:"status,omitempty"`
}

ConnectorClusterStatus struct for ConnectorClusterStatus

type ConnectorClusterStatusStatus 

type ConnectorClusterStatusStatus struct {
	State ConnectorClusterState `json:"state,omitempty"`
	Error string                `json:"error,omitempty"`
}

ConnectorClusterStatusStatus struct for ConnectorClusterStatusStatus

type ConnectorClustersApiService 

type ConnectorClustersApiService service

ConnectorClustersApiService ConnectorClustersApi service

func (*ConnectorClustersApiService) CreateConnectorCluster 

func (a *ConnectorClustersApiService) CreateConnectorCluster(ctx context.Context) ApiCreateConnectorClusterRequest

CreateConnectorCluster Create a new connector cluster

Create a new connector cluster 

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

func (*ConnectorClustersApiService) CreateConnectorClusterExecute 

func (a *ConnectorClustersApiService) CreateConnectorClusterExecute(r ApiCreateConnectorClusterRequest) (*ConnectorCluster, *http.Response, error)

Execute executes the request 

@return ConnectorCluster

func (*ConnectorClustersApiService) DeleteConnectorCluster 

func (a *ConnectorClustersApiService) DeleteConnectorCluster(ctx context.Context, connectorClusterId string) ApiDeleteConnectorClusterRequest

DeleteConnectorCluster Delete a connector cluster

Delete a connector cluster 

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

func (*ConnectorClustersApiService) DeleteConnectorClusterExecute 

func (a *ConnectorClustersApiService) DeleteConnectorClusterExecute(r ApiDeleteConnectorClusterRequest) (*Error, *http.Response, error)

Execute executes the request 

@return Error

func (*ConnectorClustersApiService) GetConnectorCluster 

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

GetConnectorCluster Get a connector cluster

Get a connector cluster 

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

func (*ConnectorClustersApiService) GetConnectorClusterAddonParameters 

func (a *ConnectorClustersApiService) GetConnectorClusterAddonParameters(ctx context.Context, connectorClusterId string) ApiGetConnectorClusterAddonParametersRequest

GetConnectorClusterAddonParameters Get a connector cluster's addon parameters

Get a connector cluster's addon parameters 

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

func (*ConnectorClustersApiService) GetConnectorClusterAddonParametersExecute 

func (a *ConnectorClustersApiService) GetConnectorClusterAddonParametersExecute(r ApiGetConnectorClusterAddonParametersRequest) ([]AddonParameter, *http.Response, error)

Execute executes the request 

@return []AddonParameter

func (*ConnectorClustersApiService) GetConnectorClusterExecute 

func (a *ConnectorClustersApiService) GetConnectorClusterExecute(r ApiGetConnectorClusterRequest) (*ConnectorCluster, *http.Response, error)

Execute executes the request 

@return ConnectorCluster

func (*ConnectorClustersApiService) GetConnectorClusterNamespaces 

func (a *ConnectorClustersApiService) GetConnectorClusterNamespaces(ctx context.Context, connectorClusterId string) ApiGetConnectorClusterNamespacesRequest

GetConnectorClusterNamespaces Get a connector cluster's namespaces

Get a connector cluster's namespaces 

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

func (*ConnectorClustersApiService) GetConnectorClusterNamespacesExecute 

func (a *ConnectorClustersApiService) GetConnectorClusterNamespacesExecute(r ApiGetConnectorClusterNamespacesRequest) (*ConnectorNamespaceList, *http.Response, error)

Execute executes the request 

@return ConnectorNamespaceList

func (*ConnectorClustersApiService) ListConnectorClusters 

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

ListConnectorClusters Returns a list of connector clusters

Returns a list of connector clusters 

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

func (*ConnectorClustersApiService) ListConnectorClustersExecute 

func (a *ConnectorClustersApiService) ListConnectorClustersExecute(r ApiListConnectorClustersRequest) (*ConnectorClusterList, *http.Response, error)

Execute executes the request 

@return ConnectorClusterList

func (*ConnectorClustersApiService) UpdateConnectorClusterById 

func (a *ConnectorClustersApiService) UpdateConnectorClusterById(ctx context.Context, connectorClusterId string) ApiUpdateConnectorClusterByIdRequest

UpdateConnectorClusterById udpate a connector cluster

udpate a connector cluster 

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

func (*ConnectorClustersApiService) UpdateConnectorClusterByIdExecute 

func (a *ConnectorClustersApiService) UpdateConnectorClusterByIdExecute(r ApiUpdateConnectorClusterByIdRequest) (*http.Response, error)

Execute executes the request

type ConnectorConfiguration 

type ConnectorConfiguration struct {
	Kafka          KafkaConnectionSettings          `json:"kafka"`
	ServiceAccount ServiceAccount                   `json:"service_account"`
	SchemaRegistry SchemaRegistryConnectionSettings `json:"schema_registry,omitempty"`
	Connector      map[string]interface{}           `json:"connector"`
}

ConnectorConfiguration struct for ConnectorConfiguration

type ConnectorDesiredState 

type ConnectorDesiredState string

ConnectorDesiredState the model 'ConnectorDesiredState' 

const (
	CONNECTORDESIREDSTATE_UNASSIGNED ConnectorDesiredState = "unassigned"
	CONNECTORDESIREDSTATE_READY      ConnectorDesiredState = "ready"
	CONNECTORDESIREDSTATE_STOPPED    ConnectorDesiredState = "stopped"
	CONNECTORDESIREDSTATE_DELETED    ConnectorDesiredState = "deleted"
)

List of ConnectorDesiredState

type ConnectorList 

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

ConnectorList struct for ConnectorList

type ConnectorListAllOf 

type ConnectorListAllOf struct {
	Items []Connector `json:"items,omitempty"`
}

ConnectorListAllOf struct for ConnectorListAllOf

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 ConnectorNamespacePatchRequest 

type ConnectorNamespacePatchRequest struct {
	// Namespace name must match pattern `^(([A-Za-z0-9][-A-Za-z0-9_.]*)?[A-Za-z0-9])?$`, or it may be empty to be auto-generated.
	Name string `json:"name,omitempty"`
	// Name-value string annotations for resource
	Annotations map[string]string `json:"annotations,omitempty"`
}

ConnectorNamespacePatchRequest A connector namespace patch request

type ConnectorNamespaceQuota 

type ConnectorNamespaceQuota struct {
	Connectors int32 `json:"connectors,omitempty"`
	// Memory quota for limits or requests
	MemoryRequests string `json:"memory_requests,omitempty"`
	// Memory quota for limits or requests
	MemoryLimits string `json:"memory_limits,omitempty"`
	// CPU quota for limits or requests
	CpuRequests string `json:"cpu_requests,omitempty"`
	// CPU quota for limits or requests
	CpuLimits string `json:"cpu_limits,omitempty"`
}

ConnectorNamespaceQuota struct for ConnectorNamespaceQuota

type ConnectorNamespaceRequest 

type ConnectorNamespaceRequest struct {
	// Namespace name must match pattern `^(([A-Za-z0-9][-A-Za-z0-9_.]*)?[A-Za-z0-9])?$`, or it may be empty to be auto-generated.
	Name string `json:"name"`
	// Name-value string annotations for resource
	Annotations map[string]string            `json:"annotations,omitempty"`
	ClusterId   string                       `json:"cluster_id"`
	Kind        ConnectorNamespaceTenantKind `json:"kind"`
}

ConnectorNamespaceRequest A connector namespace create request

type ConnectorNamespaceRequestAllOf 

type ConnectorNamespaceRequestAllOf struct {
	ClusterId string                       `json:"cluster_id,omitempty"`
	Kind      ConnectorNamespaceTenantKind `json:"kind,omitempty"`
}

ConnectorNamespaceRequestAllOf struct for ConnectorNamespaceRequestAllOf

type ConnectorNamespaceRequestMeta 

type ConnectorNamespaceRequestMeta struct {
	// Namespace name must match pattern `^(([A-Za-z0-9][-A-Za-z0-9_.]*)?[A-Za-z0-9])?$`, or it may be empty to be auto-generated.
	Name string `json:"name,omitempty"`
	// Name-value string annotations for resource
	Annotations map[string]string `json:"annotations,omitempty"`
}

ConnectorNamespaceRequestMeta struct for ConnectorNamespaceRequestMeta

type ConnectorNamespaceState 

type ConnectorNamespaceState string

ConnectorNamespaceState the model 'ConnectorNamespaceState' 

const (
	CONNECTORNAMESPACESTATE_DISCONNECTED ConnectorNamespaceState = "disconnected"
	CONNECTORNAMESPACESTATE_READY        ConnectorNamespaceState = "ready"
	CONNECTORNAMESPACESTATE_DELETING     ConnectorNamespaceState = "deleting"
	CONNECTORNAMESPACESTATE_DELETED      ConnectorNamespaceState = "deleted"
)

List of ConnectorNamespaceState

type ConnectorNamespaceStatus 

type ConnectorNamespaceStatus struct {
	State              ConnectorNamespaceState `json:"state"`
	Version            string                  `json:"version,omitempty"`
	ConnectorsDeployed int32                   `json:"connectors_deployed"`
	Error              string                  `json:"error,omitempty"`
}

ConnectorNamespaceStatus struct for ConnectorNamespaceStatus

type ConnectorNamespaceTenant 

type ConnectorNamespaceTenant struct {
	Kind ConnectorNamespaceTenantKind `json:"kind"`
	// Either user or organisation id depending on the value of kind
	Id string `json:"id"`
}

ConnectorNamespaceTenant struct for ConnectorNamespaceTenant

type ConnectorNamespaceTenantKind 

type ConnectorNamespaceTenantKind string

ConnectorNamespaceTenantKind the model 'ConnectorNamespaceTenantKind' 

const (
	CONNECTORNAMESPACETENANTKIND_USER         ConnectorNamespaceTenantKind = "user"
	CONNECTORNAMESPACETENANTKIND_ORGANISATION ConnectorNamespaceTenantKind = "organisation"
)

List of ConnectorNamespaceTenantKind

type ConnectorNamespacesApiService 

type ConnectorNamespacesApiService service

ConnectorNamespacesApiService ConnectorNamespacesApi service

func (*ConnectorNamespacesApiService) CreateEvaluationNamespace 

func (a *ConnectorNamespacesApiService) CreateEvaluationNamespace(ctx context.Context) ApiCreateEvaluationNamespaceRequest

CreateEvaluationNamespace Create a new short lived evaluation connector namespace

Create a new evaluation connector namespace 

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

func (*ConnectorNamespacesApiService) CreateEvaluationNamespaceExecute 

func (a *ConnectorNamespacesApiService) CreateEvaluationNamespaceExecute(r ApiCreateEvaluationNamespaceRequest) (*ConnectorNamespace, *http.Response, error)

Execute executes the request 

@return ConnectorNamespace

func (*ConnectorNamespacesApiService) GetConnectorNamespace 

func (a *ConnectorNamespacesApiService) GetConnectorNamespace(ctx context.Context, connectorNamespaceId 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 connectorNamespaceId The id of the connector namespace
@return ApiGetConnectorNamespaceRequest

func (*ConnectorNamespacesApiService) GetConnectorNamespaceExecute 

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

Execute executes the request 

@return ConnectorNamespace

func (*ConnectorNamespacesApiService) ListConnectorNamespaces 

func (a *ConnectorNamespacesApiService) ListConnectorNamespaces(ctx context.Context) ApiListConnectorNamespacesRequest

ListConnectorNamespaces Returns a list of connector namespaces

Returns a list of connector namespaces 

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

func (*ConnectorNamespacesApiService) ListConnectorNamespacesExecute 

func (a *ConnectorNamespacesApiService) ListConnectorNamespacesExecute(r ApiListConnectorNamespacesRequest) (*ConnectorNamespaceList, *http.Response, error)

Execute executes the request 

@return ConnectorNamespaceList

type ConnectorRequest 

type ConnectorRequest struct {
	Name            string                `json:"name"`
	ConnectorTypeId string                `json:"connector_type_id"`
	NamespaceId     string                `json:"namespace_id"`
	Channel         Channel               `json:"channel,omitempty"`
	DesiredState    ConnectorDesiredState `json:"desired_state"`
	// Name-value string annotations for resource
	Annotations    map[string]string                `json:"annotations,omitempty"`
	Kafka          KafkaConnectionSettings          `json:"kafka"`
	ServiceAccount ServiceAccount                   `json:"service_account"`
	SchemaRegistry SchemaRegistryConnectionSettings `json:"schema_registry,omitempty"`
	Connector      map[string]interface{}           `json:"connector"`
}

ConnectorRequest struct for ConnectorRequest

type ConnectorRequestMeta 

type ConnectorRequestMeta struct {
	Name            string                `json:"name"`
	ConnectorTypeId string                `json:"connector_type_id"`
	NamespaceId     string                `json:"namespace_id"`
	Channel         Channel               `json:"channel,omitempty"`
	DesiredState    ConnectorDesiredState `json:"desired_state"`
	// Name-value string annotations for resource
	Annotations map[string]string `json:"annotations,omitempty"`
}

ConnectorRequestMeta struct for ConnectorRequestMeta

type ConnectorServiceApiService 

type ConnectorServiceApiService service

ConnectorServiceApiService ConnectorServiceApi service

func (*ConnectorServiceApiService) GetVersionMetadata 

func (a *ConnectorServiceApiService) GetVersionMetadata(ctx context.Context) ApiGetVersionMetadataRequest

GetVersionMetadata Returns the version metadata

Returns the version metadata 

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

func (*ConnectorServiceApiService) GetVersionMetadataExecute 

func (a *ConnectorServiceApiService) GetVersionMetadataExecute(r ApiGetVersionMetadataRequest) (*VersionMetadata, *http.Response, error)

Execute executes the request 

@return VersionMetadata

type ConnectorState 

type ConnectorState string

ConnectorState the model 'ConnectorState' 

const (
	CONNECTORSTATE_ASSIGNING      ConnectorState = "assigning"
	CONNECTORSTATE_ASSIGNED       ConnectorState = "assigned"
	CONNECTORSTATE_UPDATING       ConnectorState = "updating"
	CONNECTORSTATE_READY          ConnectorState = "ready"
	CONNECTORSTATE_STOPPED        ConnectorState = "stopped"
	CONNECTORSTATE_FAILED         ConnectorState = "failed"
	CONNECTORSTATE_DELETING       ConnectorState = "deleting"
	CONNECTORSTATE_DELETED        ConnectorState = "deleted"
	CONNECTORSTATE_PROVISIONING   ConnectorState = "provisioning"
	CONNECTORSTATE_DEPROVISIONING ConnectorState = "deprovisioning"
)

List of ConnectorState

type ConnectorStatus 

type ConnectorStatus struct {
	Status ConnectorStatusStatus `json:"status,omitempty"`
}

ConnectorStatus struct for ConnectorStatus

type ConnectorStatusStatus 

type ConnectorStatusStatus struct {
	State ConnectorState `json:"state,omitempty"`
	Error string         `json:"error,omitempty"`
}

ConnectorStatusStatus struct for ConnectorStatusStatus

type ConnectorType 

type ConnectorType struct {
	Id   string `json:"id,omitempty"`
	Kind string `json:"kind,omitempty"`
	Href string `json:"href,omitempty"`
	// Name of the connector type.
	Name string `json:"name"`
	// Version of the connector type.
	Version string `json:"version"`
	// Channels of the connector type.
	Channels []Channel `json:"channels,omitempty"`
	// A description of the connector.
	Description string `json:"description,omitempty"`
	// Connector type is deprecated and removed from the catalog.
	Deprecated bool `json:"deprecated,omitempty"`
	// URL to an icon of the connector.
	IconHref string `json:"icon_href,omitempty"`
	// Labels used to categorize the connector
	Labels []string `json:"labels,omitempty"`
	// Name-value string annotations for resource
	Annotations map[string]string `json:"annotations,omitempty"`
	// Ranking for featured connectors
	FeaturedRank int32 `json:"featured_rank,omitempty"`
	// The capabilities supported by the connector
	Capabilities []string `json:"capabilities,omitempty"`
	// A json schema that can be used to validate a ConnectorRequest connector field.
	Schema map[string]interface{} `json:"schema"`
}

ConnectorType Represents a connector type supported by the API

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

type ConnectorTypeLabelCount struct {
	// Name of the connector type label.
	Label string `json:"label"`
	// Number of connector types with this label.
	Count int32 `json:"count"`
}

ConnectorTypeLabelCount Represents a connector type label and the number of types with that label

type ConnectorTypeLabelCountList 

type ConnectorTypeLabelCountList struct {
	Items []ConnectorTypeLabelCount `json:"items,omitempty"`
}

ConnectorTypeLabelCountList struct for ConnectorTypeLabelCountList

type ConnectorTypeList 

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

ConnectorTypeList struct for ConnectorTypeList

type ConnectorTypeListAllOf 

type ConnectorTypeListAllOf struct {
	Items []ConnectorType `json:"items,omitempty"`
}

ConnectorTypeListAllOf struct for ConnectorTypeListAllOf

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) (*ConnectorType, *http.Response, error)

Execute executes the request 

@return ConnectorType

func (*ConnectorTypesApiService) GetConnectorTypeLabels 

func (a *ConnectorTypesApiService) GetConnectorTypeLabels(ctx context.Context) ApiGetConnectorTypeLabelsRequest

GetConnectorTypeLabels Returns a list of connector type labels

Returns a list of connector type labels 

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

func (*ConnectorTypesApiService) GetConnectorTypeLabelsExecute 

func (a *ConnectorTypesApiService) GetConnectorTypeLabelsExecute(r ApiGetConnectorTypeLabelsRequest) (*ConnectorTypeLabelCountList, *http.Response, error)

Execute executes the request 

@return ConnectorTypeLabelCountList

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) (*ConnectorTypeList, *http.Response, error)

Execute executes the request 

@return ConnectorTypeList

type ConnectorsApiService 

type ConnectorsApiService service

ConnectorsApiService ConnectorsApi service

func (*ConnectorsApiService) CreateConnector 

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

CreateConnector Create a new connector

Create a new connector 

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

func (*ConnectorsApiService) CreateConnectorExecute 

func (a *ConnectorsApiService) CreateConnectorExecute(r ApiCreateConnectorRequest) (*Connector, *http.Response, error)

Execute executes the request 

@return Connector

func (*ConnectorsApiService) DeleteConnector 

func (a *ConnectorsApiService) DeleteConnector(ctx context.Context, id string) ApiDeleteConnectorRequest

DeleteConnector Delete a connector

Delete a connector 

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

func (*ConnectorsApiService) DeleteConnectorExecute 

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

Execute executes the request 

@return Error

func (*ConnectorsApiService) GetConnector 

func (a *ConnectorsApiService) GetConnector(ctx context.Context, id 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 id The ID of record
@return ApiGetConnectorRequest

func (*ConnectorsApiService) GetConnectorExecute 

func (a *ConnectorsApiService) GetConnectorExecute(r ApiGetConnectorRequest) (*Connector, *http.Response, error)

Execute executes the request 

@return Connector

func (*ConnectorsApiService) ListConnectors 

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

ListConnectors Returns a list of connector types

Returns a list of connector types 

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

func (*ConnectorsApiService) ListConnectorsExecute 

func (a *ConnectorsApiService) ListConnectorsExecute(r ApiListConnectorsRequest) (*ConnectorList, *http.Response, error)

Execute executes the request 

@return ConnectorList

func (*ConnectorsApiService) PatchConnector 

func (a *ConnectorsApiService) PatchConnector(ctx context.Context, id 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 id The ID of record
@return ApiPatchConnectorRequest

func (*ConnectorsApiService) PatchConnectorExecute 

func (a *ConnectorsApiService) PatchConnectorExecute(r ApiPatchConnectorRequest) (*Connector, *http.Response, error)

Execute executes the request 

@return Connector

type Error 

type Error struct {
	Reason      string `json:"reason"`
	OperationId string `json:"operation_id,omitempty"`
	Id          string `json:"id"`
	Kind        string `json:"kind"`
	Href        string `json:"href"`
	Code        string `json:"code"`
}

Error struct for Error

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

type KafkaConnectionSettings struct {
	Id  string `json:"id"`
	Url string `json:"url"`
}

KafkaConnectionSettings Holds the configuration to connect to a Kafka Instance.

type List 

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

List struct for List

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 SchemaRegistryConnectionSettings 

type SchemaRegistryConnectionSettings struct {
	Id  string `json:"id"`
	Url string `json:"url"`
}

SchemaRegistryConnectionSettings Holds the configuration to connect to a Schem Registry Instance.

type ServerConfiguration 

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

ServerConfiguration stores the information about a server

type ServerConfigurations 

type ServerConfigurations []ServerConfiguration

ServerConfigurations stores multiple ServerConfiguration items

func (ServerConfigurations) URL 

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

URL formats template on a index using given variables

type ServerVariable 

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

ServerVariable stores the information about a server variable

type ServiceAccount 

type ServiceAccount struct {
	ClientId     string `json:"client_id"`
	ClientSecret string `json:"client_secret"`
}

ServiceAccount struct for ServiceAccount

type ServiceConnectionSettings 

type ServiceConnectionSettings struct {
	Id  string `json:"id"`
	Url string `json:"url"`
}

ServiceConnectionSettings struct for ServiceConnectionSettings

type VersionMetadata 

type VersionMetadata struct {
	Id          string            `json:"id,omitempty"`
	Kind        string            `json:"kind,omitempty"`
	Href        string            `json:"href,omitempty"`
	Collections []ObjectReference `json:"collections,omitempty"`
}

VersionMetadata struct for VersionMetadata

type VersionMetadataAllOf 

type VersionMetadataAllOf struct {
	Collections []ObjectReference `json:"collections,omitempty"`
}

VersionMetadataAllOf struct for VersionMetadataAllOf

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.