diff --git a/client/operation_auction_get_offers.go b/client/operation_auction_get_offers.go index 9a808dc..178f9f1 100644 --- a/client/operation_auction_get_offers.go +++ b/client/operation_auction_get_offers.go @@ -63,5 +63,5 @@ func (op operationAuctionGetOffersResponse) Process(state *albionState, uploader return } - uploader.sendToIngest(data, lib.MarketOrdersIngest) + uploader.sendToIngest(data, lib.NatsMarketOrdersIngest) } diff --git a/client/operation_auction_get_requests.go b/client/operation_auction_get_requests.go index b991ce2..7b4e0d0 100644 --- a/client/operation_auction_get_requests.go +++ b/client/operation_auction_get_requests.go @@ -48,5 +48,5 @@ func (op operationAuctionGetRequestsResponse) Process(state *albionState, upload return } - uploader.sendToIngest(data, lib.MarketOrdersIngest) + uploader.sendToIngest(data, lib.NatsMarketOrdersIngest) } diff --git a/client/operation_gold_market_get_average_info.go b/client/operation_gold_market_get_average_info.go index 823a89d..d9536fa 100644 --- a/client/operation_gold_market_get_average_info.go +++ b/client/operation_gold_market_get_average_info.go @@ -32,5 +32,5 @@ func (op operationGoldMarketGetAverageInfoResponse) Process(state *albionState, return } - uploader.sendToIngest(data, lib.GoldPricesIngest) + uploader.sendToIngest(data, lib.NatsGoldPricesIngest) } diff --git a/cmd/natsdumper/natsdumper.go b/cmd/natsdumper/natsdumper.go index 9175595..089a0c4 100644 --- a/cmd/natsdumper/natsdumper.go +++ b/cmd/natsdumper/natsdumper.go @@ -39,7 +39,7 @@ func main() { defer nc.Close() marketCh := make(chan *nats.Msg, 64) - marketSub, err := nc.ChanSubscribe(lib.GoldPricesDeduped, marketCh) + marketSub, err := nc.ChanSubscribe(lib.NatsGoldPricesDeduped, marketCh) if err != nil { fmt.Printf("%v\n", err) return diff --git a/lib/nats.go b/lib/nats.go index 8113422..1f012bf 100644 --- a/lib/nats.go +++ b/lib/nats.go @@ -1,8 +1,8 @@ package lib const ( - GoldPricesIngest = "goldprices.ingest" - GoldPricesDeduped = "goldprices.deduped" - MarketOrdersIngest = "marketorders.ingest" - MarketOrdersDeduped = "marketorders.deduped" + NatsGoldPricesIngest = "goldprices.ingest" + NatsGoldPricesDeduped = "goldprices.deduped" + NatsMarketOrdersIngest = "marketorders.ingest" + NatsMarketOrdersDeduped = "marketorders.deduped" )