operations

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Aug 30, 2020 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

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

Client for operations API

func (*Client) DeleteSchemaVersion 

func (a *Client) DeleteSchemaVersion(params *DeleteSchemaVersionParams) (*DeleteSchemaVersionOK, 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

func (*Client) DeleteSubject 

func (a *Client) DeleteSubject(params *DeleteSubjectParams) (*DeleteSubjectOK, 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

func (*Client) Get 

func (a *Client) Get(params *GetParams) (*GetOK, error)

Get schemas registry root resource

The Root resource is a no-op.

func (*Client) GetClusterID 

func (a *Client) GetClusterID(params *GetClusterIDParams) (*GetClusterIDOK, error)

GetClusterID gets the server metadata

func (*Client) GetMode 

func (a *Client) GetMode(params *GetModeParams) (*GetModeOK, error)

GetMode get mode API

func (*Client) GetReferencedBy 

func (a *Client) GetReferencedBy(params *GetReferencedByParams) (*GetReferencedByOK, error)

GetReferencedBy gets the schemas that reference the specified schema

func (*Client) GetSchema 

func (a *Client) GetSchema(params *GetSchemaParams) (*GetSchemaOK, error)

GetSchema gets the schema string identified by the input ID

func (*Client) GetSchemaByVersion 

func (a *Client) GetSchemaByVersion(params *GetSchemaByVersionParams) (*GetSchemaByVersionOK, error)

GetSchemaByVersion gets a specific version of the schema registered under this subject

func (*Client) GetSchemaOnly 

func (a *Client) GetSchemaOnly(params *GetSchemaOnlyParams) (*GetSchemaOnlyOK, error)

GetSchemaOnly gets the schema for the specified version of this subject the unescaped schema only is returned

func (*Client) GetSchemaTypes 

func (a *Client) GetSchemaTypes(params *GetSchemaTypesParams) (*GetSchemaTypesOK, error)

GetSchemaTypes gets the schema types supported by this registry

func (*Client) GetSchemas 

func (a *Client) GetSchemas(params *GetSchemasParams) (*GetSchemasOK, error)

GetSchemas gets the schemas

func (*Client) GetSubjectLevelConfig 

func (a *Client) GetSubjectLevelConfig(params *GetSubjectLevelConfigParams) (*GetSubjectLevelConfigOK, error)

GetSubjectLevelConfig gets compatibility level for a subject

func (*Client) GetSubjects 

func (a *Client) GetSubjects(params *GetSubjectsParams) (*GetSubjectsOK, error)

GetSubjects gets all the subjects associated with the input ID

func (*Client) GetTopLevelConfig 

func (a *Client) GetTopLevelConfig(params *GetTopLevelConfigParams) (*GetTopLevelConfigOK, error)

GetTopLevelConfig gets global compatibility level

func (*Client) GetTopLevelMode 

func (a *Client) GetTopLevelMode(params *GetTopLevelModeParams) (*GetTopLevelModeOK, error)

GetTopLevelMode get top level mode API

func (*Client) GetVersions 

func (a *Client) GetVersions(params *GetVersionsParams) (*GetVersionsOK, error)

GetVersions gets all the subject version pairs associated with the input ID

func (*Client) List 

func (a *Client) List(params *ListParams) (*ListOK, error)

List gets a list of registered subjects

func (*Client) ListVersions 

func (a *Client) ListVersions(params *ListVersionsParams) (*ListVersionsOK, error)

ListVersions gets a list of versions registered under the specified subject

func (*Client) LookUpSchemaUnderSubject 

func (a *Client) LookUpSchemaUnderSubject(params *LookUpSchemaUnderSubjectParams) error

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

func (*Client) Post 

func (a *Client) Post(params *PostParams) (*PostOK, error)

Post post API

func (*Client) Register 

func (a *Client) Register(params *RegisterParams) (*RegisterOK, error)

Register registers 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 g e t http get config string subject if that returns null then g e t 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

func (*Client) SetTransport 

func (a *Client) SetTransport(transport runtime.ClientTransport)

SetTransport changes the transport on the client

func (*Client) TestCompatibilityBySubjectName 

func (a *Client) TestCompatibilityBySubjectName(params *TestCompatibilityBySubjectNameParams) (*TestCompatibilityBySubjectNameOK, error)

TestCompatibilityBySubjectName tests 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).

func (*Client) UpdateMode 

func (a *Client) UpdateMode(params *UpdateModeParams) (*UpdateModeOK, error)

UpdateMode update mode API

func (*Client) UpdateSubjectLevelConfig 

func (a *Client) UpdateSubjectLevelConfig(params *UpdateSubjectLevelConfigParams) (*UpdateSubjectLevelConfigOK, error)

UpdateSubjectLevelConfig updates compatibility level for the specified subject

func (*Client) UpdateTopLevelConfig 

func (a *Client) UpdateTopLevelConfig(params *UpdateTopLevelConfigParams) (*UpdateTopLevelConfigOK, error)

UpdateTopLevelConfig updates global compatibility level

func (*Client) UpdateTopLevelMode 

func (a *Client) UpdateTopLevelMode(params *UpdateTopLevelModeParams) (*UpdateTopLevelModeOK, error)

UpdateTopLevelMode update top level mode API

type ClientService 

type ClientService interface {
	DeleteSchemaVersion(params *DeleteSchemaVersionParams) (*DeleteSchemaVersionOK, error)

	DeleteSubject(params *DeleteSubjectParams) (*DeleteSubjectOK, error)

	Get(params *GetParams) (*GetOK, error)

	GetClusterID(params *GetClusterIDParams) (*GetClusterIDOK, error)

	GetMode(params *GetModeParams) (*GetModeOK, error)

	GetReferencedBy(params *GetReferencedByParams) (*GetReferencedByOK, error)

	GetSchema(params *GetSchemaParams) (*GetSchemaOK, error)

	GetSchemaByVersion(params *GetSchemaByVersionParams) (*GetSchemaByVersionOK, error)

	GetSchemaOnly(params *GetSchemaOnlyParams) (*GetSchemaOnlyOK, error)

	GetSchemaTypes(params *GetSchemaTypesParams) (*GetSchemaTypesOK, error)

	GetSchemas(params *GetSchemasParams) (*GetSchemasOK, error)

	GetSubjectLevelConfig(params *GetSubjectLevelConfigParams) (*GetSubjectLevelConfigOK, error)

	GetSubjects(params *GetSubjectsParams) (*GetSubjectsOK, error)

	GetTopLevelConfig(params *GetTopLevelConfigParams) (*GetTopLevelConfigOK, error)

	GetTopLevelMode(params *GetTopLevelModeParams) (*GetTopLevelModeOK, error)

	GetVersions(params *GetVersionsParams) (*GetVersionsOK, error)

	List(params *ListParams) (*ListOK, error)

	ListVersions(params *ListVersionsParams) (*ListVersionsOK, error)

	LookUpSchemaUnderSubject(params *LookUpSchemaUnderSubjectParams) error

	Post(params *PostParams) (*PostOK, error)

	Register(params *RegisterParams) (*RegisterOK, error)

	TestCompatibilityBySubjectName(params *TestCompatibilityBySubjectNameParams) (*TestCompatibilityBySubjectNameOK, error)

	UpdateMode(params *UpdateModeParams) (*UpdateModeOK, error)

	UpdateSubjectLevelConfig(params *UpdateSubjectLevelConfigParams) (*UpdateSubjectLevelConfigOK, error)

	UpdateTopLevelConfig(params *UpdateTopLevelConfigParams) (*UpdateTopLevelConfigOK, error)

	UpdateTopLevelMode(params *UpdateTopLevelModeParams) (*UpdateTopLevelModeOK, error)

	SetTransport(transport runtime.ClientTransport)
}

ClientService is the interface for Client methods

func New 

func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientService

New creates a new operations API client.

type DeleteSchemaVersionInternalServerError 

type DeleteSchemaVersionInternalServerError struct {
}

DeleteSchemaVersionInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store

func NewDeleteSchemaVersionInternalServerError 

func NewDeleteSchemaVersionInternalServerError() *DeleteSchemaVersionInternalServerError

NewDeleteSchemaVersionInternalServerError creates a DeleteSchemaVersionInternalServerError with default headers values

func (*DeleteSchemaVersionInternalServerError) Error 

func (o *DeleteSchemaVersionInternalServerError) Error() string

type DeleteSchemaVersionNotFound 

type DeleteSchemaVersionNotFound struct {
}

DeleteSchemaVersionNotFound handles this case with default header values.

Error code 40401 -- Subject not found Error code 40402 -- Version not found

func NewDeleteSchemaVersionNotFound 

func NewDeleteSchemaVersionNotFound() *DeleteSchemaVersionNotFound

NewDeleteSchemaVersionNotFound creates a DeleteSchemaVersionNotFound with default headers values

func (*DeleteSchemaVersionNotFound) Error 

func (o *DeleteSchemaVersionNotFound) Error() string

type DeleteSchemaVersionOK 

type DeleteSchemaVersionOK struct {
	Payload int32
}

DeleteSchemaVersionOK handles this case with default header values.

successful operation

func NewDeleteSchemaVersionOK 

func NewDeleteSchemaVersionOK() *DeleteSchemaVersionOK

NewDeleteSchemaVersionOK creates a DeleteSchemaVersionOK with default headers values

func (*DeleteSchemaVersionOK) Error 

func (o *DeleteSchemaVersionOK) Error() string

func (*DeleteSchemaVersionOK) GetPayload 

func (o *DeleteSchemaVersionOK) GetPayload() int32

type DeleteSchemaVersionParams 

type DeleteSchemaVersionParams struct {

	/*Permanent*/
	Permanent *bool
	/*Subject
	  Name of the Subject

	*/
	Subject string
	/*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.

	*/
	Version string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

DeleteSchemaVersionParams contains all the parameters to send to the API endpoint for the delete schema version operation typically these are written to a http.Request

func NewDeleteSchemaVersionParams 

func NewDeleteSchemaVersionParams() *DeleteSchemaVersionParams

NewDeleteSchemaVersionParams creates a new DeleteSchemaVersionParams object with the default values initialized.

func NewDeleteSchemaVersionParamsWithContext 

func NewDeleteSchemaVersionParamsWithContext(ctx context.Context) *DeleteSchemaVersionParams

NewDeleteSchemaVersionParamsWithContext creates a new DeleteSchemaVersionParams object with the default values initialized, and the ability to set a context for a request

func NewDeleteSchemaVersionParamsWithHTTPClient 

func NewDeleteSchemaVersionParamsWithHTTPClient(client *http.Client) *DeleteSchemaVersionParams

NewDeleteSchemaVersionParamsWithHTTPClient creates a new DeleteSchemaVersionParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewDeleteSchemaVersionParamsWithTimeout 

func NewDeleteSchemaVersionParamsWithTimeout(timeout time.Duration) *DeleteSchemaVersionParams

NewDeleteSchemaVersionParamsWithTimeout creates a new DeleteSchemaVersionParams object with the default values initialized, and the ability to set a timeout on a request

func (*DeleteSchemaVersionParams) SetContext 

func (o *DeleteSchemaVersionParams) SetContext(ctx context.Context)

SetContext adds the context to the delete schema version params

func (*DeleteSchemaVersionParams) SetHTTPClient 

func (o *DeleteSchemaVersionParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the delete schema version params

func (*DeleteSchemaVersionParams) SetPermanent 

func (o *DeleteSchemaVersionParams) SetPermanent(permanent *bool)

SetPermanent adds the permanent to the delete schema version params

func (*DeleteSchemaVersionParams) SetSubject 

func (o *DeleteSchemaVersionParams) SetSubject(subject string)

SetSubject adds the subject to the delete schema version params

func (*DeleteSchemaVersionParams) SetTimeout 

func (o *DeleteSchemaVersionParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the delete schema version params

func (*DeleteSchemaVersionParams) SetVersion 

func (o *DeleteSchemaVersionParams) SetVersion(version string)

SetVersion adds the version to the delete schema version params

func (*DeleteSchemaVersionParams) WithContext 

func (o *DeleteSchemaVersionParams) WithContext(ctx context.Context) *DeleteSchemaVersionParams

WithContext adds the context to the delete schema version params

func (*DeleteSchemaVersionParams) WithHTTPClient 

func (o *DeleteSchemaVersionParams) WithHTTPClient(client *http.Client) *DeleteSchemaVersionParams

WithHTTPClient adds the HTTPClient to the delete schema version params

func (*DeleteSchemaVersionParams) WithPermanent 

func (o *DeleteSchemaVersionParams) WithPermanent(permanent *bool) *DeleteSchemaVersionParams

WithPermanent adds the permanent to the delete schema version params

func (*DeleteSchemaVersionParams) WithSubject 

func (o *DeleteSchemaVersionParams) WithSubject(subject string) *DeleteSchemaVersionParams

WithSubject adds the subject to the delete schema version params

func (*DeleteSchemaVersionParams) WithTimeout 

func (o *DeleteSchemaVersionParams) WithTimeout(timeout time.Duration) *DeleteSchemaVersionParams

WithTimeout adds the timeout to the delete schema version params

func (*DeleteSchemaVersionParams) WithVersion 

func (o *DeleteSchemaVersionParams) WithVersion(version string) *DeleteSchemaVersionParams

WithVersion adds the version to the delete schema version params

func (*DeleteSchemaVersionParams) WriteToRequest 

func (o *DeleteSchemaVersionParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type DeleteSchemaVersionReader 

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

DeleteSchemaVersionReader is a Reader for the DeleteSchemaVersion structure.

func (*DeleteSchemaVersionReader) ReadResponse 

func (o *DeleteSchemaVersionReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type DeleteSchemaVersionUnprocessableEntity 

type DeleteSchemaVersionUnprocessableEntity struct {
}

DeleteSchemaVersionUnprocessableEntity handles this case with default header values.

Error code 42202 -- Invalid version

func NewDeleteSchemaVersionUnprocessableEntity 

func NewDeleteSchemaVersionUnprocessableEntity() *DeleteSchemaVersionUnprocessableEntity

NewDeleteSchemaVersionUnprocessableEntity creates a DeleteSchemaVersionUnprocessableEntity with default headers values

func (*DeleteSchemaVersionUnprocessableEntity) Error 

func (o *DeleteSchemaVersionUnprocessableEntity) Error() string

type DeleteSubjectInternalServerError 

type DeleteSubjectInternalServerError struct {
}

DeleteSubjectInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend datastore

func NewDeleteSubjectInternalServerError 

func NewDeleteSubjectInternalServerError() *DeleteSubjectInternalServerError

NewDeleteSubjectInternalServerError creates a DeleteSubjectInternalServerError with default headers values

func (*DeleteSubjectInternalServerError) Error 

func (o *DeleteSubjectInternalServerError) Error() string

type DeleteSubjectNotFound 

type DeleteSubjectNotFound struct {
}

DeleteSubjectNotFound handles this case with default header values.

Error code 40401 -- Subject not found

func NewDeleteSubjectNotFound 

func NewDeleteSubjectNotFound() *DeleteSubjectNotFound

NewDeleteSubjectNotFound creates a DeleteSubjectNotFound with default headers values

func (*DeleteSubjectNotFound) Error 

func (o *DeleteSubjectNotFound) Error() string

type DeleteSubjectOK 

type DeleteSubjectOK struct {
	Payload []int32
}

DeleteSubjectOK handles this case with default header values.

successful operation

func NewDeleteSubjectOK 

func NewDeleteSubjectOK() *DeleteSubjectOK

NewDeleteSubjectOK creates a DeleteSubjectOK with default headers values

func (*DeleteSubjectOK) Error 

func (o *DeleteSubjectOK) Error() string

func (*DeleteSubjectOK) GetPayload 

func (o *DeleteSubjectOK) GetPayload() []int32

type DeleteSubjectParams 

type DeleteSubjectParams struct {

	/*Permanent*/
	Permanent *bool
	/*Subject
	  the name of the subject

	*/
	Subject string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

DeleteSubjectParams contains all the parameters to send to the API endpoint for the delete subject operation typically these are written to a http.Request

func NewDeleteSubjectParams 

func NewDeleteSubjectParams() *DeleteSubjectParams

NewDeleteSubjectParams creates a new DeleteSubjectParams object with the default values initialized.

func NewDeleteSubjectParamsWithContext 

func NewDeleteSubjectParamsWithContext(ctx context.Context) *DeleteSubjectParams

NewDeleteSubjectParamsWithContext creates a new DeleteSubjectParams object with the default values initialized, and the ability to set a context for a request

func NewDeleteSubjectParamsWithHTTPClient 

func NewDeleteSubjectParamsWithHTTPClient(client *http.Client) *DeleteSubjectParams

NewDeleteSubjectParamsWithHTTPClient creates a new DeleteSubjectParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewDeleteSubjectParamsWithTimeout 

func NewDeleteSubjectParamsWithTimeout(timeout time.Duration) *DeleteSubjectParams

NewDeleteSubjectParamsWithTimeout creates a new DeleteSubjectParams object with the default values initialized, and the ability to set a timeout on a request

func (*DeleteSubjectParams) SetContext 

func (o *DeleteSubjectParams) SetContext(ctx context.Context)

SetContext adds the context to the delete subject params

func (*DeleteSubjectParams) SetHTTPClient 

func (o *DeleteSubjectParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the delete subject params

func (*DeleteSubjectParams) SetPermanent 

func (o *DeleteSubjectParams) SetPermanent(permanent *bool)

SetPermanent adds the permanent to the delete subject params

func (*DeleteSubjectParams) SetSubject 

func (o *DeleteSubjectParams) SetSubject(subject string)

SetSubject adds the subject to the delete subject params

func (*DeleteSubjectParams) SetTimeout 

func (o *DeleteSubjectParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the delete subject params

func (*DeleteSubjectParams) WithContext 

func (o *DeleteSubjectParams) WithContext(ctx context.Context) *DeleteSubjectParams

WithContext adds the context to the delete subject params

func (*DeleteSubjectParams) WithHTTPClient 

func (o *DeleteSubjectParams) WithHTTPClient(client *http.Client) *DeleteSubjectParams

WithHTTPClient adds the HTTPClient to the delete subject params

func (*DeleteSubjectParams) WithPermanent 

func (o *DeleteSubjectParams) WithPermanent(permanent *bool) *DeleteSubjectParams

WithPermanent adds the permanent to the delete subject params

func (*DeleteSubjectParams) WithSubject 

func (o *DeleteSubjectParams) WithSubject(subject string) *DeleteSubjectParams

WithSubject adds the subject to the delete subject params

func (*DeleteSubjectParams) WithTimeout 

func (o *DeleteSubjectParams) WithTimeout(timeout time.Duration) *DeleteSubjectParams

WithTimeout adds the timeout to the delete subject params

func (*DeleteSubjectParams) WriteToRequest 

func (o *DeleteSubjectParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type DeleteSubjectReader 

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

DeleteSubjectReader is a Reader for the DeleteSubject structure.

func (*DeleteSubjectReader) ReadResponse 

func (o *DeleteSubjectReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetClusterIDInternalServerError 

type GetClusterIDInternalServerError struct {
}

GetClusterIDInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store

func NewGetClusterIDInternalServerError 

func NewGetClusterIDInternalServerError() *GetClusterIDInternalServerError

NewGetClusterIDInternalServerError creates a GetClusterIDInternalServerError with default headers values

func (*GetClusterIDInternalServerError) Error 

func (o *GetClusterIDInternalServerError) Error() string

type GetClusterIDOK 

type GetClusterIDOK struct {
	Payload *models.ServerClusterID
}

GetClusterIDOK handles this case with default header values.

successful operation

func NewGetClusterIDOK 

func NewGetClusterIDOK() *GetClusterIDOK

NewGetClusterIDOK creates a GetClusterIDOK with default headers values

func (*GetClusterIDOK) Error 

func (o *GetClusterIDOK) Error() string

func (*GetClusterIDOK) GetPayload 

func (o *GetClusterIDOK) GetPayload() *models.ServerClusterID

type GetClusterIDParams 

type GetClusterIDParams struct {
	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetClusterIDParams contains all the parameters to send to the API endpoint for the get cluster Id operation typically these are written to a http.Request

func NewGetClusterIDParams 

func NewGetClusterIDParams() *GetClusterIDParams

NewGetClusterIDParams creates a new GetClusterIDParams object with the default values initialized.

func NewGetClusterIDParamsWithContext 

func NewGetClusterIDParamsWithContext(ctx context.Context) *GetClusterIDParams

NewGetClusterIDParamsWithContext creates a new GetClusterIDParams object with the default values initialized, and the ability to set a context for a request

func NewGetClusterIDParamsWithHTTPClient 

func NewGetClusterIDParamsWithHTTPClient(client *http.Client) *GetClusterIDParams

NewGetClusterIDParamsWithHTTPClient creates a new GetClusterIDParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetClusterIDParamsWithTimeout 

func NewGetClusterIDParamsWithTimeout(timeout time.Duration) *GetClusterIDParams

NewGetClusterIDParamsWithTimeout creates a new GetClusterIDParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetClusterIDParams) SetContext 

func (o *GetClusterIDParams) SetContext(ctx context.Context)

SetContext adds the context to the get cluster Id params

func (*GetClusterIDParams) SetHTTPClient 

func (o *GetClusterIDParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get cluster Id params

func (*GetClusterIDParams) SetTimeout 

func (o *GetClusterIDParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get cluster Id params

func (*GetClusterIDParams) WithContext 

func (o *GetClusterIDParams) WithContext(ctx context.Context) *GetClusterIDParams

WithContext adds the context to the get cluster Id params

func (*GetClusterIDParams) WithHTTPClient 

func (o *GetClusterIDParams) WithHTTPClient(client *http.Client) *GetClusterIDParams

WithHTTPClient adds the HTTPClient to the get cluster Id params

func (*GetClusterIDParams) WithTimeout 

func (o *GetClusterIDParams) WithTimeout(timeout time.Duration) *GetClusterIDParams

WithTimeout adds the timeout to the get cluster Id params

func (*GetClusterIDParams) WriteToRequest 

func (o *GetClusterIDParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetClusterIDReader 

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

GetClusterIDReader is a Reader for the GetClusterID structure.

func (*GetClusterIDReader) ReadResponse 

func (o *GetClusterIDReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetModeOK 

type GetModeOK struct {
	Payload *models.ModeGetResponse
}

GetModeOK handles this case with default header values.

successful operation

func NewGetModeOK 

func NewGetModeOK() *GetModeOK

NewGetModeOK creates a GetModeOK with default headers values

func (*GetModeOK) Error 

func (o *GetModeOK) Error() string

func (*GetModeOK) GetPayload 

func (o *GetModeOK) GetPayload() *models.ModeGetResponse

type GetModeParams 

type GetModeParams struct {

	/*Subject*/
	Subject string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetModeParams contains all the parameters to send to the API endpoint for the get mode operation typically these are written to a http.Request

func NewGetModeParams 

func NewGetModeParams() *GetModeParams

NewGetModeParams creates a new GetModeParams object with the default values initialized.

func NewGetModeParamsWithContext 

func NewGetModeParamsWithContext(ctx context.Context) *GetModeParams

NewGetModeParamsWithContext creates a new GetModeParams object with the default values initialized, and the ability to set a context for a request

func NewGetModeParamsWithHTTPClient 

func NewGetModeParamsWithHTTPClient(client *http.Client) *GetModeParams

NewGetModeParamsWithHTTPClient creates a new GetModeParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetModeParamsWithTimeout 

func NewGetModeParamsWithTimeout(timeout time.Duration) *GetModeParams

NewGetModeParamsWithTimeout creates a new GetModeParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetModeParams) SetContext 

func (o *GetModeParams) SetContext(ctx context.Context)

SetContext adds the context to the get mode params

func (*GetModeParams) SetHTTPClient 

func (o *GetModeParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get mode params

func (*GetModeParams) SetSubject 

func (o *GetModeParams) SetSubject(subject string)

SetSubject adds the subject to the get mode params

func (*GetModeParams) SetTimeout 

func (o *GetModeParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get mode params

func (*GetModeParams) WithContext 

func (o *GetModeParams) WithContext(ctx context.Context) *GetModeParams

WithContext adds the context to the get mode params

func (*GetModeParams) WithHTTPClient 

func (o *GetModeParams) WithHTTPClient(client *http.Client) *GetModeParams

WithHTTPClient adds the HTTPClient to the get mode params

func (*GetModeParams) WithSubject 

func (o *GetModeParams) WithSubject(subject string) *GetModeParams

WithSubject adds the subject to the get mode params

func (*GetModeParams) WithTimeout 

func (o *GetModeParams) WithTimeout(timeout time.Duration) *GetModeParams

WithTimeout adds the timeout to the get mode params

func (*GetModeParams) WriteToRequest 

func (o *GetModeParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetModeReader 

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

GetModeReader is a Reader for the GetMode structure.

func (*GetModeReader) ReadResponse 

func (o *GetModeReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetOK 

type GetOK struct {
	Payload map[string]interface{}
}

GetOK handles this case with default header values.

successful operation

func NewGetOK 

func NewGetOK() *GetOK

NewGetOK creates a GetOK with default headers values

func (*GetOK) Error 

func (o *GetOK) Error() string

func (*GetOK) GetPayload 

func (o *GetOK) GetPayload() map[string]interface{}

type GetParams 

type GetParams struct {
	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetParams contains all the parameters to send to the API endpoint for the get operation typically these are written to a http.Request

func NewGetParams 

func NewGetParams() *GetParams

NewGetParams creates a new GetParams object with the default values initialized.

func NewGetParamsWithContext 

func NewGetParamsWithContext(ctx context.Context) *GetParams

NewGetParamsWithContext creates a new GetParams object with the default values initialized, and the ability to set a context for a request

func NewGetParamsWithHTTPClient 

func NewGetParamsWithHTTPClient(client *http.Client) *GetParams

NewGetParamsWithHTTPClient creates a new GetParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetParamsWithTimeout 

func NewGetParamsWithTimeout(timeout time.Duration) *GetParams

NewGetParamsWithTimeout creates a new GetParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetParams) SetContext 

func (o *GetParams) SetContext(ctx context.Context)

SetContext adds the context to the get params

func (*GetParams) SetHTTPClient 

func (o *GetParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get params

func (*GetParams) SetTimeout 

func (o *GetParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get params

func (*GetParams) WithContext 

func (o *GetParams) WithContext(ctx context.Context) *GetParams

WithContext adds the context to the get params

func (*GetParams) WithHTTPClient 

func (o *GetParams) WithHTTPClient(client *http.Client) *GetParams

WithHTTPClient adds the HTTPClient to the get params

func (*GetParams) WithTimeout 

func (o *GetParams) WithTimeout(timeout time.Duration) *GetParams

WithTimeout adds the timeout to the get params

func (*GetParams) WriteToRequest 

func (o *GetParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetReader 

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

GetReader is a Reader for the Get structure.

func (*GetReader) ReadResponse 

func (o *GetReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetReferencedByInternalServerError 

type GetReferencedByInternalServerError struct {
}

GetReferencedByInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store

func NewGetReferencedByInternalServerError 

func NewGetReferencedByInternalServerError() *GetReferencedByInternalServerError

NewGetReferencedByInternalServerError creates a GetReferencedByInternalServerError with default headers values

func (*GetReferencedByInternalServerError) Error 

func (o *GetReferencedByInternalServerError) Error() string

type GetReferencedByNotFound 

type GetReferencedByNotFound struct {
}

GetReferencedByNotFound handles this case with default header values.

Error code 40401 -- Subject not found Error code 40402 -- Version not found

func NewGetReferencedByNotFound 

func NewGetReferencedByNotFound() *GetReferencedByNotFound

NewGetReferencedByNotFound creates a GetReferencedByNotFound with default headers values

func (*GetReferencedByNotFound) Error 

func (o *GetReferencedByNotFound) Error() string

type GetReferencedByOK 

type GetReferencedByOK struct {
	Payload []int32
}

GetReferencedByOK handles this case with default header values.

successful operation

func NewGetReferencedByOK 

func NewGetReferencedByOK() *GetReferencedByOK

NewGetReferencedByOK creates a GetReferencedByOK with default headers values

func (*GetReferencedByOK) Error 

func (o *GetReferencedByOK) Error() string

func (*GetReferencedByOK) GetPayload 

func (o *GetReferencedByOK) GetPayload() []int32

type GetReferencedByParams 

type GetReferencedByParams struct {

	/*Subject
	  Name of the Subject

	*/
	Subject string
	/*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.

	*/
	Version string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetReferencedByParams contains all the parameters to send to the API endpoint for the get referenced by operation typically these are written to a http.Request

func NewGetReferencedByParams 

func NewGetReferencedByParams() *GetReferencedByParams

NewGetReferencedByParams creates a new GetReferencedByParams object with the default values initialized.

func NewGetReferencedByParamsWithContext 

func NewGetReferencedByParamsWithContext(ctx context.Context) *GetReferencedByParams

NewGetReferencedByParamsWithContext creates a new GetReferencedByParams object with the default values initialized, and the ability to set a context for a request

func NewGetReferencedByParamsWithHTTPClient 

func NewGetReferencedByParamsWithHTTPClient(client *http.Client) *GetReferencedByParams

NewGetReferencedByParamsWithHTTPClient creates a new GetReferencedByParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetReferencedByParamsWithTimeout 

func NewGetReferencedByParamsWithTimeout(timeout time.Duration) *GetReferencedByParams

NewGetReferencedByParamsWithTimeout creates a new GetReferencedByParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetReferencedByParams) SetContext 

func (o *GetReferencedByParams) SetContext(ctx context.Context)

SetContext adds the context to the get referenced by params

func (*GetReferencedByParams) SetHTTPClient 

func (o *GetReferencedByParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get referenced by params

func (*GetReferencedByParams) SetSubject 

func (o *GetReferencedByParams) SetSubject(subject string)

SetSubject adds the subject to the get referenced by params

func (*GetReferencedByParams) SetTimeout 

func (o *GetReferencedByParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get referenced by params

func (*GetReferencedByParams) SetVersion 

func (o *GetReferencedByParams) SetVersion(version string)

SetVersion adds the version to the get referenced by params

func (*GetReferencedByParams) WithContext 

func (o *GetReferencedByParams) WithContext(ctx context.Context) *GetReferencedByParams

WithContext adds the context to the get referenced by params

func (*GetReferencedByParams) WithHTTPClient 

func (o *GetReferencedByParams) WithHTTPClient(client *http.Client) *GetReferencedByParams

WithHTTPClient adds the HTTPClient to the get referenced by params

func (*GetReferencedByParams) WithSubject 

func (o *GetReferencedByParams) WithSubject(subject string) *GetReferencedByParams

WithSubject adds the subject to the get referenced by params

func (*GetReferencedByParams) WithTimeout 

func (o *GetReferencedByParams) WithTimeout(timeout time.Duration) *GetReferencedByParams

WithTimeout adds the timeout to the get referenced by params

func (*GetReferencedByParams) WithVersion 

func (o *GetReferencedByParams) WithVersion(version string) *GetReferencedByParams

WithVersion adds the version to the get referenced by params

func (*GetReferencedByParams) WriteToRequest 

func (o *GetReferencedByParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetReferencedByReader 

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

GetReferencedByReader is a Reader for the GetReferencedBy structure.

func (*GetReferencedByReader) ReadResponse 

func (o *GetReferencedByReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetReferencedByUnprocessableEntity 

type GetReferencedByUnprocessableEntity struct {
}

GetReferencedByUnprocessableEntity handles this case with default header values.

Error code 42202 -- Invalid version

func NewGetReferencedByUnprocessableEntity 

func NewGetReferencedByUnprocessableEntity() *GetReferencedByUnprocessableEntity

NewGetReferencedByUnprocessableEntity creates a GetReferencedByUnprocessableEntity with default headers values

func (*GetReferencedByUnprocessableEntity) Error 

func (o *GetReferencedByUnprocessableEntity) Error() string

type GetSchemaByVersionInternalServerError 

type GetSchemaByVersionInternalServerError struct {
}

GetSchemaByVersionInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store

func NewGetSchemaByVersionInternalServerError 

func NewGetSchemaByVersionInternalServerError() *GetSchemaByVersionInternalServerError

NewGetSchemaByVersionInternalServerError creates a GetSchemaByVersionInternalServerError with default headers values

func (*GetSchemaByVersionInternalServerError) Error 

func (o *GetSchemaByVersionInternalServerError) Error() string

type GetSchemaByVersionNotFound 

type GetSchemaByVersionNotFound struct {
}

GetSchemaByVersionNotFound handles this case with default header values.

Error code 40401 -- Subject not found Error code 40402 -- Version not found

func NewGetSchemaByVersionNotFound 

func NewGetSchemaByVersionNotFound() *GetSchemaByVersionNotFound

NewGetSchemaByVersionNotFound creates a GetSchemaByVersionNotFound with default headers values

func (*GetSchemaByVersionNotFound) Error 

func (o *GetSchemaByVersionNotFound) Error() string

type GetSchemaByVersionOK 

type GetSchemaByVersionOK struct {
	Payload *models.Schema
}

GetSchemaByVersionOK handles this case with default header values.

successful operation

func NewGetSchemaByVersionOK 

func NewGetSchemaByVersionOK() *GetSchemaByVersionOK

NewGetSchemaByVersionOK creates a GetSchemaByVersionOK with default headers values

func (*GetSchemaByVersionOK) Error 

func (o *GetSchemaByVersionOK) Error() string

func (*GetSchemaByVersionOK) GetPayload 

func (o *GetSchemaByVersionOK) GetPayload() *models.Schema

type GetSchemaByVersionParams 

type GetSchemaByVersionParams struct {

	/*Deleted*/
	Deleted *bool
	/*Subject
	  Name of the Subject

	*/
	Subject string
	/*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.

	*/
	Version string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetSchemaByVersionParams contains all the parameters to send to the API endpoint for the get schema by version operation typically these are written to a http.Request

func NewGetSchemaByVersionParams 

func NewGetSchemaByVersionParams() *GetSchemaByVersionParams

NewGetSchemaByVersionParams creates a new GetSchemaByVersionParams object with the default values initialized.

func NewGetSchemaByVersionParamsWithContext 

func NewGetSchemaByVersionParamsWithContext(ctx context.Context) *GetSchemaByVersionParams

NewGetSchemaByVersionParamsWithContext creates a new GetSchemaByVersionParams object with the default values initialized, and the ability to set a context for a request

func NewGetSchemaByVersionParamsWithHTTPClient 

func NewGetSchemaByVersionParamsWithHTTPClient(client *http.Client) *GetSchemaByVersionParams

NewGetSchemaByVersionParamsWithHTTPClient creates a new GetSchemaByVersionParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetSchemaByVersionParamsWithTimeout 

func NewGetSchemaByVersionParamsWithTimeout(timeout time.Duration) *GetSchemaByVersionParams

NewGetSchemaByVersionParamsWithTimeout creates a new GetSchemaByVersionParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetSchemaByVersionParams) SetContext 

func (o *GetSchemaByVersionParams) SetContext(ctx context.Context)

SetContext adds the context to the get schema by version params

func (*GetSchemaByVersionParams) SetDeleted 

func (o *GetSchemaByVersionParams) SetDeleted(deleted *bool)

SetDeleted adds the deleted to the get schema by version params

func (*GetSchemaByVersionParams) SetHTTPClient 

func (o *GetSchemaByVersionParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get schema by version params

func (*GetSchemaByVersionParams) SetSubject 

func (o *GetSchemaByVersionParams) SetSubject(subject string)

SetSubject adds the subject to the get schema by version params

func (*GetSchemaByVersionParams) SetTimeout 

func (o *GetSchemaByVersionParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get schema by version params

func (*GetSchemaByVersionParams) SetVersion 

func (o *GetSchemaByVersionParams) SetVersion(version string)

SetVersion adds the version to the get schema by version params

func (*GetSchemaByVersionParams) WithContext 

func (o *GetSchemaByVersionParams) WithContext(ctx context.Context) *GetSchemaByVersionParams

WithContext adds the context to the get schema by version params

func (*GetSchemaByVersionParams) WithDeleted 

func (o *GetSchemaByVersionParams) WithDeleted(deleted *bool) *GetSchemaByVersionParams

WithDeleted adds the deleted to the get schema by version params

func (*GetSchemaByVersionParams) WithHTTPClient 

func (o *GetSchemaByVersionParams) WithHTTPClient(client *http.Client) *GetSchemaByVersionParams

WithHTTPClient adds the HTTPClient to the get schema by version params

func (*GetSchemaByVersionParams) WithSubject 

func (o *GetSchemaByVersionParams) WithSubject(subject string) *GetSchemaByVersionParams

WithSubject adds the subject to the get schema by version params

func (*GetSchemaByVersionParams) WithTimeout 

func (o *GetSchemaByVersionParams) WithTimeout(timeout time.Duration) *GetSchemaByVersionParams

WithTimeout adds the timeout to the get schema by version params

func (*GetSchemaByVersionParams) WithVersion 

func (o *GetSchemaByVersionParams) WithVersion(version string) *GetSchemaByVersionParams

WithVersion adds the version to the get schema by version params

func (*GetSchemaByVersionParams) WriteToRequest 

func (o *GetSchemaByVersionParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetSchemaByVersionReader 

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

GetSchemaByVersionReader is a Reader for the GetSchemaByVersion structure.

func (*GetSchemaByVersionReader) ReadResponse 

func (o *GetSchemaByVersionReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetSchemaByVersionUnprocessableEntity 

type GetSchemaByVersionUnprocessableEntity struct {
}

GetSchemaByVersionUnprocessableEntity handles this case with default header values.

Error code 42202 -- Invalid version

func NewGetSchemaByVersionUnprocessableEntity 

func NewGetSchemaByVersionUnprocessableEntity() *GetSchemaByVersionUnprocessableEntity

NewGetSchemaByVersionUnprocessableEntity creates a GetSchemaByVersionUnprocessableEntity with default headers values

func (*GetSchemaByVersionUnprocessableEntity) Error 

func (o *GetSchemaByVersionUnprocessableEntity) Error() string

type GetSchemaInternalServerError 

type GetSchemaInternalServerError struct {
}

GetSchemaInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store

func NewGetSchemaInternalServerError 

func NewGetSchemaInternalServerError() *GetSchemaInternalServerError

NewGetSchemaInternalServerError creates a GetSchemaInternalServerError with default headers values

func (*GetSchemaInternalServerError) Error 

func (o *GetSchemaInternalServerError) Error() string

type GetSchemaNotFound 

type GetSchemaNotFound struct {
}

GetSchemaNotFound handles this case with default header values.

Error code 40403 -- Schema not found

func NewGetSchemaNotFound 

func NewGetSchemaNotFound() *GetSchemaNotFound

NewGetSchemaNotFound creates a GetSchemaNotFound with default headers values

func (*GetSchemaNotFound) Error 

func (o *GetSchemaNotFound) Error() string

type GetSchemaOK 

type GetSchemaOK struct {
	Payload *models.SchemaString
}

GetSchemaOK handles this case with default header values.

successful operation

func NewGetSchemaOK 

func NewGetSchemaOK() *GetSchemaOK

NewGetSchemaOK creates a GetSchemaOK with default headers values

func (*GetSchemaOK) Error 

func (o *GetSchemaOK) Error() string

func (*GetSchemaOK) GetPayload 

func (o *GetSchemaOK) GetPayload() *models.SchemaString

type GetSchemaOnlyInternalServerError 

type GetSchemaOnlyInternalServerError struct {
}

GetSchemaOnlyInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store

func NewGetSchemaOnlyInternalServerError 

func NewGetSchemaOnlyInternalServerError() *GetSchemaOnlyInternalServerError

NewGetSchemaOnlyInternalServerError creates a GetSchemaOnlyInternalServerError with default headers values

func (*GetSchemaOnlyInternalServerError) Error 

func (o *GetSchemaOnlyInternalServerError) Error() string

type GetSchemaOnlyNotFound 

type GetSchemaOnlyNotFound struct {
}

GetSchemaOnlyNotFound handles this case with default header values.

Error code 40401 -- Subject not found Error code 40402 -- Version not found

func NewGetSchemaOnlyNotFound 

func NewGetSchemaOnlyNotFound() *GetSchemaOnlyNotFound

NewGetSchemaOnlyNotFound creates a GetSchemaOnlyNotFound with default headers values

func (*GetSchemaOnlyNotFound) Error 

func (o *GetSchemaOnlyNotFound) Error() string

type GetSchemaOnlyOK 

type GetSchemaOnlyOK struct {
	Payload string
}

GetSchemaOnlyOK handles this case with default header values.

successful operation

func NewGetSchemaOnlyOK 

func NewGetSchemaOnlyOK() *GetSchemaOnlyOK

NewGetSchemaOnlyOK creates a GetSchemaOnlyOK with default headers values

func (*GetSchemaOnlyOK) Error 

func (o *GetSchemaOnlyOK) Error() string

func (*GetSchemaOnlyOK) GetPayload 

func (o *GetSchemaOnlyOK) GetPayload() string

type GetSchemaOnlyParams 

type GetSchemaOnlyParams struct {

	/*Deleted*/
	Deleted *bool
	/*Subject
	  Name of the Subject

	*/
	Subject string
	/*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.

	*/
	Version string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetSchemaOnlyParams contains all the parameters to send to the API endpoint for the get schema only operation typically these are written to a http.Request

func NewGetSchemaOnlyParams 

func NewGetSchemaOnlyParams() *GetSchemaOnlyParams

NewGetSchemaOnlyParams creates a new GetSchemaOnlyParams object with the default values initialized.

func NewGetSchemaOnlyParamsWithContext 

func NewGetSchemaOnlyParamsWithContext(ctx context.Context) *GetSchemaOnlyParams

NewGetSchemaOnlyParamsWithContext creates a new GetSchemaOnlyParams object with the default values initialized, and the ability to set a context for a request

func NewGetSchemaOnlyParamsWithHTTPClient 

func NewGetSchemaOnlyParamsWithHTTPClient(client *http.Client) *GetSchemaOnlyParams

NewGetSchemaOnlyParamsWithHTTPClient creates a new GetSchemaOnlyParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetSchemaOnlyParamsWithTimeout 

func NewGetSchemaOnlyParamsWithTimeout(timeout time.Duration) *GetSchemaOnlyParams

NewGetSchemaOnlyParamsWithTimeout creates a new GetSchemaOnlyParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetSchemaOnlyParams) SetContext 

func (o *GetSchemaOnlyParams) SetContext(ctx context.Context)

SetContext adds the context to the get schema only params

func (*GetSchemaOnlyParams) SetDeleted 

func (o *GetSchemaOnlyParams) SetDeleted(deleted *bool)

SetDeleted adds the deleted to the get schema only params

func (*GetSchemaOnlyParams) SetHTTPClient 

func (o *GetSchemaOnlyParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get schema only params

func (*GetSchemaOnlyParams) SetSubject 

func (o *GetSchemaOnlyParams) SetSubject(subject string)

SetSubject adds the subject to the get schema only params

func (*GetSchemaOnlyParams) SetTimeout 

func (o *GetSchemaOnlyParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get schema only params

func (*GetSchemaOnlyParams) SetVersion 

func (o *GetSchemaOnlyParams) SetVersion(version string)

SetVersion adds the version to the get schema only params

func (*GetSchemaOnlyParams) WithContext 

func (o *GetSchemaOnlyParams) WithContext(ctx context.Context) *GetSchemaOnlyParams

WithContext adds the context to the get schema only params

func (*GetSchemaOnlyParams) WithDeleted 

func (o *GetSchemaOnlyParams) WithDeleted(deleted *bool) *GetSchemaOnlyParams

WithDeleted adds the deleted to the get schema only params

func (*GetSchemaOnlyParams) WithHTTPClient 

func (o *GetSchemaOnlyParams) WithHTTPClient(client *http.Client) *GetSchemaOnlyParams

WithHTTPClient adds the HTTPClient to the get schema only params

func (*GetSchemaOnlyParams) WithSubject 

func (o *GetSchemaOnlyParams) WithSubject(subject string) *GetSchemaOnlyParams

WithSubject adds the subject to the get schema only params

func (*GetSchemaOnlyParams) WithTimeout 

func (o *GetSchemaOnlyParams) WithTimeout(timeout time.Duration) *GetSchemaOnlyParams

WithTimeout adds the timeout to the get schema only params

func (*GetSchemaOnlyParams) WithVersion 

func (o *GetSchemaOnlyParams) WithVersion(version string) *GetSchemaOnlyParams

WithVersion adds the version to the get schema only params

func (*GetSchemaOnlyParams) WriteToRequest 

func (o *GetSchemaOnlyParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetSchemaOnlyReader 

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

GetSchemaOnlyReader is a Reader for the GetSchemaOnly structure.

func (*GetSchemaOnlyReader) ReadResponse 

func (o *GetSchemaOnlyReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetSchemaOnlyUnprocessableEntity 

type GetSchemaOnlyUnprocessableEntity struct {
}

GetSchemaOnlyUnprocessableEntity handles this case with default header values.

Error code 42202 -- Invalid version

func NewGetSchemaOnlyUnprocessableEntity 

func NewGetSchemaOnlyUnprocessableEntity() *GetSchemaOnlyUnprocessableEntity

NewGetSchemaOnlyUnprocessableEntity creates a GetSchemaOnlyUnprocessableEntity with default headers values

func (*GetSchemaOnlyUnprocessableEntity) Error 

func (o *GetSchemaOnlyUnprocessableEntity) Error() string

type GetSchemaParams 

type GetSchemaParams struct {

	/*FetchMaxID*/
	FetchMaxID *bool
	/*Format*/
	Format *string
	/*ID
	  Globally unique identifier of the schema

	*/
	ID int32

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetSchemaParams contains all the parameters to send to the API endpoint for the get schema operation typically these are written to a http.Request

func NewGetSchemaParams 

func NewGetSchemaParams() *GetSchemaParams

NewGetSchemaParams creates a new GetSchemaParams object with the default values initialized.

func NewGetSchemaParamsWithContext 

func NewGetSchemaParamsWithContext(ctx context.Context) *GetSchemaParams

NewGetSchemaParamsWithContext creates a new GetSchemaParams object with the default values initialized, and the ability to set a context for a request

func NewGetSchemaParamsWithHTTPClient 

func NewGetSchemaParamsWithHTTPClient(client *http.Client) *GetSchemaParams

NewGetSchemaParamsWithHTTPClient creates a new GetSchemaParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetSchemaParamsWithTimeout 

func NewGetSchemaParamsWithTimeout(timeout time.Duration) *GetSchemaParams

NewGetSchemaParamsWithTimeout creates a new GetSchemaParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetSchemaParams) SetContext 

func (o *GetSchemaParams) SetContext(ctx context.Context)

SetContext adds the context to the get schema params

func (*GetSchemaParams) SetFetchMaxID 

func (o *GetSchemaParams) SetFetchMaxID(fetchMaxID *bool)

SetFetchMaxID adds the fetchMaxId to the get schema params

func (*GetSchemaParams) SetFormat 

func (o *GetSchemaParams) SetFormat(format *string)

SetFormat adds the format to the get schema params

func (*GetSchemaParams) SetHTTPClient 

func (o *GetSchemaParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get schema params

func (*GetSchemaParams) SetID 

func (o *GetSchemaParams) SetID(id int32)

SetID adds the id to the get schema params

func (*GetSchemaParams) SetTimeout 

func (o *GetSchemaParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get schema params

func (*GetSchemaParams) WithContext 

func (o *GetSchemaParams) WithContext(ctx context.Context) *GetSchemaParams

WithContext adds the context to the get schema params

func (*GetSchemaParams) WithFetchMaxID 

func (o *GetSchemaParams) WithFetchMaxID(fetchMaxID *bool) *GetSchemaParams

WithFetchMaxID adds the fetchMaxID to the get schema params

func (*GetSchemaParams) WithFormat 

func (o *GetSchemaParams) WithFormat(format *string) *GetSchemaParams

WithFormat adds the format to the get schema params

func (*GetSchemaParams) WithHTTPClient 

func (o *GetSchemaParams) WithHTTPClient(client *http.Client) *GetSchemaParams

WithHTTPClient adds the HTTPClient to the get schema params

func (*GetSchemaParams) WithID 

func (o *GetSchemaParams) WithID(id int32) *GetSchemaParams

WithID adds the id to the get schema params

func (*GetSchemaParams) WithTimeout 

func (o *GetSchemaParams) WithTimeout(timeout time.Duration) *GetSchemaParams

WithTimeout adds the timeout to the get schema params

func (*GetSchemaParams) WriteToRequest 

func (o *GetSchemaParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetSchemaReader 

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

GetSchemaReader is a Reader for the GetSchema structure.

func (*GetSchemaReader) ReadResponse 

func (o *GetSchemaReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetSchemaTypesInternalServerError 

type GetSchemaTypesInternalServerError struct {
}

GetSchemaTypesInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store

func NewGetSchemaTypesInternalServerError 

func NewGetSchemaTypesInternalServerError() *GetSchemaTypesInternalServerError

NewGetSchemaTypesInternalServerError creates a GetSchemaTypesInternalServerError with default headers values

func (*GetSchemaTypesInternalServerError) Error 

func (o *GetSchemaTypesInternalServerError) Error() string

type GetSchemaTypesOK 

type GetSchemaTypesOK struct {
	Payload []string
}

GetSchemaTypesOK handles this case with default header values.

successful operation

func NewGetSchemaTypesOK 

func NewGetSchemaTypesOK() *GetSchemaTypesOK

NewGetSchemaTypesOK creates a GetSchemaTypesOK with default headers values

func (*GetSchemaTypesOK) Error 

func (o *GetSchemaTypesOK) Error() string

func (*GetSchemaTypesOK) GetPayload 

func (o *GetSchemaTypesOK) GetPayload() []string

type GetSchemaTypesParams 

type GetSchemaTypesParams struct {
	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetSchemaTypesParams contains all the parameters to send to the API endpoint for the get schema types operation typically these are written to a http.Request

func NewGetSchemaTypesParams 

func NewGetSchemaTypesParams() *GetSchemaTypesParams

NewGetSchemaTypesParams creates a new GetSchemaTypesParams object with the default values initialized.

func NewGetSchemaTypesParamsWithContext 

func NewGetSchemaTypesParamsWithContext(ctx context.Context) *GetSchemaTypesParams

NewGetSchemaTypesParamsWithContext creates a new GetSchemaTypesParams object with the default values initialized, and the ability to set a context for a request

func NewGetSchemaTypesParamsWithHTTPClient 

func NewGetSchemaTypesParamsWithHTTPClient(client *http.Client) *GetSchemaTypesParams

NewGetSchemaTypesParamsWithHTTPClient creates a new GetSchemaTypesParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetSchemaTypesParamsWithTimeout 

func NewGetSchemaTypesParamsWithTimeout(timeout time.Duration) *GetSchemaTypesParams

NewGetSchemaTypesParamsWithTimeout creates a new GetSchemaTypesParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetSchemaTypesParams) SetContext 

func (o *GetSchemaTypesParams) SetContext(ctx context.Context)

SetContext adds the context to the get schema types params

func (*GetSchemaTypesParams) SetHTTPClient 

func (o *GetSchemaTypesParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get schema types params

func (*GetSchemaTypesParams) SetTimeout 

func (o *GetSchemaTypesParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get schema types params

func (*GetSchemaTypesParams) WithContext 

func (o *GetSchemaTypesParams) WithContext(ctx context.Context) *GetSchemaTypesParams

WithContext adds the context to the get schema types params

func (*GetSchemaTypesParams) WithHTTPClient 

func (o *GetSchemaTypesParams) WithHTTPClient(client *http.Client) *GetSchemaTypesParams

WithHTTPClient adds the HTTPClient to the get schema types params

func (*GetSchemaTypesParams) WithTimeout 

func (o *GetSchemaTypesParams) WithTimeout(timeout time.Duration) *GetSchemaTypesParams

WithTimeout adds the timeout to the get schema types params

func (*GetSchemaTypesParams) WriteToRequest 

func (o *GetSchemaTypesParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetSchemaTypesReader 

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

GetSchemaTypesReader is a Reader for the GetSchemaTypes structure.

func (*GetSchemaTypesReader) ReadResponse 

func (o *GetSchemaTypesReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetSchemasInternalServerError 

type GetSchemasInternalServerError struct {
}

GetSchemasInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store

func NewGetSchemasInternalServerError 

func NewGetSchemasInternalServerError() *GetSchemasInternalServerError

NewGetSchemasInternalServerError creates a GetSchemasInternalServerError with default headers values

func (*GetSchemasInternalServerError) Error 

func (o *GetSchemasInternalServerError) Error() string

type GetSchemasOK 

type GetSchemasOK struct {
	Payload []*models.Schema
}

GetSchemasOK handles this case with default header values.

successful operation

func NewGetSchemasOK 

func NewGetSchemasOK() *GetSchemasOK

NewGetSchemasOK creates a GetSchemasOK with default headers values

func (*GetSchemasOK) Error 

func (o *GetSchemasOK) Error() string

func (*GetSchemasOK) GetPayload 

func (o *GetSchemasOK) GetPayload() []*models.Schema

type GetSchemasParams 

type GetSchemasParams struct {

	/*Deleted*/
	Deleted *bool
	/*LatestOnly*/
	LatestOnly *bool
	/*Limit*/
	Limit *int32
	/*Offset*/
	Offset *int32
	/*SubjectPrefix*/
	SubjectPrefix *string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetSchemasParams contains all the parameters to send to the API endpoint for the get schemas operation typically these are written to a http.Request

func NewGetSchemasParams 

func NewGetSchemasParams() *GetSchemasParams

NewGetSchemasParams creates a new GetSchemasParams object with the default values initialized.

func NewGetSchemasParamsWithContext 

func NewGetSchemasParamsWithContext(ctx context.Context) *GetSchemasParams

NewGetSchemasParamsWithContext creates a new GetSchemasParams object with the default values initialized, and the ability to set a context for a request

func NewGetSchemasParamsWithHTTPClient 

func NewGetSchemasParamsWithHTTPClient(client *http.Client) *GetSchemasParams

NewGetSchemasParamsWithHTTPClient creates a new GetSchemasParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetSchemasParamsWithTimeout 

func NewGetSchemasParamsWithTimeout(timeout time.Duration) *GetSchemasParams

NewGetSchemasParamsWithTimeout creates a new GetSchemasParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetSchemasParams) SetContext 

func (o *GetSchemasParams) SetContext(ctx context.Context)

SetContext adds the context to the get schemas params

func (*GetSchemasParams) SetDeleted 

func (o *GetSchemasParams) SetDeleted(deleted *bool)

SetDeleted adds the deleted to the get schemas params

func (*GetSchemasParams) SetHTTPClient 

func (o *GetSchemasParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get schemas params

func (*GetSchemasParams) SetLatestOnly 

func (o *GetSchemasParams) SetLatestOnly(latestOnly *bool)

SetLatestOnly adds the latestOnly to the get schemas params

func (*GetSchemasParams) SetLimit 

func (o *GetSchemasParams) SetLimit(limit *int32)

SetLimit adds the limit to the get schemas params

func (*GetSchemasParams) SetOffset 

func (o *GetSchemasParams) SetOffset(offset *int32)

SetOffset adds the offset to the get schemas params

func (*GetSchemasParams) SetSubjectPrefix 

func (o *GetSchemasParams) SetSubjectPrefix(subjectPrefix *string)

SetSubjectPrefix adds the subjectPrefix to the get schemas params

func (*GetSchemasParams) SetTimeout 

func (o *GetSchemasParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get schemas params

func (*GetSchemasParams) WithContext 

func (o *GetSchemasParams) WithContext(ctx context.Context) *GetSchemasParams

WithContext adds the context to the get schemas params

func (*GetSchemasParams) WithDeleted 

func (o *GetSchemasParams) WithDeleted(deleted *bool) *GetSchemasParams

WithDeleted adds the deleted to the get schemas params

func (*GetSchemasParams) WithHTTPClient 

func (o *GetSchemasParams) WithHTTPClient(client *http.Client) *GetSchemasParams

WithHTTPClient adds the HTTPClient to the get schemas params

func (*GetSchemasParams) WithLatestOnly 

func (o *GetSchemasParams) WithLatestOnly(latestOnly *bool) *GetSchemasParams

WithLatestOnly adds the latestOnly to the get schemas params

func (*GetSchemasParams) WithLimit 

func (o *GetSchemasParams) WithLimit(limit *int32) *GetSchemasParams

WithLimit adds the limit to the get schemas params

func (*GetSchemasParams) WithOffset 

func (o *GetSchemasParams) WithOffset(offset *int32) *GetSchemasParams

WithOffset adds the offset to the get schemas params

func (*GetSchemasParams) WithSubjectPrefix 

func (o *GetSchemasParams) WithSubjectPrefix(subjectPrefix *string) *GetSchemasParams

WithSubjectPrefix adds the subjectPrefix to the get schemas params

func (*GetSchemasParams) WithTimeout 

func (o *GetSchemasParams) WithTimeout(timeout time.Duration) *GetSchemasParams

WithTimeout adds the timeout to the get schemas params

func (*GetSchemasParams) WriteToRequest 

func (o *GetSchemasParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetSchemasReader 

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

GetSchemasReader is a Reader for the GetSchemas structure.

func (*GetSchemasReader) ReadResponse 

func (o *GetSchemasReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetSubjectLevelConfigInternalServerError 

type GetSubjectLevelConfigInternalServerError struct {
}

GetSubjectLevelConfigInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store

func NewGetSubjectLevelConfigInternalServerError 

func NewGetSubjectLevelConfigInternalServerError() *GetSubjectLevelConfigInternalServerError

NewGetSubjectLevelConfigInternalServerError creates a GetSubjectLevelConfigInternalServerError with default headers values

func (*GetSubjectLevelConfigInternalServerError) Error 

func (o *GetSubjectLevelConfigInternalServerError) Error() string

type GetSubjectLevelConfigNotFound 

type GetSubjectLevelConfigNotFound struct {
}

GetSubjectLevelConfigNotFound handles this case with default header values.

Subject not found

func NewGetSubjectLevelConfigNotFound 

func NewGetSubjectLevelConfigNotFound() *GetSubjectLevelConfigNotFound

NewGetSubjectLevelConfigNotFound creates a GetSubjectLevelConfigNotFound with default headers values

func (*GetSubjectLevelConfigNotFound) Error 

func (o *GetSubjectLevelConfigNotFound) Error() string

type GetSubjectLevelConfigOK 

type GetSubjectLevelConfigOK struct {
	Payload *models.Config
}

GetSubjectLevelConfigOK handles this case with default header values.

successful operation

func NewGetSubjectLevelConfigOK 

func NewGetSubjectLevelConfigOK() *GetSubjectLevelConfigOK

NewGetSubjectLevelConfigOK creates a GetSubjectLevelConfigOK with default headers values

func (*GetSubjectLevelConfigOK) Error 

func (o *GetSubjectLevelConfigOK) Error() string

func (*GetSubjectLevelConfigOK) GetPayload 

func (o *GetSubjectLevelConfigOK) GetPayload() *models.Config

type GetSubjectLevelConfigParams 

type GetSubjectLevelConfigParams struct {

	/*DefaultToGlobal*/
	DefaultToGlobal *bool
	/*Subject*/
	Subject string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetSubjectLevelConfigParams contains all the parameters to send to the API endpoint for the get subject level config operation typically these are written to a http.Request

func NewGetSubjectLevelConfigParams 

func NewGetSubjectLevelConfigParams() *GetSubjectLevelConfigParams

NewGetSubjectLevelConfigParams creates a new GetSubjectLevelConfigParams object with the default values initialized.

func NewGetSubjectLevelConfigParamsWithContext 

func NewGetSubjectLevelConfigParamsWithContext(ctx context.Context) *GetSubjectLevelConfigParams

NewGetSubjectLevelConfigParamsWithContext creates a new GetSubjectLevelConfigParams object with the default values initialized, and the ability to set a context for a request

func NewGetSubjectLevelConfigParamsWithHTTPClient 

func NewGetSubjectLevelConfigParamsWithHTTPClient(client *http.Client) *GetSubjectLevelConfigParams

NewGetSubjectLevelConfigParamsWithHTTPClient creates a new GetSubjectLevelConfigParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetSubjectLevelConfigParamsWithTimeout 

func NewGetSubjectLevelConfigParamsWithTimeout(timeout time.Duration) *GetSubjectLevelConfigParams

NewGetSubjectLevelConfigParamsWithTimeout creates a new GetSubjectLevelConfigParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetSubjectLevelConfigParams) SetContext 

func (o *GetSubjectLevelConfigParams) SetContext(ctx context.Context)

SetContext adds the context to the get subject level config params

func (*GetSubjectLevelConfigParams) SetDefaultToGlobal 

func (o *GetSubjectLevelConfigParams) SetDefaultToGlobal(defaultToGlobal *bool)

SetDefaultToGlobal adds the defaultToGlobal to the get subject level config params

func (*GetSubjectLevelConfigParams) SetHTTPClient 

func (o *GetSubjectLevelConfigParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get subject level config params

func (*GetSubjectLevelConfigParams) SetSubject 

func (o *GetSubjectLevelConfigParams) SetSubject(subject string)

SetSubject adds the subject to the get subject level config params

func (*GetSubjectLevelConfigParams) SetTimeout 

func (o *GetSubjectLevelConfigParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get subject level config params

func (*GetSubjectLevelConfigParams) WithContext 

func (o *GetSubjectLevelConfigParams) WithContext(ctx context.Context) *GetSubjectLevelConfigParams

WithContext adds the context to the get subject level config params

func (*GetSubjectLevelConfigParams) WithDefaultToGlobal 

func (o *GetSubjectLevelConfigParams) WithDefaultToGlobal(defaultToGlobal *bool) *GetSubjectLevelConfigParams

WithDefaultToGlobal adds the defaultToGlobal to the get subject level config params

func (*GetSubjectLevelConfigParams) WithHTTPClient 

func (o *GetSubjectLevelConfigParams) WithHTTPClient(client *http.Client) *GetSubjectLevelConfigParams

WithHTTPClient adds the HTTPClient to the get subject level config params

func (*GetSubjectLevelConfigParams) WithSubject 

func (o *GetSubjectLevelConfigParams) WithSubject(subject string) *GetSubjectLevelConfigParams

WithSubject adds the subject to the get subject level config params

func (*GetSubjectLevelConfigParams) WithTimeout 

func (o *GetSubjectLevelConfigParams) WithTimeout(timeout time.Duration) *GetSubjectLevelConfigParams

WithTimeout adds the timeout to the get subject level config params

func (*GetSubjectLevelConfigParams) WriteToRequest 

func (o *GetSubjectLevelConfigParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetSubjectLevelConfigReader 

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

GetSubjectLevelConfigReader is a Reader for the GetSubjectLevelConfig structure.

func (*GetSubjectLevelConfigReader) ReadResponse 

func (o *GetSubjectLevelConfigReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetSubjectsInternalServerError 

type GetSubjectsInternalServerError struct {
}

GetSubjectsInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store

func NewGetSubjectsInternalServerError 

func NewGetSubjectsInternalServerError() *GetSubjectsInternalServerError

NewGetSubjectsInternalServerError creates a GetSubjectsInternalServerError with default headers values

func (*GetSubjectsInternalServerError) Error 

func (o *GetSubjectsInternalServerError) Error() string

type GetSubjectsNotFound 

type GetSubjectsNotFound struct {
}

GetSubjectsNotFound handles this case with default header values.

Error code 40403 -- Schema not found

func NewGetSubjectsNotFound 

func NewGetSubjectsNotFound() *GetSubjectsNotFound

NewGetSubjectsNotFound creates a GetSubjectsNotFound with default headers values

func (*GetSubjectsNotFound) Error 

func (o *GetSubjectsNotFound) Error() string

type GetSubjectsOK 

type GetSubjectsOK struct {
	Payload []string
}

GetSubjectsOK handles this case with default header values.

successful operation

func NewGetSubjectsOK 

func NewGetSubjectsOK() *GetSubjectsOK

NewGetSubjectsOK creates a GetSubjectsOK with default headers values

func (*GetSubjectsOK) Error 

func (o *GetSubjectsOK) Error() string

func (*GetSubjectsOK) GetPayload 

func (o *GetSubjectsOK) GetPayload() []string

type GetSubjectsParams 

type GetSubjectsParams struct {

	/*Deleted*/
	Deleted *bool
	/*ID
	  Globally unique identifier of the schema

	*/
	ID int32

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetSubjectsParams contains all the parameters to send to the API endpoint for the get subjects operation typically these are written to a http.Request

func NewGetSubjectsParams 

func NewGetSubjectsParams() *GetSubjectsParams

NewGetSubjectsParams creates a new GetSubjectsParams object with the default values initialized.

func NewGetSubjectsParamsWithContext 

func NewGetSubjectsParamsWithContext(ctx context.Context) *GetSubjectsParams

NewGetSubjectsParamsWithContext creates a new GetSubjectsParams object with the default values initialized, and the ability to set a context for a request

func NewGetSubjectsParamsWithHTTPClient 

func NewGetSubjectsParamsWithHTTPClient(client *http.Client) *GetSubjectsParams

NewGetSubjectsParamsWithHTTPClient creates a new GetSubjectsParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetSubjectsParamsWithTimeout 

func NewGetSubjectsParamsWithTimeout(timeout time.Duration) *GetSubjectsParams

NewGetSubjectsParamsWithTimeout creates a new GetSubjectsParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetSubjectsParams) SetContext 

func (o *GetSubjectsParams) SetContext(ctx context.Context)

SetContext adds the context to the get subjects params

func (*GetSubjectsParams) SetDeleted 

func (o *GetSubjectsParams) SetDeleted(deleted *bool)

SetDeleted adds the deleted to the get subjects params

func (*GetSubjectsParams) SetHTTPClient 

func (o *GetSubjectsParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get subjects params

func (*GetSubjectsParams) SetID 

func (o *GetSubjectsParams) SetID(id int32)

SetID adds the id to the get subjects params

func (*GetSubjectsParams) SetTimeout 

func (o *GetSubjectsParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get subjects params

func (*GetSubjectsParams) WithContext 

func (o *GetSubjectsParams) WithContext(ctx context.Context) *GetSubjectsParams

WithContext adds the context to the get subjects params

func (*GetSubjectsParams) WithDeleted 

func (o *GetSubjectsParams) WithDeleted(deleted *bool) *GetSubjectsParams

WithDeleted adds the deleted to the get subjects params

func (*GetSubjectsParams) WithHTTPClient 

func (o *GetSubjectsParams) WithHTTPClient(client *http.Client) *GetSubjectsParams

WithHTTPClient adds the HTTPClient to the get subjects params

func (*GetSubjectsParams) WithID 

func (o *GetSubjectsParams) WithID(id int32) *GetSubjectsParams

WithID adds the id to the get subjects params

func (*GetSubjectsParams) WithTimeout 

func (o *GetSubjectsParams) WithTimeout(timeout time.Duration) *GetSubjectsParams

WithTimeout adds the timeout to the get subjects params

func (*GetSubjectsParams) WriteToRequest 

func (o *GetSubjectsParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetSubjectsReader 

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

GetSubjectsReader is a Reader for the GetSubjects structure.

func (*GetSubjectsReader) ReadResponse 

func (o *GetSubjectsReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetTopLevelConfigInternalServerError 

type GetTopLevelConfigInternalServerError struct {
}

GetTopLevelConfigInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store

func NewGetTopLevelConfigInternalServerError 

func NewGetTopLevelConfigInternalServerError() *GetTopLevelConfigInternalServerError

NewGetTopLevelConfigInternalServerError creates a GetTopLevelConfigInternalServerError with default headers values

func (*GetTopLevelConfigInternalServerError) Error 

func (o *GetTopLevelConfigInternalServerError) Error() string

type GetTopLevelConfigOK 

type GetTopLevelConfigOK struct {
	Payload *models.Config
}

GetTopLevelConfigOK handles this case with default header values.

successful operation

func NewGetTopLevelConfigOK 

func NewGetTopLevelConfigOK() *GetTopLevelConfigOK

NewGetTopLevelConfigOK creates a GetTopLevelConfigOK with default headers values

func (*GetTopLevelConfigOK) Error 

func (o *GetTopLevelConfigOK) Error() string

func (*GetTopLevelConfigOK) GetPayload 

func (o *GetTopLevelConfigOK) GetPayload() *models.Config

type GetTopLevelConfigParams 

type GetTopLevelConfigParams struct {
	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetTopLevelConfigParams contains all the parameters to send to the API endpoint for the get top level config operation typically these are written to a http.Request

func NewGetTopLevelConfigParams 

func NewGetTopLevelConfigParams() *GetTopLevelConfigParams

NewGetTopLevelConfigParams creates a new GetTopLevelConfigParams object with the default values initialized.

func NewGetTopLevelConfigParamsWithContext 

func NewGetTopLevelConfigParamsWithContext(ctx context.Context) *GetTopLevelConfigParams

NewGetTopLevelConfigParamsWithContext creates a new GetTopLevelConfigParams object with the default values initialized, and the ability to set a context for a request

func NewGetTopLevelConfigParamsWithHTTPClient 

func NewGetTopLevelConfigParamsWithHTTPClient(client *http.Client) *GetTopLevelConfigParams

NewGetTopLevelConfigParamsWithHTTPClient creates a new GetTopLevelConfigParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetTopLevelConfigParamsWithTimeout 

func NewGetTopLevelConfigParamsWithTimeout(timeout time.Duration) *GetTopLevelConfigParams

NewGetTopLevelConfigParamsWithTimeout creates a new GetTopLevelConfigParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetTopLevelConfigParams) SetContext 

func (o *GetTopLevelConfigParams) SetContext(ctx context.Context)

SetContext adds the context to the get top level config params

func (*GetTopLevelConfigParams) SetHTTPClient 

func (o *GetTopLevelConfigParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get top level config params

func (*GetTopLevelConfigParams) SetTimeout 

func (o *GetTopLevelConfigParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get top level config params

func (*GetTopLevelConfigParams) WithContext 

func (o *GetTopLevelConfigParams) WithContext(ctx context.Context) *GetTopLevelConfigParams

WithContext adds the context to the get top level config params

func (*GetTopLevelConfigParams) WithHTTPClient 

func (o *GetTopLevelConfigParams) WithHTTPClient(client *http.Client) *GetTopLevelConfigParams

WithHTTPClient adds the HTTPClient to the get top level config params

func (*GetTopLevelConfigParams) WithTimeout 

func (o *GetTopLevelConfigParams) WithTimeout(timeout time.Duration) *GetTopLevelConfigParams

WithTimeout adds the timeout to the get top level config params

func (*GetTopLevelConfigParams) WriteToRequest 

func (o *GetTopLevelConfigParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetTopLevelConfigReader 

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

GetTopLevelConfigReader is a Reader for the GetTopLevelConfig structure.

func (*GetTopLevelConfigReader) ReadResponse 

func (o *GetTopLevelConfigReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetTopLevelModeOK 

type GetTopLevelModeOK struct {
	Payload *models.ModeGetResponse
}

GetTopLevelModeOK handles this case with default header values.

successful operation

func NewGetTopLevelModeOK 

func NewGetTopLevelModeOK() *GetTopLevelModeOK

NewGetTopLevelModeOK creates a GetTopLevelModeOK with default headers values

func (*GetTopLevelModeOK) Error 

func (o *GetTopLevelModeOK) Error() string

func (*GetTopLevelModeOK) GetPayload 

func (o *GetTopLevelModeOK) GetPayload() *models.ModeGetResponse

type GetTopLevelModeParams 

type GetTopLevelModeParams struct {
	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetTopLevelModeParams contains all the parameters to send to the API endpoint for the get top level mode operation typically these are written to a http.Request

func NewGetTopLevelModeParams 

func NewGetTopLevelModeParams() *GetTopLevelModeParams

NewGetTopLevelModeParams creates a new GetTopLevelModeParams object with the default values initialized.

func NewGetTopLevelModeParamsWithContext 

func NewGetTopLevelModeParamsWithContext(ctx context.Context) *GetTopLevelModeParams

NewGetTopLevelModeParamsWithContext creates a new GetTopLevelModeParams object with the default values initialized, and the ability to set a context for a request

func NewGetTopLevelModeParamsWithHTTPClient 

func NewGetTopLevelModeParamsWithHTTPClient(client *http.Client) *GetTopLevelModeParams

NewGetTopLevelModeParamsWithHTTPClient creates a new GetTopLevelModeParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetTopLevelModeParamsWithTimeout 

func NewGetTopLevelModeParamsWithTimeout(timeout time.Duration) *GetTopLevelModeParams

NewGetTopLevelModeParamsWithTimeout creates a new GetTopLevelModeParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetTopLevelModeParams) SetContext 

func (o *GetTopLevelModeParams) SetContext(ctx context.Context)

SetContext adds the context to the get top level mode params

func (*GetTopLevelModeParams) SetHTTPClient 

func (o *GetTopLevelModeParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get top level mode params

func (*GetTopLevelModeParams) SetTimeout 

func (o *GetTopLevelModeParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get top level mode params

func (*GetTopLevelModeParams) WithContext 

func (o *GetTopLevelModeParams) WithContext(ctx context.Context) *GetTopLevelModeParams

WithContext adds the context to the get top level mode params

func (*GetTopLevelModeParams) WithHTTPClient 

func (o *GetTopLevelModeParams) WithHTTPClient(client *http.Client) *GetTopLevelModeParams

WithHTTPClient adds the HTTPClient to the get top level mode params

func (*GetTopLevelModeParams) WithTimeout 

func (o *GetTopLevelModeParams) WithTimeout(timeout time.Duration) *GetTopLevelModeParams

WithTimeout adds the timeout to the get top level mode params

func (*GetTopLevelModeParams) WriteToRequest 

func (o *GetTopLevelModeParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetTopLevelModeReader 

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

GetTopLevelModeReader is a Reader for the GetTopLevelMode structure.

func (*GetTopLevelModeReader) ReadResponse 

func (o *GetTopLevelModeReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetVersionsInternalServerError 

type GetVersionsInternalServerError struct {
}

GetVersionsInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store

func NewGetVersionsInternalServerError 

func NewGetVersionsInternalServerError() *GetVersionsInternalServerError

NewGetVersionsInternalServerError creates a GetVersionsInternalServerError with default headers values

func (*GetVersionsInternalServerError) Error 

func (o *GetVersionsInternalServerError) Error() string

type GetVersionsNotFound 

type GetVersionsNotFound struct {
}

GetVersionsNotFound handles this case with default header values.

Error code 40403 -- Schema not found

func NewGetVersionsNotFound 

func NewGetVersionsNotFound() *GetVersionsNotFound

NewGetVersionsNotFound creates a GetVersionsNotFound with default headers values

func (*GetVersionsNotFound) Error 

func (o *GetVersionsNotFound) Error() string

type GetVersionsOK 

type GetVersionsOK struct {
	Payload []*models.SubjectVersion
}

GetVersionsOK handles this case with default header values.

successful operation

func NewGetVersionsOK 

func NewGetVersionsOK() *GetVersionsOK

NewGetVersionsOK creates a GetVersionsOK with default headers values

func (*GetVersionsOK) Error 

func (o *GetVersionsOK) Error() string

func (*GetVersionsOK) GetPayload 

func (o *GetVersionsOK) GetPayload() []*models.SubjectVersion

type GetVersionsParams 

type GetVersionsParams struct {

	/*Deleted*/
	Deleted *bool
	/*ID
	  Globally unique identifier of the schema

	*/
	ID int32

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetVersionsParams contains all the parameters to send to the API endpoint for the get versions operation typically these are written to a http.Request

func NewGetVersionsParams 

func NewGetVersionsParams() *GetVersionsParams

NewGetVersionsParams creates a new GetVersionsParams object with the default values initialized.

func NewGetVersionsParamsWithContext 

func NewGetVersionsParamsWithContext(ctx context.Context) *GetVersionsParams

NewGetVersionsParamsWithContext creates a new GetVersionsParams object with the default values initialized, and the ability to set a context for a request

func NewGetVersionsParamsWithHTTPClient 

func NewGetVersionsParamsWithHTTPClient(client *http.Client) *GetVersionsParams

NewGetVersionsParamsWithHTTPClient creates a new GetVersionsParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetVersionsParamsWithTimeout 

func NewGetVersionsParamsWithTimeout(timeout time.Duration) *GetVersionsParams

NewGetVersionsParamsWithTimeout creates a new GetVersionsParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetVersionsParams) SetContext 

func (o *GetVersionsParams) SetContext(ctx context.Context)

SetContext adds the context to the get versions params

func (*GetVersionsParams) SetDeleted 

func (o *GetVersionsParams) SetDeleted(deleted *bool)

SetDeleted adds the deleted to the get versions params

func (*GetVersionsParams) SetHTTPClient 

func (o *GetVersionsParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get versions params

func (*GetVersionsParams) SetID 

func (o *GetVersionsParams) SetID(id int32)

SetID adds the id to the get versions params

func (*GetVersionsParams) SetTimeout 

func (o *GetVersionsParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get versions params

func (*GetVersionsParams) WithContext 

func (o *GetVersionsParams) WithContext(ctx context.Context) *GetVersionsParams

WithContext adds the context to the get versions params

func (*GetVersionsParams) WithDeleted 

func (o *GetVersionsParams) WithDeleted(deleted *bool) *GetVersionsParams

WithDeleted adds the deleted to the get versions params

func (*GetVersionsParams) WithHTTPClient 

func (o *GetVersionsParams) WithHTTPClient(client *http.Client) *GetVersionsParams

WithHTTPClient adds the HTTPClient to the get versions params

func (*GetVersionsParams) WithID 

func (o *GetVersionsParams) WithID(id int32) *GetVersionsParams

WithID adds the id to the get versions params

func (*GetVersionsParams) WithTimeout 

func (o *GetVersionsParams) WithTimeout(timeout time.Duration) *GetVersionsParams

WithTimeout adds the timeout to the get versions params

func (*GetVersionsParams) WriteToRequest 

func (o *GetVersionsParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetVersionsReader 

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

GetVersionsReader is a Reader for the GetVersions structure.

func (*GetVersionsReader) ReadResponse 

func (o *GetVersionsReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type ListInternalServerError 

type ListInternalServerError struct {
}

ListInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend datastore

func NewListInternalServerError 

func NewListInternalServerError() *ListInternalServerError

NewListInternalServerError creates a ListInternalServerError with default headers values

func (*ListInternalServerError) Error 

func (o *ListInternalServerError) Error() string

type ListOK 

type ListOK struct {
	Payload []string
}

ListOK handles this case with default header values.

successful operation

func NewListOK 

func NewListOK() *ListOK

NewListOK creates a ListOK with default headers values

func (*ListOK) Error 

func (o *ListOK) Error() string

func (*ListOK) GetPayload 

func (o *ListOK) GetPayload() []string

type ListParams 

type ListParams struct {

	/*Deleted*/
	Deleted *bool

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

ListParams contains all the parameters to send to the API endpoint for the list operation typically these are written to a http.Request

func NewListParams 

func NewListParams() *ListParams

NewListParams creates a new ListParams object with the default values initialized.

func NewListParamsWithContext 

func NewListParamsWithContext(ctx context.Context) *ListParams

NewListParamsWithContext creates a new ListParams object with the default values initialized, and the ability to set a context for a request

func NewListParamsWithHTTPClient 

func NewListParamsWithHTTPClient(client *http.Client) *ListParams

NewListParamsWithHTTPClient creates a new ListParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewListParamsWithTimeout 

func NewListParamsWithTimeout(timeout time.Duration) *ListParams

NewListParamsWithTimeout creates a new ListParams object with the default values initialized, and the ability to set a timeout on a request

func (*ListParams) SetContext 

func (o *ListParams) SetContext(ctx context.Context)

SetContext adds the context to the list params

func (*ListParams) SetDeleted 

func (o *ListParams) SetDeleted(deleted *bool)

SetDeleted adds the deleted to the list params

func (*ListParams) SetHTTPClient 

func (o *ListParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the list params

func (*ListParams) SetTimeout 

func (o *ListParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the list params

func (*ListParams) WithContext 

func (o *ListParams) WithContext(ctx context.Context) *ListParams

WithContext adds the context to the list params

func (*ListParams) WithDeleted 

func (o *ListParams) WithDeleted(deleted *bool) *ListParams

WithDeleted adds the deleted to the list params

func (*ListParams) WithHTTPClient 

func (o *ListParams) WithHTTPClient(client *http.Client) *ListParams

WithHTTPClient adds the HTTPClient to the list params

func (*ListParams) WithTimeout 

func (o *ListParams) WithTimeout(timeout time.Duration) *ListParams

WithTimeout adds the timeout to the list params

func (*ListParams) WriteToRequest 

func (o *ListParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type ListReader 

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

ListReader is a Reader for the List structure.

func (*ListReader) ReadResponse 

func (o *ListReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type ListVersionsInternalServerError 

type ListVersionsInternalServerError struct {
}

ListVersionsInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store

func NewListVersionsInternalServerError 

func NewListVersionsInternalServerError() *ListVersionsInternalServerError

NewListVersionsInternalServerError creates a ListVersionsInternalServerError with default headers values

func (*ListVersionsInternalServerError) Error 

func (o *ListVersionsInternalServerError) Error() string

type ListVersionsNotFound 

type ListVersionsNotFound struct {
}

ListVersionsNotFound handles this case with default header values.

Error code 40401 -- Subject not found

func NewListVersionsNotFound 

func NewListVersionsNotFound() *ListVersionsNotFound

NewListVersionsNotFound creates a ListVersionsNotFound with default headers values

func (*ListVersionsNotFound) Error 

func (o *ListVersionsNotFound) Error() string

type ListVersionsOK 

type ListVersionsOK struct {
	Payload []int32
}

ListVersionsOK handles this case with default header values.

successful operation

func NewListVersionsOK 

func NewListVersionsOK() *ListVersionsOK

NewListVersionsOK creates a ListVersionsOK with default headers values

func (*ListVersionsOK) Error 

func (o *ListVersionsOK) Error() string

func (*ListVersionsOK) GetPayload 

func (o *ListVersionsOK) GetPayload() []int32

type ListVersionsParams 

type ListVersionsParams struct {

	/*Deleted*/
	Deleted *bool
	/*Subject
	  Name of the Subject

	*/
	Subject string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

ListVersionsParams contains all the parameters to send to the API endpoint for the list versions operation typically these are written to a http.Request

func NewListVersionsParams 

func NewListVersionsParams() *ListVersionsParams

NewListVersionsParams creates a new ListVersionsParams object with the default values initialized.

func NewListVersionsParamsWithContext 

func NewListVersionsParamsWithContext(ctx context.Context) *ListVersionsParams

NewListVersionsParamsWithContext creates a new ListVersionsParams object with the default values initialized, and the ability to set a context for a request

func NewListVersionsParamsWithHTTPClient 

func NewListVersionsParamsWithHTTPClient(client *http.Client) *ListVersionsParams

NewListVersionsParamsWithHTTPClient creates a new ListVersionsParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewListVersionsParamsWithTimeout 

func NewListVersionsParamsWithTimeout(timeout time.Duration) *ListVersionsParams

NewListVersionsParamsWithTimeout creates a new ListVersionsParams object with the default values initialized, and the ability to set a timeout on a request

func (*ListVersionsParams) SetContext 

func (o *ListVersionsParams) SetContext(ctx context.Context)

SetContext adds the context to the list versions params

func (*ListVersionsParams) SetDeleted 

func (o *ListVersionsParams) SetDeleted(deleted *bool)

SetDeleted adds the deleted to the list versions params

func (*ListVersionsParams) SetHTTPClient 

func (o *ListVersionsParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the list versions params

func (*ListVersionsParams) SetSubject 

func (o *ListVersionsParams) SetSubject(subject string)

SetSubject adds the subject to the list versions params

func (*ListVersionsParams) SetTimeout 

func (o *ListVersionsParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the list versions params

func (*ListVersionsParams) WithContext 

func (o *ListVersionsParams) WithContext(ctx context.Context) *ListVersionsParams

WithContext adds the context to the list versions params

func (*ListVersionsParams) WithDeleted 

func (o *ListVersionsParams) WithDeleted(deleted *bool) *ListVersionsParams

WithDeleted adds the deleted to the list versions params

func (*ListVersionsParams) WithHTTPClient 

func (o *ListVersionsParams) WithHTTPClient(client *http.Client) *ListVersionsParams

WithHTTPClient adds the HTTPClient to the list versions params

func (*ListVersionsParams) WithSubject 

func (o *ListVersionsParams) WithSubject(subject string) *ListVersionsParams

WithSubject adds the subject to the list versions params

func (*ListVersionsParams) WithTimeout 

func (o *ListVersionsParams) WithTimeout(timeout time.Duration) *ListVersionsParams

WithTimeout adds the timeout to the list versions params

func (*ListVersionsParams) WriteToRequest 

func (o *ListVersionsParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type ListVersionsReader 

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

ListVersionsReader is a Reader for the ListVersions structure.

func (*ListVersionsReader) ReadResponse 

func (o *ListVersionsReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type LookUpSchemaUnderSubjectInternalServerError 

type LookUpSchemaUnderSubjectInternalServerError struct {
	Payload *models.Schema
}

LookUpSchemaUnderSubjectInternalServerError handles this case with default header values.

Internal server error

func NewLookUpSchemaUnderSubjectInternalServerError 

func NewLookUpSchemaUnderSubjectInternalServerError() *LookUpSchemaUnderSubjectInternalServerError

NewLookUpSchemaUnderSubjectInternalServerError creates a LookUpSchemaUnderSubjectInternalServerError with default headers values

func (*LookUpSchemaUnderSubjectInternalServerError) Error 

func (o *LookUpSchemaUnderSubjectInternalServerError) Error() string

func (*LookUpSchemaUnderSubjectInternalServerError) GetPayload 

func (o *LookUpSchemaUnderSubjectInternalServerError) GetPayload() *models.Schema

type LookUpSchemaUnderSubjectNotFound 

type LookUpSchemaUnderSubjectNotFound struct {
}

LookUpSchemaUnderSubjectNotFound handles this case with default header values.

Error code 40401 -- Subject not found Error code 40403 -- Schema not found

func NewLookUpSchemaUnderSubjectNotFound 

func NewLookUpSchemaUnderSubjectNotFound() *LookUpSchemaUnderSubjectNotFound

NewLookUpSchemaUnderSubjectNotFound creates a LookUpSchemaUnderSubjectNotFound with default headers values

func (*LookUpSchemaUnderSubjectNotFound) Error 

func (o *LookUpSchemaUnderSubjectNotFound) Error() string

type LookUpSchemaUnderSubjectParams 

type LookUpSchemaUnderSubjectParams struct {

	/*Body
	  Schema

	*/
	Body *models.RegisterSchemaRequest
	/*Deleted*/
	Deleted *bool
	/*Subject
	  Subject under which the schema will be registered

	*/
	Subject string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

LookUpSchemaUnderSubjectParams contains all the parameters to send to the API endpoint for the look up schema under subject operation typically these are written to a http.Request

func NewLookUpSchemaUnderSubjectParams 

func NewLookUpSchemaUnderSubjectParams() *LookUpSchemaUnderSubjectParams

NewLookUpSchemaUnderSubjectParams creates a new LookUpSchemaUnderSubjectParams object with the default values initialized.

func NewLookUpSchemaUnderSubjectParamsWithContext 

func NewLookUpSchemaUnderSubjectParamsWithContext(ctx context.Context) *LookUpSchemaUnderSubjectParams

NewLookUpSchemaUnderSubjectParamsWithContext creates a new LookUpSchemaUnderSubjectParams object with the default values initialized, and the ability to set a context for a request

func NewLookUpSchemaUnderSubjectParamsWithHTTPClient 

func NewLookUpSchemaUnderSubjectParamsWithHTTPClient(client *http.Client) *LookUpSchemaUnderSubjectParams

NewLookUpSchemaUnderSubjectParamsWithHTTPClient creates a new LookUpSchemaUnderSubjectParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewLookUpSchemaUnderSubjectParamsWithTimeout 

func NewLookUpSchemaUnderSubjectParamsWithTimeout(timeout time.Duration) *LookUpSchemaUnderSubjectParams

NewLookUpSchemaUnderSubjectParamsWithTimeout creates a new LookUpSchemaUnderSubjectParams object with the default values initialized, and the ability to set a timeout on a request

func (*LookUpSchemaUnderSubjectParams) SetBody 

func (o *LookUpSchemaUnderSubjectParams) SetBody(body *models.RegisterSchemaRequest)

SetBody adds the body to the look up schema under subject params

func (*LookUpSchemaUnderSubjectParams) SetContext 

func (o *LookUpSchemaUnderSubjectParams) SetContext(ctx context.Context)

SetContext adds the context to the look up schema under subject params

func (*LookUpSchemaUnderSubjectParams) SetDeleted 

func (o *LookUpSchemaUnderSubjectParams) SetDeleted(deleted *bool)

SetDeleted adds the deleted to the look up schema under subject params

func (*LookUpSchemaUnderSubjectParams) SetHTTPClient 

func (o *LookUpSchemaUnderSubjectParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the look up schema under subject params

func (*LookUpSchemaUnderSubjectParams) SetSubject 

func (o *LookUpSchemaUnderSubjectParams) SetSubject(subject string)

SetSubject adds the subject to the look up schema under subject params

func (*LookUpSchemaUnderSubjectParams) SetTimeout 

func (o *LookUpSchemaUnderSubjectParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the look up schema under subject params

func (*LookUpSchemaUnderSubjectParams) WithBody 

func (o *LookUpSchemaUnderSubjectParams) WithBody(body *models.RegisterSchemaRequest) *LookUpSchemaUnderSubjectParams

WithBody adds the body to the look up schema under subject params

func (*LookUpSchemaUnderSubjectParams) WithContext 

func (o *LookUpSchemaUnderSubjectParams) WithContext(ctx context.Context) *LookUpSchemaUnderSubjectParams

WithContext adds the context to the look up schema under subject params

func (*LookUpSchemaUnderSubjectParams) WithDeleted 

func (o *LookUpSchemaUnderSubjectParams) WithDeleted(deleted *bool) *LookUpSchemaUnderSubjectParams

WithDeleted adds the deleted to the look up schema under subject params

func (*LookUpSchemaUnderSubjectParams) WithHTTPClient 

func (o *LookUpSchemaUnderSubjectParams) WithHTTPClient(client *http.Client) *LookUpSchemaUnderSubjectParams

WithHTTPClient adds the HTTPClient to the look up schema under subject params

func (*LookUpSchemaUnderSubjectParams) WithSubject 

func (o *LookUpSchemaUnderSubjectParams) WithSubject(subject string) *LookUpSchemaUnderSubjectParams

WithSubject adds the subject to the look up schema under subject params

func (*LookUpSchemaUnderSubjectParams) WithTimeout 

func (o *LookUpSchemaUnderSubjectParams) WithTimeout(timeout time.Duration) *LookUpSchemaUnderSubjectParams

WithTimeout adds the timeout to the look up schema under subject params

func (*LookUpSchemaUnderSubjectParams) WriteToRequest 

func (o *LookUpSchemaUnderSubjectParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type LookUpSchemaUnderSubjectReader 

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

LookUpSchemaUnderSubjectReader is a Reader for the LookUpSchemaUnderSubject structure.

func (*LookUpSchemaUnderSubjectReader) ReadResponse 

func (o *LookUpSchemaUnderSubjectReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type PostOK 

type PostOK struct {
	Payload map[string]string
}

PostOK handles this case with default header values.

successful operation

func NewPostOK 

func NewPostOK() *PostOK

NewPostOK creates a PostOK with default headers values

func (*PostOK) Error 

func (o *PostOK) Error() string

func (*PostOK) GetPayload 

func (o *PostOK) GetPayload() map[string]string

type PostParams 

type PostParams struct {
	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

PostParams contains all the parameters to send to the API endpoint for the post operation typically these are written to a http.Request

func NewPostParams 

func NewPostParams() *PostParams

NewPostParams creates a new PostParams object with the default values initialized.

func NewPostParamsWithContext 

func NewPostParamsWithContext(ctx context.Context) *PostParams

NewPostParamsWithContext creates a new PostParams object with the default values initialized, and the ability to set a context for a request

func NewPostParamsWithHTTPClient 

func NewPostParamsWithHTTPClient(client *http.Client) *PostParams

NewPostParamsWithHTTPClient creates a new PostParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewPostParamsWithTimeout 

func NewPostParamsWithTimeout(timeout time.Duration) *PostParams

NewPostParamsWithTimeout creates a new PostParams object with the default values initialized, and the ability to set a timeout on a request

func (*PostParams) SetContext 

func (o *PostParams) SetContext(ctx context.Context)

SetContext adds the context to the post params

func (*PostParams) SetHTTPClient 

func (o *PostParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the post params

func (*PostParams) SetTimeout 

func (o *PostParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the post params

func (*PostParams) WithContext 

func (o *PostParams) WithContext(ctx context.Context) *PostParams

WithContext adds the context to the post params

func (*PostParams) WithHTTPClient 

func (o *PostParams) WithHTTPClient(client *http.Client) *PostParams

WithHTTPClient adds the HTTPClient to the post params

func (*PostParams) WithTimeout 

func (o *PostParams) WithTimeout(timeout time.Duration) *PostParams

WithTimeout adds the timeout to the post params

func (*PostParams) WriteToRequest 

func (o *PostParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type PostReader 

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

PostReader is a Reader for the Post structure.

func (*PostReader) ReadResponse 

func (o *PostReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type RegisterConflict 

type RegisterConflict struct {
}

RegisterConflict handles this case with default header values.

Incompatible schema

func NewRegisterConflict 

func NewRegisterConflict() *RegisterConflict

NewRegisterConflict creates a RegisterConflict with default headers values

func (*RegisterConflict) Error 

func (o *RegisterConflict) Error() string

type RegisterInternalServerError 

type RegisterInternalServerError struct {
}

RegisterInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store Error code 50002 -- Operation timed out Error code 50003 -- Error while forwarding the request to the primary

func NewRegisterInternalServerError 

func NewRegisterInternalServerError() *RegisterInternalServerError

NewRegisterInternalServerError creates a RegisterInternalServerError with default headers values

func (*RegisterInternalServerError) Error 

func (o *RegisterInternalServerError) Error() string

type RegisterOK 

type RegisterOK struct {
	Payload *models.RegisterSchemaResponse
}

RegisterOK handles this case with default header values.

successful operation

func NewRegisterOK 

func NewRegisterOK() *RegisterOK

NewRegisterOK creates a RegisterOK with default headers values

func (*RegisterOK) Error 

func (o *RegisterOK) Error() string

func (*RegisterOK) GetPayload 

func (o *RegisterOK) GetPayload() *models.RegisterSchemaResponse

type RegisterParams 

type RegisterParams struct {

	/*Body
	  Schema

	*/
	Body *models.RegisterSchemaRequest
	/*Subject
	  Name of the Subject

	*/
	Subject string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

RegisterParams contains all the parameters to send to the API endpoint for the register operation typically these are written to a http.Request

func NewRegisterParams 

func NewRegisterParams() *RegisterParams

NewRegisterParams creates a new RegisterParams object with the default values initialized.

func NewRegisterParamsWithContext 

func NewRegisterParamsWithContext(ctx context.Context) *RegisterParams

NewRegisterParamsWithContext creates a new RegisterParams object with the default values initialized, and the ability to set a context for a request

func NewRegisterParamsWithHTTPClient 

func NewRegisterParamsWithHTTPClient(client *http.Client) *RegisterParams

NewRegisterParamsWithHTTPClient creates a new RegisterParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewRegisterParamsWithTimeout 

func NewRegisterParamsWithTimeout(timeout time.Duration) *RegisterParams

NewRegisterParamsWithTimeout creates a new RegisterParams object with the default values initialized, and the ability to set a timeout on a request

func (*RegisterParams) SetBody 

func (o *RegisterParams) SetBody(body *models.RegisterSchemaRequest)

SetBody adds the body to the register params

func (*RegisterParams) SetContext 

func (o *RegisterParams) SetContext(ctx context.Context)

SetContext adds the context to the register params

func (*RegisterParams) SetHTTPClient 

func (o *RegisterParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the register params

func (*RegisterParams) SetSubject 

func (o *RegisterParams) SetSubject(subject string)

SetSubject adds the subject to the register params

func (*RegisterParams) SetTimeout 

func (o *RegisterParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the register params

func (*RegisterParams) WithBody 

func (o *RegisterParams) WithBody(body *models.RegisterSchemaRequest) *RegisterParams

WithBody adds the body to the register params

func (*RegisterParams) WithContext 

func (o *RegisterParams) WithContext(ctx context.Context) *RegisterParams

WithContext adds the context to the register params

func (*RegisterParams) WithHTTPClient 

func (o *RegisterParams) WithHTTPClient(client *http.Client) *RegisterParams

WithHTTPClient adds the HTTPClient to the register params

func (*RegisterParams) WithSubject 

func (o *RegisterParams) WithSubject(subject string) *RegisterParams

WithSubject adds the subject to the register params

func (*RegisterParams) WithTimeout 

func (o *RegisterParams) WithTimeout(timeout time.Duration) *RegisterParams

WithTimeout adds the timeout to the register params

func (*RegisterParams) WriteToRequest 

func (o *RegisterParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type RegisterReader 

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

RegisterReader is a Reader for the Register structure.

func (*RegisterReader) ReadResponse 

func (o *RegisterReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type RegisterUnprocessableEntity 

type RegisterUnprocessableEntity struct {
}

RegisterUnprocessableEntity handles this case with default header values.

Error code 42201 -- Invalid schema or schema type

func NewRegisterUnprocessableEntity 

func NewRegisterUnprocessableEntity() *RegisterUnprocessableEntity

NewRegisterUnprocessableEntity creates a RegisterUnprocessableEntity with default headers values

func (*RegisterUnprocessableEntity) Error 

func (o *RegisterUnprocessableEntity) Error() string

type TestCompatibilityBySubjectNameInternalServerError 

type TestCompatibilityBySubjectNameInternalServerError struct {
}

TestCompatibilityBySubjectNameInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store

func NewTestCompatibilityBySubjectNameInternalServerError 

func NewTestCompatibilityBySubjectNameInternalServerError() *TestCompatibilityBySubjectNameInternalServerError

NewTestCompatibilityBySubjectNameInternalServerError creates a TestCompatibilityBySubjectNameInternalServerError with default headers values

func (*TestCompatibilityBySubjectNameInternalServerError) Error 

func (o *TestCompatibilityBySubjectNameInternalServerError) Error() string

type TestCompatibilityBySubjectNameNotFound 

type TestCompatibilityBySubjectNameNotFound struct {
}

TestCompatibilityBySubjectNameNotFound handles this case with default header values.

Error code 40401 -- Subject not found Error code 40402 -- Version not found

func NewTestCompatibilityBySubjectNameNotFound 

func NewTestCompatibilityBySubjectNameNotFound() *TestCompatibilityBySubjectNameNotFound

NewTestCompatibilityBySubjectNameNotFound creates a TestCompatibilityBySubjectNameNotFound with default headers values

func (*TestCompatibilityBySubjectNameNotFound) Error 

func (o *TestCompatibilityBySubjectNameNotFound) Error() string

type TestCompatibilityBySubjectNameOK 

type TestCompatibilityBySubjectNameOK struct {
	Payload *models.CompatibilityCheckResponse
}

TestCompatibilityBySubjectNameOK handles this case with default header values.

successful operation

func NewTestCompatibilityBySubjectNameOK 

func NewTestCompatibilityBySubjectNameOK() *TestCompatibilityBySubjectNameOK

NewTestCompatibilityBySubjectNameOK creates a TestCompatibilityBySubjectNameOK with default headers values

func (*TestCompatibilityBySubjectNameOK) Error 

func (o *TestCompatibilityBySubjectNameOK) Error() string

func (*TestCompatibilityBySubjectNameOK) GetPayload 

func (o *TestCompatibilityBySubjectNameOK) GetPayload() *models.CompatibilityCheckResponse

type TestCompatibilityBySubjectNameParams 

type TestCompatibilityBySubjectNameParams struct {

	/*Accept*/
	Accept *string
	/*ContentType*/
	ContentType *string
	/*Body
	  Schema

	*/
	Body *models.RegisterSchemaRequest
	/*Subject
	  Subject of the schema version against which compatibility is to be tested

	*/
	Subject string
	/*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

	*/
	Version string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

TestCompatibilityBySubjectNameParams contains all the parameters to send to the API endpoint for the test compatibility by subject name operation typically these are written to a http.Request

func NewTestCompatibilityBySubjectNameParams 

func NewTestCompatibilityBySubjectNameParams() *TestCompatibilityBySubjectNameParams

NewTestCompatibilityBySubjectNameParams creates a new TestCompatibilityBySubjectNameParams object with the default values initialized.

func NewTestCompatibilityBySubjectNameParamsWithContext 

func NewTestCompatibilityBySubjectNameParamsWithContext(ctx context.Context) *TestCompatibilityBySubjectNameParams

NewTestCompatibilityBySubjectNameParamsWithContext creates a new TestCompatibilityBySubjectNameParams object with the default values initialized, and the ability to set a context for a request

func NewTestCompatibilityBySubjectNameParamsWithHTTPClient 

func NewTestCompatibilityBySubjectNameParamsWithHTTPClient(client *http.Client) *TestCompatibilityBySubjectNameParams

NewTestCompatibilityBySubjectNameParamsWithHTTPClient creates a new TestCompatibilityBySubjectNameParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewTestCompatibilityBySubjectNameParamsWithTimeout 

func NewTestCompatibilityBySubjectNameParamsWithTimeout(timeout time.Duration) *TestCompatibilityBySubjectNameParams

NewTestCompatibilityBySubjectNameParamsWithTimeout creates a new TestCompatibilityBySubjectNameParams object with the default values initialized, and the ability to set a timeout on a request

func (*TestCompatibilityBySubjectNameParams) SetAccept 

func (o *TestCompatibilityBySubjectNameParams) SetAccept(accept *string)

SetAccept adds the accept to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) SetBody 

func (o *TestCompatibilityBySubjectNameParams) SetBody(body *models.RegisterSchemaRequest)

SetBody adds the body to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) SetContentType 

func (o *TestCompatibilityBySubjectNameParams) SetContentType(contentType *string)

SetContentType adds the contentType to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) SetContext 

func (o *TestCompatibilityBySubjectNameParams) SetContext(ctx context.Context)

SetContext adds the context to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) SetHTTPClient 

func (o *TestCompatibilityBySubjectNameParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) SetSubject 

func (o *TestCompatibilityBySubjectNameParams) SetSubject(subject string)

SetSubject adds the subject to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) SetTimeout 

func (o *TestCompatibilityBySubjectNameParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) SetVersion 

func (o *TestCompatibilityBySubjectNameParams) SetVersion(version string)

SetVersion adds the version to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) WithAccept 

func (o *TestCompatibilityBySubjectNameParams) WithAccept(accept *string) *TestCompatibilityBySubjectNameParams

WithAccept adds the accept to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) WithBody 

func (o *TestCompatibilityBySubjectNameParams) WithBody(body *models.RegisterSchemaRequest) *TestCompatibilityBySubjectNameParams

WithBody adds the body to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) WithContentType 

func (o *TestCompatibilityBySubjectNameParams) WithContentType(contentType *string) *TestCompatibilityBySubjectNameParams

WithContentType adds the contentType to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) WithContext 

func (o *TestCompatibilityBySubjectNameParams) WithContext(ctx context.Context) *TestCompatibilityBySubjectNameParams

WithContext adds the context to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) WithHTTPClient 

func (o *TestCompatibilityBySubjectNameParams) WithHTTPClient(client *http.Client) *TestCompatibilityBySubjectNameParams

WithHTTPClient adds the HTTPClient to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) WithSubject 

func (o *TestCompatibilityBySubjectNameParams) WithSubject(subject string) *TestCompatibilityBySubjectNameParams

WithSubject adds the subject to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) WithTimeout 

func (o *TestCompatibilityBySubjectNameParams) WithTimeout(timeout time.Duration) *TestCompatibilityBySubjectNameParams

WithTimeout adds the timeout to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) WithVersion 

func (o *TestCompatibilityBySubjectNameParams) WithVersion(version string) *TestCompatibilityBySubjectNameParams

WithVersion adds the version to the test compatibility by subject name params

func (*TestCompatibilityBySubjectNameParams) WriteToRequest 

func (o *TestCompatibilityBySubjectNameParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type TestCompatibilityBySubjectNameReader 

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

TestCompatibilityBySubjectNameReader is a Reader for the TestCompatibilityBySubjectName structure.

func (*TestCompatibilityBySubjectNameReader) ReadResponse 

func (o *TestCompatibilityBySubjectNameReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type TestCompatibilityBySubjectNameUnprocessableEntity 

type TestCompatibilityBySubjectNameUnprocessableEntity struct {
}

TestCompatibilityBySubjectNameUnprocessableEntity handles this case with default header values.

Error code 42201 -- Invalid schema or schema type Error code 42202 -- Invalid version

func NewTestCompatibilityBySubjectNameUnprocessableEntity 

func NewTestCompatibilityBySubjectNameUnprocessableEntity() *TestCompatibilityBySubjectNameUnprocessableEntity

NewTestCompatibilityBySubjectNameUnprocessableEntity creates a TestCompatibilityBySubjectNameUnprocessableEntity with default headers values

func (*TestCompatibilityBySubjectNameUnprocessableEntity) Error 

func (o *TestCompatibilityBySubjectNameUnprocessableEntity) Error() string

type UpdateModeOK 

type UpdateModeOK struct {
	Payload *models.ModeUpdateRequest
}

UpdateModeOK handles this case with default header values.

successful operation

func NewUpdateModeOK 

func NewUpdateModeOK() *UpdateModeOK

NewUpdateModeOK creates a UpdateModeOK with default headers values

func (*UpdateModeOK) Error 

func (o *UpdateModeOK) Error() string

func (*UpdateModeOK) GetPayload 

func (o *UpdateModeOK) GetPayload() *models.ModeUpdateRequest

type UpdateModeParams 

type UpdateModeParams struct {

	/*Body
	  Update Request

	*/
	Body *models.ModeUpdateRequest
	/*Subject*/
	Subject string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

UpdateModeParams contains all the parameters to send to the API endpoint for the update mode operation typically these are written to a http.Request

func NewUpdateModeParams 

func NewUpdateModeParams() *UpdateModeParams

NewUpdateModeParams creates a new UpdateModeParams object with the default values initialized.

func NewUpdateModeParamsWithContext 

func NewUpdateModeParamsWithContext(ctx context.Context) *UpdateModeParams

NewUpdateModeParamsWithContext creates a new UpdateModeParams object with the default values initialized, and the ability to set a context for a request

func NewUpdateModeParamsWithHTTPClient 

func NewUpdateModeParamsWithHTTPClient(client *http.Client) *UpdateModeParams

NewUpdateModeParamsWithHTTPClient creates a new UpdateModeParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewUpdateModeParamsWithTimeout 

func NewUpdateModeParamsWithTimeout(timeout time.Duration) *UpdateModeParams

NewUpdateModeParamsWithTimeout creates a new UpdateModeParams object with the default values initialized, and the ability to set a timeout on a request

func (*UpdateModeParams) SetBody 

func (o *UpdateModeParams) SetBody(body *models.ModeUpdateRequest)

SetBody adds the body to the update mode params

func (*UpdateModeParams) SetContext 

func (o *UpdateModeParams) SetContext(ctx context.Context)

SetContext adds the context to the update mode params

func (*UpdateModeParams) SetHTTPClient 

func (o *UpdateModeParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the update mode params

func (*UpdateModeParams) SetSubject 

func (o *UpdateModeParams) SetSubject(subject string)

SetSubject adds the subject to the update mode params

func (*UpdateModeParams) SetTimeout 

func (o *UpdateModeParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the update mode params

func (*UpdateModeParams) WithBody 

func (o *UpdateModeParams) WithBody(body *models.ModeUpdateRequest) *UpdateModeParams

WithBody adds the body to the update mode params

func (*UpdateModeParams) WithContext 

func (o *UpdateModeParams) WithContext(ctx context.Context) *UpdateModeParams

WithContext adds the context to the update mode params

func (*UpdateModeParams) WithHTTPClient 

func (o *UpdateModeParams) WithHTTPClient(client *http.Client) *UpdateModeParams

WithHTTPClient adds the HTTPClient to the update mode params

func (*UpdateModeParams) WithSubject 

func (o *UpdateModeParams) WithSubject(subject string) *UpdateModeParams

WithSubject adds the subject to the update mode params

func (*UpdateModeParams) WithTimeout 

func (o *UpdateModeParams) WithTimeout(timeout time.Duration) *UpdateModeParams

WithTimeout adds the timeout to the update mode params

func (*UpdateModeParams) WriteToRequest 

func (o *UpdateModeParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type UpdateModeReader 

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

UpdateModeReader is a Reader for the UpdateMode structure.

func (*UpdateModeReader) ReadResponse 

func (o *UpdateModeReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type UpdateSubjectLevelConfigInternalServerError 

type UpdateSubjectLevelConfigInternalServerError struct {
}

UpdateSubjectLevelConfigInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store Error code 50003 -- Error while forwarding the request to the primary

func NewUpdateSubjectLevelConfigInternalServerError 

func NewUpdateSubjectLevelConfigInternalServerError() *UpdateSubjectLevelConfigInternalServerError

NewUpdateSubjectLevelConfigInternalServerError creates a UpdateSubjectLevelConfigInternalServerError with default headers values

func (*UpdateSubjectLevelConfigInternalServerError) Error 

func (o *UpdateSubjectLevelConfigInternalServerError) Error() string

type UpdateSubjectLevelConfigOK 

type UpdateSubjectLevelConfigOK struct {
	Payload *models.ConfigUpdateRequest
}

UpdateSubjectLevelConfigOK handles this case with default header values.

successful operation

func NewUpdateSubjectLevelConfigOK 

func NewUpdateSubjectLevelConfigOK() *UpdateSubjectLevelConfigOK

NewUpdateSubjectLevelConfigOK creates a UpdateSubjectLevelConfigOK with default headers values

func (*UpdateSubjectLevelConfigOK) Error 

func (o *UpdateSubjectLevelConfigOK) Error() string

func (*UpdateSubjectLevelConfigOK) GetPayload 

func (o *UpdateSubjectLevelConfigOK) GetPayload() *models.ConfigUpdateRequest

type UpdateSubjectLevelConfigParams 

type UpdateSubjectLevelConfigParams struct {

	/*Body
	  Config Update Request

	*/
	Body *models.ConfigUpdateRequest
	/*Subject
	  Name of the Subject

	*/
	Subject string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

UpdateSubjectLevelConfigParams contains all the parameters to send to the API endpoint for the update subject level config operation typically these are written to a http.Request

func NewUpdateSubjectLevelConfigParams 

func NewUpdateSubjectLevelConfigParams() *UpdateSubjectLevelConfigParams

NewUpdateSubjectLevelConfigParams creates a new UpdateSubjectLevelConfigParams object with the default values initialized.

func NewUpdateSubjectLevelConfigParamsWithContext 

func NewUpdateSubjectLevelConfigParamsWithContext(ctx context.Context) *UpdateSubjectLevelConfigParams

NewUpdateSubjectLevelConfigParamsWithContext creates a new UpdateSubjectLevelConfigParams object with the default values initialized, and the ability to set a context for a request

func NewUpdateSubjectLevelConfigParamsWithHTTPClient 

func NewUpdateSubjectLevelConfigParamsWithHTTPClient(client *http.Client) *UpdateSubjectLevelConfigParams

NewUpdateSubjectLevelConfigParamsWithHTTPClient creates a new UpdateSubjectLevelConfigParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewUpdateSubjectLevelConfigParamsWithTimeout 

func NewUpdateSubjectLevelConfigParamsWithTimeout(timeout time.Duration) *UpdateSubjectLevelConfigParams

NewUpdateSubjectLevelConfigParamsWithTimeout creates a new UpdateSubjectLevelConfigParams object with the default values initialized, and the ability to set a timeout on a request

func (*UpdateSubjectLevelConfigParams) SetBody 

func (o *UpdateSubjectLevelConfigParams) SetBody(body *models.ConfigUpdateRequest)

SetBody adds the body to the update subject level config params

func (*UpdateSubjectLevelConfigParams) SetContext 

func (o *UpdateSubjectLevelConfigParams) SetContext(ctx context.Context)

SetContext adds the context to the update subject level config params

func (*UpdateSubjectLevelConfigParams) SetHTTPClient 

func (o *UpdateSubjectLevelConfigParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the update subject level config params

func (*UpdateSubjectLevelConfigParams) SetSubject 

func (o *UpdateSubjectLevelConfigParams) SetSubject(subject string)

SetSubject adds the subject to the update subject level config params

func (*UpdateSubjectLevelConfigParams) SetTimeout 

func (o *UpdateSubjectLevelConfigParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the update subject level config params

func (*UpdateSubjectLevelConfigParams) WithBody 

func (o *UpdateSubjectLevelConfigParams) WithBody(body *models.ConfigUpdateRequest) *UpdateSubjectLevelConfigParams

WithBody adds the body to the update subject level config params

func (*UpdateSubjectLevelConfigParams) WithContext 

func (o *UpdateSubjectLevelConfigParams) WithContext(ctx context.Context) *UpdateSubjectLevelConfigParams

WithContext adds the context to the update subject level config params

func (*UpdateSubjectLevelConfigParams) WithHTTPClient 

func (o *UpdateSubjectLevelConfigParams) WithHTTPClient(client *http.Client) *UpdateSubjectLevelConfigParams

WithHTTPClient adds the HTTPClient to the update subject level config params

func (*UpdateSubjectLevelConfigParams) WithSubject 

func (o *UpdateSubjectLevelConfigParams) WithSubject(subject string) *UpdateSubjectLevelConfigParams

WithSubject adds the subject to the update subject level config params

func (*UpdateSubjectLevelConfigParams) WithTimeout 

func (o *UpdateSubjectLevelConfigParams) WithTimeout(timeout time.Duration) *UpdateSubjectLevelConfigParams

WithTimeout adds the timeout to the update subject level config params

func (*UpdateSubjectLevelConfigParams) WriteToRequest 

func (o *UpdateSubjectLevelConfigParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type UpdateSubjectLevelConfigReader 

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

UpdateSubjectLevelConfigReader is a Reader for the UpdateSubjectLevelConfig structure.

func (*UpdateSubjectLevelConfigReader) ReadResponse 

func (o *UpdateSubjectLevelConfigReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type UpdateSubjectLevelConfigUnprocessableEntity 

type UpdateSubjectLevelConfigUnprocessableEntity struct {
}

UpdateSubjectLevelConfigUnprocessableEntity handles this case with default header values.

Error code 42203 -- Invalid compatibility level Error code 40402 -- Version not found

func NewUpdateSubjectLevelConfigUnprocessableEntity 

func NewUpdateSubjectLevelConfigUnprocessableEntity() *UpdateSubjectLevelConfigUnprocessableEntity

NewUpdateSubjectLevelConfigUnprocessableEntity creates a UpdateSubjectLevelConfigUnprocessableEntity with default headers values

func (*UpdateSubjectLevelConfigUnprocessableEntity) Error 

func (o *UpdateSubjectLevelConfigUnprocessableEntity) Error() string

type UpdateTopLevelConfigInternalServerError 

type UpdateTopLevelConfigInternalServerError struct {
}

UpdateTopLevelConfigInternalServerError handles this case with default header values.

Error code 50001 -- Error in the backend data store Error code 50003 -- Error while forwarding the request to the primary

func NewUpdateTopLevelConfigInternalServerError 

func NewUpdateTopLevelConfigInternalServerError() *UpdateTopLevelConfigInternalServerError

NewUpdateTopLevelConfigInternalServerError creates a UpdateTopLevelConfigInternalServerError with default headers values

func (*UpdateTopLevelConfigInternalServerError) Error 

func (o *UpdateTopLevelConfigInternalServerError) Error() string

type UpdateTopLevelConfigOK 

type UpdateTopLevelConfigOK struct {
	Payload *models.ConfigUpdateRequest
}

UpdateTopLevelConfigOK handles this case with default header values.

successful operation

func NewUpdateTopLevelConfigOK 

func NewUpdateTopLevelConfigOK() *UpdateTopLevelConfigOK

NewUpdateTopLevelConfigOK creates a UpdateTopLevelConfigOK with default headers values

func (*UpdateTopLevelConfigOK) Error 

func (o *UpdateTopLevelConfigOK) Error() string

func (*UpdateTopLevelConfigOK) GetPayload 

func (o *UpdateTopLevelConfigOK) GetPayload() *models.ConfigUpdateRequest

type UpdateTopLevelConfigParams 

type UpdateTopLevelConfigParams struct {

	/*Body
	  Config Update Request

	*/
	Body *models.ConfigUpdateRequest

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

UpdateTopLevelConfigParams contains all the parameters to send to the API endpoint for the update top level config operation typically these are written to a http.Request

func NewUpdateTopLevelConfigParams 

func NewUpdateTopLevelConfigParams() *UpdateTopLevelConfigParams

NewUpdateTopLevelConfigParams creates a new UpdateTopLevelConfigParams object with the default values initialized.

func NewUpdateTopLevelConfigParamsWithContext 

func NewUpdateTopLevelConfigParamsWithContext(ctx context.Context) *UpdateTopLevelConfigParams

NewUpdateTopLevelConfigParamsWithContext creates a new UpdateTopLevelConfigParams object with the default values initialized, and the ability to set a context for a request

func NewUpdateTopLevelConfigParamsWithHTTPClient 

func NewUpdateTopLevelConfigParamsWithHTTPClient(client *http.Client) *UpdateTopLevelConfigParams

NewUpdateTopLevelConfigParamsWithHTTPClient creates a new UpdateTopLevelConfigParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewUpdateTopLevelConfigParamsWithTimeout 

func NewUpdateTopLevelConfigParamsWithTimeout(timeout time.Duration) *UpdateTopLevelConfigParams

NewUpdateTopLevelConfigParamsWithTimeout creates a new UpdateTopLevelConfigParams object with the default values initialized, and the ability to set a timeout on a request

func (*UpdateTopLevelConfigParams) SetBody 

func (o *UpdateTopLevelConfigParams) SetBody(body *models.ConfigUpdateRequest)

SetBody adds the body to the update top level config params

func (*UpdateTopLevelConfigParams) SetContext 

func (o *UpdateTopLevelConfigParams) SetContext(ctx context.Context)

SetContext adds the context to the update top level config params

func (*UpdateTopLevelConfigParams) SetHTTPClient 

func (o *UpdateTopLevelConfigParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the update top level config params

func (*UpdateTopLevelConfigParams) SetTimeout 

func (o *UpdateTopLevelConfigParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the update top level config params

func (*UpdateTopLevelConfigParams) WithBody 

func (o *UpdateTopLevelConfigParams) WithBody(body *models.ConfigUpdateRequest) *UpdateTopLevelConfigParams

WithBody adds the body to the update top level config params

func (*UpdateTopLevelConfigParams) WithContext 

func (o *UpdateTopLevelConfigParams) WithContext(ctx context.Context) *UpdateTopLevelConfigParams

WithContext adds the context to the update top level config params

func (*UpdateTopLevelConfigParams) WithHTTPClient 

func (o *UpdateTopLevelConfigParams) WithHTTPClient(client *http.Client) *UpdateTopLevelConfigParams

WithHTTPClient adds the HTTPClient to the update top level config params

func (*UpdateTopLevelConfigParams) WithTimeout 

func (o *UpdateTopLevelConfigParams) WithTimeout(timeout time.Duration) *UpdateTopLevelConfigParams

WithTimeout adds the timeout to the update top level config params

func (*UpdateTopLevelConfigParams) WriteToRequest 

func (o *UpdateTopLevelConfigParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type UpdateTopLevelConfigReader 

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

UpdateTopLevelConfigReader is a Reader for the UpdateTopLevelConfig structure.

func (*UpdateTopLevelConfigReader) ReadResponse 

func (o *UpdateTopLevelConfigReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type UpdateTopLevelConfigUnprocessableEntity 

type UpdateTopLevelConfigUnprocessableEntity struct {
}

UpdateTopLevelConfigUnprocessableEntity handles this case with default header values.

Error code 42203 -- Invalid compatibility level

func NewUpdateTopLevelConfigUnprocessableEntity 

func NewUpdateTopLevelConfigUnprocessableEntity() *UpdateTopLevelConfigUnprocessableEntity

NewUpdateTopLevelConfigUnprocessableEntity creates a UpdateTopLevelConfigUnprocessableEntity with default headers values

func (*UpdateTopLevelConfigUnprocessableEntity) Error 

func (o *UpdateTopLevelConfigUnprocessableEntity) Error() string

type UpdateTopLevelModeOK 

type UpdateTopLevelModeOK struct {
	Payload *models.ModeUpdateRequest
}

UpdateTopLevelModeOK handles this case with default header values.

successful operation

func NewUpdateTopLevelModeOK 

func NewUpdateTopLevelModeOK() *UpdateTopLevelModeOK

NewUpdateTopLevelModeOK creates a UpdateTopLevelModeOK with default headers values

func (*UpdateTopLevelModeOK) Error 

func (o *UpdateTopLevelModeOK) Error() string

func (*UpdateTopLevelModeOK) GetPayload 

func (o *UpdateTopLevelModeOK) GetPayload() *models.ModeUpdateRequest

type UpdateTopLevelModeParams 

type UpdateTopLevelModeParams struct {

	/*Body
	  Update Request

	*/
	Body *models.ModeUpdateRequest

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

UpdateTopLevelModeParams contains all the parameters to send to the API endpoint for the update top level mode operation typically these are written to a http.Request

func NewUpdateTopLevelModeParams 

func NewUpdateTopLevelModeParams() *UpdateTopLevelModeParams

NewUpdateTopLevelModeParams creates a new UpdateTopLevelModeParams object with the default values initialized.

func NewUpdateTopLevelModeParamsWithContext 

func NewUpdateTopLevelModeParamsWithContext(ctx context.Context) *UpdateTopLevelModeParams

NewUpdateTopLevelModeParamsWithContext creates a new UpdateTopLevelModeParams object with the default values initialized, and the ability to set a context for a request

func NewUpdateTopLevelModeParamsWithHTTPClient 

func NewUpdateTopLevelModeParamsWithHTTPClient(client *http.Client) *UpdateTopLevelModeParams

NewUpdateTopLevelModeParamsWithHTTPClient creates a new UpdateTopLevelModeParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewUpdateTopLevelModeParamsWithTimeout 

func NewUpdateTopLevelModeParamsWithTimeout(timeout time.Duration) *UpdateTopLevelModeParams

NewUpdateTopLevelModeParamsWithTimeout creates a new UpdateTopLevelModeParams object with the default values initialized, and the ability to set a timeout on a request

func (*UpdateTopLevelModeParams) SetBody 

func (o *UpdateTopLevelModeParams) SetBody(body *models.ModeUpdateRequest)

SetBody adds the body to the update top level mode params

func (*UpdateTopLevelModeParams) SetContext 

func (o *UpdateTopLevelModeParams) SetContext(ctx context.Context)

SetContext adds the context to the update top level mode params

func (*UpdateTopLevelModeParams) SetHTTPClient 

func (o *UpdateTopLevelModeParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the update top level mode params

func (*UpdateTopLevelModeParams) SetTimeout 

func (o *UpdateTopLevelModeParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the update top level mode params

func (*UpdateTopLevelModeParams) WithBody 

func (o *UpdateTopLevelModeParams) WithBody(body *models.ModeUpdateRequest) *UpdateTopLevelModeParams

WithBody adds the body to the update top level mode params

func (*UpdateTopLevelModeParams) WithContext 

func (o *UpdateTopLevelModeParams) WithContext(ctx context.Context) *UpdateTopLevelModeParams

WithContext adds the context to the update top level mode params

func (*UpdateTopLevelModeParams) WithHTTPClient 

func (o *UpdateTopLevelModeParams) WithHTTPClient(client *http.Client) *UpdateTopLevelModeParams

WithHTTPClient adds the HTTPClient to the update top level mode params

func (*UpdateTopLevelModeParams) WithTimeout 

func (o *UpdateTopLevelModeParams) WithTimeout(timeout time.Duration) *UpdateTopLevelModeParams

WithTimeout adds the timeout to the update top level mode params

func (*UpdateTopLevelModeParams) WriteToRequest 

func (o *UpdateTopLevelModeParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type UpdateTopLevelModeReader 

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

UpdateTopLevelModeReader is a Reader for the UpdateTopLevelMode structure.

func (*UpdateTopLevelModeReader) ReadResponse 

func (o *UpdateTopLevelModeReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.