Documentation ¶
Index ¶
- Variables
- func CacheExpires(r *http.Response) time.Time
- type APIClient
- type APIKey
- type APIResponse
- type BasicAuth
- type Configuration
- type ConnectorClusterPlatform
- type ConnectorClusterState
- type ConnectorClusterStatus
- type ConnectorClusterStatusOperators
- type ConnectorClustersAgentApiService
- func (a *ConnectorClustersAgentApiService) GetClusterAsignedConnectorDeploymentById(ctx _context.Context, connectorClusterId string, deploymentId string) (ConnectorDeployment, *_nethttp.Response, error)
- func (a *ConnectorClustersAgentApiService) GetClusterAsignedConnectorDeployments(ctx _context.Context, connectorClusterId string, ...) (ConnectorDeploymentList, *_nethttp.Response, error)
- func (a *ConnectorClustersAgentApiService) GetClusterAsignedConnectorNamespaceById(ctx _context.Context, connectorClusterId string, namespaceId string) (ConnectorNamespaceDeployment, *_nethttp.Response, error)
- func (a *ConnectorClustersAgentApiService) GetClusterAsignedConnectorNamespaces(ctx _context.Context, connectorClusterId string, ...) (ConnectorNamespaceDeploymentList, *_nethttp.Response, error)
- func (a *ConnectorClustersAgentApiService) UpdateConnectorDeploymentStatus(ctx _context.Context, connectorClusterId string, deploymentId string, ...) (*_nethttp.Response, error)
- func (a *ConnectorClustersAgentApiService) UpdateConnectorNamespaceStatus(ctx _context.Context, connectorClusterId string, namespaceId string, ...) (*_nethttp.Response, error)
- func (a *ConnectorClustersAgentApiService) UpdateKafkaConnectorClusterStatus(ctx _context.Context, connectorClusterId string, ...) (*_nethttp.Response, error)
- type ConnectorDeployment
- type ConnectorDeploymentAllOfMetadata
- type ConnectorDeploymentList
- type ConnectorDeploymentSpec
- type ConnectorDeploymentStatus
- type ConnectorDeploymentStatusOperators
- type ConnectorDeploymentWatchEvent
- type ConnectorDesiredState
- type ConnectorNamespaceDeployment
- type ConnectorNamespaceDeploymentList
- type ConnectorNamespaceDeploymentStatus
- type ConnectorNamespaceMeta
- type ConnectorNamespaceQuota
- type ConnectorNamespaceRequestMeta
- type ConnectorNamespaceState
- type ConnectorNamespaceStatus
- type ConnectorNamespaceTenant
- type ConnectorNamespaceTenantKind
- type ConnectorOperator
- type ConnectorState
- type Error
- type GenericOpenAPIError
- type GetClusterAsignedConnectorDeploymentsOpts
- type GetClusterAsignedConnectorNamespacesOpts
- type KafkaConnectionSettings
- type List
- type MetaV1Condition
- type ObjectMeta
- type ObjectReference
- type SchemaRegistryConnectionSettings
- type ServerConfiguration
- type ServerVariable
- type ServiceAccount
- type ServiceConnectionSettings
- type WatchEvent
Constants ¶
This section is empty.
Variables ¶
var ( // ContextOAuth2 takes an oauth2.TokenSource as authentication for the request. ContextOAuth2 = contextKey("token") // ContextBasicAuth takes BasicAuth as authentication for the request. ContextBasicAuth = contextKey("basic") // ContextAccessToken takes a string oauth2 access token as authentication for the request. ContextAccessToken = contextKey("accesstoken") // ContextAPIKey takes an APIKey as authentication for the request ContextAPIKey = contextKey("apikey") )
Functions ¶
Types ¶
type APIClient ¶
type APIClient struct { ConnectorClustersAgentApi *ConnectorClustersAgentApiService // contains filtered or unexported fields }
APIClient manages communication with the Connector Service Fleet Manager Private APIs API v0.0.3 In most cases there should be only one, shared, APIClient.
func NewAPIClient ¶
func NewAPIClient(cfg *Configuration) *APIClient
NewAPIClient creates a new API client. Requires a userAgent string describing your application. optionally a custom http.Client to allow for advanced features such as caching.
func (*APIClient) ChangeBasePath ¶
ChangeBasePath changes base path to allow switching to mocks
func (*APIClient) GetConfig ¶
func (c *APIClient) GetConfig() *Configuration
Allow modification of underlying config for alternate implementations and testing Caution: modifying the configuration while live can cause data races and potentially unwanted behavior
type APIKey ¶
APIKey provides API key based authentication to a request passed via context using ContextAPIKey
type APIResponse ¶
type APIResponse struct { *http.Response `json:"-"` Message string `json:"message,omitempty"` // Operation is the name of the OpenAPI operation. Operation string `json:"operation,omitempty"` // RequestURL is the request URL. This value is always available, even if the // embedded *http.Response is nil. RequestURL string `json:"url,omitempty"` // Method is the HTTP method used for the request. This value is always // available, even if the embedded *http.Response is nil. Method string `json:"method,omitempty"` // Payload holds the contents of the response body (which may be nil or empty). // This is provided here as the raw response.Body() reader will have already // been drained. Payload []byte `json:"-"` }
APIResponse stores the API response returned by the server.
func NewAPIResponse ¶
func NewAPIResponse(r *http.Response) *APIResponse
NewAPIResponse returns a new APIResonse object.
func NewAPIResponseWithError ¶
func NewAPIResponseWithError(errorMessage string) *APIResponse
NewAPIResponseWithError returns a new APIResponse object with the provided error message.
type BasicAuth ¶
type BasicAuth struct { UserName string `json:"userName,omitempty"` Password string `json:"password,omitempty"` }
BasicAuth provides basic http authentication to a request passed via context using ContextBasicAuth
type Configuration ¶
type Configuration struct { BasePath string `json:"basePath,omitempty"` Host string `json:"host,omitempty"` Scheme string `json:"scheme,omitempty"` DefaultHeader map[string]string `json:"defaultHeader,omitempty"` UserAgent string `json:"userAgent,omitempty"` Debug bool `json:"debug,omitempty"` Servers []ServerConfiguration HTTPClient *http.Client }
Configuration stores the configuration of the API client
func NewConfiguration ¶
func NewConfiguration() *Configuration
NewConfiguration returns a new Configuration object
func (*Configuration) AddDefaultHeader ¶
func (c *Configuration) AddDefaultHeader(key string, value string)
AddDefaultHeader adds a new HTTP header to the default header in the request
type ConnectorClusterPlatform ¶
type ConnectorClusterPlatform struct { // the kubernetes cluster type Type string `json:"type,omitempty"` // uniquely identifies the kubernetes cluster Id string `json:"id,omitempty"` // optional version of the kubernetes cluster Version string `json:"version,omitempty"` }
ConnectorClusterPlatform information about the kubernetes platform
type 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 { Phase ConnectorClusterState `json:"phase,omitempty"` Version string `json:"version,omitempty"` Conditions []MetaV1Condition `json:"conditions,omitempty"` Platform ConnectorClusterPlatform `json:"platform,omitempty"` // the list of installed operators Operators []ConnectorClusterStatusOperators `json:"operators,omitempty"` Namespaces []ConnectorNamespaceDeploymentStatus `json:"namespaces,omitempty"` }
ConnectorClusterStatus Schema for the request to update a data plane cluster's status
type ConnectorClusterStatusOperators ¶
type ConnectorClusterStatusOperators struct { Operator ConnectorOperator `json:"operator,omitempty"` // the namespace to which the operator has been installed Namespace string `json:"namespace,omitempty"` // the status of the operator Status string `json:"status,omitempty"` }
ConnectorClusterStatusOperators struct for ConnectorClusterStatusOperators
type ConnectorClustersAgentApiService ¶
type ConnectorClustersAgentApiService service
ConnectorClustersAgentApiService ConnectorClustersAgentApi service
func (*ConnectorClustersAgentApiService) GetClusterAsignedConnectorDeploymentById ¶
func (a *ConnectorClustersAgentApiService) GetClusterAsignedConnectorDeploymentById(ctx _context.Context, connectorClusterId string, deploymentId string) (ConnectorDeployment, *_nethttp.Response, error)
GetClusterAsignedConnectorDeploymentById Returns a list of connector deployments assigned to the cluster. Returns a list of connector deployments assigned to the 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 deploymentId The id of the deployment
@return ConnectorDeployment
func (*ConnectorClustersAgentApiService) GetClusterAsignedConnectorDeployments ¶
func (a *ConnectorClustersAgentApiService) GetClusterAsignedConnectorDeployments(ctx _context.Context, connectorClusterId string, localVarOptionals *GetClusterAsignedConnectorDeploymentsOpts) (ConnectorDeploymentList, *_nethttp.Response, error)
GetClusterAsignedConnectorDeployments Returns a list of connector deployments assigned to the cluster. Returns a list of connector deployments assigned to the 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 optional nil or *GetClusterAsignedConnectorDeploymentsOpts - Optional Parameters:
- @param "Page" (optional.String) - Page index
- @param "Size" (optional.String) - Number of items in each page
- @param "GtVersion" (optional.Int64) - filters the connectors to those with a version greater than the given value
- @param "Watch" (optional.String) - watch for changes to the resources and return them as a stream of watch events. Specify gt_version to specify the starting point.
@return ConnectorDeploymentList
func (*ConnectorClustersAgentApiService) GetClusterAsignedConnectorNamespaceById ¶
func (a *ConnectorClustersAgentApiService) GetClusterAsignedConnectorNamespaceById(ctx _context.Context, connectorClusterId string, namespaceId string) (ConnectorNamespaceDeployment, *_nethttp.Response, error)
GetClusterAsignedConnectorNamespaceById Returns a connector namespace assigned to the cluster. Returns a connector namespace assigned to the 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 namespaceId The id of the namespace
@return ConnectorNamespaceDeployment
func (*ConnectorClustersAgentApiService) GetClusterAsignedConnectorNamespaces ¶
func (a *ConnectorClustersAgentApiService) GetClusterAsignedConnectorNamespaces(ctx _context.Context, connectorClusterId string, localVarOptionals *GetClusterAsignedConnectorNamespacesOpts) (ConnectorNamespaceDeploymentList, *_nethttp.Response, error)
GetClusterAsignedConnectorNamespaces Returns all connector namespaces assigned to the cluster. Returns all connector namespaces assigned to the 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 optional nil or *GetClusterAsignedConnectorNamespacesOpts - Optional Parameters:
- @param "Page" (optional.String) - Page index
- @param "Size" (optional.String) - Number of items in each page
- @param "GtVersion" (optional.Int64) - filters the connectors to those with a version greater than the given value
@return ConnectorNamespaceDeploymentList
func (*ConnectorClustersAgentApiService) UpdateConnectorDeploymentStatus ¶
func (a *ConnectorClustersAgentApiService) UpdateConnectorDeploymentStatus(ctx _context.Context, connectorClusterId string, deploymentId string, connectorDeploymentStatus ConnectorDeploymentStatus) (*_nethttp.Response, error)
UpdateConnectorDeploymentStatus update the connector deployment status update the connector deployment status
- @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
- @param connectorClusterId The id of the connector cluster
- @param deploymentId The id of the deployment
- @param connectorDeploymentStatus
func (*ConnectorClustersAgentApiService) UpdateConnectorNamespaceStatus ¶
func (a *ConnectorClustersAgentApiService) UpdateConnectorNamespaceStatus(ctx _context.Context, connectorClusterId string, namespaceId string, connectorNamespaceDeploymentStatus ConnectorNamespaceDeploymentStatus) (*_nethttp.Response, error)
UpdateConnectorNamespaceStatus update the connector namespace status update the connector namespace status
- @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 namespaceId The id of the namespace
- @param connectorNamespaceDeploymentStatus
func (*ConnectorClustersAgentApiService) UpdateKafkaConnectorClusterStatus ¶
func (a *ConnectorClustersAgentApiService) UpdateKafkaConnectorClusterStatus(ctx _context.Context, connectorClusterId string, connectorClusterStatus ConnectorClusterStatus) (*_nethttp.Response, error)
UpdateKafkaConnectorClusterStatus Update the status of a connector cluster Update the status of 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 connectorClusterStatus Cluster status update data
type ConnectorDeployment ¶
type ConnectorDeployment struct { Id string `json:"id,omitempty"` Kind string `json:"kind,omitempty"` Href string `json:"href,omitempty"` Metadata ConnectorDeploymentAllOfMetadata `json:"metadata,omitempty"` Spec ConnectorDeploymentSpec `json:"spec,omitempty"` Status ConnectorDeploymentStatus `json:"status,omitempty"` }
ConnectorDeployment Holds the deployment configuration of a connector
type ConnectorDeploymentAllOfMetadata ¶
type ConnectorDeploymentAllOfMetadata struct { CreatedAt time.Time `json:"created_at"` UpdatedAt time.Time `json:"updated_at"` ResourceVersion int64 `json:"resource_version"` ResolvedSecrets bool `json:"resolved_secrets"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` }
ConnectorDeploymentAllOfMetadata struct for ConnectorDeploymentAllOfMetadata
type ConnectorDeploymentList ¶
type ConnectorDeploymentList struct { Kind string `json:"kind"` Page int32 `json:"page"` Size int32 `json:"size"` Total int32 `json:"total"` Items []ConnectorDeployment `json:"items"` }
ConnectorDeploymentList struct for ConnectorDeploymentList
type ConnectorDeploymentSpec ¶
type ConnectorDeploymentSpec struct { ServiceAccount ServiceAccount `json:"service_account,omitempty"` Kafka KafkaConnectionSettings `json:"kafka,omitempty"` SchemaRegistry SchemaRegistryConnectionSettings `json:"schema_registry,omitempty"` ConnectorId string `json:"connector_id,omitempty"` ConnectorResourceVersion int64 `json:"connector_resource_version,omitempty"` ConnectorTypeId string `json:"connector_type_id,omitempty"` NamespaceId string `json:"namespace_id,omitempty"` ConnectorSpec map[string]interface{} `json:"connector_spec,omitempty"` // an optional operator id that the connector should be run under. OperatorId string `json:"operator_id,omitempty"` DesiredState ConnectorDesiredState `json:"desired_state,omitempty"` ShardMetadata map[string]interface{} `json:"shard_metadata,omitempty"` }
ConnectorDeploymentSpec Holds the deployment specification of a connector
type ConnectorDeploymentStatus ¶
type ConnectorDeploymentStatus struct { Phase ConnectorState `json:"phase,omitempty"` ResourceVersion int64 `json:"resource_version,omitempty"` Operators ConnectorDeploymentStatusOperators `json:"operators,omitempty"` Conditions []MetaV1Condition `json:"conditions,omitempty"` }
ConnectorDeploymentStatus The status of connector deployment
type ConnectorDeploymentStatusOperators ¶
type ConnectorDeploymentStatusOperators struct { Assigned ConnectorOperator `json:"assigned,omitempty"` Available ConnectorOperator `json:"available,omitempty"` }
ConnectorDeploymentStatusOperators struct for ConnectorDeploymentStatusOperators
type ConnectorDeploymentWatchEvent ¶
type ConnectorDeploymentWatchEvent struct { Type string `json:"type"` Error *Error `json:"error,omitempty"` Object ConnectorDeployment `json:"object,omitempty"` }
ConnectorDeploymentWatchEvent struct for ConnectorDeploymentWatchEvent
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 ConnectorNamespaceDeployment ¶
type ConnectorNamespaceDeployment 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"` }
ConnectorNamespaceDeployment A connector namespace deployment
type ConnectorNamespaceDeploymentList ¶
type ConnectorNamespaceDeploymentList struct { Kind string `json:"kind"` Page int32 `json:"page"` Size int32 `json:"size"` Total int32 `json:"total"` Items []ConnectorNamespaceDeployment `json:"items"` }
ConnectorNamespaceDeploymentList struct for ConnectorNamespaceDeploymentList
type ConnectorNamespaceDeploymentStatus ¶
type ConnectorNamespaceDeploymentStatus struct { Id string `json:"id"` Phase ConnectorNamespaceState `json:"phase"` Version string `json:"version"` ConnectorsDeployed int32 `json:"connectors_deployed"` Conditions []MetaV1Condition `json:"conditions,omitempty"` }
ConnectorNamespaceDeploymentStatus Schema for the request to update a data plane namespaces' status
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 ConnectorNamespaceQuota ¶
type ConnectorNamespaceQuota struct { Connectors int32 `json:"connectors,omitempty"` // Memory quota for limits or requests MemoryRequests string `json:"memory_requests,omitempty"` // Memory quota for limits or requests MemoryLimits string `json:"memory_limits,omitempty"` // CPU quota for limits or requests CpuRequests string `json:"cpu_requests,omitempty"` // CPU quota for limits or requests CpuLimits string `json:"cpu_limits,omitempty"` }
ConnectorNamespaceQuota struct for ConnectorNamespaceQuota
type ConnectorNamespaceRequestMeta ¶
type ConnectorNamespaceRequestMeta struct { // Namespace name must match pattern `^(([A-Za-z0-9][-A-Za-z0-9_.]*)?[A-Za-z0-9])?$`, or it may be empty to be auto-generated. Name string `json:"name,omitempty"` // Name-value string annotations for resource Annotations map[string]string `json:"annotations,omitempty"` }
ConnectorNamespaceRequestMeta struct for ConnectorNamespaceRequestMeta
type 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 ConnectorOperator ¶
type ConnectorOperator struct { // the id of the operator Id string `json:"id,omitempty"` // the type of the operator Type string `json:"type,omitempty"` // the version of the operator Version string `json:"version,omitempty"` }
ConnectorOperator identifies an operator that runs on the fleet shards used to manage connectors.
type 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 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 GetClusterAsignedConnectorDeploymentsOpts ¶
type GetClusterAsignedConnectorDeploymentsOpts struct { Page optional.String Size optional.String GtVersion optional.Int64 Watch optional.String }
GetClusterAsignedConnectorDeploymentsOpts Optional parameters for the method 'GetClusterAsignedConnectorDeployments'
type GetClusterAsignedConnectorNamespacesOpts ¶
type GetClusterAsignedConnectorNamespacesOpts struct { Page optional.String Size optional.String GtVersion optional.Int64 }
GetClusterAsignedConnectorNamespacesOpts Optional parameters for the method 'GetClusterAsignedConnectorNamespaces'
type KafkaConnectionSettings ¶
KafkaConnectionSettings Holds the configuration to connect to a Kafka Instance.
type List ¶
type List struct { Kind string `json:"kind"` Page int32 `json:"page"` Size int32 `json:"size"` Total int32 `json:"total"` }
List struct for List
type MetaV1Condition ¶
type MetaV1Condition struct { Type string `json:"type,omitempty"` Reason string `json:"reason,omitempty"` Message string `json:"message,omitempty"` Status string `json:"status,omitempty"` LastTransitionTime string `json:"last_transition_time,omitempty"` }
MetaV1Condition struct for MetaV1Condition
type ObjectMeta ¶
type ObjectMeta struct { Owner string `json:"owner,omitempty"` CreatedAt time.Time `json:"created_at,omitempty"` ModifiedAt time.Time `json:"modified_at,omitempty"` }
ObjectMeta struct for ObjectMeta
type ObjectReference ¶
type ObjectReference struct { Id string `json:"id,omitempty"` Kind string `json:"kind,omitempty"` Href string `json:"href,omitempty"` }
ObjectReference struct for ObjectReference
type SchemaRegistryConnectionSettings ¶
SchemaRegistryConnectionSettings Holds the configuration to connect to a Schem Registry Instance.
type ServerConfiguration ¶
type ServerConfiguration struct { Url string Description string Variables map[string]ServerVariable }
ServerConfiguration stores the information about a server
type ServerVariable ¶
ServerVariable stores the information about a server variable
type ServiceAccount ¶
type ServiceAccount struct { ClientId string `json:"client_id"` ClientSecret string `json:"client_secret"` }
ServiceAccount struct for ServiceAccount
type ServiceConnectionSettings ¶
ServiceConnectionSettings struct for ServiceConnectionSettings
type WatchEvent ¶
type WatchEvent struct { Type string `json:"type"` Error *Error `json:"error,omitempty"` Object *map[string]interface{} `json:"object,omitempty"` }
WatchEvent struct for WatchEvent
Source Files ¶
- api_connector_clusters_agent.go
- client.go
- configuration.go
- model_connector_cluster_platform.go
- model_connector_cluster_state.go
- model_connector_cluster_status.go
- model_connector_cluster_status_operators.go
- model_connector_deployment.go
- model_connector_deployment_all_of_metadata.go
- model_connector_deployment_list.go
- model_connector_deployment_spec.go
- model_connector_deployment_status.go
- model_connector_deployment_status_operators.go
- model_connector_deployment_watch_event.go
- model_connector_desired_state.go
- model_connector_namespace_deployment.go
- model_connector_namespace_deployment_list.go
- model_connector_namespace_deployment_status.go
- model_connector_namespace_meta.go
- model_connector_namespace_quota.go
- model_connector_namespace_request_meta.go
- model_connector_namespace_state.go
- model_connector_namespace_status.go
- model_connector_namespace_tenant.go
- model_connector_namespace_tenant_kind.go
- model_connector_operator.go
- model_connector_state.go
- model_error.go
- model_kafka_connection_settings.go
- model_list.go
- model_meta_v1_condition.go
- model_object_meta.go
- model_object_reference.go
- model_schema_registry_connection_settings.go
- model_service_account.go
- model_service_connection_settings.go
- model_watch_event.go
- response.go