mirror of
https://github.com/eosswedenorg/thalos
synced 2026-07-03 11:53:41 +02:00
internal/server/ship_processor.go: typo fix.
This commit is contained in:
parent
fbbd7a1662
commit
e8f2e79e5b
1 changed files with 1 additions and 1 deletions
|
|
@ -30,7 +30,7 @@ func logDecoratedEncoder(encoder message.Encoder) message.Encoder {
|
||||||
}
|
}
|
||||||
|
|
||||||
// A ShipProcessor will consume messages from a ship stream, convert the messages into
|
// A ShipProcessor will consume messages from a ship stream, convert the messages into
|
||||||
// thalos specfic ones, encode them and finally post them to an api.Writer
|
// thalos specific ones, encode them and finally post them to an api.Writer
|
||||||
type ShipProcessor struct {
|
type ShipProcessor struct {
|
||||||
// The ship stream to process.
|
// The ship stream to process.
|
||||||
shipStream *shipclient.Stream
|
shipStream *shipclient.Stream
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue