mirror of
https://github.com/jwetzell/showbridge-go.git
synced 2026-04-26 21:05:30 +00:00
remove Output function from non-output modules
This commit is contained in:
@@ -66,10 +66,6 @@ func (t *DbSqlite) Start(ctx context.Context) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (t *DbSqlite) Output(ctx context.Context, payload any) error {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (t *DbSqlite) Stop() {
|
func (t *DbSqlite) Stop() {
|
||||||
if t.db != nil {
|
if t.db != nil {
|
||||||
t.db.Close()
|
t.db.Close()
|
||||||
|
|||||||
@@ -79,11 +79,6 @@ func (rc *RedisClient) Start(ctx context.Context) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (rc *RedisClient) Output(ctx context.Context, payload any) error {
|
|
||||||
|
|
||||||
return errors.ErrUnsupported
|
|
||||||
}
|
|
||||||
|
|
||||||
func (rc *RedisClient) Stop() {
|
func (rc *RedisClient) Stop() {
|
||||||
rc.cancel()
|
rc.cancel()
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user