eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-07-03 11:53:41 +02:00
Code Releases Activity

transport/redis_pubsub/publisher.go: Adding Close() method.

Browse source
This commit is contained in:
Henrik Hautakoski 2023-03-29 11:51:15 +02:00
parent 6a5292da5e
commit 1de6cd9432
1 changed files with 4 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

4
transport/redis_pubsub/publisher.go
View file

@ -31,3 +31,7 @@ func (r *Publisher) Flush() error {
_, err := r.pipeline.Exec(r.ctx) _, err := r.pipeline.Exec(r.ctx)
return err return err
} }
func (r *Publisher) Close() error {
return r.pipeline.Close()
}