Skip to content

【Abondoned for commit too large】:decoupling apiserver and clustersynchro-manager by message midd…#1

Open
zhouhaoA1 wants to merge 1 commit intokosmos-io:mainfrom
zhouhaoA1:dev_messagequeue
Open

【Abondoned for commit too large】:decoupling apiserver and clustersynchro-manager by message midd…#1
zhouhaoA1 wants to merge 1 commit intokosmos-io:mainfrom
zhouhaoA1:dev_messagequeue

Conversation

@zhouhaoA1
Copy link
Copy Markdown
Collaborator

…leware

What type of PR is this?
/kind feature

What this PR does / why we need it:
decoupling apiserver and clustersynchro-manager by message middware

Which issue(s) this PR fixes:
Fixes #

Special notes for your reviewer:

Does this PR introduce a user-facing change?:


KubeStateMetrics *kubestatemetrics.Options

WorkerNumber int // WorkerNumber is the number of worker goroutines
Publisher *watchoptions.MiddlerwareOptions
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

middleware to messagequeue?

Copy link
Copy Markdown
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

middleware better

fs := fss.FlagSet("misc")
fs.StringVar(&o.Master, "master", o.Master, "The address of the Kubernetes API server (overrides any value in kubeconfig).")
fs.StringVar(&o.Kubeconfig, "kubeconfig", o.Kubeconfig, "Path to kubeconfig file with authorization and master location information.")
fs.StringVar(&o.Kubeconfig, "manager-kubeconfig", o.Kubeconfig, "Path to kubeconfig file with authorization and master location information.")
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

why do you modify the current kueconfig key

Copy link
Copy Markdown
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

ok, i will fix it.

"strings"
)

func GetShardingTable(gvr schema.GroupVersionResource) string {
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

What does GetShardingTable work for

@wuyingjun-lucky
Copy link
Copy Markdown
Member

please run make lint on your local Desktop

@zhouhaoA1 zhouhaoA1 force-pushed the dev_messagequeue branch 16 times, most recently from 1eb08d9 to 4177173 Compare October 30, 2023 06:57
@zhouhaoA1 zhouhaoA1 force-pushed the dev_messagequeue branch 2 times, most recently from 7eebc7d to 21084f6 Compare October 31, 2023 06:48
…leware

Signed-off-by: zhouhaoA1 <zhouhao_yewu@cmss.chinamobile.com>
@zhouhaoA1 zhouhaoA1 changed the title decoupling apiserver and clustersynchro-manager by message midd… 【Abondoned for commit too large】:decoupling apiserver and clustersynchro-manager by message midd… Nov 9, 2023
@zhouhaoA1 zhouhaoA1 force-pushed the main branch 2 times, most recently from d799fb3 to bf2a5d5 Compare December 27, 2023 01:03
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants