Skip to content
This repository has been archived by the owner on Sep 2, 2024. It is now read-only.

Commit

Permalink
[release-0.22] [Consolidated] Rewrote the dispatcher reconciler (#518)
Browse files Browse the repository at this point in the history
* Fix #245

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* Removed finalize kind

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* gofmt

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* Added a UT

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* WIP

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* Rewrote the dispatcher reconciler

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* Fix err not nil

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* Happy linter

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* Now it should work

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* This should fix it

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* UT fix

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* Fixed little mistake

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* Fixed another little mistake

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* Better code

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* Reverted e2e-common.sh

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* Bad comment

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* Simpler name

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

* Typo

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>

Co-authored-by: slinkydeveloper <francescoguard@gmail.com>
  • Loading branch information
knative-prow-robot and slinkydeveloper authored Apr 8, 2021
1 parent 2e59cf5 commit 314cc47
Show file tree
Hide file tree
Showing 8 changed files with 507 additions and 441 deletions.
13 changes: 8 additions & 5 deletions pkg/channel/consolidated/dispatcher/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,14 +16,17 @@ limitations under the License.

package dispatcher

type Config struct {
// The configuration of each channel in this handler.
ChannelConfigs []ChannelConfig
}

type ChannelConfig struct {
Namespace string
Name string
HostName string
Subscriptions []Subscription
}

func (cc ChannelConfig) SubscriptionsUIDs() []string {
res := make([]string, 0, len(cc.Subscriptions))
for _, s := range cc.Subscriptions {
res = append(res, string(s.UID))
}
return res
}
Loading

0 comments on commit 314cc47

Please sign in to comment.