Method Close

internal/queue/queue.go:24–24 · view source on GitHub ↗

()

Source from the content-addressed store, hash-verified

22	type Consumer interface {
23	Subscribe(topics []string) error
24	Close() error
25	}
26
27	// Handler defines the interface for message processing

nothing calls this directly

Consumerinternal/queue/internal/consumer.go

no outgoing calls

no test coverage detected