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

app/ship_processor.go: make SpawnProccessor() take in a message.Codec

Browse source
This commit is contained in:
Henrik Hautakoski 2023-04-24 16:07:31 +02:00
parent 3e8712c0c0
commit f8f1d0399f
1 changed files with 2 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

5
app/ship_processor.go
View file

@ -2,7 +2,6 @@ package app
import ( import (
"encoding/hex" "encoding/hex"
"encoding/json"
"github.com/eosswedenorg/thalos/api" "github.com/eosswedenorg/thalos/api"
"github.com/eosswedenorg/thalos/api/message" "github.com/eosswedenorg/thalos/api/message"
@ -34,12 +33,12 @@ type ShipProcessor struct {
encode message.Encoder encode message.Encoder
} }
func SpawnProccessor(shipStream *shipclient.Stream, writer api.Writer, abi *abi.AbiManager) *ShipProcessor { func SpawnProccessor(shipStream *shipclient.Stream, writer api.Writer, abi *abi.AbiManager, codec message.Codec) *ShipProcessor {
processor := &ShipProcessor{ processor := &ShipProcessor{
abi: abi, abi: abi,
writer: writer, writer: writer,
shipStream: shipStream, shipStream: shipStream,
encode: logDecoratedEncoder(json.Marshal), encode: logDecoratedEncoder(codec.Encoder),
} }
// Attach handlers // Attach handlers