class Kafka::EC2::MixedInstanceAssignmentStrategyFactory

Public Class Methods

new(instance_family_weights: {}, availability_zone_weights: {}, weights: {}, partition_weights: {}) click to toggle source

@param instance_family_weights [Hash, Proc] @param availability_zone_weights [Hash, Proc] @param weights [Hash, Proc] @see Kafka::EC2::MixedInstanceAssignmentStrategy#initialize

# File lib/kafka/ec2/mixed_instance_assignment_strategy_factory.rb, line 12
def initialize(instance_family_weights: {}, availability_zone_weights: {}, weights: {}, partition_weights: {})
  @instance_family_weights = instance_family_weights
  @availability_zone_weights = availability_zone_weights
  @weights = weights
  @partition_weights = partition_weights
end

Public Instance Methods

create(cluster:) click to toggle source
# File lib/kafka/ec2/mixed_instance_assignment_strategy_factory.rb, line 19
def create(cluster:)
  Kafka::EC2::MixedInstanceAssignmentStrategy.new(
    cluster: cluster,
    instance_family_weights: @instance_family_weights,
    availability_zone_weights: @availability_zone_weights,
    weights: @weights,
    partition_weights: @partition_weights,
  )
end