mirror of
https://github.com/jwetzell/showbridge-go.git
synced 2026-09-06 21:58:59 +00:00
add missing test module
This commit is contained in:
@@ -111,3 +111,32 @@ func (m *TestDBModule) Type() string {
|
|||||||
func (m *TestDBModule) Id() string {
|
func (m *TestDBModule) Id() string {
|
||||||
return m.id
|
return m.id
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func NewTestPubSubModule(id string) *TestPubSubModule {
|
||||||
|
return &TestPubSubModule{
|
||||||
|
id: id,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
type TestPubSubModule struct {
|
||||||
|
id string
|
||||||
|
}
|
||||||
|
|
||||||
|
func (m *TestPubSubModule) Start(ctx context.Context, router common.RouteIO) error {
|
||||||
|
<-ctx.Done()
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (m *TestPubSubModule) Publish(ctx context.Context, topic string, payload any) error {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (m *TestPubSubModule) Stop() {}
|
||||||
|
|
||||||
|
func (m *TestPubSubModule) Type() string {
|
||||||
|
return "test.pubsub"
|
||||||
|
}
|
||||||
|
|
||||||
|
func (m *TestPubSubModule) Id() string {
|
||||||
|
return m.id
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user