scottk/kubernetes
1
0
Fork 0
mirror of https://github.com/optim-enterprises-bv/kubernetes.git synced 2025-11-03 19:58:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: update conversion helpers

Browse Source 
Signed-off-by: Jian Zeng <anonymousknight96@gmail.com>
This commit is contained in:
Jian Zeng
2024-09-11 21:42:32 +08:00
parent 82c6296a95
commit 7660ce9a7e
2 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
pkg/apis/core/v1/conversion.go
View File

@@ -554,3 +554,13 @@ func Convert_core_PersistentVolumeSpec_To_v1_PersistentVolumeSpec(in *core.Persi
func Convert_v1_PersistentVolumeSpec_To_core_PersistentVolumeSpec(in *v1.PersistentVolumeSpec, out *core.PersistentVolumeSpec, s conversion.Scope) error { func Convert_v1_PersistentVolumeSpec_To_core_PersistentVolumeSpec(in *v1.PersistentVolumeSpec, out *core.PersistentVolumeSpec, s conversion.Scope) error {
return autoConvert_v1_PersistentVolumeSpec_To_core_PersistentVolumeSpec(in, out, s) return autoConvert_v1_PersistentVolumeSpec_To_core_PersistentVolumeSpec(in, out, s)
} }
// Convert_Slice_string_To_Pointer_v1_LogStreamType is needed because decoding URL parameters requires manual assistance.
func Convert_Slice_string_To_Pointer_v1_LogStreamType(in *[]string, out **v1.LogStreamType, s conversion.Scope) error {
if len(*in) == 0 {
return nil
}
temp := v1.LogStreamType((*in)[0])
*out = &temp
return nil
}

5
pkg/apis/core/v1/conversion_test.go
View File

@@ -52,6 +52,8 @@ func TestPodLogOptions(t *testing.T) {
sinceTime := metav1.NewTime(time.Date(2000, 1, 1, 12, 34, 56, 0, time.UTC).Local()) sinceTime := metav1.NewTime(time.Date(2000, 1, 1, 12, 34, 56, 0, time.UTC).Local())
tailLines := int64(2) tailLines := int64(2)
limitBytes := int64(3) limitBytes := int64(3)
v1StreamStderr := v1.LogStreamTypeStderr
coreStreamStderr := core.LogStreamTypeStderr
versionedLogOptions := &v1.PodLogOptions{ versionedLogOptions := &v1.PodLogOptions{
Container: "mycontainer", Container: "mycontainer",
@@ -62,6 +64,7 @@ func TestPodLogOptions(t *testing.T) {
Timestamps: true, Timestamps: true,
TailLines: &tailLines, TailLines: &tailLines,
LimitBytes: &limitBytes, LimitBytes: &limitBytes,
Stream: &v1StreamStderr,
} }
unversionedLogOptions := &core.PodLogOptions{ unversionedLogOptions := &core.PodLogOptions{
Container: "mycontainer", Container: "mycontainer",
@@ -72,6 +75,7 @@ func TestPodLogOptions(t *testing.T) {
Timestamps: true, Timestamps: true,
TailLines: &tailLines, TailLines: &tailLines,
LimitBytes: &limitBytes, LimitBytes: &limitBytes,
Stream: &coreStreamStderr,
} }
expectedParameters := url.Values{ expectedParameters := url.Values{
"container": {"mycontainer"}, "container": {"mycontainer"},
@@ -82,6 +86,7 @@ func TestPodLogOptions(t *testing.T) {
"timestamps": {"true"}, "timestamps": {"true"},
"tailLines": {"2"}, "tailLines": {"2"},
"limitBytes": {"3"}, "limitBytes": {"3"},
"stream": {"Stderr"},
} }
codec := runtime.NewParameterCodec(legacyscheme.Scheme) codec := runtime.NewParameterCodec(legacyscheme.Scheme)