🔧 Ensure components implement interfaces at compilation

pkg/providers/anthropic/client.go

@@ -1,6 +1,7 @@
 package anthropic
 
 import (
+	"github.com/EinStack/glide/pkg/providers"
 	"net/http"
 	"net/url"
 	"time"
@@ -26,6 +27,9 @@ type Client struct {
 	tel                 *telemetry.Telemetry
 }
 
+// ensure interfaces are implemented at compilation
+var _ providers.LangProvider = (*Client)(nil)
+
 // NewClient creates a new OpenAI client for the OpenAI API.
 func NewClient(providerConfig *Config, clientConfig *clients.ClientConfig, tel *telemetry.Telemetry) (*Client, error) {
 	chatURL, err := url.JoinPath(providerConfig.BaseURL, providerConfig.ChatEndpoint)

pkg/providers/azureopenai/chat_stream.go

@@ -33,6 +33,9 @@ type ChatStream struct {
 	errMapper          *ErrorMapper
 }
 
+// ensure interfaces are implemented at compilation
+var _ clients.ChatStream = (*ChatStream)(nil)
+
 func NewChatStream(
 	tel *telemetry.Telemetry,
 	client *http.Client,

pkg/providers/azureopenai/client.go

@@ -2,6 +2,7 @@ package azureopenai
 
 import (
 	"fmt"
+	"github.com/EinStack/glide/pkg/providers"
 	"net/http"
 	"time"
 
@@ -28,6 +29,9 @@ type Client struct {
 	tel                 *telemetry.Telemetry
 }
 
+// ensure interfaces are implemented at compilation
+var _ providers.LangProvider = (*Client)(nil)
+
 // NewClient creates a new Azure OpenAI client for the OpenAI API.
 func NewClient(providerConfig *Config, clientConfig *clients.ClientConfig, tel *telemetry.Telemetry) (*Client, error) {
 	chatURL := fmt.Sprintf(

pkg/providers/bedrock/client.go

@@ -3,6 +3,7 @@ package bedrock
 import (
 	"context"
 	"errors"
+	"github.com/EinStack/glide/pkg/providers"
 	"net/http"
 	"net/url"
 	"time"
@@ -36,6 +37,9 @@ type Client struct {
 	telemetry           *telemetry.Telemetry
 }
 
+// ensure interfaces are implemented at compilation
+var _ providers.LangProvider = (*Client)(nil)
+
 // NewClient creates a new OpenAI client for the OpenAI API.
 func NewClient(providerConfig *Config, clientConfig *clients.ClientConfig, tel *telemetry.Telemetry) (*Client, error) {
 	chatURL, err := url.JoinPath(providerConfig.BaseURL, providerConfig.ChatEndpoint, providerConfig.ModelName, "/invoke")

pkg/providers/cohere/chat_stream.go

@@ -41,6 +41,9 @@ type ChatStream struct {
 	tel                *telemetry.Telemetry
 }
 
+// ensure interfaces are implemented at compilation
+var _ clients.ChatStream = (*ChatStream)(nil)
+
 func NewChatStream(
 	tel *telemetry.Telemetry,
 	client *http.Client,

pkg/providers/cohere/client.go

@@ -1,6 +1,7 @@
 package cohere
 
 import (
+	"github.com/EinStack/glide/pkg/providers"
 	"net/http"
 	"net/url"
 	"time"
@@ -26,6 +27,9 @@ type Client struct {
 	tel                 *telemetry.Telemetry
 }
 
+// ensure interfaces are implemented at compilation
+var _ providers.LangProvider = (*Client)(nil)
+
 // NewClient creates a new Cohere client for the Cohere API.
 func NewClient(providerConfig *Config, clientConfig *clients.ClientConfig, tel *telemetry.Telemetry) (*Client, error) {
 	chatURL, err := url.JoinPath(providerConfig.BaseURL, providerConfig.ChatEndpoint)

pkg/providers/lang.go

@@ -48,6 +48,9 @@ type LanguageModel struct {
 	latencyUpdateInterval *fields.Duration
 }
 
+// ensure interfaces are implemented at compilation
+var _ LangModel = (*LanguageModel)(nil)
+
 func NewLangModel(modelID string, client LangProvider, budget *health.ErrorBudget, latencyConfig latency.Config, weight int) *LanguageModel {
 	return &LanguageModel{
 		modelID:               modelID,

pkg/providers/octoml/client.go

@@ -2,6 +2,7 @@ package octoml
 
 import (
 	"errors"
+	"github.com/EinStack/glide/pkg/providers"
 	"net/http"
 	"net/url"
 	"time"
@@ -31,6 +32,9 @@ type Client struct {
 	telemetry           *telemetry.Telemetry
 }
 
+// ensure interfaces are implemented at compilation
+var _ providers.LangProvider = (*Client)(nil)
+
 // NewClient creates a new OctoML client for the OctoML API.
 func NewClient(providerConfig *Config, clientConfig *clients.ClientConfig, tel *telemetry.Telemetry) (*Client, error) {
 	chatURL, err := url.JoinPath(providerConfig.BaseURL, providerConfig.ChatEndpoint)

pkg/providers/ollama/client.go

@@ -1,6 +1,7 @@
 package ollama
 
 import (
+	"github.com/EinStack/glide/pkg/providers"
 	"net/http"
 	"net/url"
 	"time"
@@ -24,6 +25,9 @@ type Client struct {
 	telemetry           *telemetry.Telemetry
 }
 
+// ensure interfaces are implemented at compilation
+var _ providers.LangProvider = (*Client)(nil)
+
 // NewClient creates a new OpenAI client for the OpenAI API.
 func NewClient(providerConfig *Config, clientConfig *clients.ClientConfig, tel *telemetry.Telemetry) (*Client, error) {
 	chatURL, err := url.JoinPath(providerConfig.BaseURL, providerConfig.ChatEndpoint)

pkg/providers/openai/chat_stream.go

@@ -28,6 +28,9 @@ type ChatStream struct {
 	logger             *zap.Logger
 }
 
+// ensure interfaces are implemented at compilation
+var _ clients.ChatStream = (*ChatStream)(nil)
+
 func NewChatStream(
 	client *http.Client,
 	req *http.Request,

pkg/providers/openai/client.go

@@ -1,6 +1,7 @@
 package openai
 
 import (
+	"github.com/EinStack/glide/pkg/providers"
 	"net/http"
 	"net/url"
 	"time"
@@ -29,6 +30,9 @@ type Client struct {
 	logger              *zap.Logger
 }
 
+// ensure interfaces are implemented at compilation
+var _ providers.LangProvider = (*Client)(nil)
+
 // NewClient creates a new OpenAI client for the OpenAI API.
 func NewClient(providerConfig *Config, clientConfig *clients.ClientConfig, tel *telemetry.Telemetry) (*Client, error) {
 	chatURL, err := url.JoinPath(providerConfig.BaseURL, providerConfig.ChatEndpoint)

pkg/providers/testing/models.go

@@ -18,6 +18,9 @@ type LangModelMock struct {
 	weight      int
 }
 
+// ensure interfaces are implemented at compilation
+var _ providers.Model = (*LangModelMock)(nil)
+
 func NewLangModelMock(ID string, healthy bool, avgLatency float64, weight int) LangModelMock {
 	chatLatency := latency.NewMovingAverage(0.06, 3)