// Code generated by protoc-gen-goext. DO NOT EDIT.

package kafka

import (
	wrapperspb "google.golang.org/protobuf/types/known/wrapperspb"
)

type ConnectorSpec_ConnectorConfig = isConnectorSpec_ConnectorConfig

func (m *ConnectorSpec) SetConnectorConfig(v ConnectorSpec_ConnectorConfig) {
	m.ConnectorConfig = v
}

func (m *ConnectorSpec) SetName(v string) {
	m.Name = v
}

func (m *ConnectorSpec) SetTasksMax(v *wrapperspb.Int64Value) {
	m.TasksMax = v
}

func (m *ConnectorSpec) SetProperties(v map[string]string) {
	m.Properties = v
}

func (m *ConnectorSpec) SetConnectorConfigMirrormaker(v *ConnectorConfigMirrorMakerSpec) {
	m.ConnectorConfig = &ConnectorSpec_ConnectorConfigMirrormaker{
		ConnectorConfigMirrormaker: v,
	}
}

func (m *ConnectorSpec) SetConnectorConfigS3Sink(v *ConnectorConfigS3SinkSpec) {
	m.ConnectorConfig = &ConnectorSpec_ConnectorConfigS3Sink{
		ConnectorConfigS3Sink: v,
	}
}

func (m *ConnectorSpec) SetConnectorConfigIcebergSink(v *ConnectorConfigIcebergSinkSpec) {
	m.ConnectorConfig = &ConnectorSpec_ConnectorConfigIcebergSink{
		ConnectorConfigIcebergSink: v,
	}
}

type UpdateConnectorSpec_ConnectorConfig = isUpdateConnectorSpec_ConnectorConfig

func (m *UpdateConnectorSpec) SetConnectorConfig(v UpdateConnectorSpec_ConnectorConfig) {
	m.ConnectorConfig = v
}

func (m *UpdateConnectorSpec) SetTasksMax(v *wrapperspb.Int64Value) {
	m.TasksMax = v
}

func (m *UpdateConnectorSpec) SetProperties(v map[string]string) {
	m.Properties = v
}

func (m *UpdateConnectorSpec) SetConnectorConfigMirrormaker(v *ConnectorConfigMirrorMakerSpec) {
	m.ConnectorConfig = &UpdateConnectorSpec_ConnectorConfigMirrormaker{
		ConnectorConfigMirrormaker: v,
	}
}

func (m *UpdateConnectorSpec) SetConnectorConfigS3Sink(v *UpdateConnectorConfigS3SinkSpec) {
	m.ConnectorConfig = &UpdateConnectorSpec_ConnectorConfigS3Sink{
		ConnectorConfigS3Sink: v,
	}
}

func (m *UpdateConnectorSpec) SetConnectorConfigIcebergSink(v *UpdateConnectorConfigIcebergSinkSpec) {
	m.ConnectorConfig = &UpdateConnectorSpec_ConnectorConfigIcebergSink{
		ConnectorConfigIcebergSink: v,
	}
}

func (m *ConnectorConfigMirrorMakerSpec) SetSourceCluster(v *ClusterConnectionSpec) {
	m.SourceCluster = v
}

func (m *ConnectorConfigMirrorMakerSpec) SetTargetCluster(v *ClusterConnectionSpec) {
	m.TargetCluster = v
}

func (m *ConnectorConfigMirrorMakerSpec) SetTopics(v string) {
	m.Topics = v
}

func (m *ConnectorConfigMirrorMakerSpec) SetReplicationFactor(v *wrapperspb.Int64Value) {
	m.ReplicationFactor = v
}

type ClusterConnectionSpec_ClusterConnection = isClusterConnectionSpec_ClusterConnection

func (m *ClusterConnectionSpec) SetClusterConnection(v ClusterConnectionSpec_ClusterConnection) {
	m.ClusterConnection = v
}

func (m *ClusterConnectionSpec) SetAlias(v string) {
	m.Alias = v
}

func (m *ClusterConnectionSpec) SetThisCluster(v *ThisClusterSpec) {
	m.ClusterConnection = &ClusterConnectionSpec_ThisCluster{
		ThisCluster: v,
	}
}

func (m *ClusterConnectionSpec) SetExternalCluster(v *ExternalClusterConnectionSpec) {
	m.ClusterConnection = &ClusterConnectionSpec_ExternalCluster{
		ExternalCluster: v,
	}
}

func (m *ExternalClusterConnectionSpec) SetBootstrapServers(v string) {
	m.BootstrapServers = v
}

func (m *ExternalClusterConnectionSpec) SetSaslUsername(v string) {
	m.SaslUsername = v
}

func (m *ExternalClusterConnectionSpec) SetSaslPassword(v string) {
	m.SaslPassword = v
}

func (m *ExternalClusterConnectionSpec) SetSaslMechanism(v string) {
	m.SaslMechanism = v
}

func (m *ExternalClusterConnectionSpec) SetSecurityProtocol(v string) {
	m.SecurityProtocol = v
}

func (m *ExternalClusterConnectionSpec) SetSslTruststoreCertificates(v string) {
	m.SslTruststoreCertificates = v
}

func (m *ConnectorConfigS3SinkSpec) SetTopics(v string) {
	m.Topics = v
}

func (m *ConnectorConfigS3SinkSpec) SetFileCompressionType(v string) {
	m.FileCompressionType = v
}

func (m *ConnectorConfigS3SinkSpec) SetFileMaxRecords(v *wrapperspb.Int64Value) {
	m.FileMaxRecords = v
}

func (m *ConnectorConfigS3SinkSpec) SetS3Connection(v *S3ConnectionSpec) {
	m.S3Connection = v
}

func (m *UpdateConnectorConfigS3SinkSpec) SetTopics(v string) {
	m.Topics = v
}

func (m *UpdateConnectorConfigS3SinkSpec) SetFileMaxRecords(v *wrapperspb.Int64Value) {
	m.FileMaxRecords = v
}

func (m *UpdateConnectorConfigS3SinkSpec) SetS3Connection(v *S3ConnectionSpec) {
	m.S3Connection = v
}

type S3ConnectionSpec_Storage = isS3ConnectionSpec_Storage

func (m *S3ConnectionSpec) SetStorage(v S3ConnectionSpec_Storage) {
	m.Storage = v
}

func (m *S3ConnectionSpec) SetBucketName(v string) {
	m.BucketName = v
}

func (m *S3ConnectionSpec) SetExternalS3(v *ExternalS3StorageSpec) {
	m.Storage = &S3ConnectionSpec_ExternalS3{
		ExternalS3: v,
	}
}

func (m *ExternalS3StorageSpec) SetAccessKeyId(v string) {
	m.AccessKeyId = v
}

func (m *ExternalS3StorageSpec) SetSecretAccessKey(v string) {
	m.SecretAccessKey = v
}

func (m *ExternalS3StorageSpec) SetEndpoint(v string) {
	m.Endpoint = v
}

func (m *ExternalS3StorageSpec) SetRegion(v string) {
	m.Region = v
}

type ConnectorConfigIcebergSinkSpec_TopicsSource = isConnectorConfigIcebergSinkSpec_TopicsSource

func (m *ConnectorConfigIcebergSinkSpec) SetTopicsSource(v ConnectorConfigIcebergSinkSpec_TopicsSource) {
	m.TopicsSource = v
}

type ConnectorConfigIcebergSinkSpec_TableRouting = isConnectorConfigIcebergSinkSpec_TableRouting

func (m *ConnectorConfigIcebergSinkSpec) SetTableRouting(v ConnectorConfigIcebergSinkSpec_TableRouting) {
	m.TableRouting = v
}

func (m *ConnectorConfigIcebergSinkSpec) SetTopics(v string) {
	m.TopicsSource = &ConnectorConfigIcebergSinkSpec_Topics{
		Topics: v,
	}
}

func (m *ConnectorConfigIcebergSinkSpec) SetTopicsRegex(v string) {
	m.TopicsSource = &ConnectorConfigIcebergSinkSpec_TopicsRegex{
		TopicsRegex: v,
	}
}

func (m *ConnectorConfigIcebergSinkSpec) SetControlTopic(v string) {
	m.ControlTopic = v
}

func (m *ConnectorConfigIcebergSinkSpec) SetMetastoreConnection(v *MetastoreConnectionSpec) {
	m.MetastoreConnection = v
}

func (m *ConnectorConfigIcebergSinkSpec) SetS3Connection(v *IcebergS3ConnectionSpec) {
	m.S3Connection = v
}

func (m *ConnectorConfigIcebergSinkSpec) SetStaticTables(v *StaticTablesSpec) {
	m.TableRouting = &ConnectorConfigIcebergSinkSpec_StaticTables{
		StaticTables: v,
	}
}

func (m *ConnectorConfigIcebergSinkSpec) SetDynamicTables(v *DynamicTablesSpec) {
	m.TableRouting = &ConnectorConfigIcebergSinkSpec_DynamicTables{
		DynamicTables: v,
	}
}

func (m *ConnectorConfigIcebergSinkSpec) SetTablesConfig(v *IcebergTablesConfigSpec) {
	m.TablesConfig = v
}

func (m *ConnectorConfigIcebergSinkSpec) SetControlConfig(v *IcebergControlSpec) {
	m.ControlConfig = v
}

type UpdateConnectorConfigIcebergSinkSpec_TopicsSource = isUpdateConnectorConfigIcebergSinkSpec_TopicsSource

func (m *UpdateConnectorConfigIcebergSinkSpec) SetTopicsSource(v UpdateConnectorConfigIcebergSinkSpec_TopicsSource) {
	m.TopicsSource = v
}

func (m *UpdateConnectorConfigIcebergSinkSpec) SetTopics(v string) {
	m.TopicsSource = &UpdateConnectorConfigIcebergSinkSpec_Topics{
		Topics: v,
	}
}

func (m *UpdateConnectorConfigIcebergSinkSpec) SetTopicsRegex(v string) {
	m.TopicsSource = &UpdateConnectorConfigIcebergSinkSpec_TopicsRegex{
		TopicsRegex: v,
	}
}

func (m *UpdateConnectorConfigIcebergSinkSpec) SetControlTopic(v string) {
	m.ControlTopic = v
}

func (m *UpdateConnectorConfigIcebergSinkSpec) SetMetastoreConnection(v *MetastoreConnectionSpec) {
	m.MetastoreConnection = v
}

func (m *UpdateConnectorConfigIcebergSinkSpec) SetS3Connection(v *IcebergS3ConnectionSpec) {
	m.S3Connection = v
}

func (m *UpdateConnectorConfigIcebergSinkSpec) SetTablesConfig(v *IcebergTablesConfigSpec) {
	m.TablesConfig = v
}

func (m *UpdateConnectorConfigIcebergSinkSpec) SetControlConfig(v *IcebergControlSpec) {
	m.ControlConfig = v
}

func (m *StaticTablesSpec) SetTables(v string) {
	m.Tables = v
}

func (m *DynamicTablesSpec) SetRouteField(v string) {
	m.RouteField = v
}

func (m *MetastoreConnectionSpec) SetCatalogUri(v string) {
	m.CatalogUri = v
}

func (m *MetastoreConnectionSpec) SetWarehouse(v string) {
	m.Warehouse = v
}

type IcebergS3ConnectionSpec_Storage = isIcebergS3ConnectionSpec_Storage

func (m *IcebergS3ConnectionSpec) SetStorage(v IcebergS3ConnectionSpec_Storage) {
	m.Storage = v
}

func (m *IcebergS3ConnectionSpec) SetExternalS3(v *ExternalIcebergS3StorageSpec) {
	m.Storage = &IcebergS3ConnectionSpec_ExternalS3{
		ExternalS3: v,
	}
}

func (m *ExternalIcebergS3StorageSpec) SetAccessKeyId(v string) {
	m.AccessKeyId = v
}

func (m *ExternalIcebergS3StorageSpec) SetSecretAccessKey(v string) {
	m.SecretAccessKey = v
}

func (m *ExternalIcebergS3StorageSpec) SetEndpoint(v string) {
	m.Endpoint = v
}

func (m *ExternalIcebergS3StorageSpec) SetRegion(v string) {
	m.Region = v
}

func (m *IcebergTablesConfigSpec) SetDefaultCommitBranch(v string) {
	m.DefaultCommitBranch = v
}

func (m *IcebergTablesConfigSpec) SetDefaultIdColumns(v string) {
	m.DefaultIdColumns = v
}

func (m *IcebergTablesConfigSpec) SetDefaultPartitionBy(v string) {
	m.DefaultPartitionBy = v
}

func (m *IcebergTablesConfigSpec) SetEvolveSchemaEnabled(v bool) {
	m.EvolveSchemaEnabled = v
}

func (m *IcebergTablesConfigSpec) SetSchemaForceOptional(v bool) {
	m.SchemaForceOptional = v
}

func (m *IcebergTablesConfigSpec) SetSchemaCaseInsensitive(v bool) {
	m.SchemaCaseInsensitive = v
}

func (m *IcebergControlSpec) SetGroupIdPrefix(v string) {
	m.GroupIdPrefix = v
}

func (m *IcebergControlSpec) SetCommitIntervalMs(v *wrapperspb.Int64Value) {
	m.CommitIntervalMs = v
}

func (m *IcebergControlSpec) SetCommitTimeoutMs(v *wrapperspb.Int64Value) {
	m.CommitTimeoutMs = v
}

func (m *IcebergControlSpec) SetCommitThreads(v *wrapperspb.Int64Value) {
	m.CommitThreads = v
}

func (m *IcebergControlSpec) SetTransactionalPrefix(v string) {
	m.TransactionalPrefix = v
}

type Connector_ConnectorConfig = isConnector_ConnectorConfig

func (m *Connector) SetConnectorConfig(v Connector_ConnectorConfig) {
	m.ConnectorConfig = v
}

func (m *Connector) SetName(v string) {
	m.Name = v
}

func (m *Connector) SetTasksMax(v *wrapperspb.Int64Value) {
	m.TasksMax = v
}

func (m *Connector) SetProperties(v map[string]string) {
	m.Properties = v
}

func (m *Connector) SetHealth(v Connector_Health) {
	m.Health = v
}

func (m *Connector) SetStatus(v Connector_Status) {
	m.Status = v
}

func (m *Connector) SetClusterId(v string) {
	m.ClusterId = v
}

func (m *Connector) SetConnectorConfigMirrormaker(v *ConnectorConfigMirrorMaker) {
	m.ConnectorConfig = &Connector_ConnectorConfigMirrormaker{
		ConnectorConfigMirrormaker: v,
	}
}

func (m *Connector) SetConnectorConfigS3Sink(v *ConnectorConfigS3Sink) {
	m.ConnectorConfig = &Connector_ConnectorConfigS3Sink{
		ConnectorConfigS3Sink: v,
	}
}

func (m *Connector) SetConnectorConfigIcebergSink(v *ConnectorConfigIcebergSink) {
	m.ConnectorConfig = &Connector_ConnectorConfigIcebergSink{
		ConnectorConfigIcebergSink: v,
	}
}

func (m *ConnectorConfigMirrorMaker) SetSourceCluster(v *ClusterConnection) {
	m.SourceCluster = v
}

func (m *ConnectorConfigMirrorMaker) SetTargetCluster(v *ClusterConnection) {
	m.TargetCluster = v
}

func (m *ConnectorConfigMirrorMaker) SetTopics(v string) {
	m.Topics = v
}

func (m *ConnectorConfigMirrorMaker) SetReplicationFactor(v *wrapperspb.Int64Value) {
	m.ReplicationFactor = v
}

type ClusterConnection_ClusterConnection = isClusterConnection_ClusterConnection

func (m *ClusterConnection) SetClusterConnection(v ClusterConnection_ClusterConnection) {
	m.ClusterConnection = v
}

func (m *ClusterConnection) SetAlias(v string) {
	m.Alias = v
}

func (m *ClusterConnection) SetThisCluster(v *ThisCluster) {
	m.ClusterConnection = &ClusterConnection_ThisCluster{
		ThisCluster: v,
	}
}

func (m *ClusterConnection) SetExternalCluster(v *ExternalClusterConnection) {
	m.ClusterConnection = &ClusterConnection_ExternalCluster{
		ExternalCluster: v,
	}
}

func (m *ExternalClusterConnection) SetBootstrapServers(v string) {
	m.BootstrapServers = v
}

func (m *ExternalClusterConnection) SetSaslUsername(v string) {
	m.SaslUsername = v
}

func (m *ExternalClusterConnection) SetSaslMechanism(v string) {
	m.SaslMechanism = v
}

func (m *ExternalClusterConnection) SetSecurityProtocol(v string) {
	m.SecurityProtocol = v
}

func (m *ConnectorConfigS3Sink) SetTopics(v string) {
	m.Topics = v
}

func (m *ConnectorConfigS3Sink) SetFileCompressionType(v string) {
	m.FileCompressionType = v
}

func (m *ConnectorConfigS3Sink) SetFileMaxRecords(v *wrapperspb.Int64Value) {
	m.FileMaxRecords = v
}

func (m *ConnectorConfigS3Sink) SetS3Connection(v *S3Connection) {
	m.S3Connection = v
}

type S3Connection_Storage = isS3Connection_Storage

func (m *S3Connection) SetStorage(v S3Connection_Storage) {
	m.Storage = v
}

func (m *S3Connection) SetBucketName(v string) {
	m.BucketName = v
}

func (m *S3Connection) SetExternalS3(v *ExternalS3Storage) {
	m.Storage = &S3Connection_ExternalS3{
		ExternalS3: v,
	}
}

func (m *ExternalS3Storage) SetAccessKeyId(v string) {
	m.AccessKeyId = v
}

func (m *ExternalS3Storage) SetEndpoint(v string) {
	m.Endpoint = v
}

func (m *ExternalS3Storage) SetRegion(v string) {
	m.Region = v
}

type ConnectorConfigIcebergSink_TopicsSource = isConnectorConfigIcebergSink_TopicsSource

func (m *ConnectorConfigIcebergSink) SetTopicsSource(v ConnectorConfigIcebergSink_TopicsSource) {
	m.TopicsSource = v
}

type ConnectorConfigIcebergSink_TableRouting = isConnectorConfigIcebergSink_TableRouting

func (m *ConnectorConfigIcebergSink) SetTableRouting(v ConnectorConfigIcebergSink_TableRouting) {
	m.TableRouting = v
}

func (m *ConnectorConfigIcebergSink) SetTopics(v string) {
	m.TopicsSource = &ConnectorConfigIcebergSink_Topics{
		Topics: v,
	}
}

func (m *ConnectorConfigIcebergSink) SetTopicsRegex(v string) {
	m.TopicsSource = &ConnectorConfigIcebergSink_TopicsRegex{
		TopicsRegex: v,
	}
}

func (m *ConnectorConfigIcebergSink) SetControlTopic(v string) {
	m.ControlTopic = v
}

func (m *ConnectorConfigIcebergSink) SetMetastoreConnection(v *MetastoreConnection) {
	m.MetastoreConnection = v
}

func (m *ConnectorConfigIcebergSink) SetS3Connection(v *IcebergS3Connection) {
	m.S3Connection = v
}

func (m *ConnectorConfigIcebergSink) SetStaticTables(v *StaticTables) {
	m.TableRouting = &ConnectorConfigIcebergSink_StaticTables{
		StaticTables: v,
	}
}

func (m *ConnectorConfigIcebergSink) SetDynamicTables(v *DynamicTables) {
	m.TableRouting = &ConnectorConfigIcebergSink_DynamicTables{
		DynamicTables: v,
	}
}

func (m *ConnectorConfigIcebergSink) SetTablesConfig(v *IcebergTablesConfig) {
	m.TablesConfig = v
}

func (m *ConnectorConfigIcebergSink) SetControlConfig(v *IcebergControl) {
	m.ControlConfig = v
}

func (m *StaticTables) SetTables(v string) {
	m.Tables = v
}

func (m *DynamicTables) SetRouteField(v string) {
	m.RouteField = v
}

func (m *MetastoreConnection) SetCatalogUri(v string) {
	m.CatalogUri = v
}

func (m *MetastoreConnection) SetWarehouse(v string) {
	m.Warehouse = v
}

type IcebergS3Connection_Storage = isIcebergS3Connection_Storage

func (m *IcebergS3Connection) SetStorage(v IcebergS3Connection_Storage) {
	m.Storage = v
}

func (m *IcebergS3Connection) SetExternalS3(v *ExternalIcebergS3Storage) {
	m.Storage = &IcebergS3Connection_ExternalS3{
		ExternalS3: v,
	}
}

func (m *ExternalIcebergS3Storage) SetAccessKeyId(v string) {
	m.AccessKeyId = v
}

func (m *ExternalIcebergS3Storage) SetEndpoint(v string) {
	m.Endpoint = v
}

func (m *ExternalIcebergS3Storage) SetRegion(v string) {
	m.Region = v
}

func (m *IcebergTablesConfig) SetDefaultCommitBranch(v string) {
	m.DefaultCommitBranch = v
}

func (m *IcebergTablesConfig) SetDefaultIdColumns(v string) {
	m.DefaultIdColumns = v
}

func (m *IcebergTablesConfig) SetDefaultPartitionBy(v string) {
	m.DefaultPartitionBy = v
}

func (m *IcebergTablesConfig) SetEvolveSchemaEnabled(v bool) {
	m.EvolveSchemaEnabled = v
}

func (m *IcebergTablesConfig) SetSchemaForceOptional(v bool) {
	m.SchemaForceOptional = v
}

func (m *IcebergTablesConfig) SetSchemaCaseInsensitive(v bool) {
	m.SchemaCaseInsensitive = v
}

func (m *IcebergControl) SetGroupIdPrefix(v string) {
	m.GroupIdPrefix = v
}

func (m *IcebergControl) SetCommitIntervalMs(v *wrapperspb.Int64Value) {
	m.CommitIntervalMs = v
}

func (m *IcebergControl) SetCommitTimeoutMs(v *wrapperspb.Int64Value) {
	m.CommitTimeoutMs = v
}

func (m *IcebergControl) SetCommitThreads(v *wrapperspb.Int64Value) {
	m.CommitThreads = v
}

func (m *IcebergControl) SetTransactionalPrefix(v string) {
	m.TransactionalPrefix = v
}
