MCPcopy
hub / github.com/flyteorg/flyte / TestInMemoryStore_Head

Function TestInMemoryStore_Head

flytestdlib/storage/mem_store_test.go:11–30  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

9)
10
11func TestInMemoryStore_Head(t *testing.T) {
12 t.Run("Empty store", func(t *testing.T) {
13 s, err := NewInMemoryRawStore(context.TODO(), &Config{}, metrics)
14 assert.NoError(t, err)
15 metadata, err := s.Head(context.TODO(), DataReference("hello"))
16 assert.NoError(t, err)
17 assert.False(t, metadata.Exists())
18 })
19
20 t.Run("Existing Item", func(t *testing.T) {
21 s, err := NewInMemoryRawStore(context.TODO(), &Config{}, metrics)
22 assert.NoError(t, err)
23 err = s.WriteRaw(context.TODO(), DataReference("hello"), 0, Options{}, bytes.NewReader([]byte{}))
24 assert.NoError(t, err)
25
26 metadata, err := s.Head(context.TODO(), DataReference("hello"))
27 assert.NoError(t, err)
28 assert.True(t, metadata.Exists())
29 })
30}
31
32func TestInMemoryStore_ReadRaw(t *testing.T) {
33 t.Run("Empty store", func(t *testing.T) {

Callers

nothing calls this directly

Calls 6

NewInMemoryRawStoreFunction · 0.85
DataReferenceTypeAlias · 0.85
HeadMethod · 0.65
ExistsMethod · 0.65
WriteRawMethod · 0.65
RunMethod · 0.45

Tested by

no test coverage detected