mirror of
https://github.com/sablierapp/sablier.git
synced 2025-12-21 21:33:06 +01:00
edbf7d9d15
* test(kubernetes): use testcontainers for test
* fix(kubernetes): get state properly reports the workload as down when scaled to 0
* refactor(kubernetes): split provider in multiple files
* refactor(provider): use Instance prefix for actions
* test(testcontainers): use provider.PullImage
* squash
* Revert "test(testcontainers): use provider.PullImage"
This reverts commit 6f958c48a5.
* test: add random generator thread safety
11 lines
279 B
Go
11 lines
279 B
Go
package kubernetes
|
|
|
|
import "context"
|
|
|
|
func (p *KubernetesProvider) NotifyInstanceStopped(ctx context.Context, instance chan<- string) {
|
|
informer := p.watchDeployents(instance)
|
|
go informer.Run(ctx.Done())
|
|
informer = p.watchStatefulSets(instance)
|
|
go informer.Run(ctx.Done())
|
|
}
|