Skip to content

Commit

Permalink
Update responsebody
Browse files Browse the repository at this point in the history
Signed-off-by: obaydullahmhs <[email protected]>
  • Loading branch information
obaydullahmhs committed Jul 30, 2024
1 parent abeb011 commit ba04974
Show file tree
Hide file tree
Showing 5 changed files with 30 additions and 11 deletions.
3 changes: 1 addition & 2 deletions kafka/restproxy/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -39,8 +39,7 @@ type Response struct {
}

type ResponseBody struct {
Status string `json:"status"`
Brokers []int `json:"checks"`
Brokers []int `json:"brokers"`
}

type Config struct {
Expand Down
30 changes: 25 additions & 5 deletions vendor/kubedb.dev/apimachinery/apis/kafka/v1alpha1/constants.go
Original file line number Diff line number Diff line change
Expand Up @@ -115,9 +115,29 @@ const (
// RestProxy constants

const (
RestProxyPrimaryPortName = "primary"
RestProxyPortName = "restproxy"
RestProxyRESTPort = 8082
RestProxyContainerName = "rest-proxy"
RestProxyConfigFileName = "karapace.config.json"
RestProxyPrimaryPortName = "primary"
RestProxyPortName = "restproxy"
RestProxyRESTPort = 8082
RestProxyContainerName = "rest-proxy"
RestProxyOperatorVolumeConfig = "rest-proxy-operator-config"
RestProxyOperatorConfigPath = "/opt/karapace/config"

RestProxyKarapaceLogLevel = "log_level"
RestProxyKarapaceLogLevelWarning = "WARNING"
RestProxyKarapaceLogLevelInfo = "INFO"
RestProxyKarapaceLogLevelDebug = "DEBUG"
RestProxyKarapaceHostName = "host"
RestProxyKarapacePortName = "port"
RestProxyKafkaBootstrapURI = "bootstrap_uri"
RestProxyKafkaSecurityProtocolName = "security_protocol"
RestProxyKafkaSASLMechanismName = "sasl_mechanism"
RestProxyKafkaSASLUsername = "sasl_plain_username"
RestProxyKafkaSASLPassword = "sasl_plain_password"
RestProxyKafkaSSLCAFile = "ssl_cafile"
RestProxyKafkaSSLCertFile = "ssl_certfile"
RestProxyKafkaSSLKeyFile = "ssl_keyfile"
RestProxyKafkaSSLCAFilePath = "/var/private/kafka-client-ssl/ca.crt"
RestProxyKafkaSSLCertFilePath = "/var/private/kafka-client-ssl/tls.crt"
RestProxyKafkaSSLKeyFilePath = "/var/private/kafka-client-ssl/tls.key"
RestProxyConfigFileName = "rest.config.json"
)
Original file line number Diff line number Diff line change
Expand Up @@ -58,10 +58,10 @@ func addKnownTypes(scheme *runtime.Scheme) error {
&ConnectClusterList{},
&Connector{},
&ConnectorList{},
&SchemaRegistry{},
&SchemaRegistryList{},
&RestProxy{},
&RestProxyList{},
&SchemaRegistry{},
&SchemaRegistryList{},
)

scheme.AddKnownTypes(SchemeGroupVersion,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ const (

// +kubebuilder:object:root=true
// +kubebuilder:subresource:status
// +kubebuilder:resource:shortName=ksr,scope=Namespaced
// +kubebuilder:resource:shortName=krp,scope=Namespaced
// +kubebuilder:printcolumn:name="Type",type="string",JSONPath=".apiVersion"
// +kubebuilder:printcolumn:name="Version",type="string",JSONPath=".spec.version"
// +kubebuilder:printcolumn:name="Kafka",type="string",JSONPath=".spec.kafkaRef.name"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ spec:
listKind: RestProxyList
plural: restproxies
shortNames:
- ksr
- krp
singular: restproxy
scope: Namespaced
versions:
Expand Down

0 comments on commit ba04974

Please sign in to comment.