Class: Google::Cloud::ManagedKafka::V1::Connector

Inherits:
Object
  • Object
show all
Extended by:
Protobuf::MessageExts::ClassMethods
Includes:
Protobuf::MessageExts
Defined in:
proto_docs/google/cloud/managedkafka/v1/resources.rb

Overview

A Kafka Connect connector in a given ConnectCluster.

Defined Under Namespace

Modules: State Classes: ConfigsEntry

Instance Attribute Summary collapse

Instance Attribute Details

#configs ⇒ ::Google::Protobuf::Map{::String => ::String}

Returns Optional. Connector config as keys/values. The keys of the map are connector property names, for example: connector.class, tasks.max, key.converter.

Returns:

  • (::Google::Protobuf::Map{::String => ::String}) —

    Optional. Connector config as keys/values. The keys of the map are connector property names, for example: connector.class, tasks.max, key.converter.



487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
 
# File 'proto_docs/google/cloud/managedkafka/v1/resources.rb', line 487

class Connector
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods

  # @!attribute [rw] key
  #   @return [::String]
  # @!attribute [rw] value
  #   @return [::String]
  class ConfigsEntry
    include ::Google::Protobuf::MessageExts
    extend ::Google::Protobuf::MessageExts::ClassMethods
  end

  # The state of the connector.
  module State
    # A state was not specified.
    STATE_UNSPECIFIED = 0

    # The connector is not assigned to any tasks, usually transient.
    UNASSIGNED = 1

    # The connector is running.
    RUNNING = 2

    # The connector has been paused.
    PAUSED = 3

    # The connector has failed. See logs for why.
    FAILED = 4

    # The connector is restarting.
    RESTARTING = 5

    # The connector has been stopped.
    STOPPED = 6
  end
end

#name ⇒ ::String

Returns Identifier. The name of the connector. Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}.

Returns:

  • (::String) —

    Identifier. The name of the connector. Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}



487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
 
# File 'proto_docs/google/cloud/managedkafka/v1/resources.rb', line 487

class Connector
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods

  # @!attribute [rw] key
  #   @return [::String]
  # @!attribute [rw] value
  #   @return [::String]
  class ConfigsEntry
    include ::Google::Protobuf::MessageExts
    extend ::Google::Protobuf::MessageExts::ClassMethods
  end

  # The state of the connector.
  module State
    # A state was not specified.
    STATE_UNSPECIFIED = 0

    # The connector is not assigned to any tasks, usually transient.
    UNASSIGNED = 1

    # The connector is running.
    RUNNING = 2

    # The connector has been paused.
    PAUSED = 3

    # The connector has failed. See logs for why.
    FAILED = 4

    # The connector is restarting.
    RESTARTING = 5

    # The connector has been stopped.
    STOPPED = 6
  end
end

#state ⇒ ::Google::Cloud::ManagedKafka::V1::Connector::State (readonly)

Returns Output only. The current state of the connector.

Returns:



487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
 
# File 'proto_docs/google/cloud/managedkafka/v1/resources.rb', line 487

class Connector
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods

  # @!attribute [rw] key
  #   @return [::String]
  # @!attribute [rw] value
  #   @return [::String]
  class ConfigsEntry
    include ::Google::Protobuf::MessageExts
    extend ::Google::Protobuf::MessageExts::ClassMethods
  end

  # The state of the connector.
  module State
    # A state was not specified.
    STATE_UNSPECIFIED = 0

    # The connector is not assigned to any tasks, usually transient.
    UNASSIGNED = 1

    # The connector is running.
    RUNNING = 2

    # The connector has been paused.
    PAUSED = 3

    # The connector has failed. See logs for why.
    FAILED = 4

    # The connector is restarting.
    RESTARTING = 5

    # The connector has been stopped.
    STOPPED = 6
  end
end

#task_restart_policy ⇒ ::Google::Cloud::ManagedKafka::V1::TaskRetryPolicy

Returns Optional. Restarts the individual tasks of a Connector.

Returns:



487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
 
# File 'proto_docs/google/cloud/managedkafka/v1/resources.rb', line 487

class Connector
  include ::Google::Protobuf::MessageExts
  extend ::Google::Protobuf::MessageExts::ClassMethods

  # @!attribute [rw] key
  #   @return [::String]
  # @!attribute [rw] value
  #   @return [::String]
  class ConfigsEntry
    include ::Google::Protobuf::MessageExts
    extend ::Google::Protobuf::MessageExts::ClassMethods
  end

  # The state of the connector.
  module State
    # A state was not specified.
    STATE_UNSPECIFIED = 0

    # The connector is not assigned to any tasks, usually transient.
    UNASSIGNED = 1

    # The connector is running.
    RUNNING = 2

    # The connector has been paused.
    PAUSED = 3

    # The connector has failed. See logs for why.
    FAILED = 4

    # The connector is restarting.
    RESTARTING = 5

    # The connector has been stopped.
    STOPPED = 6
  end
end