-
Notifications
You must be signed in to change notification settings - Fork 32
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
✨ Add transport secret for global hub manager and agent #1054
Conversation
Signed-off-by: myan <[email protected]>
Signed-off-by: myan <[email protected]>
Signed-off-by: myan <[email protected]>
Signed-off-by: myan <[email protected]>
/retest |
/retest |
Signed-off-by: myan <[email protected]>
@@ -4,10 +4,18 @@ kind: Secret | |||
metadata: | |||
name: kafka-certs-secret |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
rename to kafka-config
or something like. it is not only for certs anymore
annotations: | ||
transport-type: {{.TransportType}} | ||
client-cert-secret: {{.KafkaClientCertSecret}} | ||
cluster-ca-secret: kafka-cluster-ca-cert |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
should not hardcode cluster
here. it is kafkacluster CR name. maybe pass as a parameter is better.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Done.
type: Opaque | ||
data: | ||
"bootstrap_server": {{.KafkaBootstrapServers}} | ||
"status_topic": {{.KafkaStatusTopic}} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
can we have a same format? maybe bootstrap.server
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Done.
pkg/constants/constants.go
Outdated
@@ -63,6 +63,12 @@ const ( | |||
PostgresCAConfigMap = "multicluster-global-hub-postgres-ca" | |||
) | |||
|
|||
// the global hub transport secret for manager and agent | |||
const ( | |||
GHManagerTransportSecret = "multicluster-global-hub-manager-transport" // #nosec G101 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
maybe use kakfa-config
as secret name for both manager and agent.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
When the global hub agent supports standalone mode, the agent might send messages to different targets. So kafka is just an option, it might be a webhook credential.
Signed-off-by: myan <[email protected]>
Signed-off-by: myan <[email protected]>
Signed-off-by: myan <[email protected]>
Signed-off-by: myan <[email protected]>
Signed-off-by: myan <[email protected]>
Signed-off-by: myan <[email protected]>
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Signed-off-by: myan <[email protected]>
Quality Gate passedIssues Measures |
/lgtm |
[APPROVALNOTIFIER] This PR is APPROVED This pull-request has been approved by: clyang82, ldpliu, yanmxa The full list of commands accepted by this bot can be found here. The pull request process is described here
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
Summary
The transport-config secret for both the manager and agent will look like this:
kafka.yaml
for manager:kafka.yaml
for the AgentRelated issue(s)
Fixes # https://issues.redhat.com/browse/ACM-13019