logger log.Logger,
serializer serialization.Serializer,
return &sqlShardStore{
SqlStore: NewSQLStore(db, logger, serializer),
currentClusterName: currentClusterName,
}, nil
}
func (m *sqlShardStore) GetClusterName() string {