Skip to content

Commit

Permalink
Dev/john/9370 move to message bus event triggered merklelog sealing (…
Browse files Browse the repository at this point in the history
…#131)

* Switch to message bus to gather tenants

The technique of polling the blob store is inefficient and hugely
expensive in Azure costs.

Listen to the confirmation messsage bus instead and watch for committed
events and confirm those tenants.

re AB#9370
re AB#9378

---------

Co-authored-by: John Hartley <[email protected]>
Co-authored-by: Henry Jewell <[email protected]>
Co-authored-by: jgough <[email protected]>
Co-authored-by: John Hartley <[email protected]>
  • Loading branch information
5 people authored Apr 17, 2024
1 parent d98c75f commit 41beada
Showing 1 changed file with 7 additions and 2 deletions.
9 changes: 7 additions & 2 deletions mmrtesting/testcontext.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ func NewTestContext(t *testing.T, cfg TestConfig) TestContext {
}
logLevel := cfg.DebugLevel
if logLevel == "" {
logLevel = "INFO"
logLevel = "NOOP"
}
logger.New(logLevel)
c.Log = logger.Sugar.WithServiceName(cfg.TestLabelPrefix)
Expand Down Expand Up @@ -98,7 +98,12 @@ func (c *TestContext) DeleteBlobsByPrefix(blobPrefixPath string) {
for _, i := range r.Items {
blobs = append(blobs, *i.Name)
}
if len(r.Items) == 0 || r.Marker == nil {
if len(r.Items) == 0 {
break
}

// check for an empty marker as well as a nil marker
if r.Marker == nil || *r.Marker == "" {
break
}
marker = r.Marker
Expand Down

0 comments on commit 41beada

Please sign in to comment.