|
|
@ -17,6 +17,7 @@ limitations under the License.
|
|
|
|
package driver // import "helm.sh/helm/v3/pkg/storage/driver"
|
|
|
|
package driver // import "helm.sh/helm/v3/pkg/storage/driver"
|
|
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
import (
|
|
|
|
|
|
|
|
"reflect"
|
|
|
|
"testing"
|
|
|
|
"testing"
|
|
|
|
|
|
|
|
|
|
|
|
rspb "helm.sh/helm/v3/pkg/release"
|
|
|
|
rspb "helm.sh/helm/v3/pkg/release"
|
|
|
@ -110,3 +111,96 @@ func TestRecordsRemoveAt(t *testing.T) {
|
|
|
|
t.Fatalf("Expected length of rs to be 1, got %d", len(rs))
|
|
|
|
t.Fatalf("Expected length of rs to be 1, got %d", len(rs))
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func TestRecordsGet(t *testing.T) {
|
|
|
|
|
|
|
|
rs := records([]*record{
|
|
|
|
|
|
|
|
newRecord("rls-a.v1", releaseStub("rls-a", 1, "default", rspb.StatusSuperseded)),
|
|
|
|
|
|
|
|
newRecord("rls-a.v2", releaseStub("rls-a", 2, "default", rspb.StatusDeployed)),
|
|
|
|
|
|
|
|
})
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var tests = []struct {
|
|
|
|
|
|
|
|
desc string
|
|
|
|
|
|
|
|
key string
|
|
|
|
|
|
|
|
rec *record
|
|
|
|
|
|
|
|
}{
|
|
|
|
|
|
|
|
{
|
|
|
|
|
|
|
|
"get valid key",
|
|
|
|
|
|
|
|
"rls-a.v1",
|
|
|
|
|
|
|
|
newRecord("rls-a.v1", releaseStub("rls-a", 1, "default", rspb.StatusSuperseded)),
|
|
|
|
|
|
|
|
},
|
|
|
|
|
|
|
|
{
|
|
|
|
|
|
|
|
"get invalid key",
|
|
|
|
|
|
|
|
"rls-a.v3",
|
|
|
|
|
|
|
|
nil,
|
|
|
|
|
|
|
|
},
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
for _, tt := range tests {
|
|
|
|
|
|
|
|
got := rs.Get(tt.key)
|
|
|
|
|
|
|
|
if !reflect.DeepEqual(tt.rec, got) {
|
|
|
|
|
|
|
|
t.Fatalf("Expected %v, got %v", tt.rec, got)
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func TestRecordsIndex(t *testing.T) {
|
|
|
|
|
|
|
|
rs := records([]*record{
|
|
|
|
|
|
|
|
newRecord("rls-a.v1", releaseStub("rls-a", 1, "default", rspb.StatusSuperseded)),
|
|
|
|
|
|
|
|
newRecord("rls-a.v2", releaseStub("rls-a", 2, "default", rspb.StatusDeployed)),
|
|
|
|
|
|
|
|
})
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var tests = []struct {
|
|
|
|
|
|
|
|
desc string
|
|
|
|
|
|
|
|
key string
|
|
|
|
|
|
|
|
sort int
|
|
|
|
|
|
|
|
}{
|
|
|
|
|
|
|
|
{
|
|
|
|
|
|
|
|
"get valid key",
|
|
|
|
|
|
|
|
"rls-a.v1",
|
|
|
|
|
|
|
|
0,
|
|
|
|
|
|
|
|
},
|
|
|
|
|
|
|
|
{
|
|
|
|
|
|
|
|
"get invalid key",
|
|
|
|
|
|
|
|
"rls-a.v3",
|
|
|
|
|
|
|
|
-1,
|
|
|
|
|
|
|
|
},
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
for _, tt := range tests {
|
|
|
|
|
|
|
|
got, _ := rs.Index(tt.key)
|
|
|
|
|
|
|
|
if got != tt.sort {
|
|
|
|
|
|
|
|
t.Fatalf("Expected %d, got %d", tt.sort, got)
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func TestRecordsExists(t *testing.T) {
|
|
|
|
|
|
|
|
rs := records([]*record{
|
|
|
|
|
|
|
|
newRecord("rls-a.v1", releaseStub("rls-a", 1, "default", rspb.StatusSuperseded)),
|
|
|
|
|
|
|
|
newRecord("rls-a.v2", releaseStub("rls-a", 2, "default", rspb.StatusDeployed)),
|
|
|
|
|
|
|
|
})
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var tests = []struct {
|
|
|
|
|
|
|
|
desc string
|
|
|
|
|
|
|
|
key string
|
|
|
|
|
|
|
|
ok bool
|
|
|
|
|
|
|
|
}{
|
|
|
|
|
|
|
|
{
|
|
|
|
|
|
|
|
"get valid key",
|
|
|
|
|
|
|
|
"rls-a.v1",
|
|
|
|
|
|
|
|
true,
|
|
|
|
|
|
|
|
},
|
|
|
|
|
|
|
|
{
|
|
|
|
|
|
|
|
"get invalid key",
|
|
|
|
|
|
|
|
"rls-a.v3",
|
|
|
|
|
|
|
|
false,
|
|
|
|
|
|
|
|
},
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
for _, tt := range tests {
|
|
|
|
|
|
|
|
got := rs.Exists(tt.key)
|
|
|
|
|
|
|
|
if got != tt.ok {
|
|
|
|
|
|
|
|
t.Fatalf("Expected %t, got %t", tt.ok, got)
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|