schemaregistry

package module
v0.0.23 Latest Latest
Warning

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

 Go to latest Published: May 15, 2023 License: Apache-2.0 Imports: 23 Imported by: 8

README

Go API client for schemaregistry

No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)

Overview

This API client was generated by the OpenAPI Generator project. By using the OpenAPI-spec from a remote server, you can easily generate an API client.

  • API version: v1
  • Package version: 1.0.0
  • Build package: org.openapitools.codegen.languages.GoClientCodegen

Installation

Install the following dependencies:

go get github.com/stretchr/testify/assert
go get golang.org/x/oauth2
go get golang.org/x/net/context
go get github.com/antihax/optional

Put the package under your project folder and add the following in import:

import "./schemaregistry"

Documentation for API Endpoints

All URIs are relative to http://localhost

Class Method HTTP request Description
DefaultApi AsyncapiParsePut Put /asyncapi/parse
DefaultApi AsyncapiPut Put /asyncapi
DefaultApi CreateBusinessMetadata Post /catalog/v1/entity/businessmetadata Bulk API to create multiple business metadata.
DefaultApi CreateBusinessMetadataDefs Post /catalog/v1/types/businessmetadatadefs Bulk create API for business metadata definitions.
DefaultApi CreateExporter Post /exporters Create an exporter.
DefaultApi CreateOrUpdate Post /catalog/v1/entity
DefaultApi CreateTagDefs Post /catalog/v1/types/tagdefs Bulk create API for tag definitions.
DefaultApi CreateTags Post /catalog/v1/entity/tags Bulk API to create multiple tags.
DefaultApi DeleteBusinessMetadata Delete /catalog/v1/entity/type/{typeName}/name/{qualifiedName}/businessmetadata/{bmName} Delete a business metadata on an entity.
DefaultApi DeleteBusinessMetadataDef Delete /catalog/v1/types/businessmetadatadefs/{bmName} Delete API for business metadata definition identified by its name.
DefaultApi DeleteByUniqueAttributes Delete /catalog/v1/entity/type/{typeName}/name/{qualifiedName}
DefaultApi DeleteExporter Delete /exporters/{name} Delete an exporter.
DefaultApi DeleteSchemaVersion Delete /subjects/{subject}/versions/{version} Deletes a specific version of the schema registered under this subject. This only deletes the version and the schema ID remains intact making it still possible to decode data using the schema ID. This API is recommended to be used only in development environments or under extreme circumstances where-in, its required to delete a previously registered schema for compatibility purposes or re-register previously registered schema.
DefaultApi DeleteSubject Delete /subjects/{subject} Deletes the specified subject and its associated compatibility level if registered. It is recommended to use this API only when a topic needs to be recycled or in development environment.
DefaultApi DeleteSubjectConfig Delete /config/{subject} Deletes the specified subject-level compatibility level config and revert to the global default.
DefaultApi DeleteSubjectMode Delete /mode/{subject} Deletes the specified subject-level mode and revert to the global default.
DefaultApi DeleteTag Delete /catalog/v1/entity/type/{typeName}/name/{qualifiedName}/tags/{tagName} Delete a tag on an entity.
DefaultApi DeleteTagDef Delete /catalog/v1/types/tagdefs/{tagName} Delete API for tag definition identified by its name.
DefaultApi DeleteTopLevelConfig Delete /config Delete global compatibility level
DefaultApi Get Get / Schema Registry Root Resource
DefaultApi GetAllBusinessMetadataDefs Get /catalog/v1/types/businessmetadatadefs Bulk retrieval API for retrieving business metadata definitions.
DefaultApi GetAllTagDefs Get /catalog/v1/types/tagdefs Bulk retrieval API for retrieving tag definitions.
DefaultApi GetBusinessMetadata Get /catalog/v1/entity/type/{typeName}/name/{qualifiedName}/businessmetadata Gets the list of business metadata for a given entity represented by a qualified name.
DefaultApi GetBusinessMetadataDefByName Get /catalog/v1/types/businessmetadatadefs/{bmName} Get the business metadata definition with the given name.
DefaultApi GetByUniqueAttributes Get /catalog/v1/entity/type/{typeName}/name/{qualifiedName} Fetch complete definition of an entity given its type and unique attribute.
DefaultApi GetClusterId Get /v1/metadata/id Get the server metadata
DefaultApi GetExporterConfig Get /exporters/{name}/config Get the config for an exporter.
DefaultApi GetExporterInfo Get /exporters/{name} Get the info for an exporter.
DefaultApi GetExporterStatus Get /exporters/{name}/status Get the status for an exporter.
DefaultApi GetExporters Get /exporters Get a list of exporter names.
DefaultApi GetMode Get /mode/{subject} Get mode for a subject.
DefaultApi GetReferencedBy Get /subjects/{subject}/versions/{version}/referencedby Get the schemas that reference the specified schema.
DefaultApi GetSchema Get /schemas/ids/{id} Get the schema string identified by the input ID.
DefaultApi GetSchemaByVersion Get /subjects/{subject}/versions/{version} Get a specific version of the schema registered under this subject.
DefaultApi GetSchemaOnly Get /subjects/{subject}/versions/{version}/schema Get the schema for the specified version of this subject. The unescaped schema only is returned.
DefaultApi GetSchemaTypes Get /schemas/types Get the schema types supported by this registry.
DefaultApi GetSchemas Get /schemas Get the schemas.
DefaultApi GetSubjectLevelConfig Get /config/{subject} Get compatibility level for a subject.
DefaultApi GetSubjects Get /schemas/ids/{id}/subjects Get all the subjects associated with the input ID.
DefaultApi GetTagDefByName Get /catalog/v1/types/tagdefs/{tagName} Get the tag definition with the given name.
DefaultApi GetTags Get /catalog/v1/entity/type/{typeName}/name/{qualifiedName}/tags Gets the list of classifications for a given entity represented by a qualifed name.
DefaultApi GetTopLevelConfig Get /config Get global compatibility level
DefaultApi GetTopLevelMode Get /mode Get global mode.
DefaultApi GetVersions Get /schemas/ids/{id}/versions Get all the subject-version pairs associated with the input ID.
DefaultApi List Get /subjects Get a list of registered subjects.
DefaultApi ListContexts Get /contexts Get a list of contexts.
DefaultApi ListVersions Get /subjects/{subject}/versions Get a list of versions registered under the specified subject.
DefaultApi LookUpSchemaUnderSubject Post /subjects/{subject} Check if a schema has already been registered under the specified subject. If so, this returns the schema string along with its globally unique identifier, its version under this subject and the subject name.
DefaultApi PartialUpdateByUniqueAttributes Put /catalog/v1/entity
DefaultApi PauseExporter Put /exporters/{name}/pause Pause an exporter.
DefaultApi Post Post /
DefaultApi PutExporter Put /exporters/{name} Alters an exporter.
DefaultApi PutExporterConfig Put /exporters/{name}/config Alters the config of an exporter.
DefaultApi Register Post /subjects/{subject}/versions Register schema under a subject
DefaultApi ResetExporter Put /exporters/{name}/reset Reset an exporter.
DefaultApi ResumeExporter Put /exporters/{name}/resume Resume an exporter.
DefaultApi SearchUsingAttribute Get /catalog/v1/search/attribute Retrieve data for the specified attribute search query.
DefaultApi SearchUsingBasic Get /catalog/v1/search/basic Retrieve data for the specified fulltext query.
DefaultApi TestCompatibilityBySubjectName Post /compatibility/subjects/{subject}/versions/{version} Test input schema against a particular version of a subject's schema for compatibility.
DefaultApi TestCompatibilityForSubject Post /compatibility/subjects/{subject}/versions Test input schema against a subject's schemas for compatibility, based on the compatibility level of the subject configured. In other word, it will perform the same compatibility check as register for that subject
DefaultApi UpdateBusinessMetadata Put /catalog/v1/entity/businessmetadata Bulk API to update multiple business metadata.
DefaultApi UpdateBusinessMetadataDefs Put /catalog/v1/types/businessmetadatadefs Bulk update API for business metadata definitions.
DefaultApi UpdateMode Put /mode/{subject} Update mode for the specified subject.
DefaultApi UpdateSubjectLevelConfig Put /config/{subject} Update compatibility level for the specified subject.
DefaultApi UpdateTagDefs Put /catalog/v1/types/tagdefs Bulk update API for tag definitions.
DefaultApi UpdateTags Put /catalog/v1/entity/tags Bulk API to update multiple tags.
DefaultApi UpdateTopLevelConfig Put /config Update global compatibility level
DefaultApi UpdateTopLevelMode Put /mode Update global mode.

Documentation For Models

Documentation For Authorization

Endpoints do not require authorization.

Author

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.

func PtrBool 

func PtrBool(v bool) *bool

PtrBool is a helper routine that returns a pointer to given boolean value.

func PtrFloat32 

func PtrFloat32(v float32) *float32

PtrFloat32 is a helper routine that returns a pointer to given float value.

func PtrFloat64 

func PtrFloat64(v float64) *float64

PtrFloat64 is a helper routine that returns a pointer to given float value.

func PtrInt 

func PtrInt(v int) *int

PtrInt is a helper routine that returns a pointer to given integer value.

func PtrInt32 

func PtrInt32(v int32) *int32

PtrInt32 is a helper routine that returns a pointer to given integer value.

func PtrInt64 

func PtrInt64(v int64) *int64

PtrInt64 is a helper routine that returns a pointer to given integer value.

func PtrString 

func PtrString(v string) *string

PtrString is a helper routine that returns a pointer to given string value.

func PtrTime 

func PtrTime(v time.Time) *time.Time

PtrTime is helper routine that returns a pointer to given Time value.

Types

type APIClient 

type APIClient struct {
	DefaultApi DefaultApi
	// contains filtered or unexported fields
}

APIClient manages communication with the Confluent Schema Registry API vv1 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 AtlasAttributeDef 

type AtlasAttributeDef struct {
	Name                  string               `json:"name,omitempty"`
	TypeName              string               `json:"typeName,omitempty"`
	IsOptional            bool                 `json:"isOptional,omitempty"`
	Cardinality           string               `json:"cardinality,omitempty"`
	ValuesMinCount        int32                `json:"valuesMinCount,omitempty"`
	ValuesMaxCount        int32                `json:"valuesMaxCount,omitempty"`
	IsUnique              bool                 `json:"isUnique,omitempty"`
	IsIndexable           bool                 `json:"isIndexable,omitempty"`
	IncludeInNotification bool                 `json:"includeInNotification,omitempty"`
	DefaultValue          string               `json:"defaultValue,omitempty"`
	Description           string               `json:"description,omitempty"`
	SearchWeight          int32                `json:"searchWeight,omitempty"`
	IndexType             string               `json:"indexType,omitempty"`
	Constraints           []AtlasConstraintDef `json:"constraints,omitempty"`
	Options               map[string]string    `json:"options,omitempty"`
	DisplayName           string               `json:"displayName,omitempty"`
}

AtlasAttributeDef struct for AtlasAttributeDef

type AtlasBusinessMetadataDef 

type AtlasBusinessMetadataDef struct {
	Category      string              `json:"category,omitempty"`
	Guid          string              `json:"guid,omitempty"`
	CreatedBy     string              `json:"createdBy,omitempty"`
	UpdatedBy     string              `json:"updatedBy,omitempty"`
	CreateTime    time.Time           `json:"createTime,omitempty"`
	UpdateTime    time.Time           `json:"updateTime,omitempty"`
	Version       int64               `json:"version,omitempty"`
	Name          string              `json:"name,omitempty"`
	Description   string              `json:"description,omitempty"`
	TypeVersion   string              `json:"typeVersion,omitempty"`
	ServiceType   string              `json:"serviceType,omitempty"`
	Options       map[string]string   `json:"options,omitempty"`
	AttributeDefs []AtlasAttributeDef `json:"attributeDefs,omitempty"`
}

AtlasBusinessMetadataDef struct for AtlasBusinessMetadataDef

type AtlasClassification 

type AtlasClassification struct {
	TypeName                         string                            `json:"typeName,omitempty"`
	Attributes                       map[string]map[string]interface{} `json:"attributes,omitempty"`
	EntityGuid                       string                            `json:"entityGuid,omitempty"`
	EntityStatus                     string                            `json:"entityStatus,omitempty"`
	Propagate                        bool                              `json:"propagate,omitempty"`
	ValidityPeriods                  []TimeBoundary                    `json:"validityPeriods,omitempty"`
	RemovePropagationsOnEntityDelete bool                              `json:"removePropagationsOnEntityDelete,omitempty"`
}

AtlasClassification struct for AtlasClassification

type AtlasConstraintDef 

type AtlasConstraintDef struct {
	Type   string                            `json:"type,omitempty"`
	Params map[string]map[string]interface{} `json:"params,omitempty"`
}

AtlasConstraintDef struct for AtlasConstraintDef

type AtlasEntity 

type AtlasEntity struct {
	TypeName               string                            `json:"typeName,omitempty"`
	Attributes             map[string]interface{}            `json:"attributes,omitempty"`
	Guid                   string                            `json:"guid,omitempty"`
	HomeId                 string                            `json:"homeId,omitempty"`
	IsProxy                bool                              `json:"isProxy,omitempty"`
	IsIncomplete           bool                              `json:"isIncomplete,omitempty"`
	ProvenanceType         int32                             `json:"provenanceType,omitempty"`
	Status                 string                            `json:"status,omitempty"`
	CreatedBy              string                            `json:"createdBy,omitempty"`
	UpdatedBy              string                            `json:"updatedBy,omitempty"`
	CreateTime             int64                             `json:"createTime,omitempty"`
	UpdateTime             int64                             `json:"updateTime,omitempty"`
	Version                int64                             `json:"version,omitempty"`
	RelationshipAttributes map[string]interface{}            `json:"relationshipAttributes,omitempty"`
	Classifications        []AtlasClassification             `json:"classifications,omitempty"`
	Meanings               []AtlasTermAssignmentHeader       `json:"meanings,omitempty"`
	CustomAttributes       map[string]string                 `json:"customAttributes,omitempty"`
	BusinessAttributes     map[string]map[string]interface{} `json:"businessAttributes,omitempty"`
	Labels                 []string                          `json:"labels,omitempty"`
	PendingTasks           []string                          `json:"pendingTasks,omitempty"`
	Proxy                  bool                              `json:"proxy,omitempty"`
}

AtlasEntity struct for AtlasEntity

type AtlasEntityHeader 

type AtlasEntityHeader struct {
	TypeName            string                            `json:"typeName,omitempty"`
	Attributes          map[string]map[string]interface{} `json:"attributes,omitempty"`
	Guid                string                            `json:"guid,omitempty"`
	Status              string                            `json:"status,omitempty"`
	DisplayText         string                            `json:"displayText,omitempty"`
	ClassificationNames []string                          `json:"classificationNames,omitempty"`
	Classifications     []AtlasClassification             `json:"classifications,omitempty"`
	MeaningNames        []string                          `json:"meaningNames,omitempty"`
	Meanings            []AtlasTermAssignmentHeader       `json:"meanings,omitempty"`
	IsIncomplete        bool                              `json:"isIncomplete,omitempty"`
	Labels              []string                          `json:"labels,omitempty"`
}

AtlasEntityHeader struct for AtlasEntityHeader

type AtlasEntityWithExtInfo 

type AtlasEntityWithExtInfo struct {
	ReferredEntities map[string]AtlasEntity `json:"referredEntities,omitempty"`
	Entity           AtlasEntity            `json:"entity,omitempty"`
}

AtlasEntityWithExtInfo struct for AtlasEntityWithExtInfo

type AtlasTermAssignmentHeader 

type AtlasTermAssignmentHeader struct {
	TermGuid     string `json:"termGuid,omitempty"`
	RelationGuid string `json:"relationGuid,omitempty"`
	Description  string `json:"description,omitempty"`
	DisplayText  string `json:"displayText,omitempty"`
	Expression   string `json:"expression,omitempty"`
	CreatedBy    string `json:"createdBy,omitempty"`
	Steward      string `json:"steward,omitempty"`
	Source       string `json:"source,omitempty"`
	Confidence   int32  `json:"confidence,omitempty"`
	Status       string `json:"status,omitempty"`
}

AtlasTermAssignmentHeader struct for AtlasTermAssignmentHeader

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 BusinessMetadata 

type BusinessMetadata struct {
	TypeName   string                 `json:"typeName,omitempty"`
	Attributes map[string]interface{} `json:"attributes,omitempty"`
	EntityType string                 `json:"entityType,omitempty"`
	EntityName string                 `json:"entityName,omitempty"`
}

BusinessMetadata struct for BusinessMetadata

type BusinessMetadataDefResponse 

type BusinessMetadataDefResponse struct {
	Category      string              `json:"category,omitempty"`
	Guid          string              `json:"guid,omitempty"`
	CreatedBy     string              `json:"createdBy,omitempty"`
	UpdatedBy     string              `json:"updatedBy,omitempty"`
	CreateTime    int64               `json:"createTime,omitempty"`
	UpdateTime    int64               `json:"updateTime,omitempty"`
	Version       int64               `json:"version,omitempty"`
	Name          string              `json:"name,omitempty"`
	Description   string              `json:"description,omitempty"`
	TypeVersion   string              `json:"typeVersion,omitempty"`
	ServiceType   string              `json:"serviceType,omitempty"`
	Options       map[string]string   `json:"options,omitempty"`
	AttributeDefs []AtlasAttributeDef `json:"attributeDefs,omitempty"`
	Error         ErrorMessage        `json:"error,omitempty"`
}

BusinessMetadataDefResponse struct for BusinessMetadataDefResponse

type BusinessMetadataResponse 

type BusinessMetadataResponse struct {
	TypeName   string                 `json:"typeName,omitempty"`
	Attributes map[string]interface{} `json:"attributes,omitempty"`
	EntityType string                 `json:"entityType,omitempty"`
	EntityName string                 `json:"entityName,omitempty"`
	Error      ErrorMessage           `json:"error,omitempty"`
}

BusinessMetadataResponse struct for BusinessMetadataResponse

type CompatibilityCheckResponse 

type CompatibilityCheckResponse struct {
	IsCompatible bool     `json:"is_compatible,omitempty"`
	Messages     []string `json:"messages,omitempty"`
}

CompatibilityCheckResponse struct for CompatibilityCheckResponse

type Config 

type Config struct {
	// Compatibility Level
	CompatibilityLevel string    `json:"compatibilityLevel,omitempty"`
	CompatibilityGroup string    `json:"compatibilityGroup,omitempty"`
	DefaultMetadata    *Metadata `json:"defaultMetadata,omitempty"`
	OverrideMetadata   *Metadata `json:"overrideMetadata,omitempty"`
	DefaultRuleSet     *RuleSet  `json:"defaultRuleSet,omitempty"`
	OverrideRuleSet    *RuleSet  `json:"overrideRuleSet,omitempty"`
}

Config Config

type ConfigUpdateRequest 

type ConfigUpdateRequest struct {
	// Compatibility Level
	Compatibility      string    `json:"compatibility,omitempty"`
	CompatibilityGroup string    `json:"compatibilityGroup,omitempty"`
	DefaultMetadata    *Metadata `json:"defaultMetadata,omitempty"`
	OverrideMetadata   *Metadata `json:"overrideMetadata,omitempty"`
	DefaultRuleSet     *RuleSet  `json:"defaultRuleSet,omitempty"`
	OverrideRuleSet    *RuleSet  `json:"overrideRuleSet,omitempty"`
}

ConfigUpdateRequest Config update request

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 CreateBusinessMetadataDefsOpts 

type CreateBusinessMetadataDefsOpts struct {
	AtlasBusinessMetadataDef optional.Interface
}

CreateBusinessMetadataDefsOpts Optional parameters for the method 'CreateBusinessMetadataDefs'

type CreateBusinessMetadataOpts 

type CreateBusinessMetadataOpts struct {
	BusinessMetadata optional.Interface
}

CreateBusinessMetadataOpts Optional parameters for the method 'CreateBusinessMetadata'

type CreateExporterRequest 

type CreateExporterRequest struct {
	Name                string            `json:"name,omitempty"`
	Subjects            []string          `json:"subjects,omitempty"`
	ContextType         string            `json:"contextType,omitempty"`
	Context             string            `json:"context,omitempty"`
	SubjectRenameFormat string            `json:"subjectRenameFormat,omitempty"`
	Config              map[string]string `json:"config,omitempty"`
}

CreateExporterRequest struct for CreateExporterRequest

type CreateExporterResponse 

type CreateExporterResponse struct {
	Name string `json:"name,omitempty"`
}

CreateExporterResponse struct for CreateExporterResponse

type CreateOrUpdateOpts 

type CreateOrUpdateOpts struct {
	AtlasEntityWithExtInfo optional.Interface
}

CreateOrUpdateOpts Optional parameters for the method 'CreateOrUpdate'

type CreateTagDefsOpts 

type CreateTagDefsOpts struct {
	TagDef optional.Interface
}

CreateTagDefsOpts Optional parameters for the method 'CreateTagDefs'

type CreateTagsOpts 

type CreateTagsOpts struct {
	Tag optional.Interface
}

CreateTagsOpts Optional parameters for the method 'CreateTags'

type DefaultApi 

type DefaultApi interface {

	/*
	 * AsyncapiParsePut Method for AsyncapiParsePut
	 *
	 * Get number of times the cli tool is used to import and parse the spec file
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 */
	AsyncapiParsePut(ctx _context.Context) (*_nethttp.Response, error)

	/*
	 * AsyncapiPut Method for AsyncapiPut
	 *
	 * Get number of times the cli tool is used to export/produce the spec file
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 */
	AsyncapiPut(ctx _context.Context) (*_nethttp.Response, error)

	/*
	 * CreateBusinessMetadata Bulk API to create multiple business metadata.
	 *
	 * Bulk API to create multiple business metadata.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *CreateBusinessMetadataOpts - Optional Parameters:
	 * @param "BusinessMetadata" (optional.Interface of []BusinessMetadata) -  The business metadata
	 * @return []BusinessMetadataResponse
	 */
	CreateBusinessMetadata(ctx _context.Context, localVarOptionals *CreateBusinessMetadataOpts) ([]BusinessMetadataResponse, *_nethttp.Response, error)

	/*
	 * CreateBusinessMetadataDefs Bulk create API for business metadata definitions.
	 *
	 * Bulk create API for business metadata definitions.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *CreateBusinessMetadataDefsOpts - Optional Parameters:
	 * @param "AtlasBusinessMetadataDef" (optional.Interface of []AtlasBusinessMetadataDef) -  The business metadata definitions to create
	 * @return []BusinessMetadataDefResponse
	 */
	CreateBusinessMetadataDefs(ctx _context.Context, localVarOptionals *CreateBusinessMetadataDefsOpts) ([]BusinessMetadataDefResponse, *_nethttp.Response, error)

	/*
	 * CreateExporter Create an exporter.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param body Info
	 * @return CreateExporterResponse
	 */
	CreateExporter(ctx _context.Context, body CreateExporterRequest) (CreateExporterResponse, *_nethttp.Response, error)

	/*
	 * CreateOrUpdate Method for CreateOrUpdate
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *CreateOrUpdateOpts - Optional Parameters:
	 * @param "AtlasEntityWithExtInfo" (optional.Interface of AtlasEntityWithExtInfo) -
	 */
	CreateOrUpdate(ctx _context.Context, localVarOptionals *CreateOrUpdateOpts) (*_nethttp.Response, error)

	/*
	 * CreateTagDefs Bulk create API for tag definitions.
	 *
	 * Bulk create API for tag definitions.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *CreateTagDefsOpts - Optional Parameters:
	 * @param "TagDef" (optional.Interface of []TagDef) -  The tag definitions to create
	 * @return []TagDefResponse
	 */
	CreateTagDefs(ctx _context.Context, localVarOptionals *CreateTagDefsOpts) ([]TagDefResponse, *_nethttp.Response, error)

	/*
	 * CreateTags Bulk API to create multiple tags.
	 *
	 * Bulk API to create multiple tags.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *CreateTagsOpts - Optional Parameters:
	 * @param "Tag" (optional.Interface of []Tag) -  The tags
	 * @return []TagResponse
	 */
	CreateTags(ctx _context.Context, localVarOptionals *CreateTagsOpts) ([]TagResponse, *_nethttp.Response, error)

	/*
	 * DeleteBusinessMetadata Delete a business metadata on an entity.
	 *
	 * Delete a business metadata on an entity.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param typeName The type of the entity
	 * @param qualifiedName The qualified name of the entity
	 * @param bmName The name of the business metadata
	 */
	DeleteBusinessMetadata(ctx _context.Context, typeName string, qualifiedName string, bmName string) (*_nethttp.Response, error)

	/*
	 * DeleteBusinessMetadataDef Delete API for business metadata definition identified by its name.
	 *
	 * Delete API for business metadata definition identified by its name.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param bmName The name of the business metadata definition
	 */
	DeleteBusinessMetadataDef(ctx _context.Context, bmName string) (*_nethttp.Response, error)

	/*
	 * DeleteByUniqueAttributes Method for DeleteByUniqueAttributes
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param typeName
	 * @param qualifiedName
	 */
	DeleteByUniqueAttributes(ctx _context.Context, typeName string, qualifiedName string) (*_nethttp.Response, error)

	/*
	 * DeleteExporter Delete an exporter.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param name Name of the exporter
	 */
	DeleteExporter(ctx _context.Context, name string) (*_nethttp.Response, error)

	/*
	 * DeleteSchemaVersion Deletes a specific version of the schema registered under this subject. This only deletes the version and the schema ID remains intact making it still possible to decode data using the schema ID. This API is recommended to be used only in development environments or under extreme circumstances where-in, its required to delete a previously registered schema for compatibility purposes or re-register previously registered schema.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject Name of the Subject
	 * @param version Version of the schema to be returned. Valid values for versionId are between [1,2^31-1] or the string \"latest\". \"latest\" returns the last registered schema under the specified subject. Note that there may be a new latest schema that gets registered right after this request is served.
	 * @param optional nil or *DeleteSchemaVersionOpts - Optional Parameters:
	 * @param "Permanent" (optional.Bool) -
	 * @return int32
	 */
	DeleteSchemaVersion(ctx _context.Context, subject string, version string, localVarOptionals *DeleteSchemaVersionOpts) (int32, *_nethttp.Response, error)

	/*
	 * DeleteSubject Deletes the specified subject and its associated compatibility level if registered. It is recommended to use this API only when a topic needs to be recycled or in development environment.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject the name of the subject
	 * @param optional nil or *DeleteSubjectOpts - Optional Parameters:
	 * @param "Permanent" (optional.Bool) -
	 * @return []int32
	 */
	DeleteSubject(ctx _context.Context, subject string, localVarOptionals *DeleteSubjectOpts) ([]int32, *_nethttp.Response, error)

	/*
	 * DeleteSubjectConfig Deletes the specified subject-level compatibility level config and revert to the global default.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject the name of the subject
	 * @return string
	 */
	DeleteSubjectConfig(ctx _context.Context, subject string) (string, *_nethttp.Response, error)

	/*
	 * DeleteSubjectMode Deletes the specified subject-level mode and revert to the global default.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject the name of the subject
	 * @return string
	 */
	DeleteSubjectMode(ctx _context.Context, subject string) (string, *_nethttp.Response, error)

	/*
	 * DeleteTag Delete a tag on an entity.
	 *
	 * Delete a tag on an entity.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param typeName The type of the entity
	 * @param qualifiedName The qualified name of the entity
	 * @param tagName The name of the tag
	 */
	DeleteTag(ctx _context.Context, typeName string, qualifiedName string, tagName string) (*_nethttp.Response, error)

	/*
	 * DeleteTagDef Delete API for tag definition identified by its name.
	 *
	 * Delete API for tag definition identified by its name.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param tagName The name of the tag definition
	 */
	DeleteTagDef(ctx _context.Context, tagName string) (*_nethttp.Response, error)

	/*
	 * DeleteTopLevelConfig Delete global compatibility level
	 *
	 * Deletes the global compatibility level config and reverts to the default.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return string
	 */
	DeleteTopLevelConfig(ctx _context.Context) (string, *_nethttp.Response, error)

	/*
	 * Get Schema Registry Root Resource
	 *
	 * The Root resource is a no-op.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return map[string]map[string]interface{}
	 */
	Get(ctx _context.Context) (map[string]map[string]interface{}, *_nethttp.Response, error)

	/*
	 * GetAllBusinessMetadataDefs Bulk retrieval API for retrieving business metadata definitions.
	 *
	 * Bulk retrieval API for retrieving business metadata definitions.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *GetAllBusinessMetadataDefsOpts - Optional Parameters:
	 * @param "Prefix" (optional.String) -  The prefix of a business metadata definition name
	 * @return []BusinessMetadataDefResponse
	 */
	GetAllBusinessMetadataDefs(ctx _context.Context, localVarOptionals *GetAllBusinessMetadataDefsOpts) ([]BusinessMetadataDefResponse, *_nethttp.Response, error)

	/*
	 * GetAllTagDefs Bulk retrieval API for retrieving tag definitions.
	 *
	 * Bulk retrieval API for retrieving tag definitions.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *GetAllTagDefsOpts - Optional Parameters:
	 * @param "Prefix" (optional.String) -  The prefix of a tag definition name
	 * @return []TagDefResponse
	 */
	GetAllTagDefs(ctx _context.Context, localVarOptionals *GetAllTagDefsOpts) ([]TagDefResponse, *_nethttp.Response, error)

	/*
	 * GetBusinessMetadata Gets the list of business metadata for a given entity represented by a qualified name.
	 *
	 * Gets the list of business metadata for a given entity represented by a qualified name.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param typeName The type of the entity
	 * @param qualifiedName The qualified name of the entity
	 * @return []BusinessMetadataResponse
	 */
	GetBusinessMetadata(ctx _context.Context, typeName string, qualifiedName string) ([]BusinessMetadataResponse, *_nethttp.Response, error)

	/*
	 * GetBusinessMetadataDefByName Get the business metadata definition with the given name.
	 *
	 * Get the business metadata definition with the given name.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param bmName The name of the business metadata definition
	 * @return AtlasBusinessMetadataDef
	 */
	GetBusinessMetadataDefByName(ctx _context.Context, bmName string) (AtlasBusinessMetadataDef, *_nethttp.Response, error)

	/*
	 * GetByUniqueAttributes Fetch complete definition of an entity given its type and unique attribute.
	 *
	 * Fetch complete definition of an entity given its type and unique attribute.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param typeName The type of the entity
	 * @param qualifiedName The qualified name of the entity
	 * @param optional nil or *GetByUniqueAttributesOpts - Optional Parameters:
	 * @param "MinExtInfo" (optional.Bool) -  Whether to only populate header and schema attributes
	 * @param "IgnoreRelationships" (optional.Bool) -  Whether to ignore relationships
	 * @param "IncludeInternalPrefix" (optional.String) -  If not null, include internal attributes that start with this prefix
	 * @return AtlasEntityWithExtInfo
	 */
	GetByUniqueAttributes(ctx _context.Context, typeName string, qualifiedName string, localVarOptionals *GetByUniqueAttributesOpts) (AtlasEntityWithExtInfo, *_nethttp.Response, error)

	/*
	 * GetClusterId Get the server metadata
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return ServerClusterId
	 */
	GetClusterId(ctx _context.Context) (ServerClusterId, *_nethttp.Response, error)

	/*
	 * GetExporterConfig Get the config for an exporter.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param name
	 * @return map[string]string
	 */
	GetExporterConfig(ctx _context.Context, name string) (map[string]string, *_nethttp.Response, error)

	/*
	 * GetExporterInfo Get the info for an exporter.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param name
	 * @return ExporterInfo
	 */
	GetExporterInfo(ctx _context.Context, name string) (ExporterInfo, *_nethttp.Response, error)

	/*
	 * GetExporterStatus Get the status for an exporter.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param name
	 * @return ExporterStatus
	 */
	GetExporterStatus(ctx _context.Context, name string) (ExporterStatus, *_nethttp.Response, error)

	/*
	 * GetExporters Get a list of exporter names.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return []string
	 */
	GetExporters(ctx _context.Context) ([]string, *_nethttp.Response, error)

	/*
	 * GetMode Get mode for a subject.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject Name of the Subject
	 * @param optional nil or *GetModeOpts - Optional Parameters:
	 * @param "DefaultToGlobal" (optional.Bool) -
	 * @return Mode
	 */
	GetMode(ctx _context.Context, subject string, localVarOptionals *GetModeOpts) (Mode, *_nethttp.Response, error)

	/*
	 * GetReferencedBy Get the schemas that reference the specified schema.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject Name of the Subject
	 * @param version Version of the schema to be returned. Valid values for versionId are between [1,2^31-1] or the string \"latest\". \"latest\" returns the last registered schema under the specified subject. Note that there may be a new latest schema that gets registered right after this request is served.
	 * @return []int32
	 */
	GetReferencedBy(ctx _context.Context, subject string, version string) ([]int32, *_nethttp.Response, error)

	/*
	 * GetSchema Get the schema string identified by the input ID.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param id Globally unique identifier of the schema
	 * @param optional nil or *GetSchemaOpts - Optional Parameters:
	 * @param "Subject" (optional.String) -
	 * @param "Format" (optional.String) -
	 * @param "FetchMaxId" (optional.Bool) -
	 * @return SchemaString
	 */
	GetSchema(ctx _context.Context, id int32, localVarOptionals *GetSchemaOpts) (SchemaString, *_nethttp.Response, error)

	/*
	 * GetSchemaByVersion Get a specific version of the schema registered under this subject.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject Name of the Subject
	 * @param version Version of the schema to be returned. Valid values for versionId are between [1,2^31-1] or the string \"latest\". \"latest\" returns the last registered schema under the specified subject. Note that there may be a new latest schema that gets registered right after this request is served.
	 * @param optional nil or *GetSchemaByVersionOpts - Optional Parameters:
	 * @param "Deleted" (optional.Bool) -
	 * @return Schema
	 */
	GetSchemaByVersion(ctx _context.Context, subject string, version string, localVarOptionals *GetSchemaByVersionOpts) (Schema, *_nethttp.Response, error)

	/*
	 * GetSchemaOnly Get the schema for the specified version of this subject. The unescaped schema only is returned.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject Name of the Subject
	 * @param version Version of the schema to be returned. Valid values for versionId are between [1,2^31-1] or the string \"latest\". \"latest\" returns the last registered schema under the specified subject. Note that there may be a new latest schema that gets registered right after this request is served.
	 * @param optional nil or *GetSchemaOnlyOpts - Optional Parameters:
	 * @param "Deleted" (optional.Bool) -
	 * @return string
	 */
	GetSchemaOnly(ctx _context.Context, subject string, version string, localVarOptionals *GetSchemaOnlyOpts) (string, *_nethttp.Response, error)

	/*
	 * GetSchemaTypes Get the schema types supported by this registry.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return []string
	 */
	GetSchemaTypes(ctx _context.Context) ([]string, *_nethttp.Response, error)

	/*
	 * GetSchemas Get the schemas.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *GetSchemasOpts - Optional Parameters:
	 * @param "SubjectPrefix" (optional.String) -
	 * @param "Deleted" (optional.Bool) -
	 * @param "LatestOnly" (optional.Bool) -
	 * @param "Offset" (optional.Int32) -
	 * @param "Limit" (optional.Int32) -
	 * @return []Schema
	 */
	GetSchemas(ctx _context.Context, localVarOptionals *GetSchemasOpts) ([]Schema, *_nethttp.Response, error)

	/*
	 * GetSubjectLevelConfig Get compatibility level for a subject.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject
	 * @param optional nil or *GetSubjectLevelConfigOpts - Optional Parameters:
	 * @param "DefaultToGlobal" (optional.Bool) -
	 * @return Config
	 */
	GetSubjectLevelConfig(ctx _context.Context, subject string, localVarOptionals *GetSubjectLevelConfigOpts) (Config, *_nethttp.Response, error)

	/*
	 * GetSubjects Get all the subjects associated with the input ID.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param id Globally unique identifier of the schema
	 * @param optional nil or *GetSubjectsOpts - Optional Parameters:
	 * @param "Subject" (optional.String) -
	 * @param "Deleted" (optional.Bool) -
	 * @return []string
	 */
	GetSubjects(ctx _context.Context, id int32, localVarOptionals *GetSubjectsOpts) ([]string, *_nethttp.Response, error)

	/*
	 * GetTagDefByName Get the tag definition with the given name.
	 *
	 * Get the tag definition with the given name.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param tagName The name of the tag definiton
	 * @return TagDef
	 */
	GetTagDefByName(ctx _context.Context, tagName string) (TagDef, *_nethttp.Response, error)

	/*
	 * GetTags Gets the list of classifications for a given entity represented by a qualifed name.
	 *
	 * Gets the list of classifications for a given entity represented by a qualifed name.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param typeName The type of the entity
	 * @param qualifiedName The qualified name of the entity
	 * @return []TagResponse
	 */
	GetTags(ctx _context.Context, typeName string, qualifiedName string) ([]TagResponse, *_nethttp.Response, error)

	/*
	 * GetTopLevelConfig Get global compatibility level
	 *
	 * Retrieves the global compatibility level.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return Config
	 */
	GetTopLevelConfig(ctx _context.Context) (Config, *_nethttp.Response, error)

	/*
	 * GetTopLevelMode Get global mode.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return Mode
	 */
	GetTopLevelMode(ctx _context.Context) (Mode, *_nethttp.Response, error)

	/*
	 * GetVersions Get all the subject-version pairs associated with the input ID.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param id Globally unique identifier of the schema
	 * @param optional nil or *GetVersionsOpts - Optional Parameters:
	 * @param "Subject" (optional.String) -
	 * @param "Deleted" (optional.Bool) -
	 * @return []SubjectVersion
	 */
	GetVersions(ctx _context.Context, id int32, localVarOptionals *GetVersionsOpts) ([]SubjectVersion, *_nethttp.Response, error)

	/*
	 * List Get a list of registered subjects.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *ListOpts - Optional Parameters:
	 * @param "SubjectPrefix" (optional.String) -
	 * @param "Deleted" (optional.Bool) -
	 * @param "DeletedOnly" (optional.Bool) -  Whether to return deleted subjects only
	 * @return []string
	 */
	List(ctx _context.Context, localVarOptionals *ListOpts) ([]string, *_nethttp.Response, error)

	/*
	 * ListContexts Get a list of contexts.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return []string
	 */
	ListContexts(ctx _context.Context) ([]string, *_nethttp.Response, error)

	/*
	 * ListVersions Get a list of versions registered under the specified subject.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject Name of the Subject
	 * @param optional nil or *ListVersionsOpts - Optional Parameters:
	 * @param "Deleted" (optional.Bool) -
	 * @param "DeletedOnly" (optional.Bool) -  Whether to return deleted schemas only
	 * @return []int32
	 */
	ListVersions(ctx _context.Context, subject string, localVarOptionals *ListVersionsOpts) ([]int32, *_nethttp.Response, error)

	/*
	 * LookUpSchemaUnderSubject Check if a schema has already been registered under the specified subject. If so, this returns the schema string along with its globally unique identifier, its version under this subject and the subject name.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject Subject under which the schema will be registered
	 * @param body Schema
	 * @param optional nil or *LookUpSchemaUnderSubjectOpts - Optional Parameters:
	 * @param "Deleted" (optional.Bool) -
	 */
	LookUpSchemaUnderSubject(ctx _context.Context, subject string, body RegisterSchemaRequest, localVarOptionals *LookUpSchemaUnderSubjectOpts) (*_nethttp.Response, error)

	/*
	 * PartialUpdateByUniqueAttributes Method for PartialUpdateByUniqueAttributes
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *PartialUpdateByUniqueAttributesOpts - Optional Parameters:
	 * @param "AtlasEntityWithExtInfo" (optional.Interface of AtlasEntityWithExtInfo) -
	 */
	PartialUpdateByUniqueAttributes(ctx _context.Context, localVarOptionals *PartialUpdateByUniqueAttributesOpts) (*_nethttp.Response, error)

	/*
	 * PauseExporter Pause an exporter.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param name Name of the exporter
	 * @return UpdateExporterResponse
	 */
	PauseExporter(ctx _context.Context, name string) (UpdateExporterResponse, *_nethttp.Response, error)

	/*
	 * Post Method for Post
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return map[string]string
	 */
	Post(ctx _context.Context) (map[string]string, *_nethttp.Response, error)

	/*
	 * PutExporter Alters an exporter.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param name Name of the exporter
	 * @param body Info
	 * @return UpdateExporterResponse
	 */
	PutExporter(ctx _context.Context, name string, body UpdateExporterRequest) (UpdateExporterResponse, *_nethttp.Response, error)

	/*
	 * PutExporterConfig Alters the config of an exporter.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param name Name of the exporter
	 * @param body Config
	 * @return UpdateExporterResponse
	 */
	PutExporterConfig(ctx _context.Context, name string, body map[string]string) (UpdateExporterResponse, *_nethttp.Response, error)

	/*
	 * Register Register schema under a subject
	 *
	 * Register a new schema under the specified subject. If successfully registered, this returns the unique identifier of this schema in the registry. The returned identifier should be used to retrieve this schema from the schemas resource and is different from the schema's version which is associated with the subject. If the same schema is registered under a different subject, the same identifier will be returned. However, the version of the schema may be different under different subjects. A schema should be compatible with the previously registered schema or schemas (if there are any) as per the configured compatibility level. The configured compatibility level can be obtained by issuing a GET http:get:: /config/(string: subject). If that returns null, then GET http:get:: /config When there are multiple instances of Schema Registry running in the same cluster, the schema registration request will be forwarded to one of the instances designated as the primary. If the primary is not available, the client will get an error code indicating that the forwarding has failed.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject Name of the subject
	 * @param body Schema
	 * @param optional nil or *RegisterOpts - Optional Parameters:
	 * @param "Normalize" (optional.Bool) -  Whether to register the normalized schema
	 * @return RegisterSchemaResponse
	 */
	Register(ctx _context.Context, subject string, body RegisterSchemaRequest, localVarOptionals *RegisterOpts) (RegisterSchemaResponse, *_nethttp.Response, error)

	/*
	 * ResetExporter Reset an exporter.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param name Name of the exporter
	 * @return UpdateExporterResponse
	 */
	ResetExporter(ctx _context.Context, name string) (UpdateExporterResponse, *_nethttp.Response, error)

	/*
	 * ResumeExporter Resume an exporter.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param name Name of the exporter
	 * @return UpdateExporterResponse
	 */
	ResumeExporter(ctx _context.Context, name string) (UpdateExporterResponse, *_nethttp.Response, error)

	/*
	 * SearchUsingAttribute Retrieve data for the specified attribute search query.
	 *
	 * Retrieve data for the specified attribute search query.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *SearchUsingAttributeOpts - Optional Parameters:
	 * @param "Type_" (optional.Interface of []string) -  Limit the result to only entities of specified types
	 * @param "Types" (optional.String) -
	 * @param "Attr" (optional.Interface of []string) -  One of more additional attributes to return in the response
	 * @param "Attrs" (optional.String) -
	 * @param "AttrName" (optional.Interface of []string) -  The attribute to search
	 * @param "AttrValuePrefix" (optional.Interface of []string) -  The prefix for the attribute value to search
	 * @param "Tag" (optional.Interface of []string) -  Limit the result to only entities tagged with the given tag
	 * @param "TimeRangeType" (optional.String) -  The type of time range search, default is CUSTOM
	 * @param "TimeRangeAttr" (optional.String) -  The attribute for a time range search
	 * @param "TimeRangeStart" (optional.Int64) -  The start for a custom time range search in ms since the epoch
	 * @param "TimeRangeEnd" (optional.Int64) -  The end for a custom time range search in ms since the epoch
	 * @param "SortBy" (optional.String) -  An attribute to sort by
	 * @param "SortOrder" (optional.String) -  Sort order, either ASCENDING (default) or DESCENDING
	 * @param "Deleted" (optional.Bool) -  Whether to include deleted entities
	 * @param "Limit" (optional.Int32) -  Limit the result set to only include the specified number of entries
	 * @param "Offset" (optional.Int32) -  Start offset of the result set (useful for pagination)
	 * @return SearchResult
	 */
	SearchUsingAttribute(ctx _context.Context, localVarOptionals *SearchUsingAttributeOpts) (SearchResult, *_nethttp.Response, error)

	/*
	 * SearchUsingBasic Retrieve data for the specified fulltext query.
	 *
	 * Retrieve data for the specified fulltext query.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *SearchUsingBasicOpts - Optional Parameters:
	 * @param "Query" (optional.String) -  The full-text query
	 * @param "Type_" (optional.Interface of []string) -  Limit the result to only entities of specified types
	 * @param "Types" (optional.String) -
	 * @param "Attr" (optional.Interface of []string) -  One of more additional attributes to return in the response
	 * @param "Attrs" (optional.String) -
	 * @param "Tag" (optional.Interface of []string) -  Limit the result to only entities with the given tag
	 * @param "TimeRangeType" (optional.String) -  The type of time range search, default is CUSTOM
	 * @param "TimeRangeAttr" (optional.String) -  The attribute for a time range search
	 * @param "TimeRangeStart" (optional.Int64) -  The start for a custom time range search in ms since the epoch
	 * @param "TimeRangeEnd" (optional.Int64) -  The end for a custom time range search in ms since the epoch
	 * @param "SortBy" (optional.String) -  An attribute to sort by
	 * @param "SortOrder" (optional.String) -  Sort order, either ASCENDING (default) or DESCENDING
	 * @param "Deleted" (optional.Bool) -  Whether to include deleted entities
	 * @param "Limit" (optional.Int32) -  Limit the result set to only include the specified number of entries
	 * @param "Offset" (optional.Int32) -  Start offset of the result set (useful for pagination)
	 * @return SearchResult
	 */
	SearchUsingBasic(ctx _context.Context, localVarOptionals *SearchUsingBasicOpts) (SearchResult, *_nethttp.Response, error)

	/*
	 * TestCompatibilityBySubjectName Test input schema against a particular version of a subject's schema for compatibility.
	 *
	 * the compatibility level applied for the check is the configured compatibility level for the subject (http:get:: /config/(string: subject)). If this subject's compatibility level was never changed, then the global compatibility level applies (http:get:: /config).
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject Subject of the schema version against which compatibility is to be tested
	 * @param version Version of the subject's schema against which compatibility is to be tested. Valid values for versionId are between [1,2^31-1] or the string \"latest\".\"latest\" checks compatibility of the input schema with the last registered schema under the specified subject
	 * @param body Schema
	 * @param optional nil or *TestCompatibilityBySubjectNameOpts - Optional Parameters:
	 * @param "ContentType" (optional.String) -
	 * @param "Accept" (optional.String) -
	 * @param "Verbose" (optional.Bool) -
	 * @return CompatibilityCheckResponse
	 */
	TestCompatibilityBySubjectName(ctx _context.Context, subject string, version string, body RegisterSchemaRequest, localVarOptionals *TestCompatibilityBySubjectNameOpts) (CompatibilityCheckResponse, *_nethttp.Response, error)

	/*
	 * TestCompatibilityForSubject Test input schema against a subject's schemas for compatibility, based on the compatibility level of the subject configured. In other word, it will perform the same compatibility check as register for that subject
	 *
	 * the compatibility level applied for the check is the configured compatibility level for the subject (http:get:: /config/(string: subject)). If this subject's compatibility level was never changed, then the global compatibility level applies (http:get:: /config).
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject Subject of the schema version against which compatibility is to be tested
	 * @param body Schema
	 * @param optional nil or *TestCompatibilityForSubjectOpts - Optional Parameters:
	 * @param "ContentType" (optional.String) -
	 * @param "Accept" (optional.String) -
	 * @param "Verbose" (optional.Bool) -
	 * @return CompatibilityCheckResponse
	 */
	TestCompatibilityForSubject(ctx _context.Context, subject string, body RegisterSchemaRequest, localVarOptionals *TestCompatibilityForSubjectOpts) (CompatibilityCheckResponse, *_nethttp.Response, error)

	/*
	 * UpdateBusinessMetadata Bulk API to update multiple business metadata.
	 *
	 * Bulk API to update multiple business metadata.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *UpdateBusinessMetadataOpts - Optional Parameters:
	 * @param "BusinessMetadata" (optional.Interface of []BusinessMetadata) -  The business metadata
	 * @return []BusinessMetadataResponse
	 */
	UpdateBusinessMetadata(ctx _context.Context, localVarOptionals *UpdateBusinessMetadataOpts) ([]BusinessMetadataResponse, *_nethttp.Response, error)

	/*
	 * UpdateBusinessMetadataDefs Bulk update API for business metadata definitions.
	 *
	 * Bulk update API for business metadata definitions.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *UpdateBusinessMetadataDefsOpts - Optional Parameters:
	 * @param "AtlasBusinessMetadataDef" (optional.Interface of []AtlasBusinessMetadataDef) -  The business metadata definitions to update
	 * @return []BusinessMetadataDefResponse
	 */
	UpdateBusinessMetadataDefs(ctx _context.Context, localVarOptionals *UpdateBusinessMetadataDefsOpts) ([]BusinessMetadataDefResponse, *_nethttp.Response, error)

	/*
	 * UpdateMode Update mode for the specified subject.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject Name of the Subject
	 * @param body Update Request
	 * @return ModeUpdateRequest
	 */
	UpdateMode(ctx _context.Context, subject string, body ModeUpdateRequest) (ModeUpdateRequest, *_nethttp.Response, error)

	/*
	 * UpdateSubjectLevelConfig Update compatibility level for the specified subject.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param subject Name of the Subject
	 * @param body Config Update Request
	 * @return ConfigUpdateRequest
	 */
	UpdateSubjectLevelConfig(ctx _context.Context, subject string, body ConfigUpdateRequest) (ConfigUpdateRequest, *_nethttp.Response, error)

	/*
	 * UpdateTagDefs Bulk update API for tag definitions.
	 *
	 * Bulk update API for tag definitions.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *UpdateTagDefsOpts - Optional Parameters:
	 * @param "TagDef" (optional.Interface of []TagDef) -  The tag definitions to update
	 * @return []TagDefResponse
	 */
	UpdateTagDefs(ctx _context.Context, localVarOptionals *UpdateTagDefsOpts) ([]TagDefResponse, *_nethttp.Response, error)

	/*
	 * UpdateTags Bulk API to update multiple tags.
	 *
	 * Bulk API to update multiple tags.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param optional nil or *UpdateTagsOpts - Optional Parameters:
	 * @param "Tag" (optional.Interface of []Tag) -  The tags
	 * @return []TagResponse
	 */
	UpdateTags(ctx _context.Context, localVarOptionals *UpdateTagsOpts) ([]TagResponse, *_nethttp.Response, error)

	/*
	 * UpdateTopLevelConfig Update global compatibility level
	 *
	 * Updates the global compatibility level. On success, echoes the original request back to the client.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param configUpdateRequest Config Update Request
	 * @return ConfigUpdateRequest
	 */
	UpdateTopLevelConfig(ctx _context.Context, configUpdateRequest ConfigUpdateRequest) (ConfigUpdateRequest, *_nethttp.Response, error)

	/*
	 * UpdateTopLevelMode Update global mode.
	 *
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param body Update Request
	 * @return ModeUpdateRequest
	 */
	UpdateTopLevelMode(ctx _context.Context, body ModeUpdateRequest) (ModeUpdateRequest, *_nethttp.Response, error)
}

type DefaultApiService 

type DefaultApiService service

DefaultApiService DefaultApi service

func (*DefaultApiService) AsyncapiParsePut added in v0.0.20 

func (a *DefaultApiService) AsyncapiParsePut(ctx _context.Context) (*_nethttp.Response, error)

* AsyncapiParsePut Method for AsyncapiParsePut * * Get number of times the cli tool is used to import and parse the spec file * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

func (*DefaultApiService) AsyncapiPut 

func (a *DefaultApiService) AsyncapiPut(ctx _context.Context) (*_nethttp.Response, error)

* AsyncapiPut Method for AsyncapiPut * * Get number of times the cli tool is used to export/produce the spec file * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

func (*DefaultApiService) CreateBusinessMetadata 

func (a *DefaultApiService) CreateBusinessMetadata(ctx _context.Context, localVarOptionals *CreateBusinessMetadataOpts) ([]BusinessMetadataResponse, *_nethttp.Response, error)

* CreateBusinessMetadata Bulk API to create multiple business metadata. * * Bulk API to create multiple business metadata. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *CreateBusinessMetadataOpts - Optional Parameters: * @param "BusinessMetadata" (optional.Interface of []BusinessMetadata) - The business metadata * @return []BusinessMetadataResponse

func (*DefaultApiService) CreateBusinessMetadataDefs 

func (a *DefaultApiService) CreateBusinessMetadataDefs(ctx _context.Context, localVarOptionals *CreateBusinessMetadataDefsOpts) ([]BusinessMetadataDefResponse, *_nethttp.Response, error)

* CreateBusinessMetadataDefs Bulk create API for business metadata definitions. * * Bulk create API for business metadata definitions. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *CreateBusinessMetadataDefsOpts - Optional Parameters: * @param "AtlasBusinessMetadataDef" (optional.Interface of []AtlasBusinessMetadataDef) - The business metadata definitions to create * @return []BusinessMetadataDefResponse

func (*DefaultApiService) CreateExporter 

func (a *DefaultApiService) CreateExporter(ctx _context.Context, body CreateExporterRequest) (CreateExporterResponse, *_nethttp.Response, error)

* CreateExporter Create an exporter. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param body Info * @return CreateExporterResponse

func (*DefaultApiService) CreateOrUpdate 

func (a *DefaultApiService) CreateOrUpdate(ctx _context.Context, localVarOptionals *CreateOrUpdateOpts) (*_nethttp.Response, error)

* CreateOrUpdate Method for CreateOrUpdate * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *CreateOrUpdateOpts - Optional Parameters: * @param "AtlasEntityWithExtInfo" (optional.Interface of AtlasEntityWithExtInfo) -

func (*DefaultApiService) CreateTagDefs 

func (a *DefaultApiService) CreateTagDefs(ctx _context.Context, localVarOptionals *CreateTagDefsOpts) ([]TagDefResponse, *_nethttp.Response, error)

* CreateTagDefs Bulk create API for tag definitions. * * Bulk create API for tag definitions. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *CreateTagDefsOpts - Optional Parameters: * @param "TagDef" (optional.Interface of []TagDef) - The tag definitions to create * @return []TagDefResponse

func (*DefaultApiService) CreateTags 

func (a *DefaultApiService) CreateTags(ctx _context.Context, localVarOptionals *CreateTagsOpts) ([]TagResponse, *_nethttp.Response, error)

* CreateTags Bulk API to create multiple tags. * * Bulk API to create multiple tags. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *CreateTagsOpts - Optional Parameters: * @param "Tag" (optional.Interface of []Tag) - The tags * @return []TagResponse

func (*DefaultApiService) DeleteBusinessMetadata 

func (a *DefaultApiService) DeleteBusinessMetadata(ctx _context.Context, typeName string, qualifiedName string, bmName string) (*_nethttp.Response, error)

* DeleteBusinessMetadata Delete a business metadata on an entity. * * Delete a business metadata on an entity. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param typeName The type of the entity * @param qualifiedName The qualified name of the entity * @param bmName The name of the business metadata

func (*DefaultApiService) DeleteBusinessMetadataDef 

func (a *DefaultApiService) DeleteBusinessMetadataDef(ctx _context.Context, bmName string) (*_nethttp.Response, error)

* DeleteBusinessMetadataDef Delete API for business metadata definition identified by its name. * * Delete API for business metadata definition identified by its name. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param bmName The name of the business metadata definition

func (*DefaultApiService) DeleteByUniqueAttributes 

func (a *DefaultApiService) DeleteByUniqueAttributes(ctx _context.Context, typeName string, qualifiedName string) (*_nethttp.Response, error)

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

func (*DefaultApiService) DeleteExporter 

func (a *DefaultApiService) DeleteExporter(ctx _context.Context, name string) (*_nethttp.Response, error)

* DeleteExporter Delete an exporter. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param name Name of the exporter

func (*DefaultApiService) DeleteSchemaVersion 

func (a *DefaultApiService) DeleteSchemaVersion(ctx _context.Context, subject string, version string, localVarOptionals *DeleteSchemaVersionOpts) (int32, *_nethttp.Response, error)

* DeleteSchemaVersion Deletes a specific version of the schema registered under this subject. This only deletes the version and the schema ID remains intact making it still possible to decode data using the schema ID. This API is recommended to be used only in development environments or under extreme circumstances where-in, its required to delete a previously registered schema for compatibility purposes or re-register previously registered schema. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject Name of the Subject * @param version Version of the schema to be returned. Valid values for versionId are between [1,2^31-1] or the string \"latest\". \"latest\" returns the last registered schema under the specified subject. Note that there may be a new latest schema that gets registered right after this request is served. * @param optional nil or *DeleteSchemaVersionOpts - Optional Parameters: * @param "Permanent" (optional.Bool) - * @return int32

func (*DefaultApiService) DeleteSubject 

func (a *DefaultApiService) DeleteSubject(ctx _context.Context, subject string, localVarOptionals *DeleteSubjectOpts) ([]int32, *_nethttp.Response, error)

* DeleteSubject Deletes the specified subject and its associated compatibility level if registered. It is recommended to use this API only when a topic needs to be recycled or in development environment. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject the name of the subject * @param optional nil or *DeleteSubjectOpts - Optional Parameters: * @param "Permanent" (optional.Bool) - * @return []int32

func (*DefaultApiService) DeleteSubjectConfig 

func (a *DefaultApiService) DeleteSubjectConfig(ctx _context.Context, subject string) (string, *_nethttp.Response, error)

* DeleteSubjectConfig Deletes the specified subject-level compatibility level config and revert to the global default. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject the name of the subject * @return string

func (*DefaultApiService) DeleteSubjectMode 

func (a *DefaultApiService) DeleteSubjectMode(ctx _context.Context, subject string) (string, *_nethttp.Response, error)

* DeleteSubjectMode Deletes the specified subject-level mode and revert to the global default. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject the name of the subject * @return string

func (*DefaultApiService) DeleteTag 

func (a *DefaultApiService) DeleteTag(ctx _context.Context, typeName string, qualifiedName string, tagName string) (*_nethttp.Response, error)

* DeleteTag Delete a tag on an entity. * * Delete a tag on an entity. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param typeName The type of the entity * @param qualifiedName The qualified name of the entity * @param tagName The name of the tag

func (*DefaultApiService) DeleteTagDef 

func (a *DefaultApiService) DeleteTagDef(ctx _context.Context, tagName string) (*_nethttp.Response, error)

* DeleteTagDef Delete API for tag definition identified by its name. * * Delete API for tag definition identified by its name. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param tagName The name of the tag definition

func (*DefaultApiService) DeleteTopLevelConfig added in v0.0.21 

func (a *DefaultApiService) DeleteTopLevelConfig(ctx _context.Context) (string, *_nethttp.Response, error)

* DeleteTopLevelConfig Delete global compatibility level * * Deletes the global compatibility level config and reverts to the default. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return string

func (*DefaultApiService) Get 

func (a *DefaultApiService) Get(ctx _context.Context) (map[string]map[string]interface{}, *_nethttp.Response, error)

* Get Schema Registry Root Resource * * The Root resource is a no-op. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return map[string]map[string]interface{}

func (*DefaultApiService) GetAllBusinessMetadataDefs 

func (a *DefaultApiService) GetAllBusinessMetadataDefs(ctx _context.Context, localVarOptionals *GetAllBusinessMetadataDefsOpts) ([]BusinessMetadataDefResponse, *_nethttp.Response, error)

* GetAllBusinessMetadataDefs Bulk retrieval API for retrieving business metadata definitions. * * Bulk retrieval API for retrieving business metadata definitions. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *GetAllBusinessMetadataDefsOpts - Optional Parameters: * @param "Prefix" (optional.String) - The prefix of a business metadata definition name * @return []BusinessMetadataDefResponse

func (*DefaultApiService) GetAllTagDefs 

func (a *DefaultApiService) GetAllTagDefs(ctx _context.Context, localVarOptionals *GetAllTagDefsOpts) ([]TagDefResponse, *_nethttp.Response, error)

* GetAllTagDefs Bulk retrieval API for retrieving tag definitions. * * Bulk retrieval API for retrieving tag definitions. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *GetAllTagDefsOpts - Optional Parameters: * @param "Prefix" (optional.String) - The prefix of a tag definition name * @return []TagDefResponse

func (*DefaultApiService) GetBusinessMetadata 

func (a *DefaultApiService) GetBusinessMetadata(ctx _context.Context, typeName string, qualifiedName string) ([]BusinessMetadataResponse, *_nethttp.Response, error)

* GetBusinessMetadata Gets the list of business metadata for a given entity represented by a qualified name. * * Gets the list of business metadata for a given entity represented by a qualified name. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param typeName The type of the entity * @param qualifiedName The qualified name of the entity * @return []BusinessMetadataResponse

func (*DefaultApiService) GetBusinessMetadataDefByName 

func (a *DefaultApiService) GetBusinessMetadataDefByName(ctx _context.Context, bmName string) (AtlasBusinessMetadataDef, *_nethttp.Response, error)

* GetBusinessMetadataDefByName Get the business metadata definition with the given name. * * Get the business metadata definition with the given name. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param bmName The name of the business metadata definition * @return AtlasBusinessMetadataDef

func (*DefaultApiService) GetByUniqueAttributes 

func (a *DefaultApiService) GetByUniqueAttributes(ctx _context.Context, typeName string, qualifiedName string, localVarOptionals *GetByUniqueAttributesOpts) (AtlasEntityWithExtInfo, *_nethttp.Response, error)

* GetByUniqueAttributes Fetch complete definition of an entity given its type and unique attribute. * * Fetch complete definition of an entity given its type and unique attribute. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param typeName The type of the entity * @param qualifiedName The qualified name of the entity * @param optional nil or *GetByUniqueAttributesOpts - Optional Parameters: * @param "MinExtInfo" (optional.Bool) - Whether to only populate header and schema attributes * @param "IgnoreRelationships" (optional.Bool) - Whether to ignore relationships * @param "IncludeInternalPrefix" (optional.String) - If not null, include internal attributes that start with this prefix * @return AtlasEntityWithExtInfo

func (*DefaultApiService) GetClusterId 

func (a *DefaultApiService) GetClusterId(ctx _context.Context) (ServerClusterId, *_nethttp.Response, error)

* GetClusterId Get the server metadata * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return ServerClusterId

func (*DefaultApiService) GetExporterConfig 

func (a *DefaultApiService) GetExporterConfig(ctx _context.Context, name string) (map[string]string, *_nethttp.Response, error)

* GetExporterConfig Get the config for an exporter. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param name * @return map[string]string

func (*DefaultApiService) GetExporterInfo 

func (a *DefaultApiService) GetExporterInfo(ctx _context.Context, name string) (ExporterInfo, *_nethttp.Response, error)

* GetExporterInfo Get the info for an exporter. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param name * @return ExporterInfo

func (*DefaultApiService) GetExporterStatus 

func (a *DefaultApiService) GetExporterStatus(ctx _context.Context, name string) (ExporterStatus, *_nethttp.Response, error)

* GetExporterStatus Get the status for an exporter. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param name * @return ExporterStatus

func (*DefaultApiService) GetExporters 

func (a *DefaultApiService) GetExporters(ctx _context.Context) ([]string, *_nethttp.Response, error)

* GetExporters Get a list of exporter names. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return []string

func (*DefaultApiService) GetMode 

func (a *DefaultApiService) GetMode(ctx _context.Context, subject string, localVarOptionals *GetModeOpts) (Mode, *_nethttp.Response, error)

* GetMode Get mode for a subject. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject Name of the Subject * @param optional nil or *GetModeOpts - Optional Parameters: * @param "DefaultToGlobal" (optional.Bool) - * @return Mode

func (*DefaultApiService) GetReferencedBy 

func (a *DefaultApiService) GetReferencedBy(ctx _context.Context, subject string, version string) ([]int32, *_nethttp.Response, error)

* GetReferencedBy Get the schemas that reference the specified schema. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject Name of the Subject * @param version Version of the schema to be returned. Valid values for versionId are between [1,2^31-1] or the string \"latest\". \"latest\" returns the last registered schema under the specified subject. Note that there may be a new latest schema that gets registered right after this request is served. * @return []int32

func (*DefaultApiService) GetSchema 

func (a *DefaultApiService) GetSchema(ctx _context.Context, id int32, localVarOptionals *GetSchemaOpts) (SchemaString, *_nethttp.Response, error)

* GetSchema Get the schema string identified by the input ID. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param id Globally unique identifier of the schema * @param optional nil or *GetSchemaOpts - Optional Parameters: * @param "Subject" (optional.String) - * @param "Format" (optional.String) - * @param "FetchMaxId" (optional.Bool) - * @return SchemaString

func (*DefaultApiService) GetSchemaByVersion 

func (a *DefaultApiService) GetSchemaByVersion(ctx _context.Context, subject string, version string, localVarOptionals *GetSchemaByVersionOpts) (Schema, *_nethttp.Response, error)

* GetSchemaByVersion Get a specific version of the schema registered under this subject. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject Name of the Subject * @param version Version of the schema to be returned. Valid values for versionId are between [1,2^31-1] or the string \"latest\". \"latest\" returns the last registered schema under the specified subject. Note that there may be a new latest schema that gets registered right after this request is served. * @param optional nil or *GetSchemaByVersionOpts - Optional Parameters: * @param "Deleted" (optional.Bool) - * @return Schema

func (*DefaultApiService) GetSchemaOnly 

func (a *DefaultApiService) GetSchemaOnly(ctx _context.Context, subject string, version string, localVarOptionals *GetSchemaOnlyOpts) (string, *_nethttp.Response, error)

* GetSchemaOnly Get the schema for the specified version of this subject. The unescaped schema only is returned. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject Name of the Subject * @param version Version of the schema to be returned. Valid values for versionId are between [1,2^31-1] or the string \"latest\". \"latest\" returns the last registered schema under the specified subject. Note that there may be a new latest schema that gets registered right after this request is served. * @param optional nil or *GetSchemaOnlyOpts - Optional Parameters: * @param "Deleted" (optional.Bool) - * @return string

func (*DefaultApiService) GetSchemaTypes 

func (a *DefaultApiService) GetSchemaTypes(ctx _context.Context) ([]string, *_nethttp.Response, error)

* GetSchemaTypes Get the schema types supported by this registry. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return []string

func (*DefaultApiService) GetSchemas 

func (a *DefaultApiService) GetSchemas(ctx _context.Context, localVarOptionals *GetSchemasOpts) ([]Schema, *_nethttp.Response, error)

* GetSchemas Get the schemas. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *GetSchemasOpts - Optional Parameters: * @param "SubjectPrefix" (optional.String) - * @param "Deleted" (optional.Bool) - * @param "LatestOnly" (optional.Bool) - * @param "Offset" (optional.Int32) - * @param "Limit" (optional.Int32) - * @return []Schema

func (*DefaultApiService) GetSubjectLevelConfig 

func (a *DefaultApiService) GetSubjectLevelConfig(ctx _context.Context, subject string, localVarOptionals *GetSubjectLevelConfigOpts) (Config, *_nethttp.Response, error)

* GetSubjectLevelConfig Get compatibility level for a subject. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject * @param optional nil or *GetSubjectLevelConfigOpts - Optional Parameters: * @param "DefaultToGlobal" (optional.Bool) - * @return Config

func (*DefaultApiService) GetSubjects 

func (a *DefaultApiService) GetSubjects(ctx _context.Context, id int32, localVarOptionals *GetSubjectsOpts) ([]string, *_nethttp.Response, error)

* GetSubjects Get all the subjects associated with the input ID. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param id Globally unique identifier of the schema * @param optional nil or *GetSubjectsOpts - Optional Parameters: * @param "Subject" (optional.String) - * @param "Deleted" (optional.Bool) - * @return []string

func (*DefaultApiService) GetTagDefByName 

func (a *DefaultApiService) GetTagDefByName(ctx _context.Context, tagName string) (TagDef, *_nethttp.Response, error)

* GetTagDefByName Get the tag definition with the given name. * * Get the tag definition with the given name. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param tagName The name of the tag definiton * @return TagDef

func (*DefaultApiService) GetTags 

func (a *DefaultApiService) GetTags(ctx _context.Context, typeName string, qualifiedName string) ([]TagResponse, *_nethttp.Response, error)

* GetTags Gets the list of classifications for a given entity represented by a qualifed name. * * Gets the list of classifications for a given entity represented by a qualifed name. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param typeName The type of the entity * @param qualifiedName The qualified name of the entity * @return []TagResponse

func (*DefaultApiService) GetTopLevelConfig 

func (a *DefaultApiService) GetTopLevelConfig(ctx _context.Context) (Config, *_nethttp.Response, error)

* GetTopLevelConfig Get global compatibility level * * Retrieves the global compatibility level. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return Config

func (*DefaultApiService) GetTopLevelMode 

func (a *DefaultApiService) GetTopLevelMode(ctx _context.Context) (Mode, *_nethttp.Response, error)

* GetTopLevelMode Get global mode. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return Mode

func (*DefaultApiService) GetVersions 

func (a *DefaultApiService) GetVersions(ctx _context.Context, id int32, localVarOptionals *GetVersionsOpts) ([]SubjectVersion, *_nethttp.Response, error)

* GetVersions Get all the subject-version pairs associated with the input ID. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param id Globally unique identifier of the schema * @param optional nil or *GetVersionsOpts - Optional Parameters: * @param "Subject" (optional.String) - * @param "Deleted" (optional.Bool) - * @return []SubjectVersion

func (*DefaultApiService) List 

func (a *DefaultApiService) List(ctx _context.Context, localVarOptionals *ListOpts) ([]string, *_nethttp.Response, error)

* List Get a list of registered subjects. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *ListOpts - Optional Parameters: * @param "SubjectPrefix" (optional.String) - * @param "Deleted" (optional.Bool) - * @param "DeletedOnly" (optional.Bool) - Whether to return deleted subjects only * @return []string

func (*DefaultApiService) ListContexts 

func (a *DefaultApiService) ListContexts(ctx _context.Context) ([]string, *_nethttp.Response, error)

* ListContexts Get a list of contexts. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return []string

func (*DefaultApiService) ListVersions 

func (a *DefaultApiService) ListVersions(ctx _context.Context, subject string, localVarOptionals *ListVersionsOpts) ([]int32, *_nethttp.Response, error)

* ListVersions Get a list of versions registered under the specified subject. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject Name of the Subject * @param optional nil or *ListVersionsOpts - Optional Parameters: * @param "Deleted" (optional.Bool) - * @param "DeletedOnly" (optional.Bool) - Whether to return deleted schemas only * @return []int32

func (*DefaultApiService) LookUpSchemaUnderSubject 

func (a *DefaultApiService) LookUpSchemaUnderSubject(ctx _context.Context, subject string, body RegisterSchemaRequest, localVarOptionals *LookUpSchemaUnderSubjectOpts) (*_nethttp.Response, error)

* LookUpSchemaUnderSubject Check if a schema has already been registered under the specified subject. If so, this returns the schema string along with its globally unique identifier, its version under this subject and the subject name. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject Subject under which the schema will be registered * @param body Schema * @param optional nil or *LookUpSchemaUnderSubjectOpts - Optional Parameters: * @param "Deleted" (optional.Bool) -

func (*DefaultApiService) PartialUpdateByUniqueAttributes 

func (a *DefaultApiService) PartialUpdateByUniqueAttributes(ctx _context.Context, localVarOptionals *PartialUpdateByUniqueAttributesOpts) (*_nethttp.Response, error)

* PartialUpdateByUniqueAttributes Method for PartialUpdateByUniqueAttributes * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *PartialUpdateByUniqueAttributesOpts - Optional Parameters: * @param "AtlasEntityWithExtInfo" (optional.Interface of AtlasEntityWithExtInfo) -

func (*DefaultApiService) PauseExporter 

func (a *DefaultApiService) PauseExporter(ctx _context.Context, name string) (UpdateExporterResponse, *_nethttp.Response, error)

* PauseExporter Pause an exporter. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param name Name of the exporter * @return UpdateExporterResponse

func (*DefaultApiService) Post 

func (a *DefaultApiService) Post(ctx _context.Context) (map[string]string, *_nethttp.Response, error)

* Post Method for Post * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return map[string]string

func (*DefaultApiService) PutExporter 

func (a *DefaultApiService) PutExporter(ctx _context.Context, name string, body UpdateExporterRequest) (UpdateExporterResponse, *_nethttp.Response, error)

* PutExporter Alters an exporter. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param name Name of the exporter * @param body Info * @return UpdateExporterResponse

func (*DefaultApiService) PutExporterConfig 

func (a *DefaultApiService) PutExporterConfig(ctx _context.Context, name string, body map[string]string) (UpdateExporterResponse, *_nethttp.Response, error)

* PutExporterConfig Alters the config of an exporter. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param name Name of the exporter * @param body Config * @return UpdateExporterResponse

func (*DefaultApiService) Register 

func (a *DefaultApiService) Register(ctx _context.Context, subject string, body RegisterSchemaRequest, localVarOptionals *RegisterOpts) (RegisterSchemaResponse, *_nethttp.Response, error)

* Register Register schema under a subject * * Register a new schema under the specified subject. If successfully registered, this returns the unique identifier of this schema in the registry. The returned identifier should be used to retrieve this schema from the schemas resource and is different from the schema's version which is associated with the subject. If the same schema is registered under a different subject, the same identifier will be returned. However, the version of the schema may be different under different subjects. A schema should be compatible with the previously registered schema or schemas (if there are any) as per the configured compatibility level. The configured compatibility level can be obtained by issuing a GET http:get:: /config/(string: subject). If that returns null, then GET http:get:: /config When there are multiple instances of Schema Registry running in the same cluster, the schema registration request will be forwarded to one of the instances designated as the primary. If the primary is not available, the client will get an error code indicating that the forwarding has failed. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject Name of the subject * @param body Schema * @param optional nil or *RegisterOpts - Optional Parameters: * @param "Normalize" (optional.Bool) - Whether to register the normalized schema * @return RegisterSchemaResponse

func (*DefaultApiService) ResetExporter 

func (a *DefaultApiService) ResetExporter(ctx _context.Context, name string) (UpdateExporterResponse, *_nethttp.Response, error)

* ResetExporter Reset an exporter. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param name Name of the exporter * @return UpdateExporterResponse

func (*DefaultApiService) ResumeExporter 

func (a *DefaultApiService) ResumeExporter(ctx _context.Context, name string) (UpdateExporterResponse, *_nethttp.Response, error)

* ResumeExporter Resume an exporter. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param name Name of the exporter * @return UpdateExporterResponse

func (*DefaultApiService) SearchUsingAttribute 

func (a *DefaultApiService) SearchUsingAttribute(ctx _context.Context, localVarOptionals *SearchUsingAttributeOpts) (SearchResult, *_nethttp.Response, error)

* SearchUsingAttribute Retrieve data for the specified attribute search query. * * Retrieve data for the specified attribute search query. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *SearchUsingAttributeOpts - Optional Parameters: * @param "Type_" (optional.Interface of []string) - Limit the result to only entities of specified types * @param "Types" (optional.String) - * @param "Attr" (optional.Interface of []string) - One of more additional attributes to return in the response * @param "Attrs" (optional.String) - * @param "AttrName" (optional.Interface of []string) - The attribute to search * @param "AttrValuePrefix" (optional.Interface of []string) - The prefix for the attribute value to search * @param "Tag" (optional.Interface of []string) - Limit the result to only entities tagged with the given tag * @param "TimeRangeType" (optional.String) - The type of time range search, default is CUSTOM * @param "TimeRangeAttr" (optional.String) - The attribute for a time range search * @param "TimeRangeStart" (optional.Int64) - The start for a custom time range search in ms since the epoch * @param "TimeRangeEnd" (optional.Int64) - The end for a custom time range search in ms since the epoch * @param "SortBy" (optional.String) - An attribute to sort by * @param "SortOrder" (optional.String) - Sort order, either ASCENDING (default) or DESCENDING * @param "Deleted" (optional.Bool) - Whether to include deleted entities * @param "Limit" (optional.Int32) - Limit the result set to only include the specified number of entries * @param "Offset" (optional.Int32) - Start offset of the result set (useful for pagination) * @return SearchResult

func (*DefaultApiService) SearchUsingBasic 

func (a *DefaultApiService) SearchUsingBasic(ctx _context.Context, localVarOptionals *SearchUsingBasicOpts) (SearchResult, *_nethttp.Response, error)

* SearchUsingBasic Retrieve data for the specified fulltext query. * * Retrieve data for the specified fulltext query. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *SearchUsingBasicOpts - Optional Parameters: * @param "Query" (optional.String) - The full-text query * @param "Type_" (optional.Interface of []string) - Limit the result to only entities of specified types * @param "Types" (optional.String) - * @param "Attr" (optional.Interface of []string) - One of more additional attributes to return in the response * @param "Attrs" (optional.String) - * @param "Tag" (optional.Interface of []string) - Limit the result to only entities with the given tag * @param "TimeRangeType" (optional.String) - The type of time range search, default is CUSTOM * @param "TimeRangeAttr" (optional.String) - The attribute for a time range search * @param "TimeRangeStart" (optional.Int64) - The start for a custom time range search in ms since the epoch * @param "TimeRangeEnd" (optional.Int64) - The end for a custom time range search in ms since the epoch * @param "SortBy" (optional.String) - An attribute to sort by * @param "SortOrder" (optional.String) - Sort order, either ASCENDING (default) or DESCENDING * @param "Deleted" (optional.Bool) - Whether to include deleted entities * @param "Limit" (optional.Int32) - Limit the result set to only include the specified number of entries * @param "Offset" (optional.Int32) - Start offset of the result set (useful for pagination) * @return SearchResult

func (*DefaultApiService) TestCompatibilityBySubjectName 

func (a *DefaultApiService) TestCompatibilityBySubjectName(ctx _context.Context, subject string, version string, body RegisterSchemaRequest, localVarOptionals *TestCompatibilityBySubjectNameOpts) (CompatibilityCheckResponse, *_nethttp.Response, error)

* TestCompatibilityBySubjectName Test input schema against a particular version of a subject's schema for compatibility. * * the compatibility level applied for the check is the configured compatibility level for the subject (http:get:: /config/(string: subject)). If this subject's compatibility level was never changed, then the global compatibility level applies (http:get:: /config). * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject Subject of the schema version against which compatibility is to be tested * @param version Version of the subject's schema against which compatibility is to be tested. Valid values for versionId are between [1,2^31-1] or the string \"latest\".\"latest\" checks compatibility of the input schema with the last registered schema under the specified subject * @param body Schema * @param optional nil or *TestCompatibilityBySubjectNameOpts - Optional Parameters: * @param "ContentType" (optional.String) - * @param "Accept" (optional.String) - * @param "Verbose" (optional.Bool) - * @return CompatibilityCheckResponse

func (*DefaultApiService) TestCompatibilityForSubject 

func (a *DefaultApiService) TestCompatibilityForSubject(ctx _context.Context, subject string, body RegisterSchemaRequest, localVarOptionals *TestCompatibilityForSubjectOpts) (CompatibilityCheckResponse, *_nethttp.Response, error)

* TestCompatibilityForSubject Test input schema against a subject's schemas for compatibility, based on the compatibility level of the subject configured. In other word, it will perform the same compatibility check as register for that subject * * the compatibility level applied for the check is the configured compatibility level for the subject (http:get:: /config/(string: subject)). If this subject's compatibility level was never changed, then the global compatibility level applies (http:get:: /config). * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject Subject of the schema version against which compatibility is to be tested * @param body Schema * @param optional nil or *TestCompatibilityForSubjectOpts - Optional Parameters: * @param "ContentType" (optional.String) - * @param "Accept" (optional.String) - * @param "Verbose" (optional.Bool) - * @return CompatibilityCheckResponse

func (*DefaultApiService) UpdateBusinessMetadata 

func (a *DefaultApiService) UpdateBusinessMetadata(ctx _context.Context, localVarOptionals *UpdateBusinessMetadataOpts) ([]BusinessMetadataResponse, *_nethttp.Response, error)

* UpdateBusinessMetadata Bulk API to update multiple business metadata. * * Bulk API to update multiple business metadata. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *UpdateBusinessMetadataOpts - Optional Parameters: * @param "BusinessMetadata" (optional.Interface of []BusinessMetadata) - The business metadata * @return []BusinessMetadataResponse

func (*DefaultApiService) UpdateBusinessMetadataDefs 

func (a *DefaultApiService) UpdateBusinessMetadataDefs(ctx _context.Context, localVarOptionals *UpdateBusinessMetadataDefsOpts) ([]BusinessMetadataDefResponse, *_nethttp.Response, error)

* UpdateBusinessMetadataDefs Bulk update API for business metadata definitions. * * Bulk update API for business metadata definitions. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *UpdateBusinessMetadataDefsOpts - Optional Parameters: * @param "AtlasBusinessMetadataDef" (optional.Interface of []AtlasBusinessMetadataDef) - The business metadata definitions to update * @return []BusinessMetadataDefResponse

func (*DefaultApiService) UpdateMode 

func (a *DefaultApiService) UpdateMode(ctx _context.Context, subject string, body ModeUpdateRequest) (ModeUpdateRequest, *_nethttp.Response, error)

* UpdateMode Update mode for the specified subject. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject Name of the Subject * @param body Update Request * @return ModeUpdateRequest

func (*DefaultApiService) UpdateSubjectLevelConfig 

func (a *DefaultApiService) UpdateSubjectLevelConfig(ctx _context.Context, subject string, body ConfigUpdateRequest) (ConfigUpdateRequest, *_nethttp.Response, error)

* UpdateSubjectLevelConfig Update compatibility level for the specified subject. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param subject Name of the Subject * @param body Config Update Request * @return ConfigUpdateRequest

func (*DefaultApiService) UpdateTagDefs 

func (a *DefaultApiService) UpdateTagDefs(ctx _context.Context, localVarOptionals *UpdateTagDefsOpts) ([]TagDefResponse, *_nethttp.Response, error)

* UpdateTagDefs Bulk update API for tag definitions. * * Bulk update API for tag definitions. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *UpdateTagDefsOpts - Optional Parameters: * @param "TagDef" (optional.Interface of []TagDef) - The tag definitions to update * @return []TagDefResponse

func (*DefaultApiService) UpdateTags 

func (a *DefaultApiService) UpdateTags(ctx _context.Context, localVarOptionals *UpdateTagsOpts) ([]TagResponse, *_nethttp.Response, error)

* UpdateTags Bulk API to update multiple tags. * * Bulk API to update multiple tags. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param optional nil or *UpdateTagsOpts - Optional Parameters: * @param "Tag" (optional.Interface of []Tag) - The tags * @return []TagResponse

func (*DefaultApiService) UpdateTopLevelConfig 

func (a *DefaultApiService) UpdateTopLevelConfig(ctx _context.Context, configUpdateRequest ConfigUpdateRequest) (ConfigUpdateRequest, *_nethttp.Response, error)

* UpdateTopLevelConfig Update global compatibility level * * Updates the global compatibility level. On success, echoes the original request back to the client. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param configUpdateRequest Config Update Request * @return ConfigUpdateRequest

func (*DefaultApiService) UpdateTopLevelMode 

func (a *DefaultApiService) UpdateTopLevelMode(ctx _context.Context, body ModeUpdateRequest) (ModeUpdateRequest, *_nethttp.Response, error)

* UpdateTopLevelMode Update global mode. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param body Update Request * @return ModeUpdateRequest

type DeleteSchemaVersionOpts 

type DeleteSchemaVersionOpts struct {
	Permanent optional.Bool
}

DeleteSchemaVersionOpts Optional parameters for the method 'DeleteSchemaVersion'

type DeleteSubjectOpts 

type DeleteSubjectOpts struct {
	Permanent optional.Bool
}

DeleteSubjectOpts Optional parameters for the method 'DeleteSubject'

type ErrorMessage 

type ErrorMessage struct {
	ErrorCode int32  `json:"error_code,omitempty"`
	Message   string `json:"message,omitempty"`
}

ErrorMessage struct for ErrorMessage

type ExporterInfo 

type ExporterInfo struct {
	Name                string            `json:"name,omitempty"`
	Subjects            []string          `json:"subjects,omitempty"`
	ContextType         string            `json:"contextType,omitempty"`
	Context             string            `json:"context,omitempty"`
	SubjectRenameFormat string            `json:"subjectRenameFormat,omitempty"`
	Config              map[string]string `json:"config,omitempty"`
}

ExporterInfo struct for ExporterInfo

type ExporterStatus 

type ExporterStatus struct {
	Name   string `json:"name,omitempty"`
	State  string `json:"state,omitempty"`
	Offset int64  `json:"offset,omitempty"`
	Ts     int64  `json:"ts,omitempty"`
	Trace  string `json:"trace,omitempty"`
}

ExporterStatus struct for ExporterStatus

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 GetAllBusinessMetadataDefsOpts 

type GetAllBusinessMetadataDefsOpts struct {
	Prefix optional.String
}

GetAllBusinessMetadataDefsOpts Optional parameters for the method 'GetAllBusinessMetadataDefs'

type GetAllTagDefsOpts 

type GetAllTagDefsOpts struct {
	Prefix optional.String
}

GetAllTagDefsOpts Optional parameters for the method 'GetAllTagDefs'

type GetByUniqueAttributesOpts 

type GetByUniqueAttributesOpts struct {
	MinExtInfo            optional.Bool
	IgnoreRelationships   optional.Bool
	IncludeInternalPrefix optional.String
}

GetByUniqueAttributesOpts Optional parameters for the method 'GetByUniqueAttributes'

type GetModeOpts 

type GetModeOpts struct {
	DefaultToGlobal optional.Bool
}

GetModeOpts Optional parameters for the method 'GetMode'

type GetSchemaByVersionOpts 

type GetSchemaByVersionOpts struct {
	Deleted optional.Bool
}

GetSchemaByVersionOpts Optional parameters for the method 'GetSchemaByVersion'

type GetSchemaOnlyOpts 

type GetSchemaOnlyOpts struct {
	Deleted optional.Bool
}

GetSchemaOnlyOpts Optional parameters for the method 'GetSchemaOnly'

type GetSchemaOpts 

type GetSchemaOpts struct {
	Subject    optional.String
	Format     optional.String
	FetchMaxId optional.Bool
}

GetSchemaOpts Optional parameters for the method 'GetSchema'

type GetSchemasOpts 

type GetSchemasOpts struct {
	SubjectPrefix optional.String
	Deleted       optional.Bool
	LatestOnly    optional.Bool
	Offset        optional.Int32
	Limit         optional.Int32
}

GetSchemasOpts Optional parameters for the method 'GetSchemas'

type GetSubjectLevelConfigOpts 

type GetSubjectLevelConfigOpts struct {
	DefaultToGlobal optional.Bool
}

GetSubjectLevelConfigOpts Optional parameters for the method 'GetSubjectLevelConfig'

type GetSubjectsOpts 

type GetSubjectsOpts struct {
	Subject optional.String
	Deleted optional.Bool
}

GetSubjectsOpts Optional parameters for the method 'GetSubjects'

type GetVersionsOpts 

type GetVersionsOpts struct {
	Subject optional.String
	Deleted optional.Bool
}

GetVersionsOpts Optional parameters for the method 'GetVersions'

type ListOpts 

type ListOpts struct {
	SubjectPrefix optional.String
	Deleted       optional.Bool
	DeletedOnly   optional.Bool
}

ListOpts Optional parameters for the method 'List'

type ListVersionsOpts 

type ListVersionsOpts struct {
	Deleted     optional.Bool
	DeletedOnly optional.Bool
}

ListVersionsOpts Optional parameters for the method 'ListVersions'

type LookUpSchemaUnderSubjectOpts 

type LookUpSchemaUnderSubjectOpts struct {
	Deleted optional.Bool
}

LookUpSchemaUnderSubjectOpts Optional parameters for the method 'LookUpSchemaUnderSubject'

type Metadata added in v0.0.21 

type Metadata struct {
	Tags       map[string][]string `json:"tags,omitempty"`
	Properties map[string]string   `json:"properties,omitempty"`
	Sensitive  []string            `json:"sensitive,omitempty"`
}

Metadata User-defined metadata

type Mode 

type Mode struct {
	Mode string `json:"mode,omitempty"`
}

Mode struct for Mode

type ModeGetResponse 

type ModeGetResponse struct {
	Mode string `json:"mode,omitempty"`
}

type ModeUpdateRequest 

type ModeUpdateRequest struct {
	Mode string `json:"mode,omitempty"`
}

ModeUpdateRequest struct for ModeUpdateRequest

type NullableBool 

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

func NewNullableBool 

func NewNullableBool(val *bool) *NullableBool

func (NullableBool) Get 

func (v NullableBool) Get() *bool

func (NullableBool) IsSet 

func (v NullableBool) IsSet() bool

func (NullableBool) MarshalJSON 

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

func (*NullableBool) Set 

func (v *NullableBool) Set(val *bool)

func (*NullableBool) UnmarshalJSON 

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

func (*NullableBool) Unset 

func (v *NullableBool) Unset()

type NullableFloat32 

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

func NewNullableFloat32 

func NewNullableFloat32(val *float32) *NullableFloat32

func (NullableFloat32) Get 

func (v NullableFloat32) Get() *float32

func (NullableFloat32) IsSet 

func (v NullableFloat32) IsSet() bool

func (NullableFloat32) MarshalJSON 

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

func (*NullableFloat32) Set 

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

func (*NullableFloat32) UnmarshalJSON 

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

func (*NullableFloat32) Unset 

func (v *NullableFloat32) Unset()

type NullableFloat64 

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

func NewNullableFloat64 

func NewNullableFloat64(val *float64) *NullableFloat64

func (NullableFloat64) Get 

func (v NullableFloat64) Get() *float64

func (NullableFloat64) IsSet 

func (v NullableFloat64) IsSet() bool

func (NullableFloat64) MarshalJSON 

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

func (*NullableFloat64) Set 

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

func (*NullableFloat64) UnmarshalJSON 

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

func (*NullableFloat64) Unset 

func (v *NullableFloat64) Unset()

type NullableInt 

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

func NewNullableInt 

func NewNullableInt(val *int) *NullableInt

func (NullableInt) Get 

func (v NullableInt) Get() *int

func (NullableInt) IsSet 

func (v NullableInt) IsSet() bool

func (NullableInt) MarshalJSON 

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

func (*NullableInt) Set 

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

func (*NullableInt) UnmarshalJSON 

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

func (*NullableInt) Unset 

func (v *NullableInt) Unset()

type NullableInt32 

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

func NewNullableInt32 

func NewNullableInt32(val *int32) *NullableInt32

func (NullableInt32) Get 

func (v NullableInt32) Get() *int32

func (NullableInt32) IsSet 

func (v NullableInt32) IsSet() bool

func (NullableInt32) MarshalJSON 

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

func (*NullableInt32) Set 

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

func (*NullableInt32) UnmarshalJSON 

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

func (*NullableInt32) Unset 

func (v *NullableInt32) Unset()

type NullableInt64 

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

func NewNullableInt64 

func NewNullableInt64(val *int64) *NullableInt64

func (NullableInt64) Get 

func (v NullableInt64) Get() *int64

func (NullableInt64) IsSet 

func (v NullableInt64) IsSet() bool

func (NullableInt64) MarshalJSON 

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

func (*NullableInt64) Set 

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

func (*NullableInt64) UnmarshalJSON 

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

func (*NullableInt64) Unset 

func (v *NullableInt64) Unset()

type NullableString 

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

func NewNullableString 

func NewNullableString(val *string) *NullableString

func (NullableString) Get 

func (v NullableString) Get() *string

func (NullableString) IsSet 

func (v NullableString) IsSet() bool

func (NullableString) MarshalJSON 

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

func (*NullableString) Set 

func (v *NullableString) Set(val *string)

func (*NullableString) UnmarshalJSON 

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

func (*NullableString) Unset 

func (v *NullableString) Unset()

type NullableTime 

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

func NewNullableTime 

func NewNullableTime(val *time.Time) *NullableTime

func (NullableTime) Get 

func (v NullableTime) Get() *time.Time

func (NullableTime) IsSet 

func (v NullableTime) IsSet() bool

func (NullableTime) MarshalJSON 

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

func (*NullableTime) Set 

func (v *NullableTime) Set(val *time.Time)

func (*NullableTime) UnmarshalJSON 

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

func (*NullableTime) Unset 

func (v *NullableTime) Unset()

type PartialUpdateByUniqueAttributesOpts 

type PartialUpdateByUniqueAttributesOpts struct {
	AtlasEntityWithExtInfo optional.Interface
}

PartialUpdateByUniqueAttributesOpts Optional parameters for the method 'PartialUpdateByUniqueAttributes'

type RegisterOpts added in v0.0.21 

type RegisterOpts struct {
	Normalize optional.Bool
}

RegisterOpts Optional parameters for the method 'Register'

type RegisterSchemaRequest 

type RegisterSchemaRequest struct {
	// Version number
	Version int32 `json:"version,omitempty"`
	// Globally unique identifier of the schema
	Id int32 `json:"id,omitempty"`
	// Schema type
	SchemaType string `json:"schemaType,omitempty"`
	// References to other schemas
	References []SchemaReference `json:"references,omitempty"`
	Metadata   *Metadata         `json:"metadata,omitempty"`
	RuleSet    *RuleSet          `json:"ruleSet,omitempty"`
	// Schema definition string
	Schema string `json:"schema,omitempty"`
}

RegisterSchemaRequest Schema register request

type RegisterSchemaResponse 

type RegisterSchemaResponse struct {
	// Globally unique identifier of the schema
	Id int32 `json:"id,omitempty"`
}

RegisterSchemaResponse Schema register response

type Rule added in v0.0.21 

type Rule struct {
	// Rule name
	Name string `json:"name,omitempty"`
	// Rule doc
	Doc string `json:"doc,omitempty"`
	// Rule kind
	Kind string `json:"kind,omitempty"`
	// Rule mode
	Mode string `json:"mode,omitempty"`
	// Rule type
	Type string `json:"type,omitempty"`
	// The tags to which this rule applies
	Tags []string `json:"tags,omitempty"`
	// Optional params for the rule
	Params map[string]string `json:"params,omitempty"`
	// Rule expression
	Expr string `json:"expr,omitempty"`
	// Rule action on success
	OnSuccess string `json:"onSuccess,omitempty"`
	// Rule action on failure
	OnFailure string `json:"onFailure,omitempty"`
	// Whether the rule is disabled
	Disabled bool `json:"disabled,omitempty"`
}

Rule Rule

type RuleSet added in v0.0.21 

type RuleSet struct {
	MigrationRules []Rule `json:"migrationRules,omitempty"`
	DomainRules    []Rule `json:"domainRules,omitempty"`
}

RuleSet Schema rule set

type Schema 

type Schema struct {
	Subject    string            `json:"subject,omitempty"`
	Version    int32             `json:"version,omitempty"`
	Id         int32             `json:"id,omitempty"`
	SchemaType string            `json:"schemaType,omitempty"`
	References []SchemaReference `json:"references,omitempty"`
	Schema     string            `json:"schema,omitempty"`
	Metadata   *Metadata         `json:"metadata,omitempty"`
	Ruleset    *RuleSet          `json:"ruleset,omitempty"`
}

Schema struct for Schema

type SchemaReference 

type SchemaReference struct {
	Name    string `json:"name,omitempty"`
	Subject string `json:"subject,omitempty"`
	Version int32  `json:"version,omitempty"`
}

SchemaReference struct for SchemaReference

type SchemaString 

type SchemaString struct {
	// Schema type
	SchemaType string `json:"schemaType,omitempty"`
	// Schema string identified by the ID
	Schema string `json:"schema,omitempty"`
	// Schema references
	References []SchemaReference `json:"references,omitempty"`
	Metadata   *Metadata         `json:"metadata,omitempty"`
	RuleSet    *RuleSet          `json:"ruleSet,omitempty"`
	// Maximum ID
	MaxId int32 `json:"maxId,omitempty"`
}

SchemaString struct for SchemaString

type SearchParams 

type SearchParams struct {
	IncludeDeleted bool  `json:"includeDeleted,omitempty"`
	Limit          int32 `json:"limit,omitempty"`
	Offset         int32 `json:"offset,omitempty"`
}

SearchParams struct for SearchParams

type SearchResult 

type SearchResult struct {
	SearchParameters SearchParams                 `json:"searchParameters,omitempty"`
	Types            []string                     `json:"types,omitempty"`
	Entities         []AtlasEntityHeader          `json:"entities,omitempty"`
	ReferredEntities map[string]AtlasEntityHeader `json:"referredEntities,omitempty"`
}

SearchResult struct for SearchResult

type SearchUsingAttributeOpts 

type SearchUsingAttributeOpts struct {
	Type_           optional.Interface
	Types           optional.String
	Attr            optional.Interface
	Attrs           optional.String
	AttrName        optional.Interface
	AttrValuePrefix optional.Interface
	Tag             optional.Interface
	TimeRangeType   optional.String
	TimeRangeAttr   optional.String
	TimeRangeStart  optional.Int64
	TimeRangeEnd    optional.Int64
	SortBy          optional.String
	SortOrder       optional.String
	Deleted         optional.Bool
	Limit           optional.Int32
	Offset          optional.Int32
}

SearchUsingAttributeOpts Optional parameters for the method 'SearchUsingAttribute'

type SearchUsingBasicOpts 

type SearchUsingBasicOpts struct {
	Query          optional.String
	Type_          optional.Interface
	Types          optional.String
	Attr           optional.Interface
	Attrs          optional.String
	Tag            optional.Interface
	TimeRangeType  optional.String
	TimeRangeAttr  optional.String
	TimeRangeStart optional.Int64
	TimeRangeEnd   optional.Int64
	SortBy         optional.String
	SortOrder      optional.String
	Deleted        optional.Bool
	Limit          optional.Int32
	Offset         optional.Int32
}

SearchUsingBasicOpts Optional parameters for the method 'SearchUsingBasic'

type ServerClusterId 

type ServerClusterId struct {
	Scope map[string]map[string]interface{} `json:"scope,omitempty"`
	Id    string                            `json:"id,omitempty"`
}

ServerClusterId struct for ServerClusterId

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 SubjectVersion 

type SubjectVersion struct {
	Subject string `json:"subject,omitempty"`
	Version int32  `json:"version,omitempty"`
}

SubjectVersion struct for SubjectVersion

type Tag 

type Tag struct {
	TypeName                         string                            `json:"typeName,omitempty"`
	Attributes                       map[string]map[string]interface{} `json:"attributes,omitempty"`
	EntityGuid                       string                            `json:"entityGuid,omitempty"`
	EntityStatus                     string                            `json:"entityStatus,omitempty"`
	Propagate                        bool                              `json:"propagate,omitempty"`
	ValidityPeriods                  []TimeBoundary                    `json:"validityPeriods,omitempty"`
	RemovePropagationsOnEntityDelete bool                              `json:"removePropagationsOnEntityDelete,omitempty"`
	EntityType                       string                            `json:"entityType,omitempty"`
	EntityName                       string                            `json:"entityName,omitempty"`
}

Tag struct for Tag

type TagDef 

type TagDef struct {
	Category      string              `json:"category,omitempty"`
	Guid          string              `json:"guid,omitempty"`
	CreatedBy     string              `json:"createdBy,omitempty"`
	UpdatedBy     string              `json:"updatedBy,omitempty"`
	CreateTime    int64               `json:"createTime,omitempty"`
	UpdateTime    int64               `json:"updateTime,omitempty"`
	Version       int64               `json:"version,omitempty"`
	Name          string              `json:"name,omitempty"`
	Description   string              `json:"description,omitempty"`
	TypeVersion   string              `json:"typeVersion,omitempty"`
	ServiceType   string              `json:"serviceType,omitempty"`
	Options       map[string]string   `json:"options,omitempty"`
	AttributeDefs []AtlasAttributeDef `json:"attributeDefs,omitempty"`
	SuperTypes    []string            `json:"superTypes,omitempty"`
	EntityTypes   []string            `json:"entityTypes,omitempty"`
	SubTypes      []string            `json:"subTypes,omitempty"`
}

TagDef struct for TagDef

type TagDefResponse 

type TagDefResponse struct {
	Category      string              `json:"category,omitempty"`
	Guid          string              `json:"guid,omitempty"`
	CreatedBy     string              `json:"createdBy,omitempty"`
	UpdatedBy     string              `json:"updatedBy,omitempty"`
	CreateTime    int64               `json:"createTime,omitempty"`
	UpdateTime    int64               `json:"updateTime,omitempty"`
	Version       int64               `json:"version,omitempty"`
	Name          string              `json:"name,omitempty"`
	Description   string              `json:"description,omitempty"`
	TypeVersion   string              `json:"typeVersion,omitempty"`
	ServiceType   string              `json:"serviceType,omitempty"`
	Options       map[string]string   `json:"options,omitempty"`
	AttributeDefs []AtlasAttributeDef `json:"attributeDefs,omitempty"`
	SuperTypes    []string            `json:"superTypes,omitempty"`
	EntityTypes   []string            `json:"entityTypes,omitempty"`
	SubTypes      []string            `json:"subTypes,omitempty"`
	Error         ErrorMessage        `json:"error,omitempty"`
}

TagDefResponse struct for TagDefResponse

type TagResponse 

type TagResponse struct {
	TypeName                         string                            `json:"typeName,omitempty"`
	Attributes                       map[string]map[string]interface{} `json:"attributes,omitempty"`
	EntityGuid                       string                            `json:"entityGuid,omitempty"`
	EntityStatus                     string                            `json:"entityStatus,omitempty"`
	Propagate                        bool                              `json:"propagate,omitempty"`
	ValidityPeriods                  []TimeBoundary                    `json:"validityPeriods,omitempty"`
	RemovePropagationsOnEntityDelete bool                              `json:"removePropagationsOnEntityDelete,omitempty"`
	EntityType                       string                            `json:"entityType,omitempty"`
	EntityName                       string                            `json:"entityName,omitempty"`
	Error                            ErrorMessage                      `json:"error,omitempty"`
}

TagResponse struct for TagResponse

type TestCompatibilityBySubjectNameOpts 

type TestCompatibilityBySubjectNameOpts struct {
	ContentType optional.String
	Accept      optional.String
	Verbose     optional.Bool
}

TestCompatibilityBySubjectNameOpts Optional parameters for the method 'TestCompatibilityBySubjectName'

type TestCompatibilityForSubjectOpts 

type TestCompatibilityForSubjectOpts struct {
	ContentType optional.String
	Accept      optional.String
	Verbose     optional.Bool
}

TestCompatibilityForSubjectOpts Optional parameters for the method 'TestCompatibilityForSubject'

type TimeBoundary 

type TimeBoundary struct {
	StartTime string `json:"startTime,omitempty"`
	EndTime   string `json:"endTime,omitempty"`
	TimeZone  string `json:"timeZone,omitempty"`
}

TimeBoundary struct for TimeBoundary

type UpdateBusinessMetadataDefsOpts 

type UpdateBusinessMetadataDefsOpts struct {
	AtlasBusinessMetadataDef optional.Interface
}

UpdateBusinessMetadataDefsOpts Optional parameters for the method 'UpdateBusinessMetadataDefs'

type UpdateBusinessMetadataOpts 

type UpdateBusinessMetadataOpts struct {
	BusinessMetadata optional.Interface
}

UpdateBusinessMetadataOpts Optional parameters for the method 'UpdateBusinessMetadata'

type UpdateExporterRequest 

type UpdateExporterRequest struct {
	Subjects            []string          `json:"subjects,omitempty"`
	ContextType         string            `json:"contextType,omitempty"`
	Context             string            `json:"context,omitempty"`
	SubjectRenameFormat string            `json:"subjectRenameFormat,omitempty"`
	Config              map[string]string `json:"config,omitempty"`
}

UpdateExporterRequest struct for UpdateExporterRequest

type UpdateExporterResponse 

type UpdateExporterResponse struct {
	Name string `json:"name,omitempty"`
}

UpdateExporterResponse struct for UpdateExporterResponse

type UpdateTagDefsOpts 

type UpdateTagDefsOpts struct {
	TagDef optional.Interface
}

UpdateTagDefsOpts Optional parameters for the method 'UpdateTagDefs'

type UpdateTagsOpts 

type UpdateTagsOpts struct {
	Tag optional.Interface
}

UpdateTagsOpts Optional parameters for the method 'UpdateTags'

Source Files

View all Source files

Directories

Path Synopsis

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.