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

internal/server/ship_processor.go: adding FetchDeltas()

Browse source
This commit is contained in:
Henrik Hautakoski 2024-10-21 12:27:29 +02:00
parent bedb8a92e8
commit 33c983f6c5
1 changed files with 9 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

9
internal/server/ship_processor.go
View file

@ -66,6 +66,15 @@ func SpawnProccessor(shipStream *shipclient.Stream, loader StateLoader, saver St
return processor return processor
} }
func (processor *ShipProcessor) FetchDeltas(value bool) {
if value {
// empty callback will signal that traces should be included in the response from ship.
processor.shipStream.TableDeltaHandler = func(*ship.TableDeltaArray) {}
} else {
processor.shipStream.TableDeltaHandler = nil
}
}
func (processor *ShipProcessor) SetBlacklist(list types.Blacklist) { func (processor *ShipProcessor) SetBlacklist(list types.Blacklist) {
processor.blacklist = list processor.blacklist = list
} }