Skip to content

Commit

Permalink
Merge remote-tracking branch 'origin/main' into feat/pex-support-pare…
Browse files Browse the repository at this point in the history
…nt-task
  • Loading branch information
jim3ma committed May 15, 2024
2 parents db68e16 + 1d96401 commit 0932c6e
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 8 deletions.
5 changes: 3 additions & 2 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,7 @@ require (
github.com/hashicorp/memberlist v0.5.0
github.com/huaweicloud/huaweicloud-sdk-go-obs v3.23.12+incompatible
github.com/jarcoal/httpmock v1.3.1
github.com/jellydator/ttlcache/v3 v3.2.0
github.com/johanbrandhorst/certify v1.9.0
github.com/juju/ratelimit v1.0.2
github.com/looplab/fsm v1.0.1
Expand Down Expand Up @@ -170,14 +171,14 @@ require (
github.com/inconshreveable/mousetrap v1.1.0 // indirect
github.com/jackc/pgpassfile v1.0.0 // indirect
github.com/jackc/pgservicefile v0.0.0-20221227161230-091c0ba34f0a // indirect
github.com/jackc/pgx/v5 v5.4.3 // indirect
github.com/jackc/pgx/v5 v5.5.4 // indirect
github.com/jackc/puddle/v2 v2.2.1 // indirect
github.com/jcmturner/aescts/v2 v2.0.0 // indirect
github.com/jcmturner/dnsutils/v2 v2.0.0 // indirect
github.com/jcmturner/gofork v1.0.0 // indirect
github.com/jcmturner/goidentity/v6 v6.0.1 // indirect
github.com/jcmturner/gokrb5/v8 v8.4.2 // indirect
github.com/jcmturner/rpc/v2 v2.0.3 // indirect
github.com/jellydator/ttlcache/v3 v3.2.0 // indirect
github.com/jinzhu/inflection v1.0.0 // indirect
github.com/jinzhu/now v1.1.5 // indirect
github.com/jmespath/go-jmespath v0.4.0 // indirect
Expand Down
6 changes: 4 additions & 2 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -867,11 +867,13 @@ github.com/jackc/pgx/v4 v4.0.0-20190421002000-1b8f0016e912/go.mod h1:no/Y67Jkk/9
github.com/jackc/pgx/v4 v4.0.0-pre1.0.20190824185557-6972a5742186/go.mod h1:X+GQnOEnf1dqHGpw7JmHqHc1NxDoalibchSk9/RWuDc=
github.com/jackc/pgx/v4 v4.12.1-0.20210724153913-640aa07df17c/go.mod h1:1QD0+tgSXP7iUjYm9C1NxKhny7lq6ee99u/z+IHFcgs=
github.com/jackc/pgx/v4 v4.13.0/go.mod h1:9P4X524sErlaxj0XSGZk7s+LD0eOyu1ZDUrrpznYDF0=
github.com/jackc/pgx/v5 v5.4.3 h1:cxFyXhxlvAifxnkKKdlxv8XqUf59tDlYjnV5YYfsJJY=
github.com/jackc/pgx/v5 v5.4.3/go.mod h1:Ig06C2Vu0t5qXC60W8sqIthScaEnFvojjj9dSljmHRA=
github.com/jackc/pgx/v5 v5.5.4 h1:Xp2aQS8uXButQdnCMWNmvx6UysWQQC+u1EoizjguY+8=
github.com/jackc/pgx/v5 v5.5.4/go.mod h1:ez9gk+OAat140fv9ErkZDYFWmXLfV+++K0uAOiwgm1A=
github.com/jackc/puddle v0.0.0-20190413234325-e4ced69a3a2b/go.mod h1:m4B5Dj62Y0fbyuIc15OsIqK0+JU8nkqQjsgx7dvjSWk=
github.com/jackc/puddle v0.0.0-20190608224051-11cab39313c9/go.mod h1:m4B5Dj62Y0fbyuIc15OsIqK0+JU8nkqQjsgx7dvjSWk=
github.com/jackc/puddle v1.1.3/go.mod h1:m4B5Dj62Y0fbyuIc15OsIqK0+JU8nkqQjsgx7dvjSWk=
github.com/jackc/puddle/v2 v2.2.1 h1:RhxXJtFG022u4ibrCSMSiu5aOq1i77R3OHKNJj77OAk=
github.com/jackc/puddle/v2 v2.2.1/go.mod h1:vriiEXHvEE654aYKXXjOvZM39qJ0q+azkZFrfEOc3H4=
github.com/jarcoal/httpmock v1.3.1 h1:iUx3whfZWVf3jT01hQTO/Eo5sAYtB2/rqaUuOtpInww=
github.com/jarcoal/httpmock v1.3.1/go.mod h1:3yb8rc4BI7TCBhFY8ng0gjuLKJNquuDNiPaZjnENuYg=
github.com/jcmturner/aescts/v2 v2.0.0 h1:9YKLH6ey7H4eDBXW8khjYslgyqG2xZikXP0EQFKrle8=
Expand Down
8 changes: 4 additions & 4 deletions scheduler/config/dynconfig.go
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@ type DynconfigInterface interface {
// GetSeedPeers returns the dynamic seed peers config from manager.
GetSeedPeers() ([]*managerv2.SeedPeer, error)

// GetSchedulerCluster returns the the scheduler cluster config from manager.
// GetSchedulerCluster returns the scheduler cluster config from manager.
GetSchedulerCluster() (*managerv2.SchedulerCluster, error)

// GetSchedulerClusterConfig returns the scheduler cluster config.
Expand Down Expand Up @@ -162,7 +162,7 @@ func NewDynconfig(rawManagerClient managerclient.V2, cacheDir string, cfg *Confi
return d, nil
}

// GetResolveSeedPeerAddrs returns the the schedulers resolve addrs.
// GetResolveSeedPeerAddrs returns the schedulers resolve addrs.
func (d *dynconfig) GetResolveSeedPeerAddrs() ([]resolver.Address, error) {
seedPeers, err := d.GetSeedPeers()
if err != nil {
Expand Down Expand Up @@ -257,7 +257,7 @@ func (d *dynconfig) GetApplications() ([]*managerv2.Application, error) {
return data.Applications, nil
}

// GetSeedPeers returns the the seed peers config from manager.
// GetSeedPeers returns the seed peers config from manager.
func (d *dynconfig) GetSeedPeers() ([]*managerv2.SeedPeer, error) {
scheduler, err := d.GetScheduler()
if err != nil {
Expand All @@ -271,7 +271,7 @@ func (d *dynconfig) GetSeedPeers() ([]*managerv2.SeedPeer, error) {
return scheduler.SeedPeers, nil
}

// GetSchedulerCluster returns the the scheduler cluster config from manager.
// GetSchedulerCluster returns the scheduler cluster config from manager.
func (d *dynconfig) GetSchedulerCluster() (*managerv2.SchedulerCluster, error) {
scheduler, err := d.GetScheduler()
if err != nil {
Expand Down

0 comments on commit 0932c6e

Please sign in to comment.