utils

Documentation

Index

• Constants
• func BuildControlAPIClient(offlineToken string, clientID string, authURL string, apiURL string) *kafkamgmtclient.APIClient
• func BuildDataAPIClient(offlineToken string, clientID string, authURL string, apiURL string) *kafkainstanceclient.APIClient
• func ContainsString(slice []string, s string) bool
• func ConvertToKafkaInstance(kafkaRequest kafkamgmtclient.KafkaRequest, namespace string, ...)
• func ConvertToKafkaInstanceSpec(kafkaRequest kafkamgmtclient.KafkaRequest, ...)
• func ConvertToKafkaInstanceStatus(kafkaRequest kafkamgmtclient.KafkaRequest, ...)
• func EncodeKubernetesName(name string, length int) string
• func GetAPIError(err error) *kafkamgmtclient.Error
• func IsErr(err error, code ServiceErrorCode) bool
• func LoadOfflineToken(c client.Client, ctx context.Context, req ctrl.Request) (string, error)
• func RemoveString(slice []string, s string) (result []string)
• func UpdateKafkaInstanceStatus(c client.Client, ctx context.Context, ...) error
• type Error
  • func (e *Error) Error() string
  • func (e *Error) Unwrap() error
• type ServiceErrorCode

Constants

const (
	DefaultAuthURL  = "https://sso.redhat.com/auth/realms/redhat-external"
	DefaultAPIURL   = "https://api.openshift.com"
	DefaultClientID = "cloud-services"
	// gap between API polls
	WatchInterval = 5 * time.Second
)

const (
	// ErrorCode7 Resource not found
	ErrorCode7 = "KAFKAS-MGMT-7"
	// ErrorCode24 The maximum number of allowed kafka instances has been reached
	ErrorCode24 = "KAFKAS-MGMT-24"
	// ErrorCode21 Bad Request
	ErrorCode21 = "KAFKAS-MGMT-21"
	// ErrorCode36 Kafka cluster name is already used
	ErrorCode36 = "KAFKAS-MGMT-36"
)

Functions

func BuildControlAPIClient

func BuildControlAPIClient(offlineToken string, clientID string, authURL string, apiURL string) *kafkamgmtclient.APIClient

func BuildDataAPIClient

func BuildDataAPIClient(offlineToken string, clientID string, authURL string, apiURL string) *kafkainstanceclient.APIClient

func ContainsString

func ContainsString(slice []string, s string) bool

Helper functions to check and remove string from a slice of strings.

func ConvertToKafkaInstance

func ConvertToKafkaInstance(kafkaRequest kafkamgmtclient.KafkaRequest, namespace string, kafkaInstance *rhosakkcpv1.KafkaInstance)

func ConvertToKafkaInstanceSpec

func ConvertToKafkaInstanceSpec(kafkaRequest kafkamgmtclient.KafkaRequest, kafkaInstance *rhosakkcpv1.KafkaInstance)

func ConvertToKafkaInstanceStatus

func ConvertToKafkaInstanceStatus(kafkaRequest kafkamgmtclient.KafkaRequest, kafkaInstance *rhosakkcpv1.KafkaInstance)

func EncodeKubernetesName

func EncodeKubernetesName(name string, length int) string

func GetAPIError

func GetAPIError(err error) *kafkamgmtclient.Error

GetAPIError gets a strongly typed error from an error

func IsErr

func IsErr(err error, code ServiceErrorCode) bool

IsErr returns true if the error contains the errCode

func LoadOfflineToken

func LoadOfflineToken(c client.Client, ctx context.Context, req ctrl.Request) (string, error)

func RemoveString

func RemoveString(slice []string, s string) (result []string)

func UpdateKafkaInstanceStatus

func UpdateKafkaInstanceStatus(c client.Client, ctx context.Context, kafkaRequest kafkamgmtclient.KafkaRequest, kafkaInstance *rhosakkcpv1.KafkaInstance) error

Types

type Error

type Error struct {
	Err error
}

func (*Error) Error

func (e *Error) Error() string

func (*Error) Unwrap

func (e *Error) Unwrap() error

type ServiceErrorCode

type ServiceErrorCode string