diff --git a/api/api_replications.gen.go b/api/api_replications.gen.go
new file mode 100644
index 0000000..ab41b42
--- /dev/null
+++ b/api/api_replications.gen.go
@@ -0,0 +1,1155 @@
+/*
+ * Subset of Influx API covered by Influx CLI
+ *
+ * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
+ *
+ * API version: 2.0.0
+ */
+
+// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT.
+
+package api
+
+import (
+	_context "context"
+	_fmt "fmt"
+	_io "io"
+	_nethttp "net/http"
+	_neturl "net/url"
+	"strings"
+)
+
+// Linger please
+var (
+	_ _context.Context
+)
+
+type ReplicationsApi interface {
+
+	/*
+	 * DeleteReplicationByID Delete a replication
+	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+	 * @param replicationID
+	 * @return ApiDeleteReplicationByIDRequest
+	 */
+	DeleteReplicationByID(ctx _context.Context, replicationID string) ApiDeleteReplicationByIDRequest
+
+	/*
+	 * DeleteReplicationByIDExecute executes the request
+	 */
+	DeleteReplicationByIDExecute(r ApiDeleteReplicationByIDRequest) error
+
+	/*
+	 * GetReplicationByID Retrieve a replication
+	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+	 * @param replicationID
+	 * @return ApiGetReplicationByIDRequest
+	 */
+	GetReplicationByID(ctx _context.Context, replicationID string) ApiGetReplicationByIDRequest
+
+	/*
+	 * GetReplicationByIDExecute executes the request
+	 * @return Replication
+	 */
+	GetReplicationByIDExecute(r ApiGetReplicationByIDRequest) (Replication, error)
+
+	/*
+	 * GetReplications List all replications
+	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+	 * @return ApiGetReplicationsRequest
+	 */
+	GetReplications(ctx _context.Context) ApiGetReplicationsRequest
+
+	/*
+	 * GetReplicationsExecute executes the request
+	 * @return Replications
+	 */
+	GetReplicationsExecute(r ApiGetReplicationsRequest) (Replications, error)
+
+	/*
+	 * PatchReplicationByID Update a replication
+	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+	 * @param replicationID
+	 * @return ApiPatchReplicationByIDRequest
+	 */
+	PatchReplicationByID(ctx _context.Context, replicationID string) ApiPatchReplicationByIDRequest
+
+	/*
+	 * PatchReplicationByIDExecute executes the request
+	 * @return Replication
+	 */
+	PatchReplicationByIDExecute(r ApiPatchReplicationByIDRequest) (Replication, error)
+
+	/*
+	 * PostReplication Register a new replication
+	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+	 * @return ApiPostReplicationRequest
+	 */
+	PostReplication(ctx _context.Context) ApiPostReplicationRequest
+
+	/*
+	 * PostReplicationExecute executes the request
+	 * @return Replication
+	 */
+	PostReplicationExecute(r ApiPostReplicationRequest) (Replication, error)
+
+	/*
+	 * PostValidateReplicationByID Validate a replication
+	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+	 * @param replicationID
+	 * @return ApiPostValidateReplicationByIDRequest
+	 */
+	PostValidateReplicationByID(ctx _context.Context, replicationID string) ApiPostValidateReplicationByIDRequest
+
+	/*
+	 * PostValidateReplicationByIDExecute executes the request
+	 */
+	PostValidateReplicationByIDExecute(r ApiPostValidateReplicationByIDRequest) error
+
+	// Sets additional descriptive text in the error message if any request in
+	// this API fails, indicating that it is intended to be used only on OSS
+	// servers.
+	OnlyOSS() ReplicationsApi
+
+	// Sets additional descriptive text in the error message if any request in
+	// this API fails, indicating that it is intended to be used only on cloud
+	// servers.
+	OnlyCloud() ReplicationsApi
+}
+
+// ReplicationsApiService ReplicationsApi service
+type ReplicationsApiService service
+
+func (a *ReplicationsApiService) OnlyOSS() ReplicationsApi {
+	a.isOnlyOSS = true
+	return a
+}
+
+func (a *ReplicationsApiService) OnlyCloud() ReplicationsApi {
+	a.isOnlyCloud = true
+	return a
+}
+
+type ApiDeleteReplicationByIDRequest struct {
+	ctx           _context.Context
+	ApiService    ReplicationsApi
+	replicationID string
+	zapTraceSpan  *string
+}
+
+func (r ApiDeleteReplicationByIDRequest) ReplicationID(replicationID string) ApiDeleteReplicationByIDRequest {
+	r.replicationID = replicationID
+	return r
+}
+func (r ApiDeleteReplicationByIDRequest) GetReplicationID() string {
+	return r.replicationID
+}
+
+func (r ApiDeleteReplicationByIDRequest) ZapTraceSpan(zapTraceSpan string) ApiDeleteReplicationByIDRequest {
+	r.zapTraceSpan = &zapTraceSpan
+	return r
+}
+func (r ApiDeleteReplicationByIDRequest) GetZapTraceSpan() *string {
+	return r.zapTraceSpan
+}
+
+func (r ApiDeleteReplicationByIDRequest) Execute() error {
+	return r.ApiService.DeleteReplicationByIDExecute(r)
+}
+
+/*
+ * DeleteReplicationByID Delete a replication
+ * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+ * @param replicationID
+ * @return ApiDeleteReplicationByIDRequest
+ */
+func (a *ReplicationsApiService) DeleteReplicationByID(ctx _context.Context, replicationID string) ApiDeleteReplicationByIDRequest {
+	return ApiDeleteReplicationByIDRequest{
+		ApiService:    a,
+		ctx:           ctx,
+		replicationID: replicationID,
+	}
+}
+
+/*
+ * Execute executes the request
+ */
+func (a *ReplicationsApiService) DeleteReplicationByIDExecute(r ApiDeleteReplicationByIDRequest) error {
+	var (
+		localVarHTTPMethod   = _nethttp.MethodDelete
+		localVarPostBody     interface{}
+		localVarFormFileName string
+		localVarFileName     string
+		localVarFileBytes    []byte
+	)
+
+	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "ReplicationsApiService.DeleteReplicationByID")
+	if err != nil {
+		return GenericOpenAPIError{error: err.Error()}
+	}
+
+	localVarPath := localBasePath + "/replications/{replicationID}"
+	localVarPath = strings.Replace(localVarPath, "{"+"replicationID"+"}", _neturl.PathEscape(parameterToString(r.replicationID, "")), -1)
+
+	localVarHeaderParams := make(map[string]string)
+	localVarQueryParams := _neturl.Values{}
+	localVarFormParams := _neturl.Values{}
+
+	// to determine the Content-Type header
+	localVarHTTPContentTypes := []string{}
+
+	// set Content-Type header
+	localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes)
+	if localVarHTTPContentType != "" {
+		localVarHeaderParams["Content-Type"] = localVarHTTPContentType
+	}
+
+	// to determine the Accept header
+	localVarHTTPHeaderAccepts := []string{"application/json"}
+
+	// set Accept header
+	localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
+	if localVarHTTPHeaderAccept != "" {
+		localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept
+	}
+	if r.zapTraceSpan != nil {
+		localVarHeaderParams["Zap-Trace-Span"] = parameterToString(*r.zapTraceSpan, "")
+	}
+	req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, localVarFormFileName, localVarFileName, localVarFileBytes)
+	if err != nil {
+		return err
+	}
+
+	localVarHTTPResponse, err := a.client.callAPI(req)
+	if err != nil || localVarHTTPResponse == nil {
+		return err
+	}
+
+	var errorPrefix string
+	if a.isOnlyOSS {
+		errorPrefix = "InfluxDB OSS-only command failed: "
+	} else if a.isOnlyCloud {
+		errorPrefix = "InfluxDB Cloud-only command failed: "
+	}
+
+	if localVarHTTPResponse.StatusCode >= 300 {
+		body, err := GunzipIfNeeded(localVarHTTPResponse)
+		if err != nil {
+			body.Close()
+			return _fmt.Errorf("%s%w", errorPrefix, err)
+		}
+		localVarBody, err := _io.ReadAll(body)
+		body.Close()
+		if err != nil {
+			return _fmt.Errorf("%s%w", errorPrefix, err)
+		}
+		newErr := GenericOpenAPIError{
+			body:  localVarBody,
+			error: _fmt.Sprintf("%s%s", errorPrefix, localVarHTTPResponse.Status),
+		}
+		if localVarHTTPResponse.StatusCode == 404 {
+			var v Error
+			err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+			if err != nil {
+				newErr.error = _fmt.Sprintf("%s: %s", newErr.Error(), err.Error())
+				return newErr
+			}
+			v.SetMessage(_fmt.Sprintf("%s: %s", newErr.Error(), v.GetMessage()))
+			newErr.model = &v
+			return newErr
+		}
+		var v Error
+		err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+		if err != nil {
+			newErr.error = _fmt.Sprintf("%s: %s", newErr.Error(), err.Error())
+			return newErr
+		}
+		v.SetMessage(_fmt.Sprintf("%s: %s", newErr.Error(), v.GetMessage()))
+		newErr.model = &v
+		return newErr
+	}
+
+	return nil
+}
+
+type ApiGetReplicationByIDRequest struct {
+	ctx           _context.Context
+	ApiService    ReplicationsApi
+	replicationID string
+	zapTraceSpan  *string
+}
+
+func (r ApiGetReplicationByIDRequest) ReplicationID(replicationID string) ApiGetReplicationByIDRequest {
+	r.replicationID = replicationID
+	return r
+}
+func (r ApiGetReplicationByIDRequest) GetReplicationID() string {
+	return r.replicationID
+}
+
+func (r ApiGetReplicationByIDRequest) ZapTraceSpan(zapTraceSpan string) ApiGetReplicationByIDRequest {
+	r.zapTraceSpan = &zapTraceSpan
+	return r
+}
+func (r ApiGetReplicationByIDRequest) GetZapTraceSpan() *string {
+	return r.zapTraceSpan
+}
+
+func (r ApiGetReplicationByIDRequest) Execute() (Replication, error) {
+	return r.ApiService.GetReplicationByIDExecute(r)
+}
+
+/*
+ * GetReplicationByID Retrieve a replication
+ * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+ * @param replicationID
+ * @return ApiGetReplicationByIDRequest
+ */
+func (a *ReplicationsApiService) GetReplicationByID(ctx _context.Context, replicationID string) ApiGetReplicationByIDRequest {
+	return ApiGetReplicationByIDRequest{
+		ApiService:    a,
+		ctx:           ctx,
+		replicationID: replicationID,
+	}
+}
+
+/*
+ * Execute executes the request
+ * @return Replication
+ */
+func (a *ReplicationsApiService) GetReplicationByIDExecute(r ApiGetReplicationByIDRequest) (Replication, error) {
+	var (
+		localVarHTTPMethod   = _nethttp.MethodGet
+		localVarPostBody     interface{}
+		localVarFormFileName string
+		localVarFileName     string
+		localVarFileBytes    []byte
+		localVarReturnValue  Replication
+	)
+
+	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "ReplicationsApiService.GetReplicationByID")
+	if err != nil {
+		return localVarReturnValue, GenericOpenAPIError{error: err.Error()}
+	}
+
+	localVarPath := localBasePath + "/replications/{replicationID}"
+	localVarPath = strings.Replace(localVarPath, "{"+"replicationID"+"}", _neturl.PathEscape(parameterToString(r.replicationID, "")), -1)
+
+	localVarHeaderParams := make(map[string]string)
+	localVarQueryParams := _neturl.Values{}
+	localVarFormParams := _neturl.Values{}
+
+	// to determine the Content-Type header
+	localVarHTTPContentTypes := []string{}
+
+	// set Content-Type header
+	localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes)
+	if localVarHTTPContentType != "" {
+		localVarHeaderParams["Content-Type"] = localVarHTTPContentType
+	}
+
+	// to determine the Accept header
+	localVarHTTPHeaderAccepts := []string{"application/json"}
+
+	// set Accept header
+	localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
+	if localVarHTTPHeaderAccept != "" {
+		localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept
+	}
+	if r.zapTraceSpan != nil {
+		localVarHeaderParams["Zap-Trace-Span"] = parameterToString(*r.zapTraceSpan, "")
+	}
+	req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, localVarFormFileName, localVarFileName, localVarFileBytes)
+	if err != nil {
+		return localVarReturnValue, err
+	}
+
+	localVarHTTPResponse, err := a.client.callAPI(req)
+	if err != nil || localVarHTTPResponse == nil {
+		return localVarReturnValue, err
+	}
+
+	var errorPrefix string
+	if a.isOnlyOSS {
+		errorPrefix = "InfluxDB OSS-only command failed: "
+	} else if a.isOnlyCloud {
+		errorPrefix = "InfluxDB Cloud-only command failed: "
+	}
+
+	if localVarHTTPResponse.StatusCode >= 300 {
+		body, err := GunzipIfNeeded(localVarHTTPResponse)
+		if err != nil {
+			body.Close()
+			return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+		}
+		localVarBody, err := _io.ReadAll(body)
+		body.Close()
+		if err != nil {
+			return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+		}
+		newErr := GenericOpenAPIError{
+			body:  localVarBody,
+			error: _fmt.Sprintf("%s%s", errorPrefix, localVarHTTPResponse.Status),
+		}
+		if localVarHTTPResponse.StatusCode == 404 {
+			var v Error
+			err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+			if err != nil {
+				newErr.error = _fmt.Sprintf("%s: %s", newErr.Error(), err.Error())
+				return localVarReturnValue, newErr
+			}
+			v.SetMessage(_fmt.Sprintf("%s: %s", newErr.Error(), v.GetMessage()))
+			newErr.model = &v
+			return localVarReturnValue, newErr
+		}
+		var v Error
+		err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+		if err != nil {
+			newErr.error = _fmt.Sprintf("%s: %s", newErr.Error(), err.Error())
+			return localVarReturnValue, newErr
+		}
+		v.SetMessage(_fmt.Sprintf("%s: %s", newErr.Error(), v.GetMessage()))
+		newErr.model = &v
+		return localVarReturnValue, newErr
+	}
+
+	body, err := GunzipIfNeeded(localVarHTTPResponse)
+	if err != nil {
+		body.Close()
+		return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+	}
+	localVarBody, err := _io.ReadAll(body)
+	body.Close()
+	if err != nil {
+		return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+	}
+	err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+	if err != nil {
+		newErr := GenericOpenAPIError{
+			body:  localVarBody,
+			error: _fmt.Sprintf("%s%s", errorPrefix, err.Error()),
+		}
+		return localVarReturnValue, newErr
+	}
+
+	return localVarReturnValue, nil
+}
+
+type ApiGetReplicationsRequest struct {
+	ctx           _context.Context
+	ApiService    ReplicationsApi
+	orgID         *string
+	zapTraceSpan  *string
+	name          *string
+	remoteID      *string
+	localBucketID *string
+}
+
+func (r ApiGetReplicationsRequest) OrgID(orgID string) ApiGetReplicationsRequest {
+	r.orgID = &orgID
+	return r
+}
+func (r ApiGetReplicationsRequest) GetOrgID() *string {
+	return r.orgID
+}
+
+func (r ApiGetReplicationsRequest) ZapTraceSpan(zapTraceSpan string) ApiGetReplicationsRequest {
+	r.zapTraceSpan = &zapTraceSpan
+	return r
+}
+func (r ApiGetReplicationsRequest) GetZapTraceSpan() *string {
+	return r.zapTraceSpan
+}
+
+func (r ApiGetReplicationsRequest) Name(name string) ApiGetReplicationsRequest {
+	r.name = &name
+	return r
+}
+func (r ApiGetReplicationsRequest) GetName() *string {
+	return r.name
+}
+
+func (r ApiGetReplicationsRequest) RemoteID(remoteID string) ApiGetReplicationsRequest {
+	r.remoteID = &remoteID
+	return r
+}
+func (r ApiGetReplicationsRequest) GetRemoteID() *string {
+	return r.remoteID
+}
+
+func (r ApiGetReplicationsRequest) LocalBucketID(localBucketID string) ApiGetReplicationsRequest {
+	r.localBucketID = &localBucketID
+	return r
+}
+func (r ApiGetReplicationsRequest) GetLocalBucketID() *string {
+	return r.localBucketID
+}
+
+func (r ApiGetReplicationsRequest) Execute() (Replications, error) {
+	return r.ApiService.GetReplicationsExecute(r)
+}
+
+/*
+ * GetReplications List all replications
+ * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+ * @return ApiGetReplicationsRequest
+ */
+func (a *ReplicationsApiService) GetReplications(ctx _context.Context) ApiGetReplicationsRequest {
+	return ApiGetReplicationsRequest{
+		ApiService: a,
+		ctx:        ctx,
+	}
+}
+
+/*
+ * Execute executes the request
+ * @return Replications
+ */
+func (a *ReplicationsApiService) GetReplicationsExecute(r ApiGetReplicationsRequest) (Replications, error) {
+	var (
+		localVarHTTPMethod   = _nethttp.MethodGet
+		localVarPostBody     interface{}
+		localVarFormFileName string
+		localVarFileName     string
+		localVarFileBytes    []byte
+		localVarReturnValue  Replications
+	)
+
+	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "ReplicationsApiService.GetReplications")
+	if err != nil {
+		return localVarReturnValue, GenericOpenAPIError{error: err.Error()}
+	}
+
+	localVarPath := localBasePath + "/replications"
+
+	localVarHeaderParams := make(map[string]string)
+	localVarQueryParams := _neturl.Values{}
+	localVarFormParams := _neturl.Values{}
+	if r.orgID == nil {
+		return localVarReturnValue, reportError("orgID is required and must be specified")
+	}
+
+	localVarQueryParams.Add("orgID", parameterToString(*r.orgID, ""))
+	if r.name != nil {
+		localVarQueryParams.Add("name", parameterToString(*r.name, ""))
+	}
+	if r.remoteID != nil {
+		localVarQueryParams.Add("remoteID", parameterToString(*r.remoteID, ""))
+	}
+	if r.localBucketID != nil {
+		localVarQueryParams.Add("localBucketID", parameterToString(*r.localBucketID, ""))
+	}
+	// to determine the Content-Type header
+	localVarHTTPContentTypes := []string{}
+
+	// set Content-Type header
+	localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes)
+	if localVarHTTPContentType != "" {
+		localVarHeaderParams["Content-Type"] = localVarHTTPContentType
+	}
+
+	// to determine the Accept header
+	localVarHTTPHeaderAccepts := []string{"application/json"}
+
+	// set Accept header
+	localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
+	if localVarHTTPHeaderAccept != "" {
+		localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept
+	}
+	if r.zapTraceSpan != nil {
+		localVarHeaderParams["Zap-Trace-Span"] = parameterToString(*r.zapTraceSpan, "")
+	}
+	req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, localVarFormFileName, localVarFileName, localVarFileBytes)
+	if err != nil {
+		return localVarReturnValue, err
+	}
+
+	localVarHTTPResponse, err := a.client.callAPI(req)
+	if err != nil || localVarHTTPResponse == nil {
+		return localVarReturnValue, err
+	}
+
+	var errorPrefix string
+	if a.isOnlyOSS {
+		errorPrefix = "InfluxDB OSS-only command failed: "
+	} else if a.isOnlyCloud {
+		errorPrefix = "InfluxDB Cloud-only command failed: "
+	}
+
+	if localVarHTTPResponse.StatusCode >= 300 {
+		body, err := GunzipIfNeeded(localVarHTTPResponse)
+		if err != nil {
+			body.Close()
+			return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+		}
+		localVarBody, err := _io.ReadAll(body)
+		body.Close()
+		if err != nil {
+			return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+		}
+		newErr := GenericOpenAPIError{
+			body:  localVarBody,
+			error: _fmt.Sprintf("%s%s", errorPrefix, localVarHTTPResponse.Status),
+		}
+		if localVarHTTPResponse.StatusCode == 404 {
+			var v Error
+			err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+			if err != nil {
+				newErr.error = _fmt.Sprintf("%s: %s", newErr.Error(), err.Error())
+				return localVarReturnValue, newErr
+			}
+			v.SetMessage(_fmt.Sprintf("%s: %s", newErr.Error(), v.GetMessage()))
+			newErr.model = &v
+			return localVarReturnValue, newErr
+		}
+		var v Error
+		err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+		if err != nil {
+			newErr.error = _fmt.Sprintf("%s: %s", newErr.Error(), err.Error())
+			return localVarReturnValue, newErr
+		}
+		v.SetMessage(_fmt.Sprintf("%s: %s", newErr.Error(), v.GetMessage()))
+		newErr.model = &v
+		return localVarReturnValue, newErr
+	}
+
+	body, err := GunzipIfNeeded(localVarHTTPResponse)
+	if err != nil {
+		body.Close()
+		return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+	}
+	localVarBody, err := _io.ReadAll(body)
+	body.Close()
+	if err != nil {
+		return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+	}
+	err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+	if err != nil {
+		newErr := GenericOpenAPIError{
+			body:  localVarBody,
+			error: _fmt.Sprintf("%s%s", errorPrefix, err.Error()),
+		}
+		return localVarReturnValue, newErr
+	}
+
+	return localVarReturnValue, nil
+}
+
+type ApiPatchReplicationByIDRequest struct {
+	ctx                      _context.Context
+	ApiService               ReplicationsApi
+	replicationID            string
+	replicationUpdateRequest *ReplicationUpdateRequest
+	zapTraceSpan             *string
+	validate                 *bool
+}
+
+func (r ApiPatchReplicationByIDRequest) ReplicationID(replicationID string) ApiPatchReplicationByIDRequest {
+	r.replicationID = replicationID
+	return r
+}
+func (r ApiPatchReplicationByIDRequest) GetReplicationID() string {
+	return r.replicationID
+}
+
+func (r ApiPatchReplicationByIDRequest) ReplicationUpdateRequest(replicationUpdateRequest ReplicationUpdateRequest) ApiPatchReplicationByIDRequest {
+	r.replicationUpdateRequest = &replicationUpdateRequest
+	return r
+}
+func (r ApiPatchReplicationByIDRequest) GetReplicationUpdateRequest() *ReplicationUpdateRequest {
+	return r.replicationUpdateRequest
+}
+
+func (r ApiPatchReplicationByIDRequest) ZapTraceSpan(zapTraceSpan string) ApiPatchReplicationByIDRequest {
+	r.zapTraceSpan = &zapTraceSpan
+	return r
+}
+func (r ApiPatchReplicationByIDRequest) GetZapTraceSpan() *string {
+	return r.zapTraceSpan
+}
+
+func (r ApiPatchReplicationByIDRequest) Validate(validate bool) ApiPatchReplicationByIDRequest {
+	r.validate = &validate
+	return r
+}
+func (r ApiPatchReplicationByIDRequest) GetValidate() *bool {
+	return r.validate
+}
+
+func (r ApiPatchReplicationByIDRequest) Execute() (Replication, error) {
+	return r.ApiService.PatchReplicationByIDExecute(r)
+}
+
+/*
+ * PatchReplicationByID Update a replication
+ * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+ * @param replicationID
+ * @return ApiPatchReplicationByIDRequest
+ */
+func (a *ReplicationsApiService) PatchReplicationByID(ctx _context.Context, replicationID string) ApiPatchReplicationByIDRequest {
+	return ApiPatchReplicationByIDRequest{
+		ApiService:    a,
+		ctx:           ctx,
+		replicationID: replicationID,
+	}
+}
+
+/*
+ * Execute executes the request
+ * @return Replication
+ */
+func (a *ReplicationsApiService) PatchReplicationByIDExecute(r ApiPatchReplicationByIDRequest) (Replication, error) {
+	var (
+		localVarHTTPMethod   = _nethttp.MethodPatch
+		localVarPostBody     interface{}
+		localVarFormFileName string
+		localVarFileName     string
+		localVarFileBytes    []byte
+		localVarReturnValue  Replication
+	)
+
+	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "ReplicationsApiService.PatchReplicationByID")
+	if err != nil {
+		return localVarReturnValue, GenericOpenAPIError{error: err.Error()}
+	}
+
+	localVarPath := localBasePath + "/replications/{replicationID}"
+	localVarPath = strings.Replace(localVarPath, "{"+"replicationID"+"}", _neturl.PathEscape(parameterToString(r.replicationID, "")), -1)
+
+	localVarHeaderParams := make(map[string]string)
+	localVarQueryParams := _neturl.Values{}
+	localVarFormParams := _neturl.Values{}
+	if r.replicationUpdateRequest == nil {
+		return localVarReturnValue, reportError("replicationUpdateRequest is required and must be specified")
+	}
+
+	if r.validate != nil {
+		localVarQueryParams.Add("validate", parameterToString(*r.validate, ""))
+	}
+	// to determine the Content-Type header
+	localVarHTTPContentTypes := []string{"application/json"}
+
+	// set Content-Type header
+	localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes)
+	if localVarHTTPContentType != "" {
+		localVarHeaderParams["Content-Type"] = localVarHTTPContentType
+	}
+
+	// to determine the Accept header
+	localVarHTTPHeaderAccepts := []string{"application/json"}
+
+	// set Accept header
+	localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
+	if localVarHTTPHeaderAccept != "" {
+		localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept
+	}
+	if r.zapTraceSpan != nil {
+		localVarHeaderParams["Zap-Trace-Span"] = parameterToString(*r.zapTraceSpan, "")
+	}
+	// body params
+	localVarPostBody = r.replicationUpdateRequest
+	req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, localVarFormFileName, localVarFileName, localVarFileBytes)
+	if err != nil {
+		return localVarReturnValue, err
+	}
+
+	localVarHTTPResponse, err := a.client.callAPI(req)
+	if err != nil || localVarHTTPResponse == nil {
+		return localVarReturnValue, err
+	}
+
+	var errorPrefix string
+	if a.isOnlyOSS {
+		errorPrefix = "InfluxDB OSS-only command failed: "
+	} else if a.isOnlyCloud {
+		errorPrefix = "InfluxDB Cloud-only command failed: "
+	}
+
+	if localVarHTTPResponse.StatusCode >= 300 {
+		body, err := GunzipIfNeeded(localVarHTTPResponse)
+		if err != nil {
+			body.Close()
+			return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+		}
+		localVarBody, err := _io.ReadAll(body)
+		body.Close()
+		if err != nil {
+			return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+		}
+		newErr := GenericOpenAPIError{
+			body:  localVarBody,
+			error: _fmt.Sprintf("%s%s", errorPrefix, localVarHTTPResponse.Status),
+		}
+		if localVarHTTPResponse.StatusCode == 400 {
+			var v Error
+			err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+			if err != nil {
+				newErr.error = _fmt.Sprintf("%s: %s", newErr.Error(), err.Error())
+				return localVarReturnValue, newErr
+			}
+			v.SetMessage(_fmt.Sprintf("%s: %s", newErr.Error(), v.GetMessage()))
+			newErr.model = &v
+			return localVarReturnValue, newErr
+		}
+		if localVarHTTPResponse.StatusCode == 404 {
+			var v Error
+			err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+			if err != nil {
+				newErr.error = _fmt.Sprintf("%s: %s", newErr.Error(), err.Error())
+				return localVarReturnValue, newErr
+			}
+			v.SetMessage(_fmt.Sprintf("%s: %s", newErr.Error(), v.GetMessage()))
+			newErr.model = &v
+			return localVarReturnValue, newErr
+		}
+		var v Error
+		err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+		if err != nil {
+			newErr.error = _fmt.Sprintf("%s: %s", newErr.Error(), err.Error())
+			return localVarReturnValue, newErr
+		}
+		v.SetMessage(_fmt.Sprintf("%s: %s", newErr.Error(), v.GetMessage()))
+		newErr.model = &v
+		return localVarReturnValue, newErr
+	}
+
+	body, err := GunzipIfNeeded(localVarHTTPResponse)
+	if err != nil {
+		body.Close()
+		return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+	}
+	localVarBody, err := _io.ReadAll(body)
+	body.Close()
+	if err != nil {
+		return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+	}
+	err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+	if err != nil {
+		newErr := GenericOpenAPIError{
+			body:  localVarBody,
+			error: _fmt.Sprintf("%s%s", errorPrefix, err.Error()),
+		}
+		return localVarReturnValue, newErr
+	}
+
+	return localVarReturnValue, nil
+}
+
+type ApiPostReplicationRequest struct {
+	ctx                        _context.Context
+	ApiService                 ReplicationsApi
+	replicationCreationRequest *ReplicationCreationRequest
+	zapTraceSpan               *string
+	validate                   *bool
+}
+
+func (r ApiPostReplicationRequest) ReplicationCreationRequest(replicationCreationRequest ReplicationCreationRequest) ApiPostReplicationRequest {
+	r.replicationCreationRequest = &replicationCreationRequest
+	return r
+}
+func (r ApiPostReplicationRequest) GetReplicationCreationRequest() *ReplicationCreationRequest {
+	return r.replicationCreationRequest
+}
+
+func (r ApiPostReplicationRequest) ZapTraceSpan(zapTraceSpan string) ApiPostReplicationRequest {
+	r.zapTraceSpan = &zapTraceSpan
+	return r
+}
+func (r ApiPostReplicationRequest) GetZapTraceSpan() *string {
+	return r.zapTraceSpan
+}
+
+func (r ApiPostReplicationRequest) Validate(validate bool) ApiPostReplicationRequest {
+	r.validate = &validate
+	return r
+}
+func (r ApiPostReplicationRequest) GetValidate() *bool {
+	return r.validate
+}
+
+func (r ApiPostReplicationRequest) Execute() (Replication, error) {
+	return r.ApiService.PostReplicationExecute(r)
+}
+
+/*
+ * PostReplication Register a new replication
+ * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+ * @return ApiPostReplicationRequest
+ */
+func (a *ReplicationsApiService) PostReplication(ctx _context.Context) ApiPostReplicationRequest {
+	return ApiPostReplicationRequest{
+		ApiService: a,
+		ctx:        ctx,
+	}
+}
+
+/*
+ * Execute executes the request
+ * @return Replication
+ */
+func (a *ReplicationsApiService) PostReplicationExecute(r ApiPostReplicationRequest) (Replication, error) {
+	var (
+		localVarHTTPMethod   = _nethttp.MethodPost
+		localVarPostBody     interface{}
+		localVarFormFileName string
+		localVarFileName     string
+		localVarFileBytes    []byte
+		localVarReturnValue  Replication
+	)
+
+	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "ReplicationsApiService.PostReplication")
+	if err != nil {
+		return localVarReturnValue, GenericOpenAPIError{error: err.Error()}
+	}
+
+	localVarPath := localBasePath + "/replications"
+
+	localVarHeaderParams := make(map[string]string)
+	localVarQueryParams := _neturl.Values{}
+	localVarFormParams := _neturl.Values{}
+	if r.replicationCreationRequest == nil {
+		return localVarReturnValue, reportError("replicationCreationRequest is required and must be specified")
+	}
+
+	if r.validate != nil {
+		localVarQueryParams.Add("validate", parameterToString(*r.validate, ""))
+	}
+	// to determine the Content-Type header
+	localVarHTTPContentTypes := []string{"application/json"}
+
+	// set Content-Type header
+	localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes)
+	if localVarHTTPContentType != "" {
+		localVarHeaderParams["Content-Type"] = localVarHTTPContentType
+	}
+
+	// to determine the Accept header
+	localVarHTTPHeaderAccepts := []string{"application/json"}
+
+	// set Accept header
+	localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
+	if localVarHTTPHeaderAccept != "" {
+		localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept
+	}
+	if r.zapTraceSpan != nil {
+		localVarHeaderParams["Zap-Trace-Span"] = parameterToString(*r.zapTraceSpan, "")
+	}
+	// body params
+	localVarPostBody = r.replicationCreationRequest
+	req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, localVarFormFileName, localVarFileName, localVarFileBytes)
+	if err != nil {
+		return localVarReturnValue, err
+	}
+
+	localVarHTTPResponse, err := a.client.callAPI(req)
+	if err != nil || localVarHTTPResponse == nil {
+		return localVarReturnValue, err
+	}
+
+	var errorPrefix string
+	if a.isOnlyOSS {
+		errorPrefix = "InfluxDB OSS-only command failed: "
+	} else if a.isOnlyCloud {
+		errorPrefix = "InfluxDB Cloud-only command failed: "
+	}
+
+	if localVarHTTPResponse.StatusCode >= 300 {
+		body, err := GunzipIfNeeded(localVarHTTPResponse)
+		if err != nil {
+			body.Close()
+			return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+		}
+		localVarBody, err := _io.ReadAll(body)
+		body.Close()
+		if err != nil {
+			return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+		}
+		newErr := GenericOpenAPIError{
+			body:  localVarBody,
+			error: _fmt.Sprintf("%s%s", errorPrefix, localVarHTTPResponse.Status),
+		}
+		if localVarHTTPResponse.StatusCode == 400 {
+			var v Error
+			err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+			if err != nil {
+				newErr.error = _fmt.Sprintf("%s: %s", newErr.Error(), err.Error())
+				return localVarReturnValue, newErr
+			}
+			v.SetMessage(_fmt.Sprintf("%s: %s", newErr.Error(), v.GetMessage()))
+			newErr.model = &v
+			return localVarReturnValue, newErr
+		}
+		var v Error
+		err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+		if err != nil {
+			newErr.error = _fmt.Sprintf("%s: %s", newErr.Error(), err.Error())
+			return localVarReturnValue, newErr
+		}
+		v.SetMessage(_fmt.Sprintf("%s: %s", newErr.Error(), v.GetMessage()))
+		newErr.model = &v
+		return localVarReturnValue, newErr
+	}
+
+	body, err := GunzipIfNeeded(localVarHTTPResponse)
+	if err != nil {
+		body.Close()
+		return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+	}
+	localVarBody, err := _io.ReadAll(body)
+	body.Close()
+	if err != nil {
+		return localVarReturnValue, _fmt.Errorf("%s%w", errorPrefix, err)
+	}
+	err = a.client.decode(&localVarReturnValue, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+	if err != nil {
+		newErr := GenericOpenAPIError{
+			body:  localVarBody,
+			error: _fmt.Sprintf("%s%s", errorPrefix, err.Error()),
+		}
+		return localVarReturnValue, newErr
+	}
+
+	return localVarReturnValue, nil
+}
+
+type ApiPostValidateReplicationByIDRequest struct {
+	ctx           _context.Context
+	ApiService    ReplicationsApi
+	replicationID string
+	zapTraceSpan  *string
+}
+
+func (r ApiPostValidateReplicationByIDRequest) ReplicationID(replicationID string) ApiPostValidateReplicationByIDRequest {
+	r.replicationID = replicationID
+	return r
+}
+func (r ApiPostValidateReplicationByIDRequest) GetReplicationID() string {
+	return r.replicationID
+}
+
+func (r ApiPostValidateReplicationByIDRequest) ZapTraceSpan(zapTraceSpan string) ApiPostValidateReplicationByIDRequest {
+	r.zapTraceSpan = &zapTraceSpan
+	return r
+}
+func (r ApiPostValidateReplicationByIDRequest) GetZapTraceSpan() *string {
+	return r.zapTraceSpan
+}
+
+func (r ApiPostValidateReplicationByIDRequest) Execute() error {
+	return r.ApiService.PostValidateReplicationByIDExecute(r)
+}
+
+/*
+ * PostValidateReplicationByID Validate a replication
+ * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
+ * @param replicationID
+ * @return ApiPostValidateReplicationByIDRequest
+ */
+func (a *ReplicationsApiService) PostValidateReplicationByID(ctx _context.Context, replicationID string) ApiPostValidateReplicationByIDRequest {
+	return ApiPostValidateReplicationByIDRequest{
+		ApiService:    a,
+		ctx:           ctx,
+		replicationID: replicationID,
+	}
+}
+
+/*
+ * Execute executes the request
+ */
+func (a *ReplicationsApiService) PostValidateReplicationByIDExecute(r ApiPostValidateReplicationByIDRequest) error {
+	var (
+		localVarHTTPMethod   = _nethttp.MethodPost
+		localVarPostBody     interface{}
+		localVarFormFileName string
+		localVarFileName     string
+		localVarFileBytes    []byte
+	)
+
+	localBasePath, err := a.client.cfg.ServerURLWithContext(r.ctx, "ReplicationsApiService.PostValidateReplicationByID")
+	if err != nil {
+		return GenericOpenAPIError{error: err.Error()}
+	}
+
+	localVarPath := localBasePath + "/replications/{replicationID}/validate"
+	localVarPath = strings.Replace(localVarPath, "{"+"replicationID"+"}", _neturl.PathEscape(parameterToString(r.replicationID, "")), -1)
+
+	localVarHeaderParams := make(map[string]string)
+	localVarQueryParams := _neturl.Values{}
+	localVarFormParams := _neturl.Values{}
+
+	// to determine the Content-Type header
+	localVarHTTPContentTypes := []string{}
+
+	// set Content-Type header
+	localVarHTTPContentType := selectHeaderContentType(localVarHTTPContentTypes)
+	if localVarHTTPContentType != "" {
+		localVarHeaderParams["Content-Type"] = localVarHTTPContentType
+	}
+
+	// to determine the Accept header
+	localVarHTTPHeaderAccepts := []string{"application/json"}
+
+	// set Accept header
+	localVarHTTPHeaderAccept := selectHeaderAccept(localVarHTTPHeaderAccepts)
+	if localVarHTTPHeaderAccept != "" {
+		localVarHeaderParams["Accept"] = localVarHTTPHeaderAccept
+	}
+	if r.zapTraceSpan != nil {
+		localVarHeaderParams["Zap-Trace-Span"] = parameterToString(*r.zapTraceSpan, "")
+	}
+	req, err := a.client.prepareRequest(r.ctx, localVarPath, localVarHTTPMethod, localVarPostBody, localVarHeaderParams, localVarQueryParams, localVarFormParams, localVarFormFileName, localVarFileName, localVarFileBytes)
+	if err != nil {
+		return err
+	}
+
+	localVarHTTPResponse, err := a.client.callAPI(req)
+	if err != nil || localVarHTTPResponse == nil {
+		return err
+	}
+
+	var errorPrefix string
+	if a.isOnlyOSS {
+		errorPrefix = "InfluxDB OSS-only command failed: "
+	} else if a.isOnlyCloud {
+		errorPrefix = "InfluxDB Cloud-only command failed: "
+	}
+
+	if localVarHTTPResponse.StatusCode >= 300 {
+		body, err := GunzipIfNeeded(localVarHTTPResponse)
+		if err != nil {
+			body.Close()
+			return _fmt.Errorf("%s%w", errorPrefix, err)
+		}
+		localVarBody, err := _io.ReadAll(body)
+		body.Close()
+		if err != nil {
+			return _fmt.Errorf("%s%w", errorPrefix, err)
+		}
+		newErr := GenericOpenAPIError{
+			body:  localVarBody,
+			error: _fmt.Sprintf("%s%s", errorPrefix, localVarHTTPResponse.Status),
+		}
+		if localVarHTTPResponse.StatusCode == 400 {
+			var v Error
+			err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+			if err != nil {
+				newErr.error = _fmt.Sprintf("%s: %s", newErr.Error(), err.Error())
+				return newErr
+			}
+			v.SetMessage(_fmt.Sprintf("%s: %s", newErr.Error(), v.GetMessage()))
+			newErr.model = &v
+			return newErr
+		}
+		var v Error
+		err = a.client.decode(&v, localVarBody, localVarHTTPResponse.Header.Get("Content-Type"))
+		if err != nil {
+			newErr.error = _fmt.Sprintf("%s: %s", newErr.Error(), err.Error())
+			return newErr
+		}
+		v.SetMessage(_fmt.Sprintf("%s: %s", newErr.Error(), v.GetMessage()))
+		newErr.model = &v
+		return newErr
+	}
+
+	return nil
+}
diff --git a/api/client.gen.go b/api/client.gen.go
index 46e279b..de00354 100644
--- a/api/client.gen.go
+++ b/api/client.gen.go
@@ -70,6 +70,8 @@ type APIClient struct {
 
 	RemoteConnectionsApi RemoteConnectionsApi
 
+	ReplicationsApi ReplicationsApi
+
 	RestoreApi RestoreApi
 
 	SecretsApi SecretsApi
@@ -119,6 +121,7 @@ func NewAPIClient(cfg *Configuration) *APIClient {
 	c.OrganizationsApi = (*OrganizationsApiService)(&c.common)
 	c.QueryApi = (*QueryApiService)(&c.common)
 	c.RemoteConnectionsApi = (*RemoteConnectionsApiService)(&c.common)
+	c.ReplicationsApi = (*ReplicationsApiService)(&c.common)
 	c.RestoreApi = (*RestoreApiService)(&c.common)
 	c.SecretsApi = (*SecretsApiService)(&c.common)
 	c.SetupApi = (*SetupApiService)(&c.common)
diff --git a/api/contract/cli.yml b/api/contract/cli.yml
index af5a09a..0a3b9f8 100644
--- a/api/contract/cli.yml
+++ b/api/contract/cli.yml
@@ -113,6 +113,12 @@ paths:
     $ref: "./openapi/src/oss/paths/remotes_remoteID.yml"
   /remotes/{remoteID}/validate:
     $ref: "./openapi/src/oss/paths/remotes_remoteID_validate.yml"
+  /replications:
+    $ref: "./openapi/src/oss/paths/replications.yml"
+  /replications/{replicationID}:
+    $ref: "./openapi/src/oss/paths/replications_replicationID.yml"
+  /replications/{replicationID}/validate:
+    $ref: "./openapi/src/oss/paths/replications_replicationID_validate.yml"
 components:
   parameters:
     TraceSpan:
@@ -431,3 +437,11 @@ components:
       $ref: "./openapi/src/oss/schemas/RemoteConnectionUpdateRequest.yml"
     RemoteConnections:
       $ref: "./openapi/src/oss/schemas/RemoteConnections.yml"
+    Replication:
+      $ref: "./openapi/src/oss/schemas/Replication.yml"
+    ReplicationCreationRequest:
+      $ref: "./openapi/src/oss/schemas/ReplicationCreationRequest.yml"
+    ReplicationUpdateRequest:
+      $ref: "./openapi/src/oss/schemas/ReplicationUpdateRequest.yml"
+    Replications:
+      $ref: "./openapi/src/oss/schemas/Replications.yml"
diff --git a/api/model_replication.gen.go b/api/model_replication.gen.go
new file mode 100644
index 0000000..4b69adc
--- /dev/null
+++ b/api/model_replication.gen.go
@@ -0,0 +1,417 @@
+/*
+ * Subset of Influx API covered by Influx CLI
+ *
+ * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
+ *
+ * API version: 2.0.0
+ */
+
+// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT.
+
+package api
+
+import (
+	"encoding/json"
+)
+
+// Replication struct for Replication
+type Replication struct {
+	Id                    string  `json:"id" yaml:"id"`
+	Name                  string  `json:"name" yaml:"name"`
+	Description           *string `json:"description,omitempty" yaml:"description,omitempty"`
+	OrgID                 string  `json:"orgID" yaml:"orgID"`
+	RemoteID              string  `json:"remoteID" yaml:"remoteID"`
+	LocalBucketID         string  `json:"localBucketID" yaml:"localBucketID"`
+	RemoteBucketID        string  `json:"remoteBucketID" yaml:"remoteBucketID"`
+	MaxQueueSizeBytes     int64   `json:"maxQueueSizeBytes" yaml:"maxQueueSizeBytes"`
+	CurrentQueueSizeBytes int64   `json:"currentQueueSizeBytes" yaml:"currentQueueSizeBytes"`
+	LatestResponseCode    *int32  `json:"latestResponseCode,omitempty" yaml:"latestResponseCode,omitempty"`
+	LatestErrorMessage    *string `json:"latestErrorMessage,omitempty" yaml:"latestErrorMessage,omitempty"`
+}
+
+// NewReplication instantiates a new Replication object
+// This constructor will assign default values to properties that have it defined,
+// and makes sure properties required by API are set, but the set of arguments
+// will change when the set of required properties is changed
+func NewReplication(id string, name string, orgID string, remoteID string, localBucketID string, remoteBucketID string, maxQueueSizeBytes int64, currentQueueSizeBytes int64) *Replication {
+	this := Replication{}
+	this.Id = id
+	this.Name = name
+	this.OrgID = orgID
+	this.RemoteID = remoteID
+	this.LocalBucketID = localBucketID
+	this.RemoteBucketID = remoteBucketID
+	this.MaxQueueSizeBytes = maxQueueSizeBytes
+	this.CurrentQueueSizeBytes = currentQueueSizeBytes
+	return &this
+}
+
+// NewReplicationWithDefaults instantiates a new Replication object
+// This constructor will only assign default values to properties that have it defined,
+// but it doesn't guarantee that properties required by API are set
+func NewReplicationWithDefaults() *Replication {
+	this := Replication{}
+	return &this
+}
+
+// GetId returns the Id field value
+func (o *Replication) GetId() string {
+	if o == nil {
+		var ret string
+		return ret
+	}
+
+	return o.Id
+}
+
+// GetIdOk returns a tuple with the Id field value
+// and a boolean to check if the value has been set.
+func (o *Replication) GetIdOk() (*string, bool) {
+	if o == nil {
+		return nil, false
+	}
+	return &o.Id, true
+}
+
+// SetId sets field value
+func (o *Replication) SetId(v string) {
+	o.Id = v
+}
+
+// GetName returns the Name field value
+func (o *Replication) GetName() string {
+	if o == nil {
+		var ret string
+		return ret
+	}
+
+	return o.Name
+}
+
+// GetNameOk returns a tuple with the Name field value
+// and a boolean to check if the value has been set.
+func (o *Replication) GetNameOk() (*string, bool) {
+	if o == nil {
+		return nil, false
+	}
+	return &o.Name, true
+}
+
+// SetName sets field value
+func (o *Replication) SetName(v string) {
+	o.Name = v
+}
+
+// GetDescription returns the Description field value if set, zero value otherwise.
+func (o *Replication) GetDescription() string {
+	if o == nil || o.Description == nil {
+		var ret string
+		return ret
+	}
+	return *o.Description
+}
+
+// GetDescriptionOk returns a tuple with the Description field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *Replication) GetDescriptionOk() (*string, bool) {
+	if o == nil || o.Description == nil {
+		return nil, false
+	}
+	return o.Description, true
+}
+
+// HasDescription returns a boolean if a field has been set.
+func (o *Replication) HasDescription() bool {
+	if o != nil && o.Description != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetDescription gets a reference to the given string and assigns it to the Description field.
+func (o *Replication) SetDescription(v string) {
+	o.Description = &v
+}
+
+// GetOrgID returns the OrgID field value
+func (o *Replication) GetOrgID() string {
+	if o == nil {
+		var ret string
+		return ret
+	}
+
+	return o.OrgID
+}
+
+// GetOrgIDOk returns a tuple with the OrgID field value
+// and a boolean to check if the value has been set.
+func (o *Replication) GetOrgIDOk() (*string, bool) {
+	if o == nil {
+		return nil, false
+	}
+	return &o.OrgID, true
+}
+
+// SetOrgID sets field value
+func (o *Replication) SetOrgID(v string) {
+	o.OrgID = v
+}
+
+// GetRemoteID returns the RemoteID field value
+func (o *Replication) GetRemoteID() string {
+	if o == nil {
+		var ret string
+		return ret
+	}
+
+	return o.RemoteID
+}
+
+// GetRemoteIDOk returns a tuple with the RemoteID field value
+// and a boolean to check if the value has been set.
+func (o *Replication) GetRemoteIDOk() (*string, bool) {
+	if o == nil {
+		return nil, false
+	}
+	return &o.RemoteID, true
+}
+
+// SetRemoteID sets field value
+func (o *Replication) SetRemoteID(v string) {
+	o.RemoteID = v
+}
+
+// GetLocalBucketID returns the LocalBucketID field value
+func (o *Replication) GetLocalBucketID() string {
+	if o == nil {
+		var ret string
+		return ret
+	}
+
+	return o.LocalBucketID
+}
+
+// GetLocalBucketIDOk returns a tuple with the LocalBucketID field value
+// and a boolean to check if the value has been set.
+func (o *Replication) GetLocalBucketIDOk() (*string, bool) {
+	if o == nil {
+		return nil, false
+	}
+	return &o.LocalBucketID, true
+}
+
+// SetLocalBucketID sets field value
+func (o *Replication) SetLocalBucketID(v string) {
+	o.LocalBucketID = v
+}
+
+// GetRemoteBucketID returns the RemoteBucketID field value
+func (o *Replication) GetRemoteBucketID() string {
+	if o == nil {
+		var ret string
+		return ret
+	}
+
+	return o.RemoteBucketID
+}
+
+// GetRemoteBucketIDOk returns a tuple with the RemoteBucketID field value
+// and a boolean to check if the value has been set.
+func (o *Replication) GetRemoteBucketIDOk() (*string, bool) {
+	if o == nil {
+		return nil, false
+	}
+	return &o.RemoteBucketID, true
+}
+
+// SetRemoteBucketID sets field value
+func (o *Replication) SetRemoteBucketID(v string) {
+	o.RemoteBucketID = v
+}
+
+// GetMaxQueueSizeBytes returns the MaxQueueSizeBytes field value
+func (o *Replication) GetMaxQueueSizeBytes() int64 {
+	if o == nil {
+		var ret int64
+		return ret
+	}
+
+	return o.MaxQueueSizeBytes
+}
+
+// GetMaxQueueSizeBytesOk returns a tuple with the MaxQueueSizeBytes field value
+// and a boolean to check if the value has been set.
+func (o *Replication) GetMaxQueueSizeBytesOk() (*int64, bool) {
+	if o == nil {
+		return nil, false
+	}
+	return &o.MaxQueueSizeBytes, true
+}
+
+// SetMaxQueueSizeBytes sets field value
+func (o *Replication) SetMaxQueueSizeBytes(v int64) {
+	o.MaxQueueSizeBytes = v
+}
+
+// GetCurrentQueueSizeBytes returns the CurrentQueueSizeBytes field value
+func (o *Replication) GetCurrentQueueSizeBytes() int64 {
+	if o == nil {
+		var ret int64
+		return ret
+	}
+
+	return o.CurrentQueueSizeBytes
+}
+
+// GetCurrentQueueSizeBytesOk returns a tuple with the CurrentQueueSizeBytes field value
+// and a boolean to check if the value has been set.
+func (o *Replication) GetCurrentQueueSizeBytesOk() (*int64, bool) {
+	if o == nil {
+		return nil, false
+	}
+	return &o.CurrentQueueSizeBytes, true
+}
+
+// SetCurrentQueueSizeBytes sets field value
+func (o *Replication) SetCurrentQueueSizeBytes(v int64) {
+	o.CurrentQueueSizeBytes = v
+}
+
+// GetLatestResponseCode returns the LatestResponseCode field value if set, zero value otherwise.
+func (o *Replication) GetLatestResponseCode() int32 {
+	if o == nil || o.LatestResponseCode == nil {
+		var ret int32
+		return ret
+	}
+	return *o.LatestResponseCode
+}
+
+// GetLatestResponseCodeOk returns a tuple with the LatestResponseCode field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *Replication) GetLatestResponseCodeOk() (*int32, bool) {
+	if o == nil || o.LatestResponseCode == nil {
+		return nil, false
+	}
+	return o.LatestResponseCode, true
+}
+
+// HasLatestResponseCode returns a boolean if a field has been set.
+func (o *Replication) HasLatestResponseCode() bool {
+	if o != nil && o.LatestResponseCode != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetLatestResponseCode gets a reference to the given int32 and assigns it to the LatestResponseCode field.
+func (o *Replication) SetLatestResponseCode(v int32) {
+	o.LatestResponseCode = &v
+}
+
+// GetLatestErrorMessage returns the LatestErrorMessage field value if set, zero value otherwise.
+func (o *Replication) GetLatestErrorMessage() string {
+	if o == nil || o.LatestErrorMessage == nil {
+		var ret string
+		return ret
+	}
+	return *o.LatestErrorMessage
+}
+
+// GetLatestErrorMessageOk returns a tuple with the LatestErrorMessage field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *Replication) GetLatestErrorMessageOk() (*string, bool) {
+	if o == nil || o.LatestErrorMessage == nil {
+		return nil, false
+	}
+	return o.LatestErrorMessage, true
+}
+
+// HasLatestErrorMessage returns a boolean if a field has been set.
+func (o *Replication) HasLatestErrorMessage() bool {
+	if o != nil && o.LatestErrorMessage != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetLatestErrorMessage gets a reference to the given string and assigns it to the LatestErrorMessage field.
+func (o *Replication) SetLatestErrorMessage(v string) {
+	o.LatestErrorMessage = &v
+}
+
+func (o Replication) MarshalJSON() ([]byte, error) {
+	toSerialize := map[string]interface{}{}
+	if true {
+		toSerialize["id"] = o.Id
+	}
+	if true {
+		toSerialize["name"] = o.Name
+	}
+	if o.Description != nil {
+		toSerialize["description"] = o.Description
+	}
+	if true {
+		toSerialize["orgID"] = o.OrgID
+	}
+	if true {
+		toSerialize["remoteID"] = o.RemoteID
+	}
+	if true {
+		toSerialize["localBucketID"] = o.LocalBucketID
+	}
+	if true {
+		toSerialize["remoteBucketID"] = o.RemoteBucketID
+	}
+	if true {
+		toSerialize["maxQueueSizeBytes"] = o.MaxQueueSizeBytes
+	}
+	if true {
+		toSerialize["currentQueueSizeBytes"] = o.CurrentQueueSizeBytes
+	}
+	if o.LatestResponseCode != nil {
+		toSerialize["latestResponseCode"] = o.LatestResponseCode
+	}
+	if o.LatestErrorMessage != nil {
+		toSerialize["latestErrorMessage"] = o.LatestErrorMessage
+	}
+	return json.Marshal(toSerialize)
+}
+
+type NullableReplication struct {
+	value *Replication
+	isSet bool
+}
+
+func (v NullableReplication) Get() *Replication {
+	return v.value
+}
+
+func (v *NullableReplication) Set(val *Replication) {
+	v.value = val
+	v.isSet = true
+}
+
+func (v NullableReplication) IsSet() bool {
+	return v.isSet
+}
+
+func (v *NullableReplication) Unset() {
+	v.value = nil
+	v.isSet = false
+}
+
+func NewNullableReplication(val *Replication) *NullableReplication {
+	return &NullableReplication{value: val, isSet: true}
+}
+
+func (v NullableReplication) MarshalJSON() ([]byte, error) {
+	return json.Marshal(v.value)
+}
+
+func (v *NullableReplication) UnmarshalJSON(src []byte) error {
+	v.isSet = true
+	return json.Unmarshal(src, &v.value)
+}
diff --git a/api/model_replication_creation_request.gen.go b/api/model_replication_creation_request.gen.go
new file mode 100644
index 0000000..b222610
--- /dev/null
+++ b/api/model_replication_creation_request.gen.go
@@ -0,0 +1,303 @@
+/*
+ * Subset of Influx API covered by Influx CLI
+ *
+ * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
+ *
+ * API version: 2.0.0
+ */
+
+// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT.
+
+package api
+
+import (
+	"encoding/json"
+)
+
+// ReplicationCreationRequest struct for ReplicationCreationRequest
+type ReplicationCreationRequest struct {
+	Name              string  `json:"name" yaml:"name"`
+	Description       *string `json:"description,omitempty" yaml:"description,omitempty"`
+	OrgID             string  `json:"orgID" yaml:"orgID"`
+	RemoteID          string  `json:"remoteID" yaml:"remoteID"`
+	LocalBucketID     *string `json:"localBucketID,omitempty" yaml:"localBucketID,omitempty"`
+	RemoteBucketID    *string `json:"remoteBucketID,omitempty" yaml:"remoteBucketID,omitempty"`
+	MaxQueueSizeBytes int64   `json:"maxQueueSizeBytes" yaml:"maxQueueSizeBytes"`
+}
+
+// NewReplicationCreationRequest instantiates a new ReplicationCreationRequest object
+// This constructor will assign default values to properties that have it defined,
+// and makes sure properties required by API are set, but the set of arguments
+// will change when the set of required properties is changed
+func NewReplicationCreationRequest(name string, orgID string, remoteID string, maxQueueSizeBytes int64) *ReplicationCreationRequest {
+	this := ReplicationCreationRequest{}
+	this.Name = name
+	this.OrgID = orgID
+	this.RemoteID = remoteID
+	this.MaxQueueSizeBytes = maxQueueSizeBytes
+	return &this
+}
+
+// NewReplicationCreationRequestWithDefaults instantiates a new ReplicationCreationRequest object
+// This constructor will only assign default values to properties that have it defined,
+// but it doesn't guarantee that properties required by API are set
+func NewReplicationCreationRequestWithDefaults() *ReplicationCreationRequest {
+	this := ReplicationCreationRequest{}
+	var maxQueueSizeBytes int64 = 67108860
+	this.MaxQueueSizeBytes = maxQueueSizeBytes
+	return &this
+}
+
+// GetName returns the Name field value
+func (o *ReplicationCreationRequest) GetName() string {
+	if o == nil {
+		var ret string
+		return ret
+	}
+
+	return o.Name
+}
+
+// GetNameOk returns a tuple with the Name field value
+// and a boolean to check if the value has been set.
+func (o *ReplicationCreationRequest) GetNameOk() (*string, bool) {
+	if o == nil {
+		return nil, false
+	}
+	return &o.Name, true
+}
+
+// SetName sets field value
+func (o *ReplicationCreationRequest) SetName(v string) {
+	o.Name = v
+}
+
+// GetDescription returns the Description field value if set, zero value otherwise.
+func (o *ReplicationCreationRequest) GetDescription() string {
+	if o == nil || o.Description == nil {
+		var ret string
+		return ret
+	}
+	return *o.Description
+}
+
+// GetDescriptionOk returns a tuple with the Description field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *ReplicationCreationRequest) GetDescriptionOk() (*string, bool) {
+	if o == nil || o.Description == nil {
+		return nil, false
+	}
+	return o.Description, true
+}
+
+// HasDescription returns a boolean if a field has been set.
+func (o *ReplicationCreationRequest) HasDescription() bool {
+	if o != nil && o.Description != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetDescription gets a reference to the given string and assigns it to the Description field.
+func (o *ReplicationCreationRequest) SetDescription(v string) {
+	o.Description = &v
+}
+
+// GetOrgID returns the OrgID field value
+func (o *ReplicationCreationRequest) GetOrgID() string {
+	if o == nil {
+		var ret string
+		return ret
+	}
+
+	return o.OrgID
+}
+
+// GetOrgIDOk returns a tuple with the OrgID field value
+// and a boolean to check if the value has been set.
+func (o *ReplicationCreationRequest) GetOrgIDOk() (*string, bool) {
+	if o == nil {
+		return nil, false
+	}
+	return &o.OrgID, true
+}
+
+// SetOrgID sets field value
+func (o *ReplicationCreationRequest) SetOrgID(v string) {
+	o.OrgID = v
+}
+
+// GetRemoteID returns the RemoteID field value
+func (o *ReplicationCreationRequest) GetRemoteID() string {
+	if o == nil {
+		var ret string
+		return ret
+	}
+
+	return o.RemoteID
+}
+
+// GetRemoteIDOk returns a tuple with the RemoteID field value
+// and a boolean to check if the value has been set.
+func (o *ReplicationCreationRequest) GetRemoteIDOk() (*string, bool) {
+	if o == nil {
+		return nil, false
+	}
+	return &o.RemoteID, true
+}
+
+// SetRemoteID sets field value
+func (o *ReplicationCreationRequest) SetRemoteID(v string) {
+	o.RemoteID = v
+}
+
+// GetLocalBucketID returns the LocalBucketID field value if set, zero value otherwise.
+func (o *ReplicationCreationRequest) GetLocalBucketID() string {
+	if o == nil || o.LocalBucketID == nil {
+		var ret string
+		return ret
+	}
+	return *o.LocalBucketID
+}
+
+// GetLocalBucketIDOk returns a tuple with the LocalBucketID field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *ReplicationCreationRequest) GetLocalBucketIDOk() (*string, bool) {
+	if o == nil || o.LocalBucketID == nil {
+		return nil, false
+	}
+	return o.LocalBucketID, true
+}
+
+// HasLocalBucketID returns a boolean if a field has been set.
+func (o *ReplicationCreationRequest) HasLocalBucketID() bool {
+	if o != nil && o.LocalBucketID != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetLocalBucketID gets a reference to the given string and assigns it to the LocalBucketID field.
+func (o *ReplicationCreationRequest) SetLocalBucketID(v string) {
+	o.LocalBucketID = &v
+}
+
+// GetRemoteBucketID returns the RemoteBucketID field value if set, zero value otherwise.
+func (o *ReplicationCreationRequest) GetRemoteBucketID() string {
+	if o == nil || o.RemoteBucketID == nil {
+		var ret string
+		return ret
+	}
+	return *o.RemoteBucketID
+}
+
+// GetRemoteBucketIDOk returns a tuple with the RemoteBucketID field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *ReplicationCreationRequest) GetRemoteBucketIDOk() (*string, bool) {
+	if o == nil || o.RemoteBucketID == nil {
+		return nil, false
+	}
+	return o.RemoteBucketID, true
+}
+
+// HasRemoteBucketID returns a boolean if a field has been set.
+func (o *ReplicationCreationRequest) HasRemoteBucketID() bool {
+	if o != nil && o.RemoteBucketID != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetRemoteBucketID gets a reference to the given string and assigns it to the RemoteBucketID field.
+func (o *ReplicationCreationRequest) SetRemoteBucketID(v string) {
+	o.RemoteBucketID = &v
+}
+
+// GetMaxQueueSizeBytes returns the MaxQueueSizeBytes field value
+func (o *ReplicationCreationRequest) GetMaxQueueSizeBytes() int64 {
+	if o == nil {
+		var ret int64
+		return ret
+	}
+
+	return o.MaxQueueSizeBytes
+}
+
+// GetMaxQueueSizeBytesOk returns a tuple with the MaxQueueSizeBytes field value
+// and a boolean to check if the value has been set.
+func (o *ReplicationCreationRequest) GetMaxQueueSizeBytesOk() (*int64, bool) {
+	if o == nil {
+		return nil, false
+	}
+	return &o.MaxQueueSizeBytes, true
+}
+
+// SetMaxQueueSizeBytes sets field value
+func (o *ReplicationCreationRequest) SetMaxQueueSizeBytes(v int64) {
+	o.MaxQueueSizeBytes = v
+}
+
+func (o ReplicationCreationRequest) MarshalJSON() ([]byte, error) {
+	toSerialize := map[string]interface{}{}
+	if true {
+		toSerialize["name"] = o.Name
+	}
+	if o.Description != nil {
+		toSerialize["description"] = o.Description
+	}
+	if true {
+		toSerialize["orgID"] = o.OrgID
+	}
+	if true {
+		toSerialize["remoteID"] = o.RemoteID
+	}
+	if o.LocalBucketID != nil {
+		toSerialize["localBucketID"] = o.LocalBucketID
+	}
+	if o.RemoteBucketID != nil {
+		toSerialize["remoteBucketID"] = o.RemoteBucketID
+	}
+	if true {
+		toSerialize["maxQueueSizeBytes"] = o.MaxQueueSizeBytes
+	}
+	return json.Marshal(toSerialize)
+}
+
+type NullableReplicationCreationRequest struct {
+	value *ReplicationCreationRequest
+	isSet bool
+}
+
+func (v NullableReplicationCreationRequest) Get() *ReplicationCreationRequest {
+	return v.value
+}
+
+func (v *NullableReplicationCreationRequest) Set(val *ReplicationCreationRequest) {
+	v.value = val
+	v.isSet = true
+}
+
+func (v NullableReplicationCreationRequest) IsSet() bool {
+	return v.isSet
+}
+
+func (v *NullableReplicationCreationRequest) Unset() {
+	v.value = nil
+	v.isSet = false
+}
+
+func NewNullableReplicationCreationRequest(val *ReplicationCreationRequest) *NullableReplicationCreationRequest {
+	return &NullableReplicationCreationRequest{value: val, isSet: true}
+}
+
+func (v NullableReplicationCreationRequest) MarshalJSON() ([]byte, error) {
+	return json.Marshal(v.value)
+}
+
+func (v *NullableReplicationCreationRequest) UnmarshalJSON(src []byte) error {
+	v.isSet = true
+	return json.Unmarshal(src, &v.value)
+}
diff --git a/api/model_replication_update_request.gen.go b/api/model_replication_update_request.gen.go
new file mode 100644
index 0000000..905cd1e
--- /dev/null
+++ b/api/model_replication_update_request.gen.go
@@ -0,0 +1,257 @@
+/*
+ * Subset of Influx API covered by Influx CLI
+ *
+ * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
+ *
+ * API version: 2.0.0
+ */
+
+// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT.
+
+package api
+
+import (
+	"encoding/json"
+)
+
+// ReplicationUpdateRequest struct for ReplicationUpdateRequest
+type ReplicationUpdateRequest struct {
+	Name              *string `json:"name,omitempty" yaml:"name,omitempty"`
+	Description       *string `json:"description,omitempty" yaml:"description,omitempty"`
+	RemoteID          *string `json:"remoteID,omitempty" yaml:"remoteID,omitempty"`
+	RemoteBucketID    *string `json:"remoteBucketID,omitempty" yaml:"remoteBucketID,omitempty"`
+	MaxQueueSizeBytes *int64  `json:"maxQueueSizeBytes,omitempty" yaml:"maxQueueSizeBytes,omitempty"`
+}
+
+// NewReplicationUpdateRequest instantiates a new ReplicationUpdateRequest object
+// This constructor will assign default values to properties that have it defined,
+// and makes sure properties required by API are set, but the set of arguments
+// will change when the set of required properties is changed
+func NewReplicationUpdateRequest() *ReplicationUpdateRequest {
+	this := ReplicationUpdateRequest{}
+	return &this
+}
+
+// NewReplicationUpdateRequestWithDefaults instantiates a new ReplicationUpdateRequest object
+// This constructor will only assign default values to properties that have it defined,
+// but it doesn't guarantee that properties required by API are set
+func NewReplicationUpdateRequestWithDefaults() *ReplicationUpdateRequest {
+	this := ReplicationUpdateRequest{}
+	return &this
+}
+
+// GetName returns the Name field value if set, zero value otherwise.
+func (o *ReplicationUpdateRequest) GetName() string {
+	if o == nil || o.Name == nil {
+		var ret string
+		return ret
+	}
+	return *o.Name
+}
+
+// GetNameOk returns a tuple with the Name field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *ReplicationUpdateRequest) GetNameOk() (*string, bool) {
+	if o == nil || o.Name == nil {
+		return nil, false
+	}
+	return o.Name, true
+}
+
+// HasName returns a boolean if a field has been set.
+func (o *ReplicationUpdateRequest) HasName() bool {
+	if o != nil && o.Name != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetName gets a reference to the given string and assigns it to the Name field.
+func (o *ReplicationUpdateRequest) SetName(v string) {
+	o.Name = &v
+}
+
+// GetDescription returns the Description field value if set, zero value otherwise.
+func (o *ReplicationUpdateRequest) GetDescription() string {
+	if o == nil || o.Description == nil {
+		var ret string
+		return ret
+	}
+	return *o.Description
+}
+
+// GetDescriptionOk returns a tuple with the Description field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *ReplicationUpdateRequest) GetDescriptionOk() (*string, bool) {
+	if o == nil || o.Description == nil {
+		return nil, false
+	}
+	return o.Description, true
+}
+
+// HasDescription returns a boolean if a field has been set.
+func (o *ReplicationUpdateRequest) HasDescription() bool {
+	if o != nil && o.Description != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetDescription gets a reference to the given string and assigns it to the Description field.
+func (o *ReplicationUpdateRequest) SetDescription(v string) {
+	o.Description = &v
+}
+
+// GetRemoteID returns the RemoteID field value if set, zero value otherwise.
+func (o *ReplicationUpdateRequest) GetRemoteID() string {
+	if o == nil || o.RemoteID == nil {
+		var ret string
+		return ret
+	}
+	return *o.RemoteID
+}
+
+// GetRemoteIDOk returns a tuple with the RemoteID field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *ReplicationUpdateRequest) GetRemoteIDOk() (*string, bool) {
+	if o == nil || o.RemoteID == nil {
+		return nil, false
+	}
+	return o.RemoteID, true
+}
+
+// HasRemoteID returns a boolean if a field has been set.
+func (o *ReplicationUpdateRequest) HasRemoteID() bool {
+	if o != nil && o.RemoteID != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetRemoteID gets a reference to the given string and assigns it to the RemoteID field.
+func (o *ReplicationUpdateRequest) SetRemoteID(v string) {
+	o.RemoteID = &v
+}
+
+// GetRemoteBucketID returns the RemoteBucketID field value if set, zero value otherwise.
+func (o *ReplicationUpdateRequest) GetRemoteBucketID() string {
+	if o == nil || o.RemoteBucketID == nil {
+		var ret string
+		return ret
+	}
+	return *o.RemoteBucketID
+}
+
+// GetRemoteBucketIDOk returns a tuple with the RemoteBucketID field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *ReplicationUpdateRequest) GetRemoteBucketIDOk() (*string, bool) {
+	if o == nil || o.RemoteBucketID == nil {
+		return nil, false
+	}
+	return o.RemoteBucketID, true
+}
+
+// HasRemoteBucketID returns a boolean if a field has been set.
+func (o *ReplicationUpdateRequest) HasRemoteBucketID() bool {
+	if o != nil && o.RemoteBucketID != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetRemoteBucketID gets a reference to the given string and assigns it to the RemoteBucketID field.
+func (o *ReplicationUpdateRequest) SetRemoteBucketID(v string) {
+	o.RemoteBucketID = &v
+}
+
+// GetMaxQueueSizeBytes returns the MaxQueueSizeBytes field value if set, zero value otherwise.
+func (o *ReplicationUpdateRequest) GetMaxQueueSizeBytes() int64 {
+	if o == nil || o.MaxQueueSizeBytes == nil {
+		var ret int64
+		return ret
+	}
+	return *o.MaxQueueSizeBytes
+}
+
+// GetMaxQueueSizeBytesOk returns a tuple with the MaxQueueSizeBytes field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *ReplicationUpdateRequest) GetMaxQueueSizeBytesOk() (*int64, bool) {
+	if o == nil || o.MaxQueueSizeBytes == nil {
+		return nil, false
+	}
+	return o.MaxQueueSizeBytes, true
+}
+
+// HasMaxQueueSizeBytes returns a boolean if a field has been set.
+func (o *ReplicationUpdateRequest) HasMaxQueueSizeBytes() bool {
+	if o != nil && o.MaxQueueSizeBytes != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetMaxQueueSizeBytes gets a reference to the given int64 and assigns it to the MaxQueueSizeBytes field.
+func (o *ReplicationUpdateRequest) SetMaxQueueSizeBytes(v int64) {
+	o.MaxQueueSizeBytes = &v
+}
+
+func (o ReplicationUpdateRequest) MarshalJSON() ([]byte, error) {
+	toSerialize := map[string]interface{}{}
+	if o.Name != nil {
+		toSerialize["name"] = o.Name
+	}
+	if o.Description != nil {
+		toSerialize["description"] = o.Description
+	}
+	if o.RemoteID != nil {
+		toSerialize["remoteID"] = o.RemoteID
+	}
+	if o.RemoteBucketID != nil {
+		toSerialize["remoteBucketID"] = o.RemoteBucketID
+	}
+	if o.MaxQueueSizeBytes != nil {
+		toSerialize["maxQueueSizeBytes"] = o.MaxQueueSizeBytes
+	}
+	return json.Marshal(toSerialize)
+}
+
+type NullableReplicationUpdateRequest struct {
+	value *ReplicationUpdateRequest
+	isSet bool
+}
+
+func (v NullableReplicationUpdateRequest) Get() *ReplicationUpdateRequest {
+	return v.value
+}
+
+func (v *NullableReplicationUpdateRequest) Set(val *ReplicationUpdateRequest) {
+	v.value = val
+	v.isSet = true
+}
+
+func (v NullableReplicationUpdateRequest) IsSet() bool {
+	return v.isSet
+}
+
+func (v *NullableReplicationUpdateRequest) Unset() {
+	v.value = nil
+	v.isSet = false
+}
+
+func NewNullableReplicationUpdateRequest(val *ReplicationUpdateRequest) *NullableReplicationUpdateRequest {
+	return &NullableReplicationUpdateRequest{value: val, isSet: true}
+}
+
+func (v NullableReplicationUpdateRequest) MarshalJSON() ([]byte, error) {
+	return json.Marshal(v.value)
+}
+
+func (v *NullableReplicationUpdateRequest) UnmarshalJSON(src []byte) error {
+	v.isSet = true
+	return json.Unmarshal(src, &v.value)
+}
diff --git a/api/model_replications.gen.go b/api/model_replications.gen.go
new file mode 100644
index 0000000..de5f1f8
--- /dev/null
+++ b/api/model_replications.gen.go
@@ -0,0 +1,113 @@
+/*
+ * Subset of Influx API covered by Influx CLI
+ *
+ * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
+ *
+ * API version: 2.0.0
+ */
+
+// Code generated by OpenAPI Generator (https://openapi-generator.tech); DO NOT EDIT.
+
+package api
+
+import (
+	"encoding/json"
+)
+
+// Replications struct for Replications
+type Replications struct {
+	Replications *[]Replication `json:"replications,omitempty" yaml:"replications,omitempty"`
+}
+
+// NewReplications instantiates a new Replications object
+// This constructor will assign default values to properties that have it defined,
+// and makes sure properties required by API are set, but the set of arguments
+// will change when the set of required properties is changed
+func NewReplications() *Replications {
+	this := Replications{}
+	return &this
+}
+
+// NewReplicationsWithDefaults instantiates a new Replications object
+// This constructor will only assign default values to properties that have it defined,
+// but it doesn't guarantee that properties required by API are set
+func NewReplicationsWithDefaults() *Replications {
+	this := Replications{}
+	return &this
+}
+
+// GetReplications returns the Replications field value if set, zero value otherwise.
+func (o *Replications) GetReplications() []Replication {
+	if o == nil || o.Replications == nil {
+		var ret []Replication
+		return ret
+	}
+	return *o.Replications
+}
+
+// GetReplicationsOk returns a tuple with the Replications field value if set, nil otherwise
+// and a boolean to check if the value has been set.
+func (o *Replications) GetReplicationsOk() (*[]Replication, bool) {
+	if o == nil || o.Replications == nil {
+		return nil, false
+	}
+	return o.Replications, true
+}
+
+// HasReplications returns a boolean if a field has been set.
+func (o *Replications) HasReplications() bool {
+	if o != nil && o.Replications != nil {
+		return true
+	}
+
+	return false
+}
+
+// SetReplications gets a reference to the given []Replication and assigns it to the Replications field.
+func (o *Replications) SetReplications(v []Replication) {
+	o.Replications = &v
+}
+
+func (o Replications) MarshalJSON() ([]byte, error) {
+	toSerialize := map[string]interface{}{}
+	if o.Replications != nil {
+		toSerialize["replications"] = o.Replications
+	}
+	return json.Marshal(toSerialize)
+}
+
+type NullableReplications struct {
+	value *Replications
+	isSet bool
+}
+
+func (v NullableReplications) Get() *Replications {
+	return v.value
+}
+
+func (v *NullableReplications) Set(val *Replications) {
+	v.value = val
+	v.isSet = true
+}
+
+func (v NullableReplications) IsSet() bool {
+	return v.isSet
+}
+
+func (v *NullableReplications) Unset() {
+	v.value = nil
+	v.isSet = false
+}
+
+func NewNullableReplications(val *Replications) *NullableReplications {
+	return &NullableReplications{value: val, isSet: true}
+}
+
+func (v NullableReplications) MarshalJSON() ([]byte, error) {
+	return json.Marshal(v.value)
+}
+
+func (v *NullableReplications) UnmarshalJSON(src []byte) error {
+	v.isSet = true
+	return json.Unmarshal(src, &v.value)
+}