Documentation ¶
Index ¶
- Constants
- func ConvertDataPlaneClusterStatus(status private.DataPlaneClusterUpdateStatusRequest) (*dbapi.DataPlaneClusterStatus, error)
- func ConvertDataPlaneKafkaStatus(status map[string]private.DataPlaneKafkaStatus) []*dbapi.DataPlaneKafkaStatus
- func ConvertKafkaRequest(kafkaRequestPayload public.KafkaRequestPayload, ...) *dbapi.KafkaRequest
- func ConvertServiceAccountRequest(account public.ServiceAccountRequest) *api.ServiceAccountRequest
- func GetRegionCapacityItems(capacityItems []api.RegionCapacityListItem) []public.RegionCapacityListItem
- func GetRoutesFromKafkaRequest(kafkaRequest *dbapi.KafkaRequest) []private.KafkaAllOfRoutes
- func GetSupportedBillingModels(supportedInstanceType *config.KafkaInstanceType) []public.SupportedKafkaBillingModel
- func GetSupportedSizes(supportedInstanceType *config.KafkaInstanceType) []public.SupportedKafkaSize
- func PresentCloudProvider(cloudProvider *api.CloudProvider) public.CloudProvider
- func PresentCloudRegion(cloudRegion *api.CloudRegion) public.CloudRegion
- func PresentDataPlaneClusterConfig(config *dbapi.DataPlaneClusterConfig) private.DataplaneClusterAgentConfig
- func PresentEnterpriseCluster(cluster api.Cluster, consumedStreamingUnitsInTheCluster int32, ...) (public.EnterpriseCluster, error)
- func PresentEnterpriseClusterAddonParameters(cluster api.Cluster, fleetShardParams services.ParameterList) (public.EnterpriseClusterAddonParameters, *errors.ServiceError)
- func PresentEnterpriseClusterRegistrationResponse(cluster api.Cluster, consumedStreamingUnitsInTheCluster int32, ...) (public.EnterpriseClusterRegistrationResponse, *errors.ServiceError)
- func PresentKafkaRequest(kafkaRequest *dbapi.KafkaRequest, kafkaConfig *config.KafkaConfig) (public.KafkaRequest, *errors.ServiceError)
- func PresentKafkaRequestAdminEndpoint(kafkaRequest *dbapi.KafkaRequest, accountService account.AccountService) (*private.Kafka, *errors.ServiceError)
- func PresentManagedKafka(from *v1.ManagedKafka) private.ManagedKafka
- func PresentMetricsByInstantQuery(metrics *observatorium.KafkaMetrics) ([]public.InstantQuery, *errors.ServiceError)
- func PresentMetricsByRangeQuery(metrics *observatorium.KafkaMetrics) ([]public.RangeQuery, *errors.ServiceError)
- func PresentReference(id, obj interface{}) compat.ObjectReference
- func PresentServiceAccount(account *api.ServiceAccount) *public.ServiceAccount
- func PresentServiceAccountListItem(account *api.ServiceAccount) public.ServiceAccountListItem
- func PresentSsoProvider(provider *api.SsoProvider) public.SsoProvider
- func PresentSupportedKafkaInstanceTypes(supportedInstanceType *config.KafkaInstanceType) public.SupportedKafkaInstanceType
Constants ¶
View Source
const ( // KindKafka is a string identifier for the type api.KafkaRequest KindKafka = "Kafka" // CloudRegion is a string identifier for the type api.CloudRegion KindCloudRegion = "CloudRegion" // KindCloudProvider is a string identifier for the type api.CloudProvider KindCloudProvider = "CloudProvider" // KindError is a string identifier for the type api.ServiceError KindError = "Error" // KindServiceAccount is a string identifier for the type api.ServiceAccount KindServiceAccount = "ServiceAccount" KindCluster = "Cluster" // KindClusterAddonParameters is a string identifier for the // type public.EnterpriseClusterAddonParameters KindClusterAddonParameters = "ClusterAddonParameters" BasePath = "/api/kafkas_mgmt/v1" )
Variables ¶
This section is empty.
Functions ¶
func ConvertDataPlaneClusterStatus ¶
func ConvertDataPlaneClusterStatus(status private.DataPlaneClusterUpdateStatusRequest) (*dbapi.DataPlaneClusterStatus, error)
func ConvertDataPlaneKafkaStatus ¶
func ConvertDataPlaneKafkaStatus(status map[string]private.DataPlaneKafkaStatus) []*dbapi.DataPlaneKafkaStatus
func ConvertKafkaRequest ¶
func ConvertKafkaRequest(kafkaRequestPayload public.KafkaRequestPayload, dbKafkarequest ...*dbapi.KafkaRequest) *dbapi.KafkaRequest
ConvertKafkaRequest from payload to KafkaRequest
func ConvertServiceAccountRequest ¶
func ConvertServiceAccountRequest(account public.ServiceAccountRequest) *api.ServiceAccountRequest
func GetRegionCapacityItems ¶
func GetRegionCapacityItems(capacityItems []api.RegionCapacityListItem) []public.RegionCapacityListItem
func GetRoutesFromKafkaRequest ¶
func GetRoutesFromKafkaRequest(kafkaRequest *dbapi.KafkaRequest) []private.KafkaAllOfRoutes
func GetSupportedBillingModels ¶
func GetSupportedBillingModels(supportedInstanceType *config.KafkaInstanceType) []public.SupportedKafkaBillingModel
func GetSupportedSizes ¶
func GetSupportedSizes(supportedInstanceType *config.KafkaInstanceType) []public.SupportedKafkaSize
func PresentCloudProvider ¶
func PresentCloudProvider(cloudProvider *api.CloudProvider) public.CloudProvider
func PresentCloudRegion ¶
func PresentCloudRegion(cloudRegion *api.CloudRegion) public.CloudRegion
func PresentDataPlaneClusterConfig ¶
func PresentDataPlaneClusterConfig(config *dbapi.DataPlaneClusterConfig) private.DataplaneClusterAgentConfig
func PresentEnterpriseCluster ¶
func PresentEnterpriseCluster(cluster api.Cluster, consumedStreamingUnitsInTheCluster int32, kafkaConfig *config.KafkaConfig) (public.EnterpriseCluster, error)
func PresentEnterpriseClusterAddonParameters ¶
func PresentEnterpriseClusterAddonParameters(cluster api.Cluster, fleetShardParams services.ParameterList) (public.EnterpriseClusterAddonParameters, *errors.ServiceError)
func PresentEnterpriseClusterRegistrationResponse ¶
func PresentEnterpriseClusterRegistrationResponse(cluster api.Cluster, consumedStreamingUnitsInTheCluster int32, kafkaConfig *config.KafkaConfig, fleetShardParams services.ParameterList) (public.EnterpriseClusterRegistrationResponse, *errors.ServiceError)
func PresentKafkaRequest ¶
func PresentKafkaRequest(kafkaRequest *dbapi.KafkaRequest, kafkaConfig *config.KafkaConfig) (public.KafkaRequest, *errors.ServiceError)
PresentKafkaRequest - create KafkaRequest in an appropriate format ready to be returned by the API
func PresentKafkaRequestAdminEndpoint ¶
func PresentKafkaRequestAdminEndpoint(kafkaRequest *dbapi.KafkaRequest, accountService account.AccountService) (*private.Kafka, *errors.ServiceError)
func PresentManagedKafka ¶
func PresentManagedKafka(from *v1.ManagedKafka) private.ManagedKafka
func PresentMetricsByInstantQuery ¶
func PresentMetricsByInstantQuery(metrics *observatorium.KafkaMetrics) ([]public.InstantQuery, *errors.ServiceError)
func PresentMetricsByRangeQuery ¶
func PresentMetricsByRangeQuery(metrics *observatorium.KafkaMetrics) ([]public.RangeQuery, *errors.ServiceError)
func PresentReference ¶
func PresentReference(id, obj interface{}) compat.ObjectReference
func PresentServiceAccount ¶
func PresentServiceAccount(account *api.ServiceAccount) *public.ServiceAccount
func PresentServiceAccountListItem ¶
func PresentServiceAccountListItem(account *api.ServiceAccount) public.ServiceAccountListItem
func PresentSsoProvider ¶
func PresentSsoProvider(provider *api.SsoProvider) public.SsoProvider
func PresentSupportedKafkaInstanceTypes ¶
func PresentSupportedKafkaInstanceTypes(supportedInstanceType *config.KafkaInstanceType) public.SupportedKafkaInstanceType
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.