private

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

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

func (*Configuration) ServerUrl 

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

ServerUrl returns URL based on server settings

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 

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

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

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.