mirror of
https://github.com/eosswedenorg/thalos
synced 2026-06-17 04:30:03 +02:00
app/ship_processor.go: remove ns from struct. should not be used here.
This commit is contained in:
parent
69a9e9f47d
commit
2bec1f09c5
2 changed files with 1 additions and 7 deletions
|
|
@ -13,15 +13,13 @@ import (
|
|||
)
|
||||
|
||||
type ShipProcessor struct {
|
||||
ns transport.Namespace
|
||||
abi *abi.AbiManager
|
||||
publisher transport.Publisher
|
||||
shClient *shipclient.ShipClient
|
||||
}
|
||||
|
||||
func SpawnProccessor(shClient *shipclient.ShipClient, ns transport.Namespace, publisher transport.Publisher, abi *abi.AbiManager) {
|
||||
func SpawnProccessor(shClient *shipclient.ShipClient, publisher transport.Publisher, abi *abi.AbiManager) {
|
||||
processor := &ShipProcessor{
|
||||
ns: ns,
|
||||
abi: abi,
|
||||
publisher: publisher,
|
||||
shClient: shClient,
|
||||
|
|
|
|||
4
main.go
4
main.go
|
|
@ -241,10 +241,6 @@ func main() {
|
|||
|
||||
app.SpawnProccessor(
|
||||
shClient,
|
||||
transport.Namespace{
|
||||
Prefix: conf.Redis.Prefix,
|
||||
ChainID: chainInfo.ChainID.String(),
|
||||
},
|
||||
redis_pubsub.New(rdb),
|
||||
abi.NewAbiManager(rdb, eosClient, conf.Redis.CacheID),
|
||||
)
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue