Rename SubHeartbeatInterval to SubscriptionHeartbeatInterval

Author: endigma

v2/pkg/engine/resolve/event_loop_test.go

@@ -123,16 +123,16 @@ func TestEventLoop(t *testing.T) {
 	testReporter := &TestReporter{}
 
 	resolver := New(resolverCtx, ResolverOptions{
-		MaxConcurrency:               1024,
-		Debug:                        false,
-		AsyncErrorWriter:             ew,
-		PropagateSubgraphErrors:      false,
-		PropagateSubgraphStatusCodes: false,
-		SubgraphErrorPropagationMode: SubgraphErrorPropagationModePassThrough,
-		DefaultErrorExtensionCode:    "TEST",
-		MaxRecyclableParserSize:      1024 * 1024,
-		SubHeartbeatInterval:         DefaultHeartbeatInterval,
-		Reporter:                     testReporter,
+		MaxConcurrency:                1024,
+		Debug:                         false,
+		AsyncErrorWriter:              ew,
+		PropagateSubgraphErrors:       false,
+		PropagateSubgraphStatusCodes:  false,
+		SubgraphErrorPropagationMode:  SubgraphErrorPropagationModePassThrough,
+		DefaultErrorExtensionCode:     "TEST",
+		MaxRecyclableParserSize:       1024 * 1024,
+		SubscriptionHeartbeatInterval: DefaultHeartbeatInterval,
+		Reporter:                      testReporter,
 	})
 
 	subscription := &GraphQLSubscription{

v2/pkg/engine/resolve/resolve.go

@@ -139,8 +139,8 @@ type ResolverOptions struct {
 	ResolvableOptions ResolvableOptions
 	// AllowedCustomSubgraphErrorFields defines which fields are allowed in the subgraph error when in passthrough mode
 	AllowedSubgraphErrorFields []string
-	// SubHeartbeatInterval defines the interval in which a heartbeat is sent to all subscriptions (whether or not this does anything is determined by the subscription response writer)
-	SubHeartbeatInterval time.Duration
+	// SubscriptionHeartbeatInterval defines the interval in which a heartbeat is sent to all subscriptions (whether or not this does anything is determined by the subscription response writer)
+	SubscriptionHeartbeatInterval time.Duration
 	// MaxSubscriptionFetchTimeout defines the maximum time a subscription fetch can take before it is considered timed out
 	MaxSubscriptionFetchTimeout time.Duration
 	// ApolloRouterCompatibilitySubrequestHTTPError is a compatibility flag for Apollo Router, it is used to handle HTTP errors in subrequests differently
@@ -154,8 +154,8 @@ func New(ctx context.Context, options ResolverOptions) *Resolver {
 		options.MaxConcurrency = 32
 	}
 
-	if options.SubHeartbeatInterval <= 0 {
-		options.SubHeartbeatInterval = DefaultHeartbeatInterval
+	if options.SubscriptionHeartbeatInterval <= 0 {
+		options.SubscriptionHeartbeatInterval = DefaultHeartbeatInterval
 	}
 
 	// We transform the allowed fields into a map for faster lookups
@@ -198,7 +198,7 @@ func New(ctx context.Context, options ResolverOptions) *Resolver {
 		triggerUpdateBuf:             bytes.NewBuffer(make([]byte, 0, 1024)),
 		allowedErrorExtensionFields:  allowedExtensionFields,
 		allowedErrorFields:           allowedErrorFields,
-		heartbeatInterval:            options.SubHeartbeatInterval,
+		heartbeatInterval:            options.SubscriptionHeartbeatInterval,
 		maxSubscriptionFetchTimeout:  options.MaxSubscriptionFetchTimeout,
 	}
 	resolver.maxConcurrency = make(chan struct{}, options.MaxConcurrency)

v2/pkg/engine/resolve/resolve_test.go

@@ -86,16 +86,16 @@ func (t *TestErrorWriter) WriteError(ctx *Context, err error, res *GraphQLRespon
 	}
 }
 
-var multipartSubHeartbeatInterval = 100 * time.Millisecond
+var subscriptionHeartbeatInterval = 100 * time.Millisecond
 
 func newResolver(ctx context.Context) *Resolver {
 	return New(ctx, ResolverOptions{
-		MaxConcurrency:               1024,
-		Debug:                        false,
-		PropagateSubgraphErrors:      true,
-		PropagateSubgraphStatusCodes: true,
-		AsyncErrorWriter:             &TestErrorWriter{},
-		SubHeartbeatInterval:         multipartSubHeartbeatInterval,
+		MaxConcurrency:                1024,
+		Debug:                         false,
+		PropagateSubgraphErrors:       true,
+		PropagateSubgraphStatusCodes:  true,
+		AsyncErrorWriter:              &TestErrorWriter{},
+		SubscriptionHeartbeatInterval: subscriptionHeartbeatInterval,
 	})
 }