supportedinstancetypes

Documentation

Index

• Constants
• Variables
• func BuildKafkaInstanceSize(options ...KafkaInstanceSizeBuildOption) *config.KafkaInstanceSize
• type KafkaInstanceSizeAttribute
• type KafkaInstanceSizeBuildOption
  • func With(attribute KafkaInstanceSizeAttribute, value string) KafkaInstanceSizeBuildOption
  • func WithCapacityConsumed(capacityConsumed int) KafkaInstanceSizeBuildOption
  • func WithLifespanSeconds(lifespanSeconds *int) KafkaInstanceSizeBuildOption
  • func WithMaxPartitions(maxPartitions int) KafkaInstanceSizeBuildOption
  • func WithMinInSyncReplicas(minInSyncReplicas int) KafkaInstanceSizeBuildOption
  • func WithQuotaConsumed(quotaConsumed int) KafkaInstanceSizeBuildOption
  • func WithReplicationFactor(replicationFactor int) KafkaInstanceSizeBuildOption
  • func WithSupportedAZModes(supportedAZModes []string) KafkaInstanceSizeBuildOption
  • func WithTotalMaxConnections(totalMaxConnections int) KafkaInstanceSizeBuildOption

Constants

const (
	DefaultKafkaInstanceSizeId          = "x1"
	DefaultKafkaInstanceSizeDisplayName = "x1"
	DefaultIngressThroughputPerSec      = "1Mi"
	DefaultEgressThroughputPerSec       = "1Mi"
	DefaultTotalMaxConnections          = 100
	DefaultMaxDataRetentionSize         = "1Gi"
	DefaultMaxDataRetentionPeriod       = "P14D"
	DefaultMaxConnectionAttemptsPerSec  = 100
	DefaultMaxMessageSize               = "1Mi"
	DefaultQuotaconsumed                = 1
	DefaultQuotaType                    = "RHOSAK"
	DefaultCapacityConsumed             = 1
	DefaultMinInSyncReplicas            = 1
	DefaultReplicationFactor            = 1
	DefaultMaxPartitions                = 100
)

Variables

var (
	DefaultSupportedAZModes = []string{"single", "multi"}
	DefaultMaturityStatus   = config.MaturityStatusStable
)

var DefaultLifespanSeconds *int = &lifespanSeconds

Functions

func BuildKafkaInstanceSize

func BuildKafkaInstanceSize(options ...KafkaInstanceSizeBuildOption) *config.KafkaInstanceSize

Types

type KafkaInstanceSizeAttribute

type KafkaInstanceSizeAttribute int

const (
	SIZE_ID KafkaInstanceSizeAttribute = iota
	DISPLAY_NAME
	INGRESS_THROUGHPUT_PER_SEC
	EGRESS_THROUGHPUT_PER_SEC
	MAX_DATA_RETENTION_SIZE
	MAX_DATA_RETENTION_PERIOD
	MAX_CONNECTION_ATTEMPTS_PER_SEC
	MAX_MESSAGE_SIZE
	QUOTA_TYPE
	MATURITY_STATUS
	MAX_PARTITIONS
)

type KafkaInstanceSizeBuildOption

type KafkaInstanceSizeBuildOption func(*config.KafkaInstanceSize)

func With

func With(attribute KafkaInstanceSizeAttribute, value string) KafkaInstanceSizeBuildOption

func WithCapacityConsumed

func WithCapacityConsumed(capacityConsumed int) KafkaInstanceSizeBuildOption

func WithLifespanSeconds

func WithLifespanSeconds(lifespanSeconds *int) KafkaInstanceSizeBuildOption

func WithMaxPartitions

func WithMaxPartitions(maxPartitions int) KafkaInstanceSizeBuildOption

func WithMinInSyncReplicas

func WithMinInSyncReplicas(minInSyncReplicas int) KafkaInstanceSizeBuildOption

func WithQuotaConsumed

func WithQuotaConsumed(quotaConsumed int) KafkaInstanceSizeBuildOption

func WithReplicationFactor

func WithReplicationFactor(replicationFactor int) KafkaInstanceSizeBuildOption

func WithSupportedAZModes

func WithSupportedAZModes(supportedAZModes []string) KafkaInstanceSizeBuildOption

func WithTotalMaxConnections

func WithTotalMaxConnections(totalMaxConnections int) KafkaInstanceSizeBuildOption