1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
package clusterkcp
import (
"context"
"errors"
"time"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"github.com/johnandersen777/socialweb-computer-kcp/api/v1alpha1"
"github.com/johnandersen777/socialweb-computer-kcp/internal/clusterprovider"
"github.com/johnandersen777/socialweb-computer-kcp/internal/controllers/runtime/kube"
)
type Objects[T any] struct {
r kube.Resource
}
var (
_ clusterprovider.Objects[v1alpha1.HostProcess] = Objects[v1alpha1.HostProcess]{}
_ clusterprovider.Objects[v1alpha1.Postgres] = Objects[v1alpha1.Postgres]{}
_ clusterprovider.Objects[v1alpha1.OpenBaoServer] = Objects[v1alpha1.OpenBaoServer]{}
)
func NewObjects[T any](r kube.Resource) Objects[T] { return Objects[T]{r: r} }
func (o Objects[T]) Get(ctx context.Context, name string) (*T, error) {
return kube.Get[T](ctx, o.r, name)
}
func (o Objects[T]) List(ctx context.Context, labelSelector string) ([]T, error) {
return kube.List[T](ctx, o.r, metav1.ListOptions{LabelSelector: labelSelector})
}
func (o Objects[T]) Create(ctx context.Context, obj *T) error {
_, err := kube.Create[T](ctx, o.r, obj, metav1.CreateOptions{})
return err
}
func (o Objects[T]) Update(ctx context.Context, obj *T) error {
_, err := kube.Update[T](ctx, o.r, obj, metav1.UpdateOptions{})
return err
}
func (o Objects[T]) Delete(ctx context.Context, name string) error {
return o.r.Delete(ctx, name, metav1.DeleteOptions{})
}
func (o Objects[T]) Await(ctx context.Context, name string, timeout time.Duration, done func(obj *T) (bool, error)) (*T, error) {
last, err := kube.Await[T](ctx, o.r, name, timeout, done)
return last, translate(err)
}
func (o Objects[T]) AwaitSelected(ctx context.Context, labelSelector string, timeout time.Duration, done func(objs []T) (bool, error)) error {
return translate(kube.AwaitSelected[T](ctx, o.r, labelSelector, timeout, done))
}
type awaitTimeout struct{ err error }
func (e awaitTimeout) Error() string { return e.err.Error() }
func (e awaitTimeout) Unwrap() []error { return []error{e.err, clusterprovider.ErrAwaitTimeout} }
func translate(err error) error {
if err != nil && errors.Is(err, kube.ErrAwaitTimeout) {
return awaitTimeout{err: err}
}
return err
}
