diff --git a/connection.go b/connection.go index 331e1c805..d4e58161a 100644 --- a/connection.go +++ b/connection.go @@ -436,7 +436,7 @@ func Connect(addr string, opts Opts) (conn *Connection, err error) { // TODO: reload schema after reconnect. if !conn.opts.SkipSchema { - if err = conn.loadSchema(); err != nil { + if err = conn.LoadSchema(); err != nil { conn.mutex.Lock() defer conn.mutex.Unlock() conn.closeConnection(err, true) diff --git a/schema.go b/schema.go index 35f65eb28..322c1393e 100644 --- a/schema.go +++ b/schema.go @@ -302,7 +302,7 @@ func (indexField *IndexField) DecodeMsgpack(d *decoder) error { return errors.New("unexpected schema format (index fields)") } -func (conn *Connection) loadSchema() (err error) { +func (conn *Connection) LoadSchema() (err error) { schema := new(Schema) schema.SpacesById = make(map[uint32]*Space) schema.Spaces = make(map[string]*Space)