public

package
v0.0.0-...-9b598c7 Latest Latest
Warning

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

 Go to latest Published: Jun 28, 2023 License: Apache-2.0 Imports: 23 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")

	// ContextAPIKey takes an APIKey as authentication for the request
	ContextAPIKey = contextKey("apikey")
)

Functions

func CacheExpires 

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

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

Types

type APIClient 

type APIClient struct {
	ConnectorClustersApi *ConnectorClustersApiService

	ConnectorNamespacesApi *ConnectorNamespacesApiService

	ConnectorServiceApi *ConnectorServiceApiService

	ConnectorTypesApi *ConnectorTypesApiService

	ConnectorsApi *ConnectorsApiService
	// contains filtered or unexported fields
}

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

func NewAPIClient 

func NewAPIClient(cfg *Configuration) *APIClient

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

func (*APIClient) ChangeBasePath 

func (c *APIClient) ChangeBasePath(path string)

ChangeBasePath changes base path to allow switching to mocks

func (*APIClient) GetConfig 

func (c *APIClient) GetConfig() *Configuration

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

type APIKey 

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 APIResonse object.

func NewAPIResponseWithError 

func NewAPIResponseWithError(errorMessage string) *APIResponse

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

type AddonParameter 

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

AddonParameter A addon parameter

type BasicAuth 

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

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

type Channel 

type Channel string

Channel the model 'Channel' 

const (
	CHANNEL_STABLE Channel = "stable"
)

List of Channel

type Configuration 

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

Configuration stores the configuration of the API client

func NewConfiguration 

func NewConfiguration() *Configuration

NewConfiguration returns a new Configuration object

func (*Configuration) AddDefaultHeader 

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

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

func (*Configuration) ServerUrl 

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

ServerUrl returns URL based on server settings

type Connector 

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

Connector struct for Connector

type ConnectorCluster 

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

ConnectorCluster struct for ConnectorCluster

type ConnectorClusterList 

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

ConnectorClusterList struct for ConnectorClusterList

type ConnectorClusterMeta 

type ConnectorClusterMeta struct {
	Owner      string    `json:"owner,omitempty"`
	CreatedAt  time.Time `json:"created_at,omitempty"`
	ModifiedAt time.Time `json:"modified_at,omitempty"`
	Name       string    `json:"name,omitempty"`
	// Name-value string annotations for resource
	Annotations map[string]string `json:"annotations,omitempty"`
}

ConnectorClusterMeta struct for ConnectorClusterMeta

type ConnectorClusterRequest 

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

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

type ConnectorClusterRequestMeta 

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

ConnectorClusterRequestMeta struct for ConnectorClusterRequestMeta

type ConnectorClusterState 

type ConnectorClusterState string

ConnectorClusterState the model 'ConnectorClusterState' 

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

List of ConnectorClusterState

type ConnectorClusterStatus 

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

ConnectorClusterStatus struct for ConnectorClusterStatus

type ConnectorClusterStatusStatus 

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

ConnectorClusterStatusStatus struct for ConnectorClusterStatusStatus

type ConnectorClustersApiService 

type ConnectorClustersApiService service

ConnectorClustersApiService ConnectorClustersApi service

func (*ConnectorClustersApiService) CreateConnectorCluster 

func (a *ConnectorClustersApiService) CreateConnectorCluster(ctx _context.Context, async bool, connectorClusterRequest ConnectorClusterRequest) (ConnectorCluster, *_nethttp.Response, error)

CreateConnectorCluster Create a new connector cluster Create a new connector cluster

  • @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param async Perform the action in an asynchronous manner
  • @param connectorClusterRequest Connector cluster data

@return ConnectorCluster

func (*ConnectorClustersApiService) DeleteConnectorCluster 

func (a *ConnectorClustersApiService) DeleteConnectorCluster(ctx _context.Context, connectorClusterId string) (Error, *_nethttp.Response, error)

DeleteConnectorCluster Delete a connector cluster Delete a connector cluster

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

@return Error

func (*ConnectorClustersApiService) GetConnectorCluster 

func (a *ConnectorClustersApiService) GetConnectorCluster(ctx _context.Context, connectorClusterId string) (ConnectorCluster, *_nethttp.Response, error)

GetConnectorCluster Get a connector cluster Get a connector cluster

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

@return ConnectorCluster

func (*ConnectorClustersApiService) GetConnectorClusterAddonParameters 

func (a *ConnectorClustersApiService) GetConnectorClusterAddonParameters(ctx _context.Context, connectorClusterId string, localVarOptionals *GetConnectorClusterAddonParametersOpts) ([]AddonParameter, *_nethttp.Response, error)

GetConnectorClusterAddonParameters Get a connector cluster's addon parameters Get a connector cluster's addon parameters

  • @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param connectorClusterId The id of the connector cluster
  • @param optional nil or *GetConnectorClusterAddonParametersOpts - Optional Parameters:
  • @param "ResetCredentials" (optional.Bool) - Resets cluster service account credentials when true

@return []AddonParameter

func (*ConnectorClustersApiService) GetConnectorClusterNamespaces 

func (a *ConnectorClustersApiService) GetConnectorClusterNamespaces(ctx _context.Context, connectorClusterId string, localVarOptionals *GetConnectorClusterNamespacesOpts) (ConnectorNamespaceList, *_nethttp.Response, error)

GetConnectorClusterNamespaces Get a connector cluster's namespaces Get a connector cluster's namespaces

  • @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param connectorClusterId The id of the connector cluster
  • @param optional nil or *GetConnectorClusterNamespacesOpts - Optional Parameters:
  • @param "Page" (optional.String) - Page index
  • @param "Size" (optional.String) - Number of items in each page
  • @param "OrderBy" (optional.String) - Specifies the order by criteria. The syntax of this parameter is similar to the syntax of the `order by` clause of an SQL statement. Each query can be ordered by any of the underlying resource fields supported in the search parameter. For example, to return all Connector types ordered by their name, use the following syntax: ```sql name asc ``` To return all Connector types ordered by their name _and_ version, use the following syntax: ```sql name asc, version asc ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then the results are ordered by name.
  • @param "Search" (optional.String) - Search criteria. The syntax of this parameter is similar to the syntax of the `where` clause of a SQL statement. Allowed fields in the search depend on the resource type: * Cluster: id, created_at, updated_at, owner, organisation_id, name, state, client_id * Namespace: id, created_at, updated_at, name, cluster_id, owner, expiration, tenant_user_id, tenant_organisation_id, state * Connector Types: id, created_at, updated_at, version, name, description, label, channel, featured_rank, pricing_tier * Connectors: id, created_at, updated_at, name, owner, organisation_id, connector_type_id, desired_state, state, channel, namespace_id, kafka_id, kafka_bootstrap_server, service_account_client_id, schema_registry_id, schema_registry_url Allowed operators are `<>`, `=`, `IN`, `NOT IN`, `LIKE`, or `ILIKE`. Allowed conjunctive operators are `AND` and `OR`. However, you can use a maximum of 10 conjunctions in a search query. Examples: To return a Connector Type with the name `aws-sqs-source` and the channel `stable`, use the following syntax: ``` name = aws-sqs-source and channel = stable ``` To return a connector instance with a name that starts with `aws`, use the following syntax: ``` name like aws%25 ``` To return a connector type with a name containing `aws` matching any character case combination, use the following syntax: ``` name ilike %25aws%25 ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then all the resources that the user has permission to see are returned. Note. If the query is invalid, an error is returned.

@return ConnectorNamespaceList

func (*ConnectorClustersApiService) ListConnectorClusters 

func (a *ConnectorClustersApiService) ListConnectorClusters(ctx _context.Context, localVarOptionals *ListConnectorClustersOpts) (ConnectorClusterList, *_nethttp.Response, error)

ListConnectorClusters Returns a list of connector clusters Returns a list of connector clusters

  • @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param optional nil or *ListConnectorClustersOpts - Optional Parameters:
  • @param "Page" (optional.String) - Page index
  • @param "Size" (optional.String) - Number of items in each page
  • @param "OrderBy" (optional.String) - Specifies the order by criteria. The syntax of this parameter is similar to the syntax of the `order by` clause of an SQL statement. Each query can be ordered by any of the underlying resource fields supported in the search parameter. For example, to return all Connector types ordered by their name, use the following syntax: ```sql name asc ``` To return all Connector types ordered by their name _and_ version, use the following syntax: ```sql name asc, version asc ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then the results are ordered by name.
  • @param "Search" (optional.String) - Search criteria. The syntax of this parameter is similar to the syntax of the `where` clause of a SQL statement. Allowed fields in the search depend on the resource type: * Cluster: id, created_at, updated_at, owner, organisation_id, name, state, client_id * Namespace: id, created_at, updated_at, name, cluster_id, owner, expiration, tenant_user_id, tenant_organisation_id, state * Connector Types: id, created_at, updated_at, version, name, description, label, channel, featured_rank, pricing_tier * Connectors: id, created_at, updated_at, name, owner, organisation_id, connector_type_id, desired_state, state, channel, namespace_id, kafka_id, kafka_bootstrap_server, service_account_client_id, schema_registry_id, schema_registry_url Allowed operators are `<>`, `=`, `IN`, `NOT IN`, `LIKE`, or `ILIKE`. Allowed conjunctive operators are `AND` and `OR`. However, you can use a maximum of 10 conjunctions in a search query. Examples: To return a Connector Type with the name `aws-sqs-source` and the channel `stable`, use the following syntax: ``` name = aws-sqs-source and channel = stable ``` To return a connector instance with a name that starts with `aws`, use the following syntax: ``` name like aws%25 ``` To return a connector type with a name containing `aws` matching any character case combination, use the following syntax: ``` name ilike %25aws%25 ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then all the resources that the user has permission to see are returned. Note. If the query is invalid, an error is returned.

@return ConnectorClusterList

func (*ConnectorClustersApiService) UpdateConnectorClusterById 

func (a *ConnectorClustersApiService) UpdateConnectorClusterById(ctx _context.Context, connectorClusterId string, connectorClusterRequest ConnectorClusterRequest) (*_nethttp.Response, error)

UpdateConnectorClusterById udpate a connector cluster udpate a connector cluster

  • @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param connectorClusterId The id of the connector cluster
  • @param connectorClusterRequest Data to updated connector with

type ConnectorConfiguration 

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

ConnectorConfiguration struct for ConnectorConfiguration

type ConnectorDesiredState 

type ConnectorDesiredState string

ConnectorDesiredState the model 'ConnectorDesiredState' 

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

List of ConnectorDesiredState

type ConnectorList 

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

ConnectorList struct for ConnectorList

type ConnectorMeta 

type ConnectorMeta struct {
	Owner           string                `json:"owner,omitempty"`
	CreatedAt       time.Time             `json:"created_at,omitempty"`
	ModifiedAt      time.Time             `json:"modified_at,omitempty"`
	Name            string                `json:"name"`
	ConnectorTypeId string                `json:"connector_type_id"`
	NamespaceId     string                `json:"namespace_id"`
	Channel         Channel               `json:"channel,omitempty"`
	DesiredState    ConnectorDesiredState `json:"desired_state"`
	// Name-value string annotations for resource
	Annotations     map[string]string `json:"annotations,omitempty"`
	ResourceVersion int64             `json:"resource_version,omitempty"`
}

ConnectorMeta struct for ConnectorMeta

type ConnectorNamespace 

type ConnectorNamespace struct {
	Id         string    `json:"id"`
	Kind       string    `json:"kind,omitempty"`
	Href       string    `json:"href,omitempty"`
	Owner      string    `json:"owner,omitempty"`
	CreatedAt  time.Time `json:"created_at,omitempty"`
	ModifiedAt time.Time `json:"modified_at,omitempty"`
	Name       string    `json:"name"`
	// Name-value string annotations for resource
	Annotations     map[string]string       `json:"annotations,omitempty"`
	ResourceVersion int64                   `json:"resource_version"`
	Quota           ConnectorNamespaceQuota `json:"quota,omitempty"`
	ClusterId       string                  `json:"cluster_id"`
	// Namespace expiration timestamp in RFC 3339 format
	Expiration string                   `json:"expiration,omitempty"`
	Tenant     ConnectorNamespaceTenant `json:"tenant"`
	Status     ConnectorNamespaceStatus `json:"status"`
}

ConnectorNamespace A connector namespace

type ConnectorNamespaceEvalRequest 

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

ConnectorNamespaceEvalRequest An evaluation connector namespace create request

type ConnectorNamespaceList 

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

ConnectorNamespaceList struct for ConnectorNamespaceList

type ConnectorNamespaceMeta 

type ConnectorNamespaceMeta struct {
	Owner      string    `json:"owner,omitempty"`
	CreatedAt  time.Time `json:"created_at,omitempty"`
	ModifiedAt time.Time `json:"modified_at,omitempty"`
	// Namespace name must match pattern `^(([A-Za-z0-9][-A-Za-z0-9_.]*)?[A-Za-z0-9])?$`, or it may be empty to be auto-generated.
	Name string `json:"name,omitempty"`
	// Name-value string annotations for resource
	Annotations     map[string]string       `json:"annotations,omitempty"`
	ResourceVersion int64                   `json:"resource_version,omitempty"`
	Quota           ConnectorNamespaceQuota `json:"quota,omitempty"`
}

ConnectorNamespaceMeta struct for ConnectorNamespaceMeta

type ConnectorNamespacePatchRequest 

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

ConnectorNamespacePatchRequest A connector namespace patch request

type ConnectorNamespaceQuota 

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

ConnectorNamespaceQuota struct for ConnectorNamespaceQuota

type ConnectorNamespaceRequest 

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

ConnectorNamespaceRequest A connector namespace create request

type ConnectorNamespaceRequestMeta 

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

ConnectorNamespaceRequestMeta struct for ConnectorNamespaceRequestMeta

type ConnectorNamespaceState 

type ConnectorNamespaceState string

ConnectorNamespaceState the model 'ConnectorNamespaceState' 

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

List of ConnectorNamespaceState

type ConnectorNamespaceStatus 

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

ConnectorNamespaceStatus struct for ConnectorNamespaceStatus

type ConnectorNamespaceTenant 

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

ConnectorNamespaceTenant struct for ConnectorNamespaceTenant

type ConnectorNamespaceTenantKind 

type ConnectorNamespaceTenantKind string

ConnectorNamespaceTenantKind the model 'ConnectorNamespaceTenantKind' 

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

List of ConnectorNamespaceTenantKind

type ConnectorNamespacesApiService 

type ConnectorNamespacesApiService service

ConnectorNamespacesApiService ConnectorNamespacesApi service

func (*ConnectorNamespacesApiService) CreateEvaluationNamespace 

func (a *ConnectorNamespacesApiService) CreateEvaluationNamespace(ctx _context.Context, connectorNamespaceEvalRequest ConnectorNamespaceEvalRequest) (ConnectorNamespace, *_nethttp.Response, error)

CreateEvaluationNamespace Create a new short lived evaluation connector namespace Create a new evaluation connector namespace

  • @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param connectorNamespaceEvalRequest Connector namespace data

@return ConnectorNamespace

func (*ConnectorNamespacesApiService) GetConnectorNamespace 

func (a *ConnectorNamespacesApiService) GetConnectorNamespace(ctx _context.Context, connectorNamespaceId string) (ConnectorNamespace, *_nethttp.Response, error)

GetConnectorNamespace Get a connector namespace Get a connector namespace

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

@return ConnectorNamespace

func (*ConnectorNamespacesApiService) ListConnectorNamespaces 

func (a *ConnectorNamespacesApiService) ListConnectorNamespaces(ctx _context.Context, localVarOptionals *ListConnectorNamespacesOpts) (ConnectorNamespaceList, *_nethttp.Response, error)

ListConnectorNamespaces Returns a list of connector namespaces Returns a list of connector namespaces

  • @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param optional nil or *ListConnectorNamespacesOpts - Optional Parameters:
  • @param "Page" (optional.String) - Page index
  • @param "Size" (optional.String) - Number of items in each page
  • @param "OrderBy" (optional.String) - Specifies the order by criteria. The syntax of this parameter is similar to the syntax of the `order by` clause of an SQL statement. Each query can be ordered by any of the underlying resource fields supported in the search parameter. For example, to return all Connector types ordered by their name, use the following syntax: ```sql name asc ``` To return all Connector types ordered by their name _and_ version, use the following syntax: ```sql name asc, version asc ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then the results are ordered by name.
  • @param "Search" (optional.String) - Search criteria. The syntax of this parameter is similar to the syntax of the `where` clause of a SQL statement. Allowed fields in the search depend on the resource type: * Cluster: id, created_at, updated_at, owner, organisation_id, name, state, client_id * Namespace: id, created_at, updated_at, name, cluster_id, owner, expiration, tenant_user_id, tenant_organisation_id, state * Connector Types: id, created_at, updated_at, version, name, description, label, channel, featured_rank, pricing_tier * Connectors: id, created_at, updated_at, name, owner, organisation_id, connector_type_id, desired_state, state, channel, namespace_id, kafka_id, kafka_bootstrap_server, service_account_client_id, schema_registry_id, schema_registry_url Allowed operators are `<>`, `=`, `IN`, `NOT IN`, `LIKE`, or `ILIKE`. Allowed conjunctive operators are `AND` and `OR`. However, you can use a maximum of 10 conjunctions in a search query. Examples: To return a Connector Type with the name `aws-sqs-source` and the channel `stable`, use the following syntax: ``` name = aws-sqs-source and channel = stable ``` To return a connector instance with a name that starts with `aws`, use the following syntax: ``` name like aws%25 ``` To return a connector type with a name containing `aws` matching any character case combination, use the following syntax: ``` name ilike %25aws%25 ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then all the resources that the user has permission to see are returned. Note. If the query is invalid, an error is returned.

@return ConnectorNamespaceList

type ConnectorRequest 

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

ConnectorRequest struct for ConnectorRequest

type ConnectorRequestMeta 

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

ConnectorRequestMeta struct for ConnectorRequestMeta

type ConnectorServiceApiService 

type ConnectorServiceApiService service

ConnectorServiceApiService ConnectorServiceApi service

func (*ConnectorServiceApiService) GetVersionMetadata 

func (a *ConnectorServiceApiService) GetVersionMetadata(ctx _context.Context) (VersionMetadata, *_nethttp.Response, error)

GetVersionMetadata Returns the version metadata Returns the version metadata

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

@return VersionMetadata

type ConnectorState 

type ConnectorState string

ConnectorState the model 'ConnectorState' 

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

List of ConnectorState

type ConnectorStatus 

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

ConnectorStatus struct for ConnectorStatus

type ConnectorStatusStatus 

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

ConnectorStatusStatus struct for ConnectorStatusStatus

type ConnectorType 

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

ConnectorType Represents a connector type supported by the API

type ConnectorTypeLabelCount 

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

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

type ConnectorTypeLabelCountList 

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

ConnectorTypeLabelCountList struct for ConnectorTypeLabelCountList

type ConnectorTypeList 

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

ConnectorTypeList struct for ConnectorTypeList

type ConnectorTypesApiService 

type ConnectorTypesApiService service

ConnectorTypesApiService ConnectorTypesApi service

func (*ConnectorTypesApiService) GetConnectorTypeByID 

func (a *ConnectorTypesApiService) GetConnectorTypeByID(ctx _context.Context, connectorTypeId string) (ConnectorType, *_nethttp.Response, error)

GetConnectorTypeByID Get a connector type by id Get a connector type by id

  • @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param connectorTypeId The id of the connector type

@return ConnectorType

func (*ConnectorTypesApiService) GetConnectorTypeLabels 

func (a *ConnectorTypesApiService) GetConnectorTypeLabels(ctx _context.Context, localVarOptionals *GetConnectorTypeLabelsOpts) (ConnectorTypeLabelCountList, *_nethttp.Response, error)

GetConnectorTypeLabels Returns a list of connector type labels Returns a list of connector type labels

  • @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param optional nil or *GetConnectorTypeLabelsOpts - Optional Parameters:
  • @param "OrderBy" (optional.String) - Specifies the order by criteria. The syntax of this parameter is similar to the syntax of the `order by` clause of an SQL statement. Each query can be ordered by any of the underlying resource fields supported in the search parameter. For example, to return all Connector types ordered by their name, use the following syntax: ```sql name asc ``` To return all Connector types ordered by their name _and_ version, use the following syntax: ```sql name asc, version asc ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then the results are ordered by name.
  • @param "Search" (optional.String) - Search criteria. The syntax of this parameter is similar to the syntax of the `where` clause of a SQL statement. Allowed fields in the search depend on the resource type: * Cluster: id, created_at, updated_at, owner, organisation_id, name, state, client_id * Namespace: id, created_at, updated_at, name, cluster_id, owner, expiration, tenant_user_id, tenant_organisation_id, state * Connector Types: id, created_at, updated_at, version, name, description, label, channel, featured_rank, pricing_tier * Connectors: id, created_at, updated_at, name, owner, organisation_id, connector_type_id, desired_state, state, channel, namespace_id, kafka_id, kafka_bootstrap_server, service_account_client_id, schema_registry_id, schema_registry_url Allowed operators are `<>`, `=`, `IN`, `NOT IN`, `LIKE`, or `ILIKE`. Allowed conjunctive operators are `AND` and `OR`. However, you can use a maximum of 10 conjunctions in a search query. Examples: To return a Connector Type with the name `aws-sqs-source` and the channel `stable`, use the following syntax: ``` name = aws-sqs-source and channel = stable ``` To return a connector instance with a name that starts with `aws`, use the following syntax: ``` name like aws%25 ``` To return a connector type with a name containing `aws` matching any character case combination, use the following syntax: ``` name ilike %25aws%25 ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then all the resources that the user has permission to see are returned. Note. If the query is invalid, an error is returned.

@return ConnectorTypeLabelCountList

func (*ConnectorTypesApiService) GetConnectorTypes 

func (a *ConnectorTypesApiService) GetConnectorTypes(ctx _context.Context, localVarOptionals *GetConnectorTypesOpts) (ConnectorTypeList, *_nethttp.Response, error)

GetConnectorTypes Returns a list of connector types Returns a list of connector types

  • @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param optional nil or *GetConnectorTypesOpts - Optional Parameters:
  • @param "Page" (optional.String) - Page index
  • @param "Size" (optional.String) - Number of items in each page
  • @param "OrderBy" (optional.String) - Specifies the order by criteria. The syntax of this parameter is similar to the syntax of the `order by` clause of an SQL statement. Each query can be ordered by any of the underlying resource fields supported in the search parameter. For example, to return all Connector types ordered by their name, use the following syntax: ```sql name asc ``` To return all Connector types ordered by their name _and_ version, use the following syntax: ```sql name asc, version asc ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then the results are ordered by name.
  • @param "Search" (optional.String) - Search criteria. The syntax of this parameter is similar to the syntax of the `where` clause of a SQL statement. Allowed fields in the search depend on the resource type: * Cluster: id, created_at, updated_at, owner, organisation_id, name, state, client_id * Namespace: id, created_at, updated_at, name, cluster_id, owner, expiration, tenant_user_id, tenant_organisation_id, state * Connector Types: id, created_at, updated_at, version, name, description, label, channel, featured_rank, pricing_tier * Connectors: id, created_at, updated_at, name, owner, organisation_id, connector_type_id, desired_state, state, channel, namespace_id, kafka_id, kafka_bootstrap_server, service_account_client_id, schema_registry_id, schema_registry_url Allowed operators are `<>`, `=`, `IN`, `NOT IN`, `LIKE`, or `ILIKE`. Allowed conjunctive operators are `AND` and `OR`. However, you can use a maximum of 10 conjunctions in a search query. Examples: To return a Connector Type with the name `aws-sqs-source` and the channel `stable`, use the following syntax: ``` name = aws-sqs-source and channel = stable ``` To return a connector instance with a name that starts with `aws`, use the following syntax: ``` name like aws%25 ``` To return a connector type with a name containing `aws` matching any character case combination, use the following syntax: ``` name ilike %25aws%25 ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then all the resources that the user has permission to see are returned. Note. If the query is invalid, an error is returned.

@return ConnectorTypeList

type ConnectorsApiService 

type ConnectorsApiService service

ConnectorsApiService ConnectorsApi service

func (*ConnectorsApiService) CreateConnector 

func (a *ConnectorsApiService) CreateConnector(ctx _context.Context, async bool, connectorRequest ConnectorRequest) (Connector, *_nethttp.Response, error)

CreateConnector Create a new connector Create a new connector

  • @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param async Perform the action in an asynchronous manner
  • @param connectorRequest Connector data

@return Connector

func (*ConnectorsApiService) DeleteConnector 

func (a *ConnectorsApiService) DeleteConnector(ctx _context.Context, id string) (Error, *_nethttp.Response, error)

DeleteConnector Delete a connector Delete a connector

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

@return Error

func (*ConnectorsApiService) GetConnector 

func (a *ConnectorsApiService) GetConnector(ctx _context.Context, id string) (Connector, *_nethttp.Response, error)

GetConnector Get a connector Get a connector

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

@return Connector

func (*ConnectorsApiService) ListConnectors 

func (a *ConnectorsApiService) ListConnectors(ctx _context.Context, localVarOptionals *ListConnectorsOpts) (ConnectorList, *_nethttp.Response, error)

ListConnectors Returns a list of connector types Returns a list of connector types

  • @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param optional nil or *ListConnectorsOpts - Optional Parameters:
  • @param "Page" (optional.String) - Page index
  • @param "Size" (optional.String) - Number of items in each page
  • @param "OrderBy" (optional.String) - Specifies the order by criteria. The syntax of this parameter is similar to the syntax of the `order by` clause of an SQL statement. Each query can be ordered by any of the underlying resource fields supported in the search parameter. For example, to return all Connector types ordered by their name, use the following syntax: ```sql name asc ``` To return all Connector types ordered by their name _and_ version, use the following syntax: ```sql name asc, version asc ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then the results are ordered by name.
  • @param "Search" (optional.String) - Search criteria. The syntax of this parameter is similar to the syntax of the `where` clause of a SQL statement. Allowed fields in the search depend on the resource type: * Cluster: id, created_at, updated_at, owner, organisation_id, name, state, client_id * Namespace: id, created_at, updated_at, name, cluster_id, owner, expiration, tenant_user_id, tenant_organisation_id, state * Connector Types: id, created_at, updated_at, version, name, description, label, channel, featured_rank, pricing_tier * Connectors: id, created_at, updated_at, name, owner, organisation_id, connector_type_id, desired_state, state, channel, namespace_id, kafka_id, kafka_bootstrap_server, service_account_client_id, schema_registry_id, schema_registry_url Allowed operators are `<>`, `=`, `IN`, `NOT IN`, `LIKE`, or `ILIKE`. Allowed conjunctive operators are `AND` and `OR`. However, you can use a maximum of 10 conjunctions in a search query. Examples: To return a Connector Type with the name `aws-sqs-source` and the channel `stable`, use the following syntax: ``` name = aws-sqs-source and channel = stable ``` To return a connector instance with a name that starts with `aws`, use the following syntax: ``` name like aws%25 ``` To return a connector type with a name containing `aws` matching any character case combination, use the following syntax: ``` name ilike %25aws%25 ``` To return connector types with labels `category-featured` AND `source`, use the following syntax: ``` label like %25category-featured%25source% ``` NOTE: The AND operator does not work for multiple labels. Instead use an alphabetically ascending order pattern with the LIKE operator to match an aggregated list of ',' separated label names. If the parameter isn't provided, or if the value is empty, then all the resources that the user has permission to see are returned. Note. If the query is invalid, an error is returned.

@return ConnectorList

func (*ConnectorsApiService) PatchConnector 

func (a *ConnectorsApiService) PatchConnector(ctx _context.Context, id string, body map[string]interface{}) (Connector, *_nethttp.Response, error)

PatchConnector Patch a connector Patch a connector

  • @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param id The ID of record
  • @param body Data to patch the connector with

@return Connector

type Error 

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

Error struct for Error

type GenericOpenAPIError 

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

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

func (GenericOpenAPIError) Body 

func (e GenericOpenAPIError) Body() []byte

Body returns the raw bytes of the response

func (GenericOpenAPIError) Error 

func (e GenericOpenAPIError) Error() string

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

func (GenericOpenAPIError) Model 

func (e GenericOpenAPIError) Model() interface{}

Model returns the unpacked model of the error

type GetConnectorClusterAddonParametersOpts 

type GetConnectorClusterAddonParametersOpts struct {
	ResetCredentials optional.Bool
}

GetConnectorClusterAddonParametersOpts Optional parameters for the method 'GetConnectorClusterAddonParameters'

type GetConnectorClusterNamespacesOpts 

type GetConnectorClusterNamespacesOpts struct {
	Page    optional.String
	Size    optional.String
	OrderBy optional.String
	Search  optional.String
}

GetConnectorClusterNamespacesOpts Optional parameters for the method 'GetConnectorClusterNamespaces'

type GetConnectorTypeLabelsOpts 

type GetConnectorTypeLabelsOpts struct {
	OrderBy optional.String
	Search  optional.String
}

GetConnectorTypeLabelsOpts Optional parameters for the method 'GetConnectorTypeLabels'

type GetConnectorTypesOpts 

type GetConnectorTypesOpts struct {
	Page    optional.String
	Size    optional.String
	OrderBy optional.String
	Search  optional.String
}

GetConnectorTypesOpts Optional parameters for the method 'GetConnectorTypes'

type KafkaConnectionSettings 

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"`
}

List struct for List

type ListConnectorClustersOpts 

type ListConnectorClustersOpts struct {
	Page    optional.String
	Size    optional.String
	OrderBy optional.String
	Search  optional.String
}

ListConnectorClustersOpts Optional parameters for the method 'ListConnectorClusters'

type ListConnectorNamespacesOpts 

type ListConnectorNamespacesOpts struct {
	Page    optional.String
	Size    optional.String
	OrderBy optional.String
	Search  optional.String
}

ListConnectorNamespacesOpts Optional parameters for the method 'ListConnectorNamespaces'

type ListConnectorsOpts 

type ListConnectorsOpts struct {
	Page    optional.String
	Size    optional.String
	OrderBy optional.String
	Search  optional.String
}

ListConnectorsOpts Optional parameters for the method 'ListConnectors'

type ObjectMeta 

type ObjectMeta struct {
	Owner      string    `json:"owner,omitempty"`
	CreatedAt  time.Time `json:"created_at,omitempty"`
	ModifiedAt time.Time `json:"modified_at,omitempty"`
}

ObjectMeta struct for ObjectMeta

type ObjectReference 

type ObjectReference struct {
	Id   string `json:"id,omitempty"`
	Kind string `json:"kind,omitempty"`
	Href string `json:"href,omitempty"`
}

ObjectReference struct for ObjectReference

type SchemaRegistryConnectionSettings 

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

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.