kasfleetshardsync

Documentation

Index

• Constants
• Variables
• func GetDefaultReportedKafkaVersion() string
• func GetDefaultReportedStrimziVersion() string
• func GetDeletedKafkaStatusResponse() private.DataPlaneKafkaStatus
• func GetErrorKafkaStatusResponse() private.DataPlaneKafkaStatus
• func GetErrorWithCustomMessageKafkaStatusResponse(message string) private.DataPlaneKafkaStatus
• func GetReadyKafkaStatusResponse(clusterDNS string) private.DataPlaneKafkaStatus
• func GetSuspendedKafkaStatusResponse() private.DataPlaneKafkaStatus
• func NewAuthenticatedContextForDataPlaneCluster(h *coreTest.Helper, clusterID string) (context.Context, error)
• func SampleDataPlaneclusterStatusRequestWithAvailableCapacity() *private.DataPlaneClusterUpdateStatusRequest
• type MockKasFleetshardSync
• type MockKasFleetshardSyncBuilder
  • func NewMockKasFleetshardSyncBuilder(helper *coreTest.Helper, t *testing.T) MockKasFleetshardSyncBuilder

Constants

const AdminServerURI = "http://test-admin-server-uri.com"

Variables

var DeveloperCapacityInfo private.DataPlaneClusterUpdateStatusRequestCapacity = private.DataPlaneClusterUpdateStatusRequestCapacity{
	MaxUnits:       50,
	RemainingUnits: 8,
}

var StandardCapacityInfo private.DataPlaneClusterUpdateStatusRequestCapacity = private.DataPlaneClusterUpdateStatusRequestCapacity{
	MaxUnits:       5,
	RemainingUnits: 3,
}

Functions

func GetDefaultReportedKafkaVersion

func GetDefaultReportedKafkaVersion() string

func GetDefaultReportedStrimziVersion

func GetDefaultReportedStrimziVersion() string

func GetDeletedKafkaStatusResponse

func GetDeletedKafkaStatusResponse() private.DataPlaneKafkaStatus

Return a Kafka status for a deleted cluster

func GetErrorKafkaStatusResponse

func GetErrorKafkaStatusResponse() private.DataPlaneKafkaStatus

func GetErrorWithCustomMessageKafkaStatusResponse

func GetErrorWithCustomMessageKafkaStatusResponse(message string) private.DataPlaneKafkaStatus

func GetReadyKafkaStatusResponse

func GetReadyKafkaStatusResponse(clusterDNS string) private.DataPlaneKafkaStatus

Return a kafka status for a ready cluster

func GetSuspendedKafkaStatusResponse

func GetSuspendedKafkaStatusResponse() private.DataPlaneKafkaStatus

Return a Kafka status for a suspended instance

func NewAuthenticatedContextForDataPlaneCluster

func NewAuthenticatedContextForDataPlaneCluster(h *coreTest.Helper, clusterID string) (context.Context, error)

Returns an authenticated context to be used for calling the data plane endpoints

func SampleDataPlaneclusterStatusRequestWithAvailableCapacity

func SampleDataPlaneclusterStatusRequestWithAvailableCapacity() *private.DataPlaneClusterUpdateStatusRequest

Returns a sample data plane cluster status request with available capacity

Types

type MockKasFleetshardSync

type MockKasFleetshardSync interface {
	// Start - Starts the KAS Fleetshard sync reconciler
	Start()
	// Stop - Stops the KAS Fleetshard sync reconciler
	Stop()
}

type MockKasFleetshardSyncBuilder

type MockKasFleetshardSyncBuilder interface {
	// SetUpdateDataplaneClusterStatusFunc - Sets behaviour for updating dataplane clusters in each KAS Fleetshard sync reconcile
	SetUpdateDataplaneClusterStatusFunc(mockKasFleetshardSyncUpdateDataPlaneClusterStatusFunc)
	// SetUpdateKafkaStatusFunc - Sets behaviour for updating kafka clusters in each KAS Fleetshard sync reconcile
	SetUpdateKafkaStatusFunc(mockKasFleetshardSyncupdateKafkaClusterStatusFunc)
	// SetInterval - Sets the repeat interval for the mock KAS Fleetshard sync
	SetInterval(interval time.Duration)
	// Build - Builds a mock KAS Fleetshard sync
	Build() MockKasFleetshardSync
}

func NewMockKasFleetshardSyncBuilder

func NewMockKasFleetshardSyncBuilder(helper *coreTest.Helper, t *testing.T) MockKasFleetshardSyncBuilder