feat: generate clients for replications APIs (#278)

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)

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"

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)
+}

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)
+}

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)
+}

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)
+}