Merge pull request #108 from k20human/schema-registry-url

feat(url): Add new function `GetSchemaRegistryURL`

mockSchemaRegistryClient.go

@@ -3,11 +3,12 @@ package srclient
 import (
 	"errors"
 	"fmt"
-	"github.com/linkedin/goavro/v2"
 	"net/url"
 	"regexp"
 	"sort"
 	"time"
+
+	"github.com/linkedin/goavro/v2"
 )
 
 // Compile-time interface check
@@ -203,6 +204,11 @@ func (mck *MockSchemaRegistryClient) GetSubjects() ([]string, error) {
 	return allSubjects, nil
 }
 
+// GetSchemaRegistryURL returns the URL of the schema registry
+func (mck *MockSchemaRegistryClient) GetSchemaRegistryURL() string {
+	return mck.schemaRegistryURL
+}
+
 // GetSubjectsIncludingDeleted is not implemented and returns an error
 func (mck *MockSchemaRegistryClient) GetSubjectsIncludingDeleted() ([]string, error) {
 	return nil, errNotImplemented

schemaRegistryClient.go

@@ -37,6 +37,7 @@ type ISchemaRegistryClient interface {
 	GetSchemaVersions(subject string) ([]int, error)
 	GetSubjectVersionsById(schemaID int) (SubjectVersionResponse, error)
 	GetSchemaByVersion(subject string, version int) (*Schema, error)
+	GetSchemaRegistryURL() string
 	CreateSchema(subject string, schema string, schemaType SchemaType, references ...Reference) (*Schema, error)
 	LookupSchema(subject string, schema string, schemaType SchemaType, references ...Reference) (*Schema, error)
 	ChangeSubjectCompatibilityLevel(subject string, compatibility CompatibilityLevel) (*CompatibilityLevel, error)
@@ -251,6 +252,11 @@ func CreateSchemaRegistryClientWithOptions(schemaRegistryURL string, client *htt
 	return NewSchemaRegistryClient(schemaRegistryURL, WithClient(client), WithSemaphoreWeight(int64(semaphoreWeight)))
 }
 
+// GetSchemaRegistryURL returns the URL of the Schema Registry
+func (client *SchemaRegistryClient) GetSchemaRegistryURL() string {
+	return client.schemaRegistryURL
+}
+
 // ResetCache resets the schema caches to be able to get updated schemas.
 func (client *SchemaRegistryClient) ResetCache() {
 	client.idSchemaCacheLock.Lock()

schemaRegistryClient_test.go

@@ -588,6 +588,23 @@ func TestSchemaRegistryClient_GetSubjectVersionsById(t *testing.T) {
 	}
 }
 
+func TestSchemaRegistryClient_GetSchemaRegistryURL(t *testing.T) {
+	t.Parallel()
+	server, _ := mockServerFromSubjectVersionPairWithSchemaResponse(t, "test1-value", "latest", schemaResponse{
+		Subject:    "test1",
+		Version:    1,
+		Schema:     "payload",
+		ID:         1,
+		References: nil,
+	})
+
+	srClient := CreateSchemaRegistryClient(server.URL)
+	// when
+	actual := srClient.GetSchemaRegistryURL()
+	// then
+	assert.Equal(t, actual, server.URL)
+}
+
 func TestSchemaRegistryClient_JsonSchemaParses(t *testing.T) {
 	t.Parallel()
 	{