mocks

Documentation

Index

• Constants
• Variables
• func BuildAdminKafkaRequest(modifyFn func(kafka *private.Kafka)) *private.Kafka
• func BuildKafkaRequest(options ...KafkaRequestBuildOption) *dbapi.KafkaRequest
• func BuildKafkaRequestMap(modifyFn func(m []map[string]interface{})) []map[string]interface{}
• func BuildKafkaRequestPayload(modifyFn func(payload *public.KafkaRequestPayload)) *public.KafkaRequestPayload
• func BuildManagedKafka(modifyFn func(managedKafka *v1.ManagedKafka)) *v1.ManagedKafka
• func BuildManagedKafkaAllOfSpecEndpointTls(modifyFn func(tls *private.ManagedKafkaAllOfSpecEndpointTls)) *private.ManagedKafkaAllOfSpecEndpointTls
• func BuildOAuthSpec(modifyFn func(oauthSpec *v1.OAuthSpec)) *v1.OAuthSpec
• func BuildPrivateKafka(modifyFn func(privatekafka *private.ManagedKafka)) *private.ManagedKafka
• func BuildPublicKafkaRequest(modifyFn func(kafka *public.KafkaRequest)) *public.KafkaRequest
• func BuildTlsSpec(modifyFn func(tlsSpec *v1.TlsSpec)) *v1.TlsSpec
• func GetMalformedRoutes() []byte
• func GetRoutes() []byte
• func GetSampleKafkaAllRoutes() []private.KafkaAllOfRoutes
• func GetTrustedCertValue() *string
• type KafkaAttribute
• type KafkaRequestAttribute
• type KafkaRequestBuildOption
  • func With(attribute KafkaRequestAttribute, value string) KafkaRequestBuildOption
  • func WithCreatedAt(createdAt time.Time) KafkaRequestBuildOption
  • func WithDeleted(deleted bool) KafkaRequestBuildOption
  • func WithExpiresAt(expiresAt sql.NullTime) KafkaRequestBuildOption
  • func WithMultiAZ(multiaz bool) KafkaRequestBuildOption
  • func WithPredefinedTestValues() KafkaRequestBuildOption
  • func WithReauthenticationEnabled(enabled bool) KafkaRequestBuildOption
  • func WithRoutes(routes api.JSON) KafkaRequestBuildOption

Constants

const (
	DefaultKafkaRequestRegion   = "us-east-1"
	DefaultKafkaRequestProvider = "aws"
	DefaultKafkaRequestName     = "test-cluster"
	DefaultClusterID            = "test-cluster-id"

	DefaultMultiAz             = true
	DefaultBootstrapServerHost = "test-bootstrap-server-host"
	DefaultPlacementId         = "test-placement-id"
	DefaultOrganisationId      = "13640203"
	DefaultKafkaID             = "test-kafka-id"
)

Variables

var (
	DefaultInstanceType = types.STANDARD.String()
)

Functions

func BuildAdminKafkaRequest

func BuildAdminKafkaRequest(modifyFn func(kafka *private.Kafka)) *private.Kafka

func BuildKafkaRequest

func BuildKafkaRequest(options ...KafkaRequestBuildOption) *dbapi.KafkaRequest

func BuildKafkaRequestMap

func BuildKafkaRequestMap(modifyFn func(m []map[string]interface{})) []map[string]interface{}

func BuildKafkaRequestPayload

func BuildKafkaRequestPayload(modifyFn func(payload *public.KafkaRequestPayload)) *public.KafkaRequestPayload

func BuildManagedKafka

func BuildManagedKafka(modifyFn func(managedKafka *v1.ManagedKafka)) *v1.ManagedKafka

func BuildManagedKafkaAllOfSpecEndpointTls

func BuildManagedKafkaAllOfSpecEndpointTls(modifyFn func(tls *private.ManagedKafkaAllOfSpecEndpointTls)) *private.ManagedKafkaAllOfSpecEndpointTls

func BuildOAuthSpec

func BuildOAuthSpec(modifyFn func(oauthSpec *v1.OAuthSpec)) *v1.OAuthSpec

func BuildPrivateKafka

func BuildPrivateKafka(modifyFn func(privatekafka *private.ManagedKafka)) *private.ManagedKafka

func BuildPublicKafkaRequest

func BuildPublicKafkaRequest(modifyFn func(kafka *public.KafkaRequest)) *public.KafkaRequest

func BuildTlsSpec

func BuildTlsSpec(modifyFn func(tlsSpec *v1.TlsSpec)) *v1.TlsSpec

func GetMalformedRoutes

func GetMalformedRoutes() []byte

func GetRoutes

func GetRoutes() []byte

func GetSampleKafkaAllRoutes

func GetSampleKafkaAllRoutes() []private.KafkaAllOfRoutes

func GetTrustedCertValue

func GetTrustedCertValue() *string

Types

type KafkaAttribute

type KafkaAttribute int

type KafkaRequestAttribute

type KafkaRequestAttribute int

const (
	STATUS KafkaRequestAttribute = iota
	OWNER
	CLUSTER_ID
	BOOTSTRAP_SERVER_HOST
	FAILED_REASON
	ACTUAL_KAFKA_VERSION
	DESIRED_KAFKA_VERSION
	INSTANCE_TYPE
	STORAGE_SIZE
	SIZE_ID
	NAME
	NAMESPACE
	REGION
	CLOUD_PROVIDER
	ACTUAL_STRIMZI_VERSION
	DESIRED_STRIMZI_VERSION
	ACTUAL_KAFKA_IBP_VERSION
	DESIRED_KAFKA_IBP_VERSION
	ORGANISATION_ID
	ID
	DESIRED_KAFKA_BILLING_MODEL
	ACTUAL_KAFKA_BILLING_MODEL
	PROMOTION_STATUS
	PROMOTION_DETAILS
	CANARY_SERVICE_ACCOUNT_CLIENT_ID
	CANARY_SERVICE_ACCOUNT_CLIENT_SECRET
)

type KafkaRequestBuildOption

type KafkaRequestBuildOption func(*dbapi.KafkaRequest)

func With

func With(attribute KafkaRequestAttribute, value string) KafkaRequestBuildOption

func WithCreatedAt

func WithCreatedAt(createdAt time.Time) KafkaRequestBuildOption

func WithDeleted

func WithDeleted(deleted bool) KafkaRequestBuildOption

func WithExpiresAt

func WithExpiresAt(expiresAt sql.NullTime) KafkaRequestBuildOption

func WithMultiAZ

func WithMultiAZ(multiaz bool) KafkaRequestBuildOption

func WithPredefinedTestValues

func WithPredefinedTestValues() KafkaRequestBuildOption

func WithReauthenticationEnabled

func WithReauthenticationEnabled(enabled bool) KafkaRequestBuildOption

func WithRoutes

func WithRoutes(routes api.JSON) KafkaRequestBuildOption