(ctx context.Context)
| 250 | } |
| 251 | |
| 252 | func (m *RegistrySQL) InitNetwork(ctx context.Context) error { |
| 253 | net, err := m.basePersister.DetermineNetwork(ctx) |
| 254 | if err != nil { |
| 255 | m.Logger().WithError(err).Warnf("Unable to determine network, retrying.") |
| 256 | return err |
| 257 | } |
| 258 | |
| 259 | m.basePersister = m.basePersister.WithFallbackNetworkID(net.ID) |
| 260 | return nil |
| 261 | } |
| 262 | |
| 263 | func (m *RegistrySQL) PingContext(ctx context.Context) error { return m.basePersister.Ping(ctx) } |
| 264 |