aljaz/crawler_v2
1
0
Fork 0
mirror of https://github.com/aljazceru/crawler_v2.git synced 2025-12-17 07:24:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

changed shutdown messages

Browse Source
This commit is contained in:
pippellia-btc
2025-09-14 12:51:45 +02:00
parent 48c59c8bff
commit ba6e9eeb33
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/pipe/arbiter.go
View File

@@ -60,7 +60,7 @@ func Arbiter(ctx context.Context, config ArbiterConfig, db redb.RedisDB, send fu
for { for {
select { select {
case <-ctx.Done(): case <-ctx.Done():
log.Println("Arbiter: shutting down...") log.Println("Arbiter: shut down")
return return
case <-ticker.C: case <-ticker.C:

2
pkg/pipe/engine.go
View File

@@ -52,7 +52,7 @@ func Engine(
defer close(graphEvents) defer close(graphEvents)
log.Println("Engine: ready to process events") log.Println("Engine: ready to process events")
defer log.Println("Engine: shutting down...") defer log.Println("Engine: shut down")
go GraphBuilder(ctx, config, db, graphEvents) go GraphBuilder(ctx, config, db, graphEvents)

6
pkg/pipe/intake.go
View File

@@ -100,7 +100,7 @@ func (b *buffer) Contains(ID string) bool {
// Firehose connects to a list of relays and pulls config.Kinds events that are newer than [FirehoseConfig.Since]. // Firehose connects to a list of relays and pulls config.Kinds events that are newer than [FirehoseConfig.Since].
// It discards events from unknown pubkeys as an anti-spam mechanism. // It discards events from unknown pubkeys as an anti-spam mechanism.
func Firehose(ctx context.Context, config FirehoseConfig, check PubkeyChecker, send func(*nostr.Event) error) { func Firehose(ctx context.Context, config FirehoseConfig, check PubkeyChecker, send func(*nostr.Event) error) {
defer log.Println("Firehose: shutting down...") defer log.Println("Firehose: shut down")
pool := nostr.NewSimplePool(ctx) pool := nostr.NewSimplePool(ctx)
defer shutdown(pool) defer shutdown(pool)
@@ -162,7 +162,7 @@ func (c FetcherConfig) Print() {
// - when the batch is bigger than config.Batch // - when the batch is bigger than config.Batch
// - after config.Interval since the last query. // - after config.Interval since the last query.
func Fetcher(ctx context.Context, config FetcherConfig, pubkeys <-chan string, send func(*nostr.Event) error) { func Fetcher(ctx context.Context, config FetcherConfig, pubkeys <-chan string, send func(*nostr.Event) error) {
defer log.Println("Fetcher: shutting down...") defer log.Println("Fetcher: shut down")
batch := make([]string, 0, config.Batch) batch := make([]string, 0, config.Batch)
timer := time.After(config.Interval) timer := time.After(config.Interval)
@@ -262,7 +262,7 @@ func FetcherDB(
pubkeys <-chan string, pubkeys <-chan string,
send func(*nostr.Event) error) { send func(*nostr.Event) error) {
defer log.Println("FetcherDB: shutting down...") defer log.Println("FetcherDB: shut down")
batch := make([]string, 0, config.Batch) batch := make([]string, 0, config.Batch)
timer := time.After(config.Interval) timer := time.After(config.Interval)