Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cloudbase/garm
/ Notify
Method
Notify
database/common/watcher.go:62–62 ·
view source on GitHub ↗
(ChangePayload)
Source
from the content-addressed store, hash-verified
60
61
type
Producer
interface
{
62
Notify(ChangePayload) error
63
IsClosed() bool
64
Close()
65
}
Callers
15
sendNotify
Method · 0.65
TestProducerAndConsumer
Method · 0.65
TestConsumeWithFilter
Method · 0.65
TestWithAnyFilter
Method · 0.65
TestWithAllFilter
Method · 0.65
TestWithEntityPoolFilterRepository
Method · 0.65
TestWithEntityPoolFilterOrg
Method · 0.65
TestWithEntityPoolFilterEnterprise
Method · 0.65
TestWithEntityPoolFilterBogusEntityType
Method · 0.65
TestWithEntityScaleSetFilterRepository
Method · 0.65
TestWithEntityScaleSetFilterOrg
Method · 0.65
TestWithEntityScaleSetFilterEnterprise
Method · 0.65
Implementers
2
producer
database/watcher/producer.go
MockProducer
internal/testing/mock_watcher.go
Calls
no outgoing calls
Tested by
15
TestProducerAndConsumer
Method · 0.52
TestConsumeWithFilter
Method · 0.52
TestWithAnyFilter
Method · 0.52
TestWithAllFilter
Method · 0.52
TestWithEntityPoolFilterRepository
Method · 0.52
TestWithEntityPoolFilterOrg
Method · 0.52
TestWithEntityPoolFilterEnterprise
Method · 0.52
TestWithEntityPoolFilterBogusEntityType
Method · 0.52
TestWithEntityScaleSetFilterRepository
Method · 0.52
TestWithEntityScaleSetFilterOrg
Method · 0.52
TestWithEntityScaleSetFilterEnterprise
Method · 0.52
TestWithEntityScaleSetFilterBogusEntityType
Method · 0.52