Fixed PR feedback

alpacahq · Jan 7, 2025 · 477f74c · 477f74c
1 parent 7db31f0
commit 477f74c
Show file tree

Hide file tree

Showing 6 changed files with 140 additions and 140 deletions.
diff --git a/examples/crypto-perp-stream/crypto_stream.go b/examples/crypto-perp-stream/crypto_stream.go
@@ -36,7 +36,7 @@ func main() {
 		stream.WithCryptoDailyBars(func(cb stream.CryptoBar) {
 			fmt.Printf("DAILY BAR: %+v\n", cb)
 		}, "BTC-PERP"),
-		stream.WithFuturesPricing(func(fp stream.CryptoFuturesPricing) {
+		stream.WithCryptoPerpPricing(func(fp stream.CryptoPerpPricing) {
 			fmt.Printf("FUTURES PRICING: %+v\n", fp)
 		}, "BTC-PERP"),
 	)

diff --git a/marketdata/stream/entities.go b/marketdata/stream/entities.go
@@ -196,7 +196,7 @@ func (e errorMessage) Error() string {
 	return e.msg
 }
 
-type CryptoFuturesPricing struct {
+type CryptoPerpPricing struct {
 	Symbol          string
 	Timestamp       time.Time
 	Exchange        string

diff --git a/marketdata/stream/entities_easyjson.go b/marketdata/stream/entities_easyjson.go
diff --git a/marketdata/stream/message.go b/marketdata/stream/message.go
@@ -447,7 +447,7 @@ type cryptoMsgHandler struct {
 	updatedBarHandler     func(CryptoBar)
 	dailyBarHandler       func(CryptoBar)
 	orderbookHandler      func(CryptoOrderbook)
-	futuresPricingHandler func(CryptoFuturesPricing)
+	futuresPricingHandler func(CryptoPerpPricing)
 }
 
 var _ msgHandler = (*cryptoMsgHandler)(nil)
@@ -489,7 +489,7 @@ func (h *cryptoMsgHandler) handleTrade(d *msgpack.Decoder, n int) error {
 }
 
 func (h *cryptoMsgHandler) handleFuturesPricing(d *msgpack.Decoder, n int) error {
-	pricing := CryptoFuturesPricing{}
+	pricing := CryptoPerpPricing{}
 	for i := 0; i < n; i++ {
 		key, err := d.DecodeString()
 		if err != nil {

diff --git a/marketdata/stream/options.go b/marketdata/stream/options.go
@@ -326,7 +326,7 @@ type cryptoOptions struct {
 	updatedBarHandler func(CryptoBar)
 	dailyBarHandler   func(CryptoBar)
 	orderbookHandler  func(CryptoOrderbook)
-	pricingHandler    func(CryptoFuturesPricing)
+	pricingHandler    func(CryptoPerpPricing)
 }
 
 // defaultCryptoOptions are the default options for a client.
@@ -364,7 +364,7 @@ func defaultCryptoOptions() *cryptoOptions {
 		updatedBarHandler: func(_ CryptoBar) {},
 		dailyBarHandler:   func(_ CryptoBar) {},
 		orderbookHandler:  func(_ CryptoOrderbook) {},
-		pricingHandler:    func(_ CryptoFuturesPricing) {},
+		pricingHandler:    func(_ CryptoPerpPricing) {},
 	}
 }
 
@@ -396,8 +396,8 @@ func WithCryptoTrades(handler func(CryptoTrade), symbols ...string) CryptoOption
 	})
 }
 
-// WithFuturesPricing configures initial pricing symbols to subscribe to and the handler
-func WithFuturesPricing(handler func(CryptoFuturesPricing), symbols ...string) CryptoOption {
+// WithCryptoPerpPricing configures initial pricing symbols to subscribe to and the handler
+func WithCryptoPerpPricing(handler func(CryptoPerpPricing), symbols ...string) CryptoOption {
 	return newFuncCryptoOption(func(o *cryptoOptions) {
 		o.sub.futuresPricing = symbols
 		o.pricingHandler = handler